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
