Commits

Commits on Sep 14, 2018

Merge pull request apache#6378 : [BEAM-5372] Make minPauseBetweenCheckpoints setting available in FlinkPipelineOptions
aljoscha
committedSep 14, 2018

Commits on Aug 10, 2018

[BEAM-4798] Fix UnboundedSourceWrapperTest
aljoscha
committedAug 10, 2018

Commits on Jun 19, 2018

Expand Read to Impulse | ParDo(Split) | ParDo(Read) in Python SDK

aljoscha
authored and
robertwb
committedJun 19, 2018
Add Impulse primitive to Python SDK

aljoscha
authored and
robertwb
committedJun 19, 2018

Commits on Jun 8, 2018

[BEAM-3905] Update Flink Runner to Flink 1.5.0
aljoscha
committedJun 8, 2018
Merge pull request apache#5572 : [BEAM-4311] Enforce ErrorProne analysis in Flink runner
aljoscha
committedJun 8, 2018

Commits on May 7, 2018

Move _CreateSource to its own package to make it pickelable
aljoscha
committedMay 7, 2018

Commits on Apr 30, 2018

Commits on Mar 27, 2018

Commits on Mar 26, 2018

Merge pull request apache#4903 : [BEAM-3800] Set uids on Flink operators
aljoscha
committedMar 26, 2018

Commits on Mar 12, 2018

Merge pull request apache#4849 : Annotate ParDoTest.duplicateTimerSetting with UsesTestStream
aljoscha
committedMar 12, 2018
Annotate ParDoTest.duplicateTimerSetting with UsesTestStream
aljoscha
committedMar 12, 2018

Commits on Mar 7, 2018

Commits on Feb 23, 2018

Merge pull request apache#4639 : [BEAM-2140] Fix SplittableDoFn ValidatesRunner tests in Flink Streaming Runner
aljoscha
committedFeb 23, 2018
[BEAM-3727] Never shutdown sources in Flink Streaming execution mode
aljoscha
committedFeb 23, 2018
[BEAM-2140] Enable SDF tests in gradle for Flink Streaming Runner
aljoscha
committedFeb 23, 2018
[BEAM-2140] Enable SDF tests for Flink Streaming Runner
aljoscha
committedFeb 23, 2018
[BEAM-2140] Use ProcessFnRunner in DoFnRunner for executing SDF
aljoscha
committedFeb 23, 2018
Make ProcessFnRunner constructor public
aljoscha
committedFeb 23, 2018
[BEAM-2140] Don't use StatefulDoFnRunner when running SDF in FlinkRunner
aljoscha
committedFeb 23, 2018
[BEAM-2140] Block DoFnOperator.close() if we have pending timers
aljoscha
committedFeb 23, 2018
[BEAM-2140] Ignore event-time timers in SplittableDoFnOperator
aljoscha
committedFeb 23, 2018
Invoke finishBundle() before teardown() in DoFnOperator
aljoscha
committedFeb 23, 2018
Allow overriding DoFnRunners in subclasses of Flink DoFnOperator
aljoscha
committedFeb 23, 2018
Make parameter of DoFnRunners.lateDataDroppingRunner() more specific
aljoscha
committedFeb 23, 2018

Commits on Feb 6, 2018

Merge pull request apache#4558 : Fixes streaming mode recognition in Flink Runner
aljoscha
committedFeb 6, 2018

Commits on Feb 5, 2018

Merge pull request apache#4563 : Fixes Flink timer service restore
aljoscha
committedFeb 5, 2018

Commits on Oct 9, 2017

This closes apache#3953
aljoscha
committedOct 9, 2017
[BEAM-3027] Correctly set output type on SourceId-stripper
aljoscha
committedOct 9, 2017

Commits on Sep 29, 2017

This closes apache#3909
aljoscha
committedSep 29, 2017
Adapt Flink StateInternals to new state semantics
aljoscha
committedSep 29, 2017

Commits on Sep 20, 2017

This closes apache#3255
aljoscha
committedSep 20, 2017