So what you should do is just call print and remove the execute call.
– Ufuk
On Sunday, July 19, 2015, Madabhattula Rajesh Kumar
wrote:
> Hi Chiwan Park,
>
> Thank you for the clarification
>
> Regards,
> Rajesh
>
> On Sun, Jul 19, 2015 at 11:49 PM, Chiwan Park > wrote:
>
>> Hi,
>>
>> Flink pr
Hi Chiwan Park,
Thank you for the clarification
Regards,
Rajesh
On Sun, Jul 19, 2015 at 11:49 PM, Chiwan Park wrote:
> 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 i
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 and
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 prin
Okay. If you are using very big values, it often helps to tell Flink to
reserve less memory for its internal processing.
Can you try and set the memory fraction lower, e.g., 0.5 lower.
Have a look at the option "taskmanager.memory.fraction" (
https://ci.apache.org/projects/flink/flink-docs-releas
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 call
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
v
why
not found Although use library
.sortPartition(1, Order.ASCENDING)
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Order-groups-by-their-keys-tp2056p2153.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
