bq. To enable Queryable State, please move the
flink-queryable-state-runtime jar from the opt to the lib folder.
Have you noticed the above and taken corresponding action ?
Thanks
On Sat, Apr 21, 2018 at 3:15 PM, JP de Vooght wrote:
> Hello,
>
> When I submit a WordCount job from the examples,
Hello,
When I submit a WordCount job from the examples, without any parameter,
to a standalone cluster running on Docker, I cannot see the
System.out.println() message. Instead I notice the
org.apache.flink.metrics.MetricGroup entry below (last)
jobmanager_1 | Starting Job Manager
jobmanager_1
Hello,
Just to provide a brief update: I got this working by moving to the stable
version 1.4.2.
I previously tested under 1.5-SNAPSHOT and 1.6-SNAPSHOT and the problem
occurred in both.
If I'm not mistaken, LocalEnvironment is primarily targeted at debugging
scenarios.
In my case, I explicitly
I would expect that to be possible as well, yes.
> On 21. Apr 2018, at 17:33, Vishal Santoshi wrote:
>
> >> After the savepoint state has been written, the sink might start new
> >> .in-progress files. These files are not part of the savepoint but renamed
> >> to .pending in close().
> >> On r
>> After the savepoint state has been written, the sink might start new
.in-progress files. These files are not part of the savepoint but renamed
to .pending in close().
>> On restore all pending files that are part of the savepoint are moved
into final state (and possibly truncated). See
handlePen
Hi,
The number 4.0.16 refer to netty version, not the Linux kernel version
Regards,
Kien
Sent from TypeApp
On Apr 20, 2018, 21:45, at 21:45, Ted Yu wrote:
>I think you should upgrade Linux to said version or newer.
>
>Cheers
>
>On Fri, Apr 20, 2018 at 6:35 AM, makeyang
>wrote:
>
>> my flin
