Commits

Branch selector

 master

User selector

scwhittle

Datepicker

All time

Commit History

Commits on Dec 17, 2019

• Merge pull request apache#10311: [BEAM-8810] Detect stuck commits in StreamingDataflowWorker

  

  scwhittle

  authored and

  reuvenlax

  committed
  bac1733

  Copy full SHA for bac1733

Commits on Jun 28, 2019

• [BEAM-7547] Avoid WindmillStateCache cache hits for stale work.

  Show description for 3c43cc1
  scwhittle

  committed
  3c43cc1

  Copy full SHA for 3c43cc1

Commits on May 8, 2019

• Modify StreamingDataflowWorker commit loop to only create a commit

  Show description for 98436d6
  scwhittle

  committed
  98436d6

  Copy full SHA for 98436d6

Commits on Mar 6, 2019

• GrpcWindmillWorker improvements:

  Show description for b37fd2a
  scwhittle

  committed
  b37fd2a

  Copy full SHA for b37fd2a

Commits on Jan 31, 2019

• Improve visibility of large key commits in StreamingDataflowWorker by

  Show description for bef135b
  scwhittle

  committed
  bef135b

  Copy full SHA for bef135b

Commits on Dec 17, 2018

• [BEAM-6170] Change Nexmark stuckness warnings to not cause pipeline failure.

  scwhittle

  committed
  bc1609d

  Copy full SHA for bc1609d

Commits on Jun 1, 2018

• Fix flaky comparison in log_handler_test.py

  Show description for d8e4032
  scwhittle

  authored
  d8e4032

  Copy full SHA for d8e4032

Commits on May 17, 2018

• [BEAM-3776] Fix issue with merging late windows where a watermark hold

  Show description for 9452aca
  scwhittle

  committed
  9452aca

  Copy full SHA for 9452aca

Commits on Jan 12, 2018

• Update NexmarkLauncher to not cancel jobs that have completed

  Show description for b99f6de
  scwhittle

  committed
  b99f6de

  Copy full SHA for b99f6de

Commits on Dec 9, 2016

• Fix LateDataDroppingDoFnRunner to not increment the counter on reiteration.

  

  scwhittle

  authored and

  kennknowles

  committed
  d7dbf16

  Copy full SHA for d7dbf16

Commits on Dec 6, 2016

• Improve ReduceFnRunner prefetching

  Show description for 2b044f3
  

  scwhittle

  authored and

  kennknowles

  committed
  2b044f3

  Copy full SHA for 2b044f3

• Add test for InMemoryTimerInternals synchronized processing time timers.

  Show description for 3434e8a
  

  scwhittle

  authored and

  kennknowles

  committed
  3434e8a

  Copy full SHA for 3434e8a

• Deprecate TimerCallback and InMemoryTimerInternals methods using it.

  Show description for e9d835e
  

  scwhittle

  authored and

  kennknowles

  committed
  e9d835e

  Copy full SHA for e9d835e

Commits on Nov 30, 2016

• Improvements to ReduceFnRunner prefetching

  Show description for 4282c67
  

  scwhittle

  authored and

  kennknowles

  committed
  4282c67

  Copy full SHA for 4282c67

Commits on Oct 28, 2015

• Optimize StreamingDataflowWorker progress updates

  Show description for f707e9c
  

  scwhittle

  authored and

  dhalperi

  committed
  f707e9c

  Copy full SHA for f707e9c

Commits on Jul 23, 2015

• Fix pushback logic in StreamingDataflowWorker

  Show description for cbe82f7
  

  scwhittle

  authored and

  davorbonaci

  committed
  cbe82f7

  Copy full SHA for cbe82f7

Commits on Jun 26, 2015

• Improve key throughput of StreamingDataflowWorker

  Show description for 5cc2461
  

  scwhittle

  authored and

  lukecwik

  committed
  5cc2461

  Copy full SHA for 5cc2461

Commits on May 12, 2015

• Add input data watermark to GetWork response.

  Show description for 67fc627
  

  scwhittle

  authored and

  davorbonaci

  committed
  67fc627

  Copy full SHA for 67fc627

• Filter debug messages in MonitoringUtil.

  Show description for 3380740
  

  scwhittle

  authored and

  davorbonaci

  committed
  3380740

  Copy full SHA for 3380740

Commits on Apr 6, 2015

• Optimize counter processing in StreamingDataflowWorker.

  Show description for 2660c39
  

  scwhittle

  authored and

  davorbonaci

  committed
  2660c39

  Copy full SHA for 2660c39

• Avoid parsing serialized DoFnInfo repeatedly.

  Show description for 8f92445
  

  scwhittle

  authored and

  davorbonaci

  committed
  8f92445

  Copy full SHA for 8f92445

• Avoid starting update progress thread in ReadOperation for

  Show description for 5d0eb9a
  

  scwhittle

  authored and

  davorbonaci

  committed
  5d0eb9a

  Copy full SHA for 5d0eb9a

Commits on Feb 11, 2015

• Fixed logic inversion and added test of exception handling retries.

  Show description for fcd3a52
  

  scwhittle

  authored and

  davorbonaci

  committed
  fcd3a52

  Copy full SHA for fcd3a52

Commits on Feb 6, 2015

• Fix infinite retries of work on lease expiration in streaming mode.

  Show description for fa8b3e0
  

  scwhittle

  authored and

  davorbonaci

  committed
  fa8b3e0

  Copy full SHA for fa8b3e0

• Add failed response to ReportStats.

  Show description for 0193099
  

  scwhittle

  authored and

  davorbonaci

  committed
  0193099

  Copy full SHA for 0193099