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

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: https://issues.apache.org/jira/browse/FLINK-30

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

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* This

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

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 som

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

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: https://issues.apa

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

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

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 Type

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

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

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 Components

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

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

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

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

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: https://issues.apache.org/jira/browse/FLINK