[jira] [Created] (FLINK-20435) Refactor ExecNode

2020-11-30 Thread godfrey he (Jira)
godfrey he created FLINK-20435: -- Summary: Refactor ExecNode Key: FLINK-20435 URL: https://issues.apache.org/jira/browse/FLINK-20435 Project: Flink Issue Type: Improvement Reporter: g

Re: flink 1.9 Restore from a checkpoint taken in 1.11

2020-11-30 Thread Yun Tang
Hi Lu Flink guarantees backwards compatibility but not forwards compatibility and you can find the compatibility table here [1]. Flink-1.11 introduced unaligned checkpoint which upgrades the savepoint version to 3, and that's why Flink-1.9 cannot consume savepoint generated by Flink-1.11. [1]

[jira] [Created] (FLINK-20434) Getting The desired archetype does not exist

2020-11-30 Thread Avi Levi (Jira)
Avi Levi created FLINK-20434: Summary: Getting The desired archetype does not exist Key: FLINK-20434 URL: https://issues.apache.org/jira/browse/FLINK-20434 Project: Flink Issue Type: Bug

[VOTE] Release 1.12.0, release candidate #2

2020-11-30 Thread Robert Metzger
Hi everyone, It seems that all blockers for 1.12.0 have been resolved, this is the first voting release candidate. Please review and vote on the release candidate #2 for the version 1.12.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific commen

[jira] [Created] (FLINK-20433) UnalignedCheckpointTestBase.execute failed with "TestTimedOutException: test timed out after 300 seconds"

2020-11-30 Thread Dian Fu (Jira)
Dian Fu created FLINK-20433: --- Summary: UnalignedCheckpointTestBase.execute failed with "TestTimedOutException: test timed out after 300 seconds" Key: FLINK-20433 URL: https://issues.apache.org/jira/browse/FLINK-20433

[jira] [Created] (FLINK-20432) SQLClientSchemaRegistryITCase hangs

2020-11-30 Thread Dian Fu (Jira)
Dian Fu created FLINK-20432: --- Summary: SQLClientSchemaRegistryITCase hangs Key: FLINK-20432 URL: https://issues.apache.org/jira/browse/FLINK-20432 Project: Flink Issue Type: Bug Component

[jira] [Created] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1>

2020-11-30 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20431: Summary: KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1> Key: FLINK-20431 URL: https

flink 1.9 Restore from a checkpoint taken in 1.11

