[jira] [Created] (FLINK-30369) Fix FlinkFilterJoinRule push wrong filters to another side while join type is left/right outer join

2022-12-11 Thread Yunhong Zheng (Jira)
Yunhong Zheng created FLINK-30369: - Summary: Fix FlinkFilterJoinRule push wrong filters to another side while join type is left/right outer join Key: FLINK-30369 URL:

Re: [DISCUSSION] Scan mode in Table Store for Flink Stream and Batch job

2022-12-11 Thread Caizhi Weng
Thanks Shammon for bringing up the discussion. My opinion is to combine everything into scan.mode so that we don't have orthogonal options. You first mention that there are two disadvantages for this solution. *1. The behaviors of some StartupModes in Stream and Batch jobs are inconsistent*

Re: [DISCUSS] FLIP-276: Data Consistency of Streaming and Batch ETL in Flink and Table Store

2022-12-11 Thread Shammon FY
Hi Piotr, Thank you for your feedback. I cannot see the DAG in 3.a in your reply, but I'd like to answer some questions first. Your understanding is very correct. We want to align the data versions of all intermediate tables through checkpoint mechanism in Flink. I'm sorry that I have omitted

[jira] [Created] (FLINK-30368) Fix calcite method RelMdUtil$numDistinctVals() wrongly return zero if the method input domainSize much larger than numSelected

2022-12-11 Thread Yunhong Zheng (Jira)
Yunhong Zheng created FLINK-30368: - Summary: Fix calcite method RelMdUtil$numDistinctVals() wrongly return zero if the method input domainSize much larger than numSelected Key: FLINK-30368 URL:

[jira] [Created] (FLINK-30367) Enrich the thread dump info with deeper stack

2022-12-11 Thread Yun Tang (Jira)
Yun Tang created FLINK-30367: Summary: Enrich the thread dump info with deeper stack Key: FLINK-30367 URL: https://issues.apache.org/jira/browse/FLINK-30367 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-30366) Python Group Agg failed in cleaning the idle state

2022-12-11 Thread Xingbo Huang (Jira)
Xingbo Huang created FLINK-30366: Summary: Python Group Agg failed in cleaning the idle state Key: FLINK-30366 URL: https://issues.apache.org/jira/browse/FLINK-30366 Project: Flink Issue

[jira] [Created] (FLINK-30365) New dynamic partition pruning strategy to support more dpp patterns

2022-12-11 Thread Yunhong Zheng (Jira)
Yunhong Zheng created FLINK-30365: - Summary: New dynamic partition pruning strategy to support more dpp patterns Key: FLINK-30365 URL: https://issues.apache.org/jira/browse/FLINK-30365 Project: Flink

[jira] [Created] (FLINK-30364) Job failed without exception stack

2022-12-11 Thread Dian Fu (Jira)
Dian Fu created FLINK-30364: --- Summary: Job failed without exception stack Key: FLINK-30364 URL: https://issues.apache.org/jira/browse/FLINK-30364 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30363) Disable HadoppConf and Kerboros Decorator by default

2022-12-11 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-30363: - Summary: Disable HadoppConf and Kerboros Decorator by default Key: FLINK-30363 URL: https://issues.apache.org/jira/browse/FLINK-30363 Project: Flink Issue

[jira] [Created] (FLINK-30362) Flink-connector-hive can't build with maven 3.8

2022-12-11 Thread Chen Qin (Jira)
Chen Qin created FLINK-30362: Summary: Flink-connector-hive can't build with maven 3.8 Key: FLINK-30362 URL: https://issues.apache.org/jira/browse/FLINK-30362 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30361) Flink cluster deleted while updating the replicas

2022-12-11 Thread SwathiChandrashekar (Jira)
SwathiChandrashekar created FLINK-30361: --- Summary: Flink cluster deleted while updating the replicas Key: FLINK-30361 URL: https://issues.apache.org/jira/browse/FLINK-30361 Project: Flink

[jira] [Created] (FLINK-30360) A null pointer exception is thrown when data is written to the HBase table using the specified column name

2022-12-11 Thread Jichao Wang (Jira)
Jichao Wang created FLINK-30360: --- Summary: A null pointer exception is thrown when data is written to the HBase table using the specified column name Key: FLINK-30360 URL: