[jira] [Created] (FLINK-10942) Deduplicate common codes in OutputEmitterTest

zhijiang created FLINK-10942: Summary: Deduplicate common codes in OutputEmitterTest Key: FLINK-10942 URL: https://issues.apache.org/jira/browse/FLINK-10942 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10941) Slots prematurely released which still contain unconsumed data

Qi created FLINK-10941: -- Summary: Slots prematurely released which still contain unconsumed data Key: FLINK-10941 URL: https://issues.apache.org/jira/browse/FLINK-10941 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-10940) Refactor the maven dependencies of Kafka 0.8 connector

vinoyang created FLINK-10940: Summary: Refactor the maven dependencies of Kafka 0.8 connector Key: FLINK-10940 URL: https://issues.apache.org/jira/browse/FLINK-10940 Project: Flink Issue Type:

Re: [DISCUSS] Table API Enhancement Outline

Hi all, Thanks all for the feedback. @Piotr About not using abbreviations naming, +1，I like your proposal！Currently both DataSet and DataStream API are using `aggregate`, BTW，I find other language also not using abbreviations naming，such as R. Sometimes the interface of the API is really

[jira] [Created] (FLINK-10939) Add documents for Flink on native k8s

JIN SUN created FLINK-10939: --- Summary: Add documents for Flink on native k8s Key: FLINK-10939 URL: https://issues.apache.org/jira/browse/FLINK-10939 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10934) Implement KubernetesJobClusterEntrypoint

JIN SUN created FLINK-10934: --- Summary: Implement KubernetesJobClusterEntrypoint Key: FLINK-10934 URL: https://issues.apache.org/jira/browse/FLINK-10934 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10938) Enable Flink on native k8s E2E Tests in Travis CI

JIN SUN created FLINK-10938: --- Summary: Enable Flink on native k8s E2E Tests in Travis CI Key: FLINK-10938 URL: https://issues.apache.org/jira/browse/FLINK-10938 Project: Flink Issue Type:

[jira] [Created] (FLINK-10936) Implement Command line tools

JIN SUN created FLINK-10936: --- Summary: Implement Command line tools Key: FLINK-10936 URL: https://issues.apache.org/jira/browse/FLINK-10936 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10935) Implement KubeClient with Faric8 Kubernetes clients

JIN SUN created FLINK-10935: --- Summary: Implement KubeClient with Faric8 Kubernetes clients Key: FLINK-10935 URL: https://issues.apache.org/jira/browse/FLINK-10935 Project: Flink Issue Type:

[jira] [Created] (FLINK-10933) Implement KubernetesSessionClusterEntrypoint

JIN SUN created FLINK-10933: --- Summary: Implement KubernetesSessionClusterEntrypoint Key: FLINK-10933 URL: https://issues.apache.org/jira/browse/FLINK-10933 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10932) Initial flink-kubernetes module with empty implementation

JIN SUN created FLINK-10932: --- Summary: Initial flink-kubernetes module with empty implementation Key: FLINK-10932 URL: https://issues.apache.org/jira/browse/FLINK-10932 Project: Flink Issue Type:

[jira] [Created] (FLINK-10931) Exclude transitive dependence on Kafka-client

vinoyang created FLINK-10931: Summary: Exclude transitive dependence on Kafka-client Key: FLINK-10931 URL: https://issues.apache.org/jira/browse/FLINK-10931 Project: Flink Issue Type:

[jira] [Created] (FLINK-10930) Refactor checkpoint directory layout

Yun Tang created FLINK-10930: Summary: Refactor checkpoint directory layout Key: FLINK-10930 URL: https://issues.apache.org/jira/browse/FLINK-10930 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10929) Add support for Apache Arrow

Pedro Cardoso Silva created FLINK-10929: --- Summary: Add support for Apache Arrow Key: FLINK-10929 URL: https://issues.apache.org/jira/browse/FLINK-10929 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-10928) Job unable to stabilise after restart

Daniel Harper created FLINK-10928: - Summary: Job unable to stabilise after restart Key: FLINK-10928 URL: https://issues.apache.org/jira/browse/FLINK-10928 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-10927) Resuming Externalized Checkpoint (r, inc, up) test instable

Timo Walther created FLINK-10927: Summary: Resuming Externalized Checkpoint (r, inc, up) test instable Key: FLINK-10927 URL: https://issues.apache.org/jira/browse/FLINK-10927 Project: Flink

Re: JIRA assignment

Hi Joey, Thanks for your offer to help and contribute to Flink! Testing a release candidate is always a much appreciated. A new RC for Flink 1.7.0 should come out in the next days. Regarding the backlog of PRs, everybody is welcome to help reviewing contributions. I would recommend to have a

[jira] [Created] (FLINK-10926) Add TIMESTAMPDIFFmath function supported in Table API and SQL

xuqianjin created FLINK-10926: - Summary: Add TIMESTAMPDIFFmath function supported in Table API and SQL Key: FLINK-10926 URL: https://issues.apache.org/jira/browse/FLINK-10926 Project: Flink

[jira] [Created] (FLINK-10925) NPE in PythonPlanStreamer

Karel Kolman created FLINK-10925: Summary: NPE in PythonPlanStreamer Key: FLINK-10925 URL: https://issues.apache.org/jira/browse/FLINK-10925 Project: Flink Issue Type: Bug Affects

[jira] [Created] (FLINK-10924) StreamExecutionEnvironment method javadocs incorrect in regards to used charset

Chesnay Schepler created FLINK-10924: Summary: StreamExecutionEnvironment method javadocs incorrect in regards to used charset Key: FLINK-10924 URL: https://issues.apache.org/jira/browse/FLINK-10924