[jira] [Created] (FLINK-22520) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition hangs

2021-04-28 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22520: - Summary: KafkaSourceLegacyITCase.testMultipleSourcesOnePartition hangs Key: FLINK-22520 URL: https://issues.apache.org/jira/browse/FLINK-22520 Project: Flink

Re: [VOTE] Release 1.13.0, release candidate #2

2021-04-28 Thread Zhu Zhu
+1 (binding) - checked signatures and checksums - built from source - ran example jobs with parallelism=8000 on a YARN cluster. checked output and logs. - the website PR looks good Thanks, Zhu Matthias Pohl 于2021年4月29日周四 上午2:34写道: > Thanks Dawid and Guowei for managing this release. > > -

[jira] [Created] (FLINK-22519) Have python-archives also take tar.gz

2021-04-28 Thread Yik San Chan (Jira)
Yik San Chan created FLINK-22519: Summary: Have python-archives also take tar.gz Key: FLINK-22519 URL: https://issues.apache.org/jira/browse/FLINK-22519 Project: Flink Issue Type: New

[jira] [Created] (FLINK-22518) Translate the page of "High Availability (HA)" into Chinese

2021-04-28 Thread movesan (Jira)
movesan created FLINK-22518: --- Summary: Translate the page of "High Availability (HA)" into Chinese Key: FLINK-22518 URL: https://issues.apache.org/jira/browse/FLINK-22518 Project: Flink Issue

Re: [VOTE] Release 1.13.0, release candidate #2

