Re: Duplicate tasks for the same query

2020-01-01 Thread Jingsong Li
Blink planner was introduced in 1.9. We recommend use blink planner after 1.9. After some bug fix, I think the latest version of 1.9 is OK. The production environment has also been set up in some places. Best, Jingsong Lee On Wed, Jan 1, 2020 at 3:24 AM RKandoji wrote: > Thanks Jingsong and Kur

Re: Does Flink SQL support stop with savepoint draining?

2020-01-01 Thread Jingsong Li
Hi Yuval: I think yes. You can take a look to FLIP-34 [1]. It is already finished in 1.9. And document in [2] [1] https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=103090212 [2] https://ci.apache.org/projects/flink/flink-docs-master/ops/cli.html#stop Best, Jingsong Lee On Tue,

Re: Best way set max heap size via env variables or program arguments?

2020-01-01 Thread Xintong Song
Hi Li, Regarding your questions: 1. Is there actually a way to pass in the heap size via arguments to > taskmanager.sh? Is passing -Dtaskmanager.heap.size supposed to work? No, '-Dtaskmanager.heap.size' is not supposed to work. The '-D' configurations are only parsed after the JVM is started, w