Probably you need to refer to the file on HDFS or manually make it available on
each node as a local file. HDFS is recommended.
If it is already on HDFS then you need to provide an HDFS URL to the file.
> On 5. Aug 2017, at 14:27, Kaepke, Marc wrote:
>
> Hi there,
>
> my really small test job
Hi there,
my really small test job reads an external file and print the input to console.
Execute it as standalone with a local cluster, everything is fine.
If I execute the same job as standalone with 1 job manager und 1 task manager,
I get an FileNotFound Exception. As a real distributed cluste
> No errors, and no
data in table.
2017-08-05 14:49 GMT+03:00 Егор Литвиненко :
> Hi
>
> I try to test Flink and have a problems.
> Why this example doesn't work - https://github.com/
> egorlitvinenko/testparsing/blob/master/test-flink/src/
> main/java/org/egorlitvinenko/testflink/StreamingJob9C.
Hi
I try to test Flink and have a problems.
Why this example doesn't work -
https://github.com/egorlitvinenko/testparsing/blob/master/test-flink/src/main/java/org/egorlitvinenko/testflink/StreamingJob9C.java
Logs - https://pastebin.com/iuBZhfeG
No errors, and no
One more question. Examples intent
What is the advantage of queryable state compared to writing the result
back to Kafka?
regards,
Georg
The Apache Flink community is pleased to announce the release of Apache Flink
1.3.2.
Apache Flink® is an open-source stream processing framework for distributed,
high-performing, always-available, and accurate data streaming applications.
The release is available for download at:
https://flin
