[jira] [Created] (FLINK-20410) SQLClientSchemaRegistryITCase.testWriting failed with "Subject 'user_behavior' not found.; error code: 40401"

2020-11-27 Thread Dian Fu (Jira)
Dian Fu created FLINK-20410: --- Summary: SQLClientSchemaRegistryITCase.testWriting failed with "Subject 'user_behavior' not found.; error code: 40401" Key: FLINK-20410 URL: https://issues.apache.org/jira/browse/FLINK-2041

Re: [DISCUSS] Stop adding new bash-based e2e tests to Flink

2020-11-27 Thread Xingbo Huang
Thanks Matthias, I have created sub-tasks for PyFlink related e2e tests. Best, Xingbo > 2020年11月27日 下午10:53,Jark Wu 写道: > > Thanks Matthias, > > I have created sub-tasks for the Table SQL related bash-based e2e tests. > > Best, > Jark > > On Fri, 27 Nov 2020 at 21:25, Matthias Pohl wrote:

[jira] [Created] (FLINK-20409) Migrate test_kubernetes_pyflink_application.sh

2020-11-27 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20409: Summary: Migrate test_kubernetes_pyflink_application.sh Key: FLINK-20409 URL: https://issues.apache.org/jira/browse/FLINK-20409 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-20408) Migrate test_pyflink_yarn.sh

2020-11-27 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20408: Summary: Migrate test_pyflink_yarn.sh Key: FLINK-20408 URL: https://issues.apache.org/jira/browse/FLINK-20408 Project: Flink Issue Type: Sub-task C

[jira] [Created] (FLINK-20407) Migrate test_pyflink.sh

2020-11-27 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20407: Summary: Migrate test_pyflink.sh Key: FLINK-20407 URL: https://issues.apache.org/jira/browse/FLINK-20407 Project: Flink Issue Type: Sub-task Compon

[jira] [Created] (FLINK-20406) Return the Checkpoint ID of the restored Checkpoint in CheckpointCoordinator.restoreLatestCheckpointedStateToSubtasks()

2020-11-27 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-20406: Summary: Return the Checkpoint ID of the restored Checkpoint in CheckpointCoordinator.restoreLatestCheckpointedStateToSubtasks() Key: FLINK-20406 URL: https://issues.apache.org/ji

[jira] [Created] (FLINK-20405) The LAG function in over window is not implements correctly

2020-11-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-20405: -- Summary: The LAG function in over window is not implements correctly Key: FLINK-20405 URL: https://issues.apache.org/jira/browse/FLINK-20405 Project: Flink Issu

[jira] [Created] (FLINK-20404) ZooKeeper quorum fails to start due to missing log4j library

2020-11-27 Thread Pedro Miguel Rainho Chaves (Jira)
Pedro Miguel Rainho Chaves created FLINK-20404: -- Summary: ZooKeeper quorum fails to start due to missing log4j library Key: FLINK-20404 URL: https://issues.apache.org/jira/browse/FLINK-20404

Re: [DISCUSS] Stop adding new bash-based e2e tests to Flink

2020-11-27 Thread Jark Wu
Thanks Matthias, I have created sub-tasks for the Table SQL related bash-based e2e tests. Best, Jark On Fri, 27 Nov 2020 at 21:25, Matthias Pohl wrote: > Thanks Robert for pushing this. +1 for creating java-based e2e tests. > > In the engine team, we decided to work towards the goal of migrati

[jira] [Created] (FLINK-20403) Migrate test_table_shaded_dependencies.sh

2020-11-27 Thread Jark Wu (Jira)
Jark Wu created FLINK-20403: --- Summary: Migrate test_table_shaded_dependencies.sh Key: FLINK-20403 URL: https://issues.apache.org/jira/browse/FLINK-20403 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20401) Migrate test_tpcds.sh

2020-11-27 Thread Jark Wu (Jira)
Jark Wu created FLINK-20401: --- Summary: Migrate test_tpcds.sh Key: FLINK-20401 URL: https://issues.apache.org/jira/browse/FLINK-20401 Project: Flink Issue Type: Sub-task Components: Table

[jira] [Created] (FLINK-20402) Migrate test_tpch.sh

2020-11-27 Thread Jark Wu (Jira)
Jark Wu created FLINK-20402: --- Summary: Migrate test_tpch.sh Key: FLINK-20402 URL: https://issues.apache.org/jira/browse/FLINK-20402 Project: Flink Issue Type: Sub-task Components: Table S

[jira] [Created] (FLINK-20400) Migrate test_streaming_sql.sh

