Re: flink1.10.0 set execution.attached

2020-08-16 Thread 魏烽
Hi Yang Wang: I meet the question “flink job failed because Am connection is timeout but application still running via yarn-per-job mode” the same as https://issues.apache.org/jira/browse/FLINK-18891 I try to set execution.attached to false,Will this cause other problems?I worry

Re: flink1.10.0 set execution.attached

2020-08-16 Thread Yang Wang
Hi weifeng, The reason why your settings in flink-conf.yaml do not take effect is that we override the "execution.attached" in "FlinkYarnSessionCli#applyDescriptorOptionToConfig" based on the cli option. If the "-d" is specified, "execution.attached" will be set to false. Otherwise, it is true.

Re: [DISCUSS] FLIP-134: DataStream Semantics for Bounded Input

2020-08-16 Thread Kurt Young
Hi Kostas, Thanks for starting this discussion. The first part of this FLIP: "Batch vs Streaming Scheduling" looks reasonable to me. However, there is another dimension I think we should also take into consideration, which is whether checkpointing is enabled. This option is orthogonal (but not

[jira] [Created] (FLINK-18969) Source code build error: Could not resolve dependencies for project org.apache.flink:flink-oss-fs-hadoop:jar:1.12-SNAPSHOT

2020-08-16 Thread Xin Wang (Jira)
Xin Wang created FLINK-18969: Summary: Source code build error: Could not resolve dependencies for project org.apache.flink:flink-oss-fs-hadoop:jar:1.12-SNAPSHOT Key: FLINK-18969 URL:

[DISCUSS] FLIP-135: Approximate Task-Local Recovery

2020-08-16 Thread Yuan Mei
Hi Devs, I would like to start a formal discussion about "FLIP-135 Approximate Task-Local Recovery" [1] which supports approximate single task failure recovery without restarting the entire streaming job. Flink is no longer a pure streaming engine as it was born and has been extended to fit into

[jira] [Created] (FLINK-18968) Translate StateFun homepage to Chinese

2020-08-16 Thread Zixuan Rao (Jira)
Zixuan Rao created FLINK-18968: -- Summary: Translate StateFun homepage to Chinese Key: FLINK-18968 URL: https://issues.apache.org/jira/browse/FLINK-18968 Project: Flink Issue Type: Task