[jira] [Created] (FLINK-28861) Cannot resume from savepoint when using fromChangelogStream in upsert mode

2022-08-08 Thread Colin Smetz (Jira)
Colin Smetz created FLINK-28861: --- Summary: Cannot resume from savepoint when using fromChangelogStream in upsert mode Key: FLINK-28861 URL: https://issues.apache.org/jira/browse/FLINK-28861 Project: Fli

[jira] [Created] (FLINK-28862) Support writing RowData to Parquet files in PyFlink

2022-08-08 Thread Juntao Hu (Jira)
Juntao Hu created FLINK-28862: - Summary: Support writing RowData to Parquet files in PyFlink Key: FLINK-28862 URL: https://issues.apache.org/jira/browse/FLINK-28862 Project: Flink Issue Type: New

[jira] [Created] (FLINK-28863) Snapshot result of RocksDB native savepoint should have empty shared-state

2022-08-08 Thread Yun Tang (Jira)
Yun Tang created FLINK-28863: Summary: Snapshot result of RocksDB native savepoint should have empty shared-state Key: FLINK-28863 URL: https://issues.apache.org/jira/browse/FLINK-28863 Project: Flink

[jira] [Created] (FLINK-28864) DynamicPartitionPruningRule#isNewSource should check if the source used by the DataStreamScanProvider is actually a new sourc

2022-08-08 Thread Gen Luo (Jira)
Gen Luo created FLINK-28864: --- Summary: DynamicPartitionPruningRule#isNewSource should check if the source used by the DataStreamScanProvider is actually a new sourc Key: FLINK-28864 URL: https://issues.apache.org/jira/b

[jira] [Created] (FLINK-28865) Add updated Print sink for new interfaces

2022-08-08 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-28865: Summary: Add updated Print sink for new interfaces Key: FLINK-28865 URL: https://issues.apache.org/jira/browse/FLINK-28865 Project: Flink Issue Type:

[jira] [Created] (FLINK-28866) Use DDL instead of legacy method to register the test source in JoinITCase

2022-08-08 Thread godfrey he (Jira)
godfrey he created FLINK-28866: -- Summary: Use DDL instead of legacy method to register the test source in JoinITCase Key: FLINK-28866 URL: https://issues.apache.org/jira/browse/FLINK-28866 Project: Flink

[jira] [Created] (FLINK-28867) Parquet reader support nested type in array/map type

2022-08-08 Thread dalongliu (Jira)
dalongliu created FLINK-28867: - Summary: Parquet reader support nested type in array/map type Key: FLINK-28867 URL: https://issues.apache.org/jira/browse/FLINK-28867 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-28868) Migrate JDBC table connector to the new LookupFunction interface

2022-08-08 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-28868: - Summary: Migrate JDBC table connector to the new LookupFunction interface Key: FLINK-28868 URL: https://issues.apache.org/jira/browse/FLINK-28868 Project: Flink

[jira] [Created] (FLINK-28869) Emit warning event for ClusterDeploymentException

2022-08-08 Thread Xin Hao (Jira)
Xin Hao created FLINK-28869: --- Summary: Emit warning event for ClusterDeploymentException Key: FLINK-28869 URL: https://issues.apache.org/jira/browse/FLINK-28869 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-28870) Modify the pulsar default consumption rate

2022-08-08 Thread xie (Jira)
xie created FLINK-28870: --- Summary: Modify the pulsar default consumption rate Key: FLINK-28870 URL: https://issues.apache.org/jira/browse/FLINK-28870 Project: Flink Issue Type: Improvement Co

[jira] [Created] (FLINK-28871) Make DPP also works if batch shuffle mode is not ALL_BLOCKING

2022-08-08 Thread Yun Gao (Jira)
Yun Gao created FLINK-28871: --- Summary: Make DPP also works if batch shuffle mode is not ALL_BLOCKING Key: FLINK-28871 URL: https://issues.apache.org/jira/browse/FLINK-28871 Project: Flink Issue Ty

[jira] [Created] (FLINK-28872) UnalignedCheckpointStressITCase fails with NoSuchFileException

2022-08-08 Thread Lihe Ma (Jira)
Lihe Ma created FLINK-28872: --- Summary: UnalignedCheckpointStressITCase fails with NoSuchFileException Key: FLINK-28872 URL: https://issues.apache.org/jira/browse/FLINK-28872 Project: Flink Issue T

[jira] [Created] (FLINK-28873) Make "jobmanager.scheduler" visible in documentation

2022-08-08 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-28873: -- Summary: Make "jobmanager.scheduler" visible in documentation Key: FLINK-28873 URL: https://issues.apache.org/jira/browse/FLINK-28873 Project: Flink Issue Type:

[jira] [Created] (FLINK-28874) Python tests fail locally with flink-connector-hive_2.12 is missing jhyde pentaho-aggdesigner-algorithm:jar:5.1.5-jhyde

2022-08-08 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-28874: --- Summary: Python tests fail locally with flink-connector-hive_2.12 is missing jhyde pentaho-aggdesigner-algorithm:jar:5.1.5-jhyde Key: FLINK-28874 URL: https://issues.apache

[jira] [Created] (FLINK-28875) Add FlinkSessionJobControllerTest

2022-08-08 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-28875: -- Summary: Add FlinkSessionJobControllerTest Key: FLINK-28875 URL: https://issues.apache.org/jira/browse/FLINK-28875 Project: Flink Issue Type: Improvement

[jira] (FLINK-24343) Revisit Scheduler and Coordinator Startup Procedure

2022-08-08 Thread WONG, DAREN
Dear FLINK community, I am looking at JIRA FLINK-24343 and I am trying to understand what this sentence means: “The scheduler must be started to the point that it can handle "failGlobal()" calls, because the coordinators might trigger that during their startup when an exception in "start()" occ

[jira] [Created] (FLINK-28876) Support writing RowData to Orc files in PyFlink

2022-08-08 Thread Juntao Hu (Jira)
Juntao Hu created FLINK-28876: - Summary: Support writing RowData to Orc files in PyFlink Key: FLINK-28876 URL: https://issues.apache.org/jira/browse/FLINK-28876 Project: Flink Issue Type: New Fea

[jira] [Created] (FLINK-28877) Elasticsearch7DynamicSinkITCase.testWritingDocumentsNoPrimaryKey case failed

2022-08-08 Thread lincoln lee (Jira)
lincoln lee created FLINK-28877: --- Summary: Elasticsearch7DynamicSinkITCase.testWritingDocumentsNoPrimaryKey case failed Key: FLINK-28877 URL: https://issues.apache.org/jira/browse/FLINK-28877 Project: F

[jira] [Created] (FLINK-28878) PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with AssertionError

2022-08-08 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-28878: Summary: PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with AssertionError Key: FLINK-28878 URL: https://issues.apache.org/jira/browse/FLINK-28878

[jira] [Created] (FLINK-28879) New File Sink s3 end-to-end test failed with Output hash mismatch

2022-08-08 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-28879: Summary: New File Sink s3 end-to-end test failed with Output hash mismatch Key: FLINK-28879 URL: https://issues.apache.org/jira/browse/FLINK-28879 Project: Flink

[jira] [Created] (FLINK-28880) Fix CEP doc with wrong result of strict contiguity of looping patterns

2022-08-08 Thread Juntao Hu (Jira)
Juntao Hu created FLINK-28880: - Summary: Fix CEP doc with wrong result of strict contiguity of looping patterns Key: FLINK-28880 URL: https://issues.apache.org/jira/browse/FLINK-28880 Project: Flink

[jira] [Created] (FLINK-28881) PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream test failure

2022-08-08 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-28881: -- Summary: PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream test failure Key: FLINK-28881 URL: https://issues.apache.org/jira/browse/FLINK-28881

[jira] [Created] (FLINK-28882) ENCODE return error

2022-08-08 Thread Luning Wang (Jira)
Luning Wang created FLINK-28882: --- Summary: ENCODE return error Key: FLINK-28882 URL: https://issues.apache.org/jira/browse/FLINK-28882 Project: Flink Issue Type: Improvement Component