This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 358898e6c0574ec97e84081485a6644ba6dd3a30 Merge: c70d5be ef4ea06 Author: Aljoscha Krettek <[email protected]> AuthorDate: Fri Jun 8 13:21:46 2018 +0200 Merge pull request #5572: [BEAM-4311] Enforce ErrorProne analysis in Flink runner runners/flink/build.gradle | 4 ++- .../runners/flink/FlinkExecutionEnvironments.java | 13 ++++---- .../wrappers/streaming/DoFnOperator.java | 20 ++++++------ .../wrappers/streaming/io/DedupingOperator.java | 5 ++- .../streaming/io/UnboundedSocketSource.java | 7 ++-- .../streaming/io/UnboundedSourceWrapper.java | 4 ++- .../state/FlinkBroadcastStateInternals.java | 38 +++++++++++----------- .../state/FlinkKeyGroupStateInternals.java | 19 ++++++----- .../streaming/state/FlinkSplitStateInternals.java | 12 +++---- .../streaming/state/FlinkStateInternals.java | 17 ++++++---- .../flink/streaming/DedupingOperatorTest.java | 31 ++++++++++++------ .../flink/streaming/GroupByNullKeyTest.java | 2 ++ .../flink/streaming/TestCountingSource.java | 7 ++-- 13 files changed, 105 insertions(+), 74 deletions(-) -- To stop receiving notification emails like this one, please contact [email protected].