2020-11-30 Thread Lu Niu
Hi, Flink dev Is it supported that a flink job in version 1.9 could restore from a checkpoint taken from the same job using 1.11? The context is we are migrating to version 1.11 and we need a backup plan for emergency fallback. We did a test and it throws error: ``` Caused by: org.apache.flink.run

[jira] [Created] (FLINK-20430) Broken links in deployment/index.zh.md

2020-11-30 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20430: Summary: Broken links in deployment/index.zh.md Key: FLINK-20430 URL: https://issues.apache.org/jira/browse/FLINK-20430 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20429) KafkaTableITCase.testKafkaTemporalJoinChangelog failed with unexpected results

2020-11-30 Thread Dian Fu (Jira)
Dian Fu created FLINK-20429: --- Summary: KafkaTableITCase.testKafkaTemporalJoinChangelog failed with unexpected results Key: FLINK-20429 URL: https://issues.apache.org/jira/browse/FLINK-20429 Project: Flink

[jira] [Created] (FLINK-20428) ZooKeeperLeaderElectionConnectionHandlingTest.testConnectionSuspendedHandlingDuringInitialization failed with "No result is expected since there was no leader elected be

2020-11-30 Thread Dian Fu (Jira)
Dian Fu created FLINK-20428: --- Summary: ZooKeeperLeaderElectionConnectionHandlingTest.testConnectionSuspendedHandlingDuringInitialization failed with "No result is expected since there was no leader elected before stopping the server, yet"

Re: [DISCUSS] Moving to JUnit5

2020-11-30 Thread Arvid Heise
Hi Till, immediate benefit would be mostly nested tests for a better test structure and new parameterized tests for less clutter (often test functionality is split into parameterized test and non-parameterized test because of JUnit4 limitation). Additionally, having Java8 lambdas to perform fine-g

[jira] [Created] (FLINK-20427) Remove CheckpointConfig.setPreferCheckpointForRecovery because it can lead to data loss

2020-11-30 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-20427: - Summary: Remove CheckpointConfig.setPreferCheckpointForRecovery because it can lead to data loss Key: FLINK-20427 URL: https://issues.apache.org/jira/browse/FLINK-20427

[jira] [Created] (FLINK-20426) Broken links to hadoop.md

2020-11-30 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-20426: Summary: Broken links to hadoop.md Key: FLINK-20426 URL: https://issues.apache.org/jira/browse/FLINK-20426 Project: Flink Issue Type: Bug C

Re: [DISCUSS] Moving to JUnit5

2020-11-30 Thread Dawid Wysakowicz
Hi all, Just wanted to express my support for the idea. I did miss certain features of JUnit 5 already, an important one being much better support for parameterized tests. Best, Dawid On 30/11/2020 13:50, Arvid Heise wrote: > Hi Chesnay, > > The vintage runner supports the old annotations, so w

[jira] [Created] (FLINK-20425) Change exit code in FatalExitExceptionHandler to be different from JvmShutdownSafeguard

2020-11-30 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-20425: -- Summary: Change exit code in FatalExitExceptionHandler to be different from JvmShutdownSafeguard Key: FLINK-20425 URL: https://issues.apache.org/jira/browse/FLINK-20425

Re: [DISCUSS] Moving to JUnit5

2020-11-30 Thread Till Rohrmann
Doing a few required changes swiftly and then porting the remaining tests bit by bit sounds like an approachable plan. However, it will still cost us some effort I guess. What exactly would be the benefit of this change other than streamlining a few things? Are there things which we cannot do at th

Re: [DISCUSS] Moving to JUnit5

2020-11-30 Thread Arvid Heise
Hi Chesnay, The vintage runner supports the old annotations, so we don't have to change them in the first step. The only thing that we need to change are all rules that do not extend ExternalResource (e.g., TestWatcher used in TestLogger). This change needs to be done swiftly as this affects the

Re: [DISCUSS] Moving to JUnit5

2020-11-30 Thread Chesnay Schepler
I presume we cannot do the migration module-wise due to shared test utilities that rely on JUnit interfaces? On 11/30/2020 1:30 PM, Chesnay Schepler wrote: Is it feasible that 2 people can do the migration within a short time-frame (say, a week)? Must the migration of a test be done in one go,

Re: [DISCUSS] Moving to JUnit5

2020-11-30 Thread Chesnay Schepler
Is it feasible that 2 people can do the migration within a short time-frame (say, a week)? Must the migration of a test be done in one go, or can we for example first rename all the Before/After annotations and then to the rest? Are there any issues with other test dependencies (i.e., hamcrest,

[jira] [Created] (FLINK-20424) The percent of acknowledged checkpoint seems incorrect

2020-11-30 Thread zlzhang0122 (Jira)
zlzhang0122 created FLINK-20424: --- Summary: The percent of acknowledged checkpoint seems incorrect Key: FLINK-20424 URL: https://issues.apache.org/jira/browse/FLINK-20424 Project: Flink Issue Ty

[jira] [Created] (FLINK-20423) Remove usage of {{site.baseurl}} from markdown files

2020-11-30 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-20423: Summary: Remove usage of {{site.baseurl}} from markdown files Key: FLINK-20423 URL: https://issues.apache.org/jira/browse/FLINK-20423 Project: Flink

[jira] [Created] (FLINK-20422) Remove {{ site.baseurl }} from .html files in flink documentation

2020-11-30 Thread Xiao Huang (Jira)
Xiao Huang created FLINK-20422: -- Summary: Remove {{ site.baseurl }} from .html files in flink documentation Key: FLINK-20422 URL: https://issues.apache.org/jira/browse/FLINK-20422 Project: Flink

[jira] [Created] (FLINK-20421) Support canal-protobuf format

2020-11-30 Thread Jark Wu (Jira)
Jark Wu created FLINK-20421: --- Summary: Support canal-protobuf format Key: FLINK-20421 URL: https://issues.apache.org/jira/browse/FLINK-20421 Project: Flink Issue Type: Sub-task Components

[jira] [Created] (FLINK-20420) ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds

2020-11-30 Thread Yun Tang (Jira)
Yun Tang created FLINK-20420: Summary: ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds Key: FLINK-20420 URL: https://issues.apache.org/jira/browse/FLINK-20420 Project: Flink

[jira] [Created] (FLINK-20419) Insert fails due to failure to generate execution plan

2020-11-30 Thread Rui Li (Jira)
Rui Li created FLINK-20419: -- Summary: Insert fails due to failure to generate execution plan Key: FLINK-20419 URL: https://issues.apache.org/jira/browse/FLINK-20419 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20418) NPE in IteratorSourceReader

2020-11-30 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-20418: - Summary: NPE in IteratorSourceReader Key: FLINK-20418 URL: https://issues.apache.org/jira/browse/FLINK-20418 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20417) Handle "Too old resource version" exception in Kubernetes watch more gracefully

2020-11-30 Thread Yang Wang (Jira)
Yang Wang created FLINK-20417: - Summary: Handle "Too old resource version" exception in Kubernetes watch more gracefully Key: FLINK-20417 URL: https://issues.apache.org/jira/browse/FLINK-20417 Project: Fl

[jira] [Created] (FLINK-20416) Need a cached catalog for batch SQL job

2020-11-30 Thread Sebastian Liu (Jira)
Sebastian Liu created FLINK-20416: - Summary: Need a cached catalog for batch SQL job Key: FLINK-20416 URL: https://issues.apache.org/jira/browse/FLINK-20416 Project: Flink Issue Type: Improve