Hi flink !

Looks like "setSlotSharing" is throwing an NPE when I try to start a
Thread  which runs a streaming job.

I'm trying to do this by creating a dataStream from env.readFileStream, and
then later starting a job which writes files out ...

However, I get

Exception in thread "main" java.lang.NullPointerException
    at
org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator.setSlotSharing(StreamingJobGraphGenerator.java:361)

What is the right way to create a stream and batch job all in one
environment?

For reference, here is a gist of the code
https://gist.github.com/jayunit100/c7ab61d1833708d290df, and the offending
line is the

DataStream<String> dataStream = env.readFileStream("/tmp/a",1000,
FileMonitoringFunction.WatchType.ONLY_NEW_FILES);

line.

Thanks again !

-- 
jay vyas

Reply via email to