Repository: flink Updated Branches: refs/heads/master 93733cc00 -> 8d67aa55f
[hotfix] Removed deprecated and commented code in SourceFunctionTest Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8a50524c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8a50524c Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8a50524c Branch: refs/heads/master Commit: 8a50524c791a4024c7fe540c7c0fd911b5e8e8db Parents: ff80dc0 Author: Stephan Ewen <[email protected]> Authored: Tue Mar 1 16:52:12 2016 +0100 Committer: Stephan Ewen <[email protected]> Committed: Tue Mar 1 17:02:21 2016 +0100 ---------------------------------------------------------------------- .../flink/streaming/api/SourceFunctionTest.java | 21 -------------------- 1 file changed, 21 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/8a50524c/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/SourceFunctionTest.java ---------------------------------------------------------------------- diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/SourceFunctionTest.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/SourceFunctionTest.java index 4b99202..946b474 100644 --- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/SourceFunctionTest.java +++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/SourceFunctionTest.java @@ -60,25 +60,4 @@ public class SourceFunctionTest { 7)); assertEquals(expectedList, actualList); } - -// TODO: does not work because we cannot set the internal socket anymore -// @Test -// public void socketTextStreamTest() throws Exception { -// List<String> expectedList = Arrays.asList("a", "b", "c"); -// List<String> actualList = new ArrayList<String>(); -// -// byte[] data = { 'a', '\n', 'b', '\n', 'c', '\n' }; -// -// Socket socket = mock(Socket.class); -// when(socket.getInputStream()).thenReturn(new ByteArrayInputStream(data)); -// when(socket.isClosed()).thenReturn(false); -// when(socket.isConnected()).thenReturn(true); -// -// SocketTextStreamFunction source = new SocketTextStreamFunction("", 0, '\n', 0); -// source.open(new Configuration()); -// while (!source.reachedEnd()) { -// actualList.add(source.next()); -// } -// assertEquals(expectedList, actualList); -// } }
