Fw: Flink Cluster Load Distribution Question

Hi Robert,Sure, I am forwarding it to user. Sorry about that. I followed the "robot's" instructions :))Topology: 4 Azure A11 CentOS 7 nodes (16 cores, 110 GB). Lets call them node1, 2, 3, 4.Flink Clustered with node1 running JM & a TM. Three more TM's running on node2,3, and 4 respectively.I

Discard message LeaderSessionMessage(null,ConnectionTimeout)

Hello, while running a job on Flink 1.1.2 on a cluster of 3 nodes using the KafkaProducer010, I encounter this error: WARN org.apache.flink.runtime.client.JobClientActor- Discard message LeaderSessionMessage(null,ConnectionTimeout) because the expected leader session ID

Re: Flink JDBC JDBCOutputFormat Open

Thanks Chesnay for update. On Tue, Sep 13, 2016 at 12:13 AM, Chesnay Schepler wrote: > Hello, > > the JDBC Sink completely ignores the taskNumber and parallelism. > > Regards, > Chesnay > > > On 12.09.2016 08:41, Swapnil Chougule wrote: > > Hi Team, > > I want to know how

Re: Sharing Java Collections within Flink Cluster

Hi, you don't need the BlockedEventState class, you should be able to just do this: private transient ValueState blockedRoads; @Override public void open(final org.apache.flink.configuration.Configuration parameters) throws Exception { final