You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2021/08/20 07:18:28 UTC
[flink-benchmarks] branch 23879 created (now 15bbd77)
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch 23879
in repository https://gitbox.apache.org/repos/asf/flink-benchmarks.git.
at 15bbd77 [FLINK-23879] Fix compilation issue
This branch includes the following new commits:
new 15bbd77 [FLINK-23879] Fix compilation issue
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[flink-benchmarks] 01/01: [FLINK-23879] Fix compilation issue
Posted by ch...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch 23879
in repository https://gitbox.apache.org/repos/asf/flink-benchmarks.git
commit 15bbd77fb249a6fce0e4576074b55551b995eaaa
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Fri Aug 20 09:18:09 2021 +0200
[FLINK-23879] Fix compilation issue
---
.../org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/src/main/java/org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java b/src/main/java/org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java
index 696a40d..ed0ee84 100644
--- a/src/main/java/org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java
+++ b/src/main/java/org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java
@@ -44,7 +44,7 @@ import org.apache.flink.streaming.api.operators.TwoInputStreamOperator;
import org.apache.flink.streaming.api.transformations.KeyedMultipleInputTransformation;
import org.apache.flink.streaming.runtime.streamrecord.LatencyMarker;
import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
-import org.apache.flink.streaming.runtime.streamstatus.StreamStatus;
+import org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus;
import org.apache.flink.util.SplittableIterator;
import org.junit.Assert;
@@ -347,7 +347,8 @@ public class SortingBoundedInputBenchmarks extends BenchmarkBase {
public void setKeyContextElement(StreamRecord<Integer> record) {}
@Override
- public void processStreamStatus(StreamStatus streamStatus) throws Exception {}
+ public void processWatermarkStatus(WatermarkStatus watermarkStatus) throws Exception {
+ }
}
private static class InputGenerator extends SplittableIterator<Integer> {