Re: different behaviour for OOM error in Flink 1.16

Hi, There are plenty of code changes comparing 1.13.6 with 1.16.1. The diff can be caused by the runtime module, connector module and many other reasons. So it is hard to give a direct answer. But if you like, you can dump the memory of the job in different versions. Then, use tools like MAT, you c

Re: KAFKA SINK ERROR IN Flink-(version 1.14.4)

Hi Harshit, Could you try to update the following line `ds = ds.map(lambda x: ','.join([str(value) for value in x]))` as following: `ds = ds.map(lambda x: ','.join([str(value) for value in x]), output_type=Types.STRING())` The reason is that if the output type is not specified, it will be seriali

KAFKA SINK ERROR IN Flink-(version 1.14.4)

Dear Team, I am new to pyflink and request for your support in issue I am facing with Pyflink. I am using Pyflink version 1.14.4 & using reference code from pyflink getting started pages. I am getting following error . py4j.protocol.Py4JJavaError: An error occurred while calling o10.exec

Re: 回复： rename error in flink sql

??0?2-- *??:* "??" ; *:*?0?22020??10??21??(??) 10:54 *??:*?0?2"Andrey Zagrebin"; *:*?0?2"user";"dwysakowicz" ;"twalthr"; *:*?0?2?? rename error in flink sql Thanks for your replies. um Could yo

?????? rename error in flink sql

Thanks for your help,I have finally modify it and solve it by luck. but new relevent question occur: https://issues.apache.org/jira/browse/FLINK-19746 Could you please have a look at it? I know JIRA is for bug only,but the email will destroy the table I posted, forgive me for posting in JIRA an

?????? rename error in flink sql

Thanks for your replies. um Could you tell me where I am wrong in this code? I'm weak in Java. The pojo is copied from flink official example: https://paste.ubuntu.com/p/kRKxwBpSVK/ the test code is: https://paste.ubuntu.com/p/yVYhZqMNq7/ Thanks for your help~! -- ?

Re: rename error in flink sql

Hi, I am not an SQL expert but I would not expect the original POJO to match the new row with the renamed field. Maybe Timo or Dawid have to add something. Best, Andrey On Tue, Oct 20, 2020 at 4:56 PM 大森林 wrote: > > I'm learning "select"from > official document >

rename error in flink sql

I'm learning "select"from official document my code is: https://paste.ubuntu.com/p/yVYhZqMNq7/ the error I got is:  total is not found in PojoType

Re: error in flink

Hi, yuvraj singh The possible reason may be that you have reached the linux system limit of max user processes. You could confirm this by using the "ulimit -a" command. Also "ulimit -u 32000" could be used to override the default value. Please make sure the user you are running the above commands

error in flink

Hi all , i am having on problem , i was running a job then i submitted one more job on the same cluster then my old job start failing by saying 2019-06-04 15:12:11,593 ERROR org.apache.flink.yarn.YarnResourceManager - Could not start TaskManager in container. java.lang.OutOfMemoryError: unable to

Re: Table API Compilation Error in Flink

:* user@flink.apache.org *Subject:* Re: Table API Compilation Error in Flink Hi Nagananda, adding `flink-streaming-scala_${scala version}` to your maven dependency would solve this. Best, Xingcan On 5 Mar 2018, at 2:21 PM, Nagananda M <mailto:naganand...@tayana.in>> wrote: Hi All,

RE: Table API Compilation Error in Flink

Cc: user@flink.apache.org Subject: Re: Table API Compilation Error in Flink Hi Nagananda, adding `flink-streaming-scala_${scala version}` to your maven dependency would solve this. Best, Xingcan On 5 Mar 2018, at 2:21 PM, Nagananda M wrote: Hi All, Am trying to compile

Re: Table API Compilation Error in Flink

Hi Nagananda, adding `flink-streaming-scala_${scala version}` to your maven dependency would solve this. Best, Xingcan > On 5 Mar 2018, at 2:21 PM, Nagananda M wrote: > > Hi All, > Am trying to compile a sample program in apache flink using TableEnvironment > and facing some issue in compi

Table API Compilation Error in Flink

Hi All, Am trying to compile a sample program in apache flink using TableEnvironment and facing some issue in compilation for the addition of the below line. "StreamTableEnvironment tableEnv = StreamTableEnvironment.getTableEnvironment(env);" The error is as below "cannot access org.apache.flin

Re: Checkpoint Error in flink with Rockdb state backend

Ah yes, if you used a local filesystem for backups this certainly was the source of the problem. On Sun, 29 May 2016 at 17:57 arpit srivastava wrote: > I think the problem was that i was using local filesystem in a cluster. > Now I have switched to hdfs. > > Thanks, > Arpit > > On Sun, May 29, 2

Re: Checkpoint Error in flink with Rockdb state backend

I think the problem was that i was using local filesystem in a cluster. Now I have switched to hdfs. Thanks, Arpit On Sun, May 29, 2016 at 12:57 PM, Aljoscha Krettek wrote: > Hi, > could you please provide the code of your user function that has the > Checkpointed interface and is keeping state

Re: Checkpoint Error in flink with Rockdb state backend

Hi, could you please provide the code of your user function that has the Checkpointed interface and is keeping state? This might give people a chance of understanding what is going on. Cheers, Aljoscha On Sat, 28 May 2016 at 20:55 arpit srivastava wrote: > Hi, > > I am using Flink on yarn clust

Checkpoint Error in flink with Rockdb state backend

Hi, I am using Flink on yarn cluster. My job was running for 2-3 days. After that it failed with two errors org.apache.flink.runtime.io.network.netty.exception.RemoteTransportException: Error at remote task manager 'ip-xx.xx.xx.xxx'. at org.apache.flink.runtime.io.network.netty.PartitionR