{"action":"created","issue":{"url":"https://api.github.com/repos/apache/flink/issues/520","labels_url":"https://api.github.com/repos/apache/flink/issues/520/labels{/name}","comments_url":"https://api.github.com/repos/apache/flink/issues/520/comments","events_url":"https://api.github.com/repos/apache/flink/issues/520/events","html_url":"https://github.com/apache/flink/pull/520","id":63732461,"number":520,"title":"[FLINK-1595] [streaming] Complex integration test wip","user":{"login":"szape","id":8025879,"avatar_url":"https://avatars.githubusercontent.com/u/8025879?v=3","gravatar_id":"","url":"https://api.github.com/users/szape","html_url":"https://github.com/szape","followers_url":"https://api.github.com/users/szape/followers","following_url":"https://api.github.com/users/szape/following{/other_user}","gists_url":"https://api.github.com/users/szape/gists{/gist_id}","starred_url":"https://api.github.com/users/szape/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/szape/subscriptions","organizations_url":"https://api.github.com/users/szape/orgs","repos_url":"https://api.github.com/users/szape/repos","events_url":"https://api.github.com/users/szape/events{/privacy}","received_events_url":"https://api.github.com/users/szape/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":2,"created_at":"2015-03-23T14:12:51Z","updated_at":"2015-05-04T08:20:57Z","closed_at":null,"pull_request":{"url":"https://api.github.com/repos/apache/flink/pulls/520","html_url":"https://github.com/apache/flink/pull/520","diff_url":"https://github.com/apache/flink/pull/520.diff","patch_url":"https://github.com/apache/flink/pull/520.patch"},"body":"Flink Streaming's complex integration test will test interactions of different streaming operators and settings.\r\n\r\nThe test topology will run in one environment but will be divided into several subgraphs, tested separately from one another.\r\nIn this way, many new tests can be added later."},"comment":{"url":"https://api.github.com/repos/apache/flink/issues/comments/98628873","html_url":"https://github.com/apache/flink/pull/520#issuecomment-98628873","issue_url":"https://api.github.com/repos/apache/flink/issues/520","id":98628873,"user":{"login":"mbalassi","id":5990983,"avatar_url":"https://avatars.githubusercontent.com/u/5990983?v=3","gravatar_id":"","url":"https://api.github.com/users/mbalassi","html_url":"https://github.com/mbalassi","followers_url":"https://api.github.com/users/mbalassi/followers","following_url":"https://api.github.com/users/mbalassi/following{/other_user}","gists_url":"https://api.github.com/users/mbalassi/gists{/gist_id}","starred_url":"https://api.github.com/users/mbalassi/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/mbalassi/subscriptions","organizations_url":"https://api.github.com/users/mbalassi/orgs","repos_url":"https://api.github.com/users/mbalassi/repos","events_url":"https://api.github.com/users/mbalassi/events{/privacy}","received_events_url":"https://api.github.com/users/mbalassi/received_events","type":"User","site_admin":false},"created_at":"2015-05-04T08:20:57Z","updated_at":"2015-05-04T08:20:57Z","body":"Hey,\r\n\r\nSorry for not attending to this for a long time. It needed a rebase for the API of the chaining. Now that I have updated that the test throws the following NPE:\r\n\r\nCaused by: java.lang.NullPointerException\r\n\tat org.apache.flink.streaming.api.complex.ComplexIntegrationTest$MyTimestamp.getTimestamp(ComplexIntegrationTest.java:659)\r\n\tat org.apache.flink.streaming.api.complex.ComplexIntegrationTest$MyTimestamp.getTimestamp(ComplexIntegrationTest.java:654)\r\n\tat org.apache.flink.streaming.api.windowing.helper.TimestampWrapper.getTimestamp(TimestampWrapper.java:34)\r\n\tat org.apache.flink.streaming.api.windowing.windowbuffer.SlidingTimePreReducer.afterEmit(SlidingTimePreReducer.java:71)\r\n\tat org.apache.flink.streaming.api.windowing.windowbuffer.SlidingPreReducer.emitWindow(SlidingPreReducer.java:59)\r\n\t... 7 more\r\n\r\nIt would be nice if we could separate the individual tests, so it is easier to track an exception like that. Maybe a solution similar to `MiltipleProgramsTestBase` for streaming would do the trick.\r\n\r\n@szape, could you please do an update with these, then I'd merge it asap so that it does not get outdated again. Thanks."}}