Re: Help with OneInputStreamOperatorTestHarness

Hi Fabian, I created FLINK-9262 . FYI, - Chris > On Apr 26, 2018, at 3:07 AM, Fabian Hueske wrote: > > Thanks for reporting the issue Chris! > Would you mind opening a JIRA issue [1] to track the bug for Flink 1.4? > >

Re: Help with OneInputStreamOperatorTestHarness

Thanks for reporting the issue Chris! Would you mind opening a JIRA issue [1] to track the bug for Flink 1.4? Thank you, Fabian [1] https://issues.apache.org/jira/browse/FLINK 2018-04-25 21:11 GMT+02:00 Chris Schneider : > Hi Gang, > > FWIW, the code below works

Re: Help with OneInputStreamOperatorTestHarness

Hi Gang, FWIW, the code below works just fine using Flink 1.5-SNAPSHOT. I also tried cherry-picking the commit that fixed FLINK-8268 to Flink 1.4.0, but that resulted in the same failure mode. I guess

Re: Help with OneInputStreamOperatorTestHarness

Hi Ted, I should have written that we’re using Flink 1.4.0. Thanks for the suggestion re: FLINK-8268 ; it could well be the issue (though the pull request appears fairly complex so I’ll need

Help with OneInputStreamOperatorTestHarness

Hi Gang, I’m having trouble getting my streaming unit test to work. The following code: @Test public void testDemo() throws Throwable { OneInputStreamOperatorTestHarness testHarness = new KeyedOneInputStreamOperatorTestHarness