Streaming issue help needed

Hi, I am trying to implement Flink steaming using an example in GitHub: https://github.com/andi1400/bestXStreamRating . While executing I am getting the below error. Can you please help guide me on the resolution. Thanks in advance! Starting

How to stop job through java API

Hi folks, How to stop link job given job_id through java API? Thanks, Will

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 hav

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 4a1c16fe-

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 tasknumber & numtasks h