Code

Make ingest executing non blocking#43361

Code

Merged

martijnvg merged 19 commits intoelastic:enrichelastic/elasticsearch:enrichfrom martijnvg:enrich_non_block_ingest_executionmartijnvg/elasticsearch:enrich_non_block_ingest_executionCopy head branch name to clipboardJul 1, 2019

+803-460

Commits

Commits on Jun 14, 2019

• Non blocking ingest processor execution.

  Show description for 7222f1e
  martijnvg

  committed
  7222f1e

  Copy full SHA for 7222f1e

• make iterator thread safe

  martijnvg

  committed
  7df6779

  Copy full SHA for 7df6779

Commits on Jun 17, 2019

• fixed simulate execution service to be async

  martijnvg

  committed
  72a4690

  Copy full SHA for 72a4690

• changed IngestService#executeBulkRequest(...) to be like a loop instead of recursively invoking a method in order to avoid SO

  martijnvg

  committed
  09bdbd1

  Copy full SHA for 09bdbd1

Commits on Jun 19, 2019

• Change BulkRequestModifier, so that it can accept items that have

  Show description for 58658be
  martijnvg

  committed
  58658be

  Copy full SHA for 58658be

Commits on Jun 26, 2019

• Merge remote-tracking branch 'es/enrich' into enrich_non_block_ingest_execution

  martijnvg

  committed
  0cc9e5f

  Copy full SHA for 0cc9e5f

• make ExactMatchProcessor execute search in a non blocking manner

  martijnvg

  committed
  d000f85

  Copy full SHA for d000f85

• iter

  martijnvg

  committed
  a77f9ee

  Copy full SHA for a77f9ee

• fork back to write thread if needed

  martijnvg

  committed
  cc718a4

  Copy full SHA for cc718a4

• jdoc tweak

  martijnvg

  committed
  2dce37a

  Copy full SHA for 2dce37a

Commits on Jun 27, 2019

• Merge remote-tracking branch 'es/enrich' into enrich_non_block_ingest_execution

  martijnvg

  committed
  5f66516

  Copy full SHA for 5f66516

• small changes

  martijnvg

  committed
  acd3671

  Copy full SHA for acd3671

• keep track of the original thread and

  Show description for 720ee01
  martijnvg

  committed
  720ee01

  Copy full SHA for 720ee01

• fixed test

  martijnvg

  committed
  5d105a1

  Copy full SHA for 5d105a1

• iter

  martijnvg

  committed
  494cdbe

  Copy full SHA for 494cdbe

Commits on Jun 28, 2019

• Added semaphore in order to avoid search thread pools from rejecting

  Show description for 9256652
  martijnvg

  committed
  9256652

  Copy full SHA for 9256652

Commits on Jun 30, 2019

• made originalSlots field look less tricky

  martijnvg

  committed
  f404843

  Copy full SHA for f404843

• for each iter

  martijnvg

  committed
  0103761

  Copy full SHA for 0103761

• Merge remote-tracking branch 'es/enrich' into enrich_non_block_ingest_execution

  martijnvg

  committed
  17f9a66

  Copy full SHA for 17f9a66