how to query the output of the scalar table function

Hi, I am not able to find what is best way to query the output of a scalar table function. Suppose I have table which has column col1 which is string. I have a scalar function and returns a POJO {col1V1 String, col1V2 String , col1V3 String}. I am using following. so table.select("sf(col1) as

Task Manager fault tolerance does not work

HI, I have set up a flink 1.4 cluster with 1 job manager and two task managers. The configs taskmanager.numberOfTaskSlots and parallelism.default were set to 2 on each node. I submitted a job to this cluster and it runs fine. To test fault tolerance, I killed one task manager. I was expecting the j

Re: How does setMaxParallelism work

No, currently, this it is up to you to decide whether you need to scale and how. If, for a running Flink job, you decide to scale, you - flink cancel --withSavepoint - flink run -p --fromSavepoint Nico On 29/03/18 19:27, NEKRASSOV, ALEXEI wrote: > Is there an auto-scaling feature in Flink,