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

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:

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

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-13845) Drop all the content of removed "Checkpointed" interface

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-13846) Implement benchmark case on MapState#isEmpty

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

Re: [DISCUSS] Enhance Support for Multicast Communication Pattern

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 concret

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

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 broken.

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

+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]: https://docs.google.com/document/d/1IQ7nwXqmhCy900t2vQLEL3N2HIdMg-JO8vTzo1BtyKU/edit#heading=h.egdw

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

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] Flink client api enhancement for downstream project

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 perjob-clust

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

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 Python User-Defined Function for Table API

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 help

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

Biao Liu created FLINK-13848: Summary: Support “scheduleAtFixedRate/scheduleAtFixedDelay” in RpcEndpoint#MainThreadExecutor Key: FLINK-13848 URL: https://issues.apache.org/jira/browse/FLINK-13848 Project:

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

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

Re: [DISCUSS] Enhance Support for Multicast Communication Pattern

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 be

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

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 Is

Re: [DISSCUSS] Tolerate temporarily suspended ZooKeeper connections

Hi Till, I'd like to revive this thread since 1.9.0 has been released. IMHO we already reached a consensus on JIRA and if you can review the pull request we hopefully address the issue in next release. Best, tison. Zili Chen 于2019年7月29日周一 下午11:05写道： > Hi Till, > > Thanks for your explanation

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

I'm sorry, but if these issues are only fixed later anyway I see no reason to run these tests on each PR. We're just adding noise to each PR that everyone will just ignore. I'm curious as to the benefit of having this directly in Flink; why aren't the ARM builds run outside of the Flink projec