fixup! Fix test compilation errors

apache · Jan 2, 2020 · d6c0ab2 · d6c0ab2
1 parent a6c13dc
commit d6c0ab2
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 0 deletions.
diff --git a/...org/apache/beam/runners/flink/translation/functions/FlinkExecutableStageFunctionTest.java b/...org/apache/beam/runners/flink/translation/functions/FlinkExecutableStageFunctionTest.java
@@ -197,6 +197,11 @@ public Map<String, FnDataReceiver> getInputReceivers() {
                     });
               }
 
+              @Override
+              public void split(double fractionOfRemainder) {
+                throw new UnsupportedOperationException();
+              }
+
               @Override
               public void close() throws Exception {
                 if (once) {

diff --git a/...he/beam/runners/flink/translation/wrappers/streaming/ExecutableStageDoFnOperatorTest.java b/...he/beam/runners/flink/translation/wrappers/streaming/ExecutableStageDoFnOperatorTest.java
@@ -314,6 +314,11 @@ public Map<String, FnDataReceiver> getInputReceivers() {
                     });
               }
 
+              @Override
+              public void split(double fractionOfRemainder) {
+                throw new UnsupportedOperationException();
+              }
+
               @Override
               public void close() throws Exception {
                 if (onceEmitted) {

diff --git a/...test/java/org/apache/beam/runners/spark/translation/SparkExecutableStageFunctionTest.java b/...test/java/org/apache/beam/runners/spark/translation/SparkExecutableStageFunctionTest.java
@@ -160,6 +160,11 @@ public Map<String, FnDataReceiver> getInputReceivers() {
                     });
               }
 
+              @Override
+              public void split(double fractionOfRemainder) {
+                throw new UnsupportedOperationException();
+              }
+
               @Override
               public void close() throws Exception {
                 if (once) {