Thank you!
On Thu, Nov 15, 2018 at 4:18 PM Chesnay Schepler wrote:
> I'm highly encouraging you to read through the examples and Batch API
> documentation:
>
>
> https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/batch/#example-program
>
>
I'm highly encouraging you to read through the examples and Batch API
documentation:
https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/batch/#example-program
https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/batch/dataset_transformations.html#dataset-transformations
Hello guys
I have wrote this code. I could print the whole file, but I want to read the
file line by line and process each line separately. would you please help
how I can do that?
ExecutionEnvironment env = ExecutionEnvironment.createLocalEnvironment();
DataSet transactions =
Hello guys
I have wrote this code. I could print the whole file, but I want to read the
file line by line and process each line separately. would you please help
how I can do that?
ExecutionEnvironment env = ExecutionEnvironment.createLocalEnvironment();
DataSet transactions =
Hi,
I have written simple wordcount program in scala. When I execute the
program, I'm getting below exception.
Please let me know how to fix this issue. I'm using Flink 0.9.0 version
*Below is the program :-*
val env = ExecutionEnvironment.getExecutionEnvironment
// get input data
Hi Scahin,
Thank you for the response. I have commented *counts print *line. After
that I got below exception
Exception in thread main java.lang.RuntimeException: No data sinks have
been created yet. A program needs at least one sink that consumes data.
Examples are writing the data set or
Hi
You do not need to call env.execute after doing a print call. Print itself
triggers the execution. The reason for the Exception is quite obvious.
After the print call, there is no sink for the program execution. So,
execution cannot proceed.
You can however explicitly define a sink and then
Hi,
Flink program should have at least one data sink. When your program calls
`print` method, the method adds a data sink into your program automatically and
execute it immediately. If you want to run Flink program without calling
`print` method, you should add a data sink into your program
