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."); }