2021-04-28 Thread Guowei Ma
Hi, Matthias Thank you very much for your careful inspection. I check the flink-python_2.11-1.13.0.jar and we do not bundle org.conscrypt:conscrypt-openjdk-uber:2.5.1 to it. So I think we may not need to add this to the NOTICE file. (BTW The jar's scope is runtime) Best, Guowei On Thu, Apr 29,

[jira] [Created] (FLINK-22517) Fix pickle compatibility problem in different Python versions

2021-04-28 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-22517: Summary: Fix pickle compatibility problem in different Python versions Key: FLINK-22517 URL: https://issues.apache.org/jira/browse/FLINK-22517 Project: Flink

[jira] [Created] (FLINK-22516) ResourceManager cannot establish leadership

2021-04-28 Thread Ricky Burnett (Jira)
Ricky Burnett created FLINK-22516: - Summary: ResourceManager cannot establish leadership Key: FLINK-22516 URL: https://issues.apache.org/jira/browse/FLINK-22516 Project: Flink Issue Type:

Re: [VOTE] Release 1.13.0, release candidate #2

2021-04-28 Thread Matthias Pohl
Thanks Dawid and Guowei for managing this release. - downloaded the sources and binaries and checked the checksums - built Flink from the downloaded sources - executed example jobs with standalone deployments - I didn't find anything suspicious in the logs - reviewed release announcement pull

[jira] [Created] (FLINK-22515) Add Documentation for Flink Glue Schema Registry Integration

2021-04-28 Thread Linyu Yao (Jira)
Linyu Yao created FLINK-22515: - Summary: Add Documentation for Flink Glue Schema Registry Integration Key: FLINK-22515 URL: https://issues.apache.org/jira/browse/FLINK-22515 Project: Flink

[jira] [Created] (FLINK-22514) TypeExtractor - Improving log message

2021-04-28 Thread Avishay Balderman (Jira)
Avishay Balderman created FLINK-22514: - Summary: TypeExtractor - Improving log message Key: FLINK-22514 URL: https://issues.apache.org/jira/browse/FLINK-22514 Project: Flink Issue Type:

[jira] [Created] (FLINK-22513) Failed to upload compile artifacts

2021-04-28 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22513: Summary: Failed to upload compile artifacts Key: FLINK-22513 URL: https://issues.apache.org/jira/browse/FLINK-22513 Project: Flink Issue Type: Bug

Does flink support multi cluster deployment with HA on multi k8s clusters

2021-04-28 Thread bhagi@R
Hi Team, production requirement is to deploy flink in multi cluster mode, i.e deploying flink cluster1 with HA on kubernetes cluster1 in data center1 & another flink cluster2 with HA on kubernetes cluster2 in data center2 .. if Flink cluster1 goes down on k8s cluster1 on DC1 ,it has to fail

[jira] [Created] (FLINK-22512) Can't call current_timestamp with hive dialect for hive-3.1

2021-04-28 Thread Rui Li (Jira)
Rui Li created FLINK-22512: -- Summary: Can't call current_timestamp with hive dialect for hive-3.1 Key: FLINK-22512 URL: https://issues.apache.org/jira/browse/FLINK-22512 Project: Flink Issue Type:

Re: flink1.12.1 read hive orc table exception. could not initialize class org.apache.orc.impl.ZlibCodec

2021-04-28 Thread Rui Li
Hi WSJian, The pictures can't be displayed. Please just copy/paste the stack trace. And btw, the user mailing list (u...@flink.apache.org) is usually more appropriate for such issues. On Wed, Apr 28, 2021 at 11:36 AM WSJian <526165...@qq.com> wrote: > flink lib jar: > > flink taskmanager log:

[RESULT][VOTE] Release 1.12.3, release candidate #1

2021-04-28 Thread Arvid Heise
Dear devs, I'm happy to announce that we have unanimously approved this release. There are 3 approving votes, 3 of which are binding: * Dian * Dawid * Robert There are no disapproving votes. Thanks everyone! Your friendly release manager Arvid On Wed, Apr 28, 2021 at 2:25 PM Arvid Heise

Re: [VOTE] Release 1.12.3, release candidate #1

2021-04-28 Thread Arvid Heise
According to the latest exchange on "[VOTE] Release 1.13.0, release candidate #2", it was a false alarm, so I'm going ahead with the release. On Wed, Apr 28, 2021 at 9:26 AM Stephan Ewen wrote: > A quick heads-up: > > A fix from 1.13.0 that I backported to 1.12.3 is apparently causing some >

[jira] [Created] (FLINK-22511) Fix the bug of non-composite result type in Python TableAggregateFunction

2021-04-28 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-22511: Summary: Fix the bug of non-composite result type in Python TableAggregateFunction Key: FLINK-22511 URL: https://issues.apache.org/jira/browse/FLINK-22511 Project:

[jira] [Created] (FLINK-22510) ConfigurationUtils always serializes Duration to nanoseconds

2021-04-28 Thread Jira
Ingo Bürk created FLINK-22510: - Summary: ConfigurationUtils always serializes Duration to nanoseconds Key: FLINK-22510 URL: https://issues.apache.org/jira/browse/FLINK-22510 Project: Flink

Re: [VOTE] Release 1.13.0, release candidate #2

2021-04-28 Thread Stephan Ewen
Glad to hear that outcome. And no worries about the false alarm. Thank you for doing thorough testing, this is very helpful! On Wed, Apr 28, 2021 at 1:04 PM Caizhi Weng wrote: > After the investigation we found that this issue is caused by the > implementation of connector, not by the Flink

[jira] [Created] (FLINK-22509) ./bin/flink run -m yarn-cluster -d submission leads to IllegalStateException

2021-04-28 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-22509: -- Summary: ./bin/flink run -m yarn-cluster -d submission leads to IllegalStateException Key: FLINK-22509 URL: https://issues.apache.org/jira/browse/FLINK-22509

Re: [VOTE] Release 1.13.0, release candidate #2

2021-04-28 Thread Caizhi Weng
After the investigation we found that this issue is caused by the implementation of connector, not by the Flink framework. Sorry for the false alarm. Stephan Ewen 于2021年4月28日周三 下午3:23写道: > @Caizhi and @Becket - let me reach out to you to jointly debug this issue. > > I am wondering if there is

[jira] [Created] (FLINK-22508) add serialVersionUID for all Serializable class in non-table module

2021-04-28 Thread lincoln lee (Jira)
lincoln lee created FLINK-22508: --- Summary: add serialVersionUID for all Serializable class in non-table module Key: FLINK-22508 URL: https://issues.apache.org/jira/browse/FLINK-22508 Project: Flink

[jira] [Created] (FLINK-22507) add serialVersionUID for all Serializable class in table module

2021-04-28 Thread lincoln lee (Jira)
lincoln lee created FLINK-22507: --- Summary: add serialVersionUID for all Serializable class in table module Key: FLINK-22507 URL: https://issues.apache.org/jira/browse/FLINK-22507 Project: Flink

[jira] [Created] (FLINK-22506) YARN job cluster stuck in retrying creating JobManager if savepoint is corrupted

2021-04-28 Thread Paul Lin (Jira)
Paul Lin created FLINK-22506: Summary: YARN job cluster stuck in retrying creating JobManager if savepoint is corrupted Key: FLINK-22506 URL: https://issues.apache.org/jira/browse/FLINK-22506 Project:

[jira] [Created] (FLINK-22505) Limit the precision of Resource

2021-04-28 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-22505: -- Summary: Limit the precision of Resource Key: FLINK-22505 URL: https://issues.apache.org/jira/browse/FLINK-22505 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22503) getting eroor on select query in flink sql

2021-04-28 Thread Bhagi (Jira)
Bhagi created FLINK-22503: - Summary: getting eroor on select query in flink sql Key: FLINK-22503 URL: https://issues.apache.org/jira/browse/FLINK-22503 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22502) DefaultCompletedCheckpointStore drops unrecoverable checkpoints silently

2021-04-28 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-22502: - Summary: DefaultCompletedCheckpointStore drops unrecoverable checkpoints silently Key: FLINK-22502 URL: https://issues.apache.org/jira/browse/FLINK-22502 Project:

[jira] [Created] (FLINK-22501) Flink HiveCatalog ParquetTable join Dim table error

2021-04-28 Thread zhanglw (Jira)
zhanglw created FLINK-22501: --- Summary: Flink HiveCatalog ParquetTable join Dim table error Key: FLINK-22501 URL: https://issues.apache.org/jira/browse/FLINK-22501 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22500) flink stop 命令找不到00000000000000000000000000000000

2021-04-28 Thread Jira
陈孝忠 created FLINK-22500: --- Summary: flink stop 命令找不到 Key: FLINK-22500 URL: https://issues.apache.org/jira/browse/FLINK-22500 Project: Flink Issue Type: Bug

Re: [VOTE] Release 1.12.3, release candidate #1

2021-04-28 Thread Stephan Ewen
A quick heads-up: A fix from 1.13.0 that I backported to 1.12.3 is apparently causing some issues at larger batch scale. We are investigating this, but it would affect this release as well. Please see the mail thread "[VOTE] Release 1.13.0, release candidate #2" for details. If we want to make

Re: [VOTE] Release 1.13.0, release candidate #2

2021-04-28 Thread Stephan Ewen
@Caizhi and @Becket - let me reach out to you to jointly debug this issue. I am wondering if there is some incorrect reporting of failed events? On Wed, Apr 28, 2021 at 8:53 AM Caizhi Weng wrote: > -1 > > We're testing this version on batch jobs with large (600~1000) parallelisms > and the

Re: [VOTE] Release 1.13.0, release candidate #2

2021-04-28 Thread Caizhi Weng
-1 We're testing this version on batch jobs with large (600~1000) parallelisms and the following exception messages appear with high frequency: 2021-04-27 21:27:26 org.apache.flink.util.FlinkException: An OperatorEvent from an OperatorCoordinator to a task was lost. Triggering task failover to