Re: java.lang.StackOverflowError

多谢，已经找到解决的issue了：https://issues.apache.org/jira/browse/FLINK-10367 > 2020年1月22日 下午4:48，zhisheng 写道： > > 1、建议问题别同时发到三个邮件去 > 2、找找还有没有更加明显的异常日志 > > 刘建刚 于2020年1月22日周三 上午10:25写道： > >> I am using flink 1.6.2 on yarn. State backend is rocksdb. >>

[State Processor API] how to convert savepoint back to broadcast state

Hi there, I would like to read the savepoints (for broadcast state) back into the broadcast state, how should I do it? // load the existingSavepoint; ExistingSavepoint existingSavepoint = Savepoint.load(environment, "file:///tmp/new_savepoints", new MemoryStateBackend()); // read state from exis

Re: request for a flink sink

hi，flink don't have facebook faiss connector now, you can custom Sink (implement SinkFunction) 容祖儿 于2020年1月22日周三 下午7:55写道： > Hi members, > > Do you know if there is a sink who writes data to facebook faiss[1]? > I am looking for a sink class like this one [2]. > > [1] https://github.com/faceboo

request for a flink sink

Hi members, Do you know if there is a sink who writes data to facebook faiss[1]? I am looking for a sink class like this one [2]. [1] https://github.com/facebookresearch/faiss [2] https://ci.apache.org/projects/flink/flink-docs-release-1.9/zh/dev/connectors/rabbitmq.html Thank you.

Re: java.lang.StackOverflowError

1、建议问题别同时发到三个邮件去 2、找找还有没有更加明显的异常日志 刘建刚 于2020年1月22日周三 上午10:25写道： > I am using flink 1.6.2 on yarn. State backend is rocksdb. > > > 2020年1月22日 上午10:15，刘建刚 写道： > > > > I have a flink job which fails occasionally. I am eager to avoid > this problem. Can anyone help me? The error stacktrace is

Re: flink on yarn任务启动报错 The assigned slot container_e10_1579661300080_0005_01_000002_0 was removed.

应该是你作业之前挂过了 郑 洁锋 于2020年1月22日周三 上午11:16写道： > 大家好， >flink on yarn任务启动时，发现报错了The assigned slot > container_e10_1579661300080_0005_01_02_0 was removed. >环境：flink1.8.1，cdh5.14.2，kafka0.10，jdk1.8.0_241 > > flink版本为1.8.1，yarn上的日志： > > 20/01/22 11:07:53 INFO entrypoint.ClusterEntrypo