This closes #3819
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d2b28512 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d2b28512 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d2b28512 Branch: refs/heads/jstorm-runner Commit: d2b2851227ae47f985f0c7d3ff6f198cf9f725b7 Parents: d24d283 4349200 Author: Pei He <[email protected]> Authored: Fri Sep 8 14:24:01 2017 +0800 Committer: Pei He <[email protected]> Committed: Fri Sep 8 14:24:01 2017 +0800 ---------------------------------------------------------------------- .../jstorm/serialization/BeamUtilsSerializer.java | 2 ++ .../runners/jstorm/translation/DoFnExecutor.java | 3 +-- .../runners/jstorm/translation/ExecutorsBolt.java | 1 - .../jstorm/translation/WindowAssignExecutor.java | 16 +++++++--------- 4 files changed, 10 insertions(+), 12 deletions(-) ----------------------------------------------------------------------
