Re: Flink issue in emitting data to same sideoutput from onTimer and processElement

2020-08-14 Thread Dawid Wysakowicz
ka.ms/ghei36> > > > *From:* Jaswin Shah > *Sent:* Friday, August 14, 2020 3:09:21 PM > *To:* user@flink.apache.org ; Dawid Wysakowicz > ; Yun Tang > *Subject:* Flink issue in emitting data to same sideoutput from > onTimer an

Re: Flink issue in emitting data to same sideoutput from onTimer and processElement

2020-08-14 Thread Jaswin Shah
I am using KeyedCoProcessFunction Get Outlook for Android<https://aka.ms/ghei36> From: Jaswin Shah Sent: Friday, August 14, 2020 3:09:21 PM To: user@flink.apache.org ; Dawid Wysakowicz ; Yun Tang Subject: Flink issue in emitting data to same sideoutpu

Flink issue in emitting data to same sideoutput from onTimer and processElement

2020-08-14 Thread Jaswin Shah
Hi, I have a coProcessFunction which emits data to same side output from processElement1 method and on timer method.But, data is not getting emitted to sideoutput from onTimer. Is it like to the same sideoutput, we can not emit data from onTimer and processElement methods? Get Outlook for And

Re: Flink issue

2019-08-02 Thread Zhu Zhu
For network issue, this answer might help http://mail-archives.apache.org/mod_mbox/flink-user/201907.mbox/%3cdb49d6f2-1a6b-490a-8502-edd9562b0163.yungao...@aliyun.com%3E . Thanks, Zhu Zhu Karthick Thanigaimani 于2019年8月2日周五 下午5:34写道: > Yes Zhu, the server is online and it didn't get died. So it

Re: Flink issue

2019-08-02 Thread Zhu Zhu
Hi Karthick, Could you check whether the `lost` TM 'flink-taskmanager-b/2:6121' is still alive when the error is reported? If it is still alive then, this seems to be a network issue between 'flink-taskmanager-c:6121' and 'flink-taskmanager-b/2:6121'. Otherwise, it is needed to check why the TM ex

Re: Flink issue

2019-08-01 Thread Zhu Zhu
Hi Karthick, >From the log seems the TM "flink-taskmanager-b/2:6121" is lost unexpectedly. You may need to check the log of that TM to see why it exits, which should be the root cause. Thanks, Zhu Zhu Karthick Thanigaimani 于2019年8月2日周五 下午1:54写道: > Hi Team, > We are facing frequent issues with

Re: Flink issue while setting up in Kubernetes

2018-12-10 Thread Gary Yao
Hi Abhi Thakur, We need more information to help you. What docker images are you using? Can you share the kubernetes resource definitions? Can you share the complete logs of the JM and TMs? Did you follow the steps outlined in the Flink documentation [1]? Best, Gary [1] https://ci.apache.org/pro

Flink issue while setting up in Kubernetes

2018-12-09 Thread Thakur, Abhi
We are trying to setup a single node Kubernetes cluster. 1 Job Manager and 1 Task Manager. Before we were getting an error, and we followed this thread. http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-1-5-4-issues-w-TaskManager-connecting-to-ResourceManager-td23298.html Af

Re: Flink issue

2017-05-16 Thread Till Rohrmann
Hi Francisco, is there anything suspicious in the logs files of the Taskmanager and the JobManager? Cheers, Till On Tue, May 16, 2017 at 5:49 PM, Francisco Alves wrote: > Hi, > > I'm running flink in a yarn session, and when a try to cancel a running > program with parameters "-yid" and "job