[jira] [Created] (FLINK-13849) The back-pressure monitoring tab in Web UI may cause errors

2019-08-25 Thread Xingcan Cui (Jira)
Xingcan Cui created FLINK-13849: --- Summary: The back-pressure monitoring tab in Web UI may cause errors Key: FLINK-13849 URL: https://issues.apache.org/jira/browse/FLINK-13849 Project: Flink

Re: [DISCUSS] Enhance Support for Multicast Communication Pattern

2019-08-25 Thread Guowei Ma
Thanks Yun for bringing up this discussion and very thanks for all the deep thoughts! For now, I think this discussion contains two scenarios: one if for iteration library support and the other is for SQL join support. I think both of the two scenarios are useful but they seem to have different

Re: [DISCUSS] Setup a bui...@flink.apache.org mailing list for travis builds

2019-08-25 Thread Jark Wu
Hi all, Sorry it take so long to get back. I have some good news. After some investigation and development and the help from Chesnay, we finally integrated Travis build notification with bui...@flink.apache.org mailing list with remaining the beautiful formatting! Currently, only the failure and

[jira] [Created] (FLINK-13848) Support “scheduleAtFixedRate/scheduleAtFixedDelay” in RpcEndpoint#MainThreadExecutor

2019-08-25 Thread Biao Liu (Jira)
Biao Liu created FLINK-13848: Summary: Support “scheduleAtFixedRate/scheduleAtFixedDelay” in RpcEndpoint#MainThreadExecutor Key: FLINK-13848 URL: https://issues.apache.org/jira/browse/FLINK-13848

Re: [DISCUSS] Flink Python User-Defined Function for Table API

2019-08-25 Thread Dian Fu
Hi Jincheng, Appreciated for the kind tips and offering of help. Definitely need it! Could you grant me write permission for confluence? My Id: Dian Fu Thanks, Dian > 在 2019年8月26日，上午9:53，jincheng sun 写道： > > Thanks for your feedback Hequn & Dian. > > Dian, I am glad to see that you want

[jira] [Created] (FLINK-13847) Update release scripts to also update docs/_config.yml

2019-08-25 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-13847: --- Summary: Update release scripts to also update docs/_config.yml Key: FLINK-13847 URL: https://issues.apache.org/jira/browse/FLINK-13847 Project: Flink

Re: [DISCUSS] Flink client api enhancement for downstream project

2019-08-25 Thread Yang Wang
Hi Zili, It make sense to me that a dedicated cluster is started for a per-job cluster and will not accept more jobs. Just have a question about the command line. Currently we could use the following commands to start different clusters. *per-job cluster* ./bin/flink run -d -p 5 -ynm

Re: [DISCUSS] Flink Python User-Defined Function for Table API

2019-08-25 Thread jincheng sun
Thanks for your feedback Hequn & Dian. Dian, I am glad to see that you want help to create the FLIP! Everyone will have first time, and I am very willing to help you complete your first FLIP creation. Here some tips: - First I'll give your account write permission for confluence. - Before create

Re: [DISCUSS] Use Java's Duration instead of Flink's Time

2019-08-25 Thread Jark Wu
+1 to use Java's Duration instead of Flink's Time. Regarding to the Duration parsing, we have mentioned this in FLIP-54[1] to use `org.apache.flink.util.TimeUtils` for the parsing. Best, Jark [1]:

Re: [DISCUSS] Add ARM CI build to Flink (information-only)

2019-08-25 Thread Xiyuan Wang
Thanks for Stephan to bring up this topic. The package build jobs work well now. I have a simple online demo which is built and ran on a ARM VM. Feel free to have a try[1]. As the first step for ARM support, maybe it's good to add them now. While for the next step, the test part is still

Re: [DISCUSS] Enhance Support for Multicast Communication Pattern

2019-08-25 Thread SHI Xiaogang
Hi all, I also think that multicasting is a necessity in Flink, but more details are needed to be considered. Currently network is tightly coupled with states in Flink to achieve automatic scaling. We can only access keyed states in keyed streams and operator states in all streams. In the

[jira] [Created] (FLINK-13846) Implement benchmark case on MapState#isEmpty

2019-08-25 Thread Yun Tang (Jira)
Yun Tang created FLINK-13846: Summary: Implement benchmark case on MapState#isEmpty Key: FLINK-13846 URL: https://issues.apache.org/jira/browse/FLINK-13846 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-13845) Drop all the content of removed "Checkpointed" interface

2019-08-25 Thread Yun Tang (Jira)
Yun Tang created FLINK-13845: Summary: Drop all the content of removed "Checkpointed" interface Key: FLINK-13845 URL: https://issues.apache.org/jira/browse/FLINK-13845 Project: Flink Issue Type:

[jira] [Created] (FLINK-13844) AtOmXpLuS

2019-08-25 Thread KORAY DURGUT (Jira)
KORAY DURGUT created FLINK-13844: - Summary: AtOmXpLuS Key: FLINK-13844 URL: https://issues.apache.org/jira/browse/FLINK-13844 Project: Flink Issue Type: Bug Components: Connectors

[jira] [Created] (FLINK-13843) Unify and clean up StreamingFileSink format builders

2019-08-25 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-13843: -- Summary: Unify and clean up StreamingFileSink format builders Key: FLINK-13843 URL: https://issues.apache.org/jira/browse/FLINK-13843 Project: Flink Issue Type: