You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by mx...@apache.org on 2019/05/27 14:25:44 UTC

[beam] branch master updated (9428cc8 -> 1da00e2)

This is an automated email from the ASF dual-hosted git repository.

mxm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 9428cc8  Merge pull request #8692: Refactor default bundle size into a constant in TextIO
     add 9ed7ca2  [cleanup] Remove dead code from Flink Runner
     add 1da00e2  Merge pull request #8694: [cleanup] Remove dead code from Flink Runner

No new revisions were added by this update.

Summary of changes:
 .../types/InspectableByteArrayOutputStream.java    | 32 --------------------
 .../translation/wrappers/DataInputViewWrapper.java |  6 +---
 .../wrappers/DataOutputViewWrapper.java            |  6 +---
 .../state/KeyGroupCheckpointedOperator.java        | 34 ----------------------
 .../streaming/state/KeyGroupRestoringOperator.java | 31 --------------------
 5 files changed, 2 insertions(+), 107 deletions(-)
 delete mode 100644 runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/InspectableByteArrayOutputStream.java
 delete mode 100644 runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/KeyGroupCheckpointedOperator.java
 delete mode 100644 runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/KeyGroupRestoringOperator.java