[jira] [Created] (FLINK-29204) JoinITCase#testUncorrelatedScalar fails with Cannot generate a valid execution plan for the given query after calcite update 1.27

2022-09-05 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-29204: --- Summary: JoinITCase#testUncorrelatedScalar fails with Cannot generate a valid execution plan for the given query after calcite update 1.27 Key: FLINK-29204 URL: https://issu

[jira] [Created] (FLINK-29203) SetOperatorsITCase#testUnionAllWithCommonType is failing after Calcite update to 1.27

2022-09-05 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-29203: --- Summary: SetOperatorsITCase#testUnionAllWithCommonType is failing after Calcite update to 1.27 Key: FLINK-29203 URL: https://issues.apache.org/jira/browse/FLINK-29203

[jira] [Created] (FLINK-29202) CliClient fails with NPE during start (after calcite update to 1.27)

2022-09-05 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-29202: --- Summary: CliClient fails with NPE during start (after calcite update to 1.27) Key: FLINK-29202 URL: https://issues.apache.org/jira/browse/FLINK-29202 Project: F

Flink Kinesis Connector EFO not working for cross-accounts

2022-09-05 Thread Iris Grace Endozo
Hey there, Checking if Flink kinesis connector (using 1.15.2 version) EFO can do cross-accounts? My configuration looks like this: if (kinesisIamRole != null && !kinesisIamRole.isEmpty()) { kinesisConsumerProps.put(AWSConfigConstants.AWS_ROLE_ARN, kinesisIamRole); kinesisConsumerProps.put(AWS

[jira] [Created] (FLINK-29201) Some tests from flink-sql-client, flink-connector-hive are not compiling in IntellijIdea with new maven

2022-09-05 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-29201: --- Summary: Some tests from flink-sql-client, flink-connector-hive are not compiling in IntellijIdea with new maven Key: FLINK-29201 URL: https://issues.apache.org/jira/browse/

[jira] [Created] (FLINK-29200) Provide the way to delay the pod deletion for debugging purpose

2022-09-05 Thread Aitozi (Jira)
Aitozi created FLINK-29200: -- Summary: Provide the way to delay the pod deletion for debugging purpose Key: FLINK-29200 URL: https://issues.apache.org/jira/browse/FLINK-29200 Project: Flink Issue Ty

[jira] [Created] (FLINK-29199) Support blue-green deployment type

2022-09-05 Thread Oleg Vorobev (Jira)
Oleg Vorobev created FLINK-29199: Summary: Support blue-green deployment type Key: FLINK-29199 URL: https://issues.apache.org/jira/browse/FLINK-29199 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-29198) RetryExtension doesn't make the test fail if the retries are exhausted

2022-09-05 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-29198: - Summary: RetryExtension doesn't make the test fail if the retries are exhausted Key: FLINK-29198 URL: https://issues.apache.org/jira/browse/FLINK-29198 Project: Fli

[jira] [Created] (FLINK-29197) Translate the "setting up of maben wrapper" into Chinese

2022-09-05 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-29197: --- Summary: Translate the "setting up of maben wrapper" into Chinese Key: FLINK-29197 URL: https://issues.apache.org/jira/browse/FLINK-29197 Project: Flink

[jira] [Created] (FLINK-29196) Check 1.16 licensing

2022-09-05 Thread Xingbo Huang (Jira)
Xingbo Huang created FLINK-29196: Summary: Check 1.16 licensing Key: FLINK-29196 URL: https://issues.apache.org/jira/browse/FLINK-29196 Project: Flink Issue Type: Technical Debt Com

[jira] [Created] (FLINK-29195) Expose lastCheckpointId metric

2022-09-05 Thread chenyuzhi (Jira)
chenyuzhi created FLINK-29195: - Summary: Expose lastCheckpointId metric Key: FLINK-29195 URL: https://issues.apache.org/jira/browse/FLINK-29195 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-29194) Add LoggingResourceListener as default

2022-09-05 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-29194: - Summary: Add LoggingResourceListener as default Key: FLINK-29194 URL: https://issues.apache.org/jira/browse/FLINK-29194 Project: Flink Issue Type: New Feat

[jira] [Created] (FLINK-29193) Add Transformer for Normalizer

2022-09-05 Thread weibo zhao (Jira)
weibo zhao created FLINK-29193: -- Summary: Add Transformer for Normalizer Key: FLINK-29193 URL: https://issues.apache.org/jira/browse/FLINK-29193 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-29192) Add completeness test for built-in functions between Java and Python Table API

2022-09-05 Thread Dian Fu (Jira)
Dian Fu created FLINK-29192: --- Summary: Add completeness test for built-in functions between Java and Python Table API Key: FLINK-29192 URL: https://issues.apache.org/jira/browse/FLINK-29192 Project: Flink

[ANNOUNCE] release-1.16 branch cut

2022-09-05 Thread Xingbo Huang
Hi devs, The release-1.16 branch has been forked out from the master branch, at the commit 4b15bc900eb60b1830bc406975ce974ad6050f98. Also, the version on the master branch has been upgraded to 1.17-SNAPSHOT. >From now on, for PRs that should be presented in 1.16.0, please make sure: - Merge the P

[jira] [Created] (FLINK-29191) Hive dialect can't get value for the variables set by set command

2022-09-05 Thread luoyuxia (Jira)
luoyuxia created FLINK-29191: Summary: Hive dialect can't get value for the variables set by set command Key: FLINK-29191 URL: https://issues.apache.org/jira/browse/FLINK-29191 Project: Flink I

[jira] [Created] (FLINK-29190) flink hive left join mysql error

2022-09-05 Thread zck (Jira)
zck created FLINK-29190: --- Summary: flink hive left join mysql error Key: FLINK-29190 URL: https://issues.apache.org/jira/browse/FLINK-29190 Project: Flink Issue Type: Bug Components: Table SQ