Re: Flink 1.7 Development Priorities

I would like to have https://issues.apache.org/jira/browse/FLINK-7289 in the release. It's problematic to control memory usage of rocksdb backend. And many people have issue on it. Best Yan Aljoscha Krettek-2 wrote > Hi Everyone, > > After the recent Flink 1.6 release the people working on Flin

答复: Flink1.6.0 submit job and got "No content to map due to end-of-input" Error

Hi Vino， Below are dependencies I used，please have a look. I floud it also inclued flink-connector-kafka-0.10_2.11-1.6.0.jar and flink-connector-kafka-0.9_2.11-1.6.0.jar, and I don’t know if it has any effect? yours, Gongsen [cid:image001.png@01D4451B.3D5B1580] 发送自 Windows 10 版邮件

[jira] [Created] (FLINK-10281) Table function parse regular expression contains backslash failed

vinoyang created FLINK-10281: Summary: Table function parse regular expression contains backslash failed Key: FLINK-10281 URL: https://issues.apache.org/jira/browse/FLINK-10281 Project: Flink Is

Re: Flink1.6.0 submit job and got "No content to map due to end-of-input" Error

Hi Pangongsen, Do you upgrade the Flink-related dependencies you use at the same time? In other words, is the dependency consistent with the flink version? Thanks, vino. ? ?? 于2018年9月4日周二 下午10:07写道： > Hi all, > I use below way to submit jar to Flink : > > StreamExecutionEnvironment env =

[jira] [Created] (FLINK-10280) json that contains an object can not be parse

sean.miao created FLINK-10280: - Summary: json that contains an object can not be parse Key: FLINK-10280 URL: https://issues.apache.org/jira/browse/FLINK-10280 Project: Flink Issue Type: Bug

Flink1.6.0 submit job and got "No content to map due to end-of-input" Error

Hi all, I use below way to submit jar to Flink : StreamExecutionEnvironment env = StreamExecutionEnvironment.createRemoteEnvironment(config.clusterIp, config.clusterPort,

Re: Cancel flink job occur exception.

Hi Devin, Why do you trigger cancel with savepoint immediately after the job status changes to Deployed? A more secure way is to wait for the job to become running after it has been running for a while before triggering. We have also encountered before, there will be a case where the client times

Cancel flink job occur exception

Hi all, I submit a flink job through yarn-cluster mode and cancel job with savepoint option immediately after job status change to deployed. Sometimes i met this error: org.apache.flink.util.FlinkException: Could not cancel job . at org.apache.flink.client.cli.CliFrontend.lamb

Cancel flink job occur exception.

Hi all, I submit a flink job through yarn-cluster mode and cancel job with savepoint option immediately after job status change to deployed. Sometimes i met this error: org.apache.flink.util.FlinkException: Could not cancel job . at org.apache.flink.client.cli.CliFrontend.lamb