You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2015/11/27 12:31:47 UTC
flink git commit: [FLINK-3082] Fixed confusing error about an
interface that no longer exists
Repository: flink
Updated Branches:
refs/heads/master 55fd5f32d -> d359a974a
[FLINK-3082] Fixed confusing error about an interface that no longer exists
This closes #1411
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d359a974
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d359a974
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d359a974
Branch: refs/heads/master
Commit: d359a974ae475ab36fd68dec1f182dc01545dc19
Parents: 55fd5f3
Author: Niels Basjes <ni...@basjes.nl>
Authored: Thu Nov 26 15:21:04 2015 +0100
Committer: Stephan Ewen <se...@apache.org>
Committed: Thu Nov 26 17:45:51 2015 +0100
----------------------------------------------------------------------
.../flink/streaming/api/operators/StreamSource.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/d359a974/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSource.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSource.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSource.java
index 56426f6..e80654a 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSource.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSource.java
@@ -95,14 +95,14 @@ public class StreamSource<T> extends AbstractUdfStreamOperator<T, SourceFunction
@Override
public void collectWithTimestamp(T element, long timestamp) {
throw new UnsupportedOperationException("Automatic-Timestamp sources cannot emit" +
- " elements with a timestamp. See interface ManualTimestampSourceFunction" +
+ " elements with a timestamp. See interface EventTimeSourceFunction" +
" if you want to manually assign timestamps to elements.");
}
@Override
public void emitWatermark(Watermark mark) {
throw new UnsupportedOperationException("Automatic-Timestamp sources cannot emit" +
- " elements with a timestamp. See interface ManualTimestampSourceFunction" +
+ " elements with a timestamp. See interface EventTimeSourceFunction" +
" if you want to manually assign timestamps to elements.");
}
@@ -139,14 +139,14 @@ public class StreamSource<T> extends AbstractUdfStreamOperator<T, SourceFunction
@Override
public void collectWithTimestamp(T element, long timestamp) {
throw new UnsupportedOperationException("Automatic-Timestamp sources cannot emit" +
- " elements with a timestamp. See interface ManualTimestampSourceFunction" +
+ " elements with a timestamp. See interface EventTimeSourceFunction" +
" if you want to manually assign timestamps to elements.");
}
@Override
public void emitWatermark(Watermark mark) {
throw new UnsupportedOperationException("Automatic-Timestamp sources cannot emit" +
- " elements with a timestamp. See interface ManualTimestampSourceFunction" +
+ " elements with a timestamp. See interface EventTimeSourceFunction" +
" if you want to manually assign timestamps to elements.");
}
@@ -224,14 +224,14 @@ public class StreamSource<T> extends AbstractUdfStreamOperator<T, SourceFunction
@Override
public void collectWithTimestamp(T element, long timestamp) {
throw new UnsupportedOperationException("Automatic-Timestamp sources cannot emit" +
- " elements with a timestamp. See interface ManualTimestampSourceFunction" +
+ " elements with a timestamp. See interface EventTimeSourceFunction" +
" if you want to manually assign timestamps to elements.");
}
@Override
public void emitWatermark(Watermark mark) {
throw new UnsupportedOperationException("Automatic-Timestamp sources cannot emit" +
- " elements with a timestamp. See interface ManualTimestampSourceFunction" +
+ " elements with a timestamp. See interface EventTimeSourceFunction" +
" if you want to manually assign timestamps to elements.");
}