This closes #2217: Fix Flink State GC Properly deal with late processing-time timers Introduce Flink-specific state GC implementations Move GC timer checking to StatefulDoFnRunner.CleanupTimer
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/75fe559a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/75fe559a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/75fe559a Branch: refs/heads/gearpump-runner Commit: 75fe559a4115661c9a138099e58a73c6f42a038f Parents: 54390a3 dbfcf4b Author: Kenneth Knowles <k...@google.com> Authored: Fri Mar 10 13:01:00 2017 -0800 Committer: Kenneth Knowles <k...@google.com> Committed: Fri Mar 10 13:01:00 2017 -0800 ---------------------------------------------------------------------- .../apache/beam/runners/core/DoFnRunners.java | 15 +- .../beam/runners/core/StatefulDoFnRunner.java | 128 +++-------- .../runners/core/StatefulDoFnRunnerTest.java | 110 ++++++++- .../wrappers/streaming/DoFnOperator.java | 111 ++++++++- .../flink/streaming/DoFnOperatorTest.java | 225 +++++++++++++++++++ 5 files changed, 472 insertions(+), 117 deletions(-) ----------------------------------------------------------------------