2020-11-27 Thread Jark Wu (Jira)
Jark Wu created FLINK-20400: --- Summary: Migrate test_streaming_sql.sh Key: FLINK-20400 URL: https://issues.apache.org/jira/browse/FLINK-20400 Project: Flink Issue Type: Sub-task Components

[jira] [Created] (FLINK-20399) Migrate test_sql_client.sh

2020-11-27 Thread Jark Wu (Jira)
Jark Wu created FLINK-20399: --- Summary: Migrate test_sql_client.sh Key: FLINK-20399 URL: https://issues.apache.org/jira/browse/FLINK-20399 Project: Flink Issue Type: Sub-task Components: T

[jira] [Created] (FLINK-20398) Migrate test_batch_sql.sh

2020-11-27 Thread Jark Wu (Jira)
Jark Wu created FLINK-20398: --- Summary: Migrate test_batch_sql.sh Key: FLINK-20398 URL: https://issues.apache.org/jira/browse/FLINK-20398 Project: Flink Issue Type: Sub-task Components: Ta

[DISCUSS] Moving to JUnit5

2020-11-27 Thread Arvid Heise
Dear devs, I'd like to start a discussion to migrate to a higher JUnit version. The main motivations are: - Making full use of Java 8 Lambdas for writing easier to read tests and a better performing way of composing failure messages. - Improved test structures with nested and dynamic tests. - Muc

[jira] [Created] (FLINK-20397) Pass checkpointId to OperatorCoordinator.resetToCheckpoint().

2020-11-27 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-20397: Summary: Pass checkpointId to OperatorCoordinator.resetToCheckpoint(). Key: FLINK-20397 URL: https://issues.apache.org/jira/browse/FLINK-20397 Project: Flink

[jira] [Created] (FLINK-20396) Replace "OperatorCoordinator.subtaskFailed()" with "subtaskRestored()"

2020-11-27 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-20396: Summary: Replace "OperatorCoordinator.subtaskFailed()" with "subtaskRestored()" Key: FLINK-20396 URL: https://issues.apache.org/jira/browse/FLINK-20396 Project: Flink

Re: [DISCUSS] Stop adding new bash-based e2e tests to Flink

2020-11-27 Thread Matthias Pohl
Thanks Robert for pushing this. +1 for creating java-based e2e tests. In the engine team, we decided to work towards the goal of migrating the bash-based e2e tests to Java/Docker. We plan to migrate the existing bash-based e2e tests located in the Engine team's component space step-by-step. I crea

[jira] [Created] (FLINK-20395) Migrate test_netty_shuffle_memory_control.sh

2020-11-27 Thread Matthias (Jira)
Matthias created FLINK-20395: Summary: Migrate test_netty_shuffle_memory_control.sh Key: FLINK-20395 URL: https://issues.apache.org/jira/browse/FLINK-20395 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20394) Migrate test_mesos_multiple_submissions.sh

2020-11-27 Thread Matthias (Jira)
Matthias created FLINK-20394: Summary: Migrate test_mesos_multiple_submissions.sh Key: FLINK-20394 URL: https://issues.apache.org/jira/browse/FLINK-20394 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20393) Migrate test_mesos_wordcount.sh

2020-11-27 Thread Matthias (Jira)
Matthias created FLINK-20393: Summary: Migrate test_mesos_wordcount.sh Key: FLINK-20393 URL: https://issues.apache.org/jira/browse/FLINK-20393 Project: Flink Issue Type: Sub-task Repo

[jira] [Created] (FLINK-20392) Migrating bash e2e tests to Java/Docker

2020-11-27 Thread Matthias (Jira)
Matthias created FLINK-20392: Summary: Migrating bash e2e tests to Java/Docker Key: FLINK-20392 URL: https://issues.apache.org/jira/browse/FLINK-20392 Project: Flink Issue Type: Test Co

[jira] [Created] (FLINK-20391) Set FORWARD_EDGES_PIPELINED for BATCH ExecutionMode

2020-11-27 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-20391: Summary: Set FORWARD_EDGES_PIPELINED for BATCH ExecutionMode Key: FLINK-20391 URL: https://issues.apache.org/jira/browse/FLINK-20391 Project: Flink I

[jira] [Created] (FLINK-20390) Programmatic access to the back-pressure

2020-11-27 Thread Jira
Gaël Renoux created FLINK-20390: --- Summary: Programmatic access to the back-pressure Key: FLINK-20390 URL: https://issues.apache.org/jira/browse/FLINK-20390 Project: Flink Issue Type: New Featur