Re: Help with OneInputStreamOperatorTestHarness

2018-04-26 Thread Chris Schneider
> Thank you, Fabian > > [1] https://issues.apache.org/jira/browse/FLINK > <https://issues.apache.org/jira/browse/FLINK> > > 2018-04-25 21:11 GMT+02:00 Chris Schneider <mailto:cschnei...@scaleunlimited.com>>: > Hi Gang, > > FWIW, the code below works jus

Re: Help with OneInputStreamOperatorTestHarness

2018-04-25 Thread Chris Schneider
guess the takeaway is that this streaming test code harness support (which everyone should note is not yet part of the public Flink API) was apparently fragile in 1.4.0. FYI, - Chris > On Apr 18, 2018, at 8:07 PM, Chris Schneider > wrote: > > Hi Ted, > > I should have

Re: Help with OneInputStreamOperatorTestHarness

2018-04-18 Thread Chris Schneider
so I’ll need some time to study it). Best Regards, - Chris > On Apr 18, 2018, at 6:33 PM, Ted Yu wrote: > > Which release are you using ? > > See if the work around from FLINK-8268 helps. > > Cheers > > On Wed, Apr 18, 2018 at 6:26 PM, Chris Schneider > mailto:c

Help with OneInputStreamOperatorTestHarness

2018-04-18 Thread Chris Schneider
ide more of my code (e.g., PldKeySelector, DomainDBFunction, CrawlStateUrl, RawUrl, etc.), but that doesn’t seem like it would have much to do with the problem. Any advice would be most welcome. Thanks, - Chris ----- Chris Schneider http://www.scaleunli

Re: How to run a Flink job in EMR?

2017-06-26 Thread Chris Schneider
user-digest-h...@flink.apache.org wrote: > From: "Foster, Craig" mailto:foscr...@amazon.com>> > Subject: Re: How to run a Flink job in EMR? > Date: June 7, 2017 at 7:27:53 PM PDT > To: Chris Schneider <mailto:cschnei...@scaleunlimited.com>>, "user@flink.apac

How to run a Flink job in EMR?

2017-06-07 Thread Chris Schneider
r.WebRuntimeMonitor - Removing web dashboard jar upload directory /tmp/flink-web-71b2e41d-b08d-43e8-bd0d-b6fb5cc329a2 ----- Chris Schneider http://www.scaleunlimited.com <http://www.scaleunlimited.com/> custom big data solutions -