flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject flink git commit: [FLINK-3082] Fixed confusing error about an interface that no longer exists
Date Fri, 27 Nov 2015 11:33:57 GMT
Repository: flink
Updated Branches:
  refs/heads/release-0.10 16e5ab09f -> d6e118b8e


[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/d6e118b8
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d6e118b8
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d6e118b8

Branch: refs/heads/release-0.10
Commit: d6e118b8e5ae6221fa3a1d98fa830a1c1dffe871
Parents: 16e5ab0
Author: Niels Basjes <niels@basjes.nl>
Authored: Thu Nov 26 15:21:04 2015 +0100
Committer: Stephan Ewen <sewen@apache.org>
Committed: Fri Nov 27 12:33:27 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/d6e118b8/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.");
 		}
 


Mime
View raw message