Re: [DISCUSS] Semantics of our JIRA fields

2020-05-24 Thread Zhijiang
Thanks for launching this discussion and giving so detailed infos, Robert! +1 on my side for the proposal. For "Affects Version", I previously thought it was only for the already released versions, so it can give a reminder that the fix should also pick into the related released branches for

Please update the Requirements of PyPI

2020-05-24 Thread Ray Chen
Hi PyFlink Developers, I got some errors from the pyarrow depended on apache-flink v1.10.1. It seems updating pyarrow version greater than 0.14 will solve the problem. The version of Flink on PyPI depends on < 0.14, so cause the error. Best, Ray Chen

Re: [DISCUSS] Semantics of our JIRA fields

2020-05-24 Thread Yun Tang
Hi I like the idea to give clear description of JIRA fields in Flink community when creating tickets. After reading from Robert's explanation, I found my previous understanding differs from the field at "Affect Version/s", and is close to general understanding as JIRA official guide said[1]: Af

Re: [DISCUSS] Semantics of our JIRA fields

2020-05-24 Thread Chesnay Schepler
flink-web is independent from any release, so there should be no affects/fix version. On 25/05/2020 07:56, Congxian Qiu wrote: Hi Currently, when I'm going to create an issue for Project-website. I'm not very sure what the "Affect Version/s" should be set. The problem is that the current Dockf

[jira] [Created] (FLINK-17917) ResourceInformationReflector#getExternalResources should ignore the external resource with a value of 0

2020-05-24 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17917: -- Summary: ResourceInformationReflector#getExternalResources should ignore the external resource with a value of 0 Key: FLINK-17917 URL: https://issues.apache.org/jira/browse/FLINK-1791

[jira] [Created] (FLINK-17915) TransitiveClosureITCase>JavaProgramTestBase.testJobWithObjectReuse:113 Error while calling the test program: Could not retrieve JobResult

2020-05-24 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17915: -- Summary: TransitiveClosureITCase>JavaProgramTestBase.testJobWithObjectReuse:113 Error while calling the test program: Could not retrieve JobResult Key: FLINK-17915 URL: https

[jira] [Created] (FLINK-17916) Separate KafkaShuffle read/write to different environments

2020-05-24 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-17916: Summary: Separate KafkaShuffle read/write to different environments Key: FLINK-17916 URL: https://issues.apache.org/jira/browse/FLINK-17916 Project: Flink Issue Type

[jira] [Created] (FLINK-17914) HistoryServerTest.testCleanExpiredJob:158->runArchiveExpirationTest:214 expected:<2> but was:<0>

2020-05-24 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17914: -- Summary: HistoryServerTest.testCleanExpiredJob:158->runArchiveExpirationTest:214 expected:<2> but was:<0> Key: FLINK-17914 URL: https://issues.apache.org/jira/browse/FLINK-17

Re: [DISCUSS] Semantics of our JIRA fields

2020-05-24 Thread Congxian Qiu
Hi Currently, when I'm going to create an issue for Project-website. I'm not very sure what the "Affect Version/s" should be set. The problem is that the current Dockfile[1] in flink-web is broken because of the EOL of Ubuntu 18.10[2], the project-web does not affect any release of Flink, it does

[jira] [Created] (FLINK-17912) KafkaShuffleITCase.testAssignedToPartitionEventTime: "Watermark should always increase"

2020-05-24 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17912: -- Summary: KafkaShuffleITCase.testAssignedToPartitionEventTime: "Watermark should always increase" Key: FLINK-17912 URL: https://issues.apache.org/jira/browse/FLINK-17912

[jira] [Created] (FLINK-17911) K8s e2e: error: timed out waiting for the condition on deployments/flink-native-k8s-session-1

2020-05-24 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17911: -- Summary: K8s e2e: error: timed out waiting for the condition on deployments/flink-native-k8s-session-1 Key: FLINK-17911 URL: https://issues.apache.org/jira/browse/FLINK-17911

[ANNOUNCE] Apache Flink 1.11.0, release candidate #1

2020-05-24 Thread Zhijiang
Hi all, Apache Flink-1.11.0-RC1 has been created. It has all the artifacts that we would typically have for a release. This preview-only RC is created only to drive the current testing efforts, and no official vote will take place. It includes the following: * The preview source release and

[jira] [Created] (FLINK-17909) Make the GenericInMemoryCatalog to hold the serialized meta data to uncover more potential bugs

2020-05-24 Thread Jark Wu (Jira)
Jark Wu created FLINK-17909: --- Summary: Make the GenericInMemoryCatalog to hold the serialized meta data to uncover more potential bugs Key: FLINK-17909 URL: https://issues.apache.org/jira/browse/FLINK-17909

Re: java.lang.NoSuchMethodError while writing to Kafka from Flink

2020-05-24 Thread Guowei Ma
Hi 1. You could check whether the 'org.apache.flink.api.java.clean' is in your classpath first. 2. Do you follow the doc[1] to deploy your local cluster and run some existed examples such as WordCount? [1] https://ci.apache.org/projects/flink/flink-docs-release-1.10/ops/deployment/cluster_setup.h

[jira] [Created] (FLINK-17908) Vague document about Kafka config in SQL-CLI

2020-05-24 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-17908: - Summary: Vague document about Kafka config in SQL-CLI Key: FLINK-17908 URL: https://issues.apache.org/jira/browse/FLINK-17908 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-17907) flink-table-api-java: Compilation failure

2020-05-24 Thread Aihua Li (Jira)
Aihua Li created FLINK-17907: Summary: flink-table-api-java: Compilation failure Key: FLINK-17907 URL: https://issues.apache.org/jira/browse/FLINK-17907 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-17906) Fix performance issues in WatermarkOutputMultiplexer

2020-05-24 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-17906: Summary: Fix performance issues in WatermarkOutputMultiplexer Key: FLINK-17906 URL: https://issues.apache.org/jira/browse/FLINK-17906 Project: Flink Issue Ty

[jira] [Created] (FLINK-17904) Add "scheduleWithFixedDelay" to ProcessingTimeService

2020-05-24 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-17904: Summary: Add "scheduleWithFixedDelay" to ProcessingTimeService Key: FLINK-17904 URL: https://issues.apache.org/jira/browse/FLINK-17904 Project: Flink Issue T

[jira] [Created] (FLINK-17905) Docs for JDBC connector show licence and markup

2020-05-24 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-17905: - Summary: Docs for JDBC connector show licence and markup Key: FLINK-17905 URL: https://issues.apache.org/jira/browse/FLINK-17905 Project: Flink Iss

[jira] [Created] (FLINK-17903) Evolve WatermarkOutputMultiplexer to make it reusable in FLIP-27 Sources

2020-05-24 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-17903: Summary: Evolve WatermarkOutputMultiplexer to make it reusable in FLIP-27 Sources Key: FLINK-17903 URL: https://issues.apache.org/jira/browse/FLINK-17903 Project: Fl

[jira] [Created] (FLINK-17902) Support the new interfaces about temporary functions in PyFlink

2020-05-24 Thread Dian Fu (Jira)
Dian Fu created FLINK-17902: --- Summary: Support the new interfaces about temporary functions in PyFlink Key: FLINK-17902 URL: https://issues.apache.org/jira/browse/FLINK-17902 Project: Flink Issue

[jira] [Created] (FLINK-17901) Add module interface in PyFlink

2020-05-24 Thread Dian Fu (Jira)
Dian Fu created FLINK-17901: --- Summary: Add module interface in PyFlink Key: FLINK-17901 URL: https://issues.apache.org/jira/browse/FLINK-17901 Project: Flink Issue Type: Task Components: