[jira] [Created] (FLINK-28917) Add sql test for adaptive hash join

2022-08-10 Thread dalongliu (Jira)
dalongliu created FLINK-28917: - Summary: Add sql test for adaptive hash join Key: FLINK-28917 URL: https://issues.apache.org/jira/browse/FLINK-28917 Project: Flink Issue Type: Bug Compo

[jira] [Created] (FLINK-28916) Add e2e test for create function using jar syntax

2022-08-10 Thread dalongliu (Jira)
dalongliu created FLINK-28916: - Summary: Add e2e test for create function using jar syntax Key: FLINK-28916 URL: https://issues.apache.org/jira/browse/FLINK-28916 Project: Flink Issue Type: Bug

Re: [DISCUSS] FLIP-234: Support Retryable Lookup Join To Solve Delayed Updates Issue In External Systems

2022-08-10 Thread Rascal Wu
Thanks Lincoln a lot for your quick response and clear explanation. It's clear now. So regarding "*For the retry support in FLIP-234, it only provide a 'lookup_miss' retry predicate which is to retry if can not find it*" , try to double confirm again: 1) if the dim record doesn't exist in dim tabl

Re: [DISCUSS] FLIP-234: Support Retryable Lookup Join To Solve Delayed Updates Issue In External Systems

2022-08-10 Thread Lincoln Lee
@Rascal Thanks for looking at this new feature! There is a lot of content in these two flips and we will prepare a more detailed user documentation before the 1.16 release. First of all, unlike regular join, the lookup join only triggers the lookup action (access the dimension table) through the

[jira] [Created] (FLINK-28915) Flink Native k8s mode jar localtion support s3 schema

2022-08-10 Thread hjw (Jira)
hjw created FLINK-28915: --- Summary: Flink Native k8s mode jar localtion support s3 schema Key: FLINK-28915 URL: https://issues.apache.org/jira/browse/FLINK-28915 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-28914) Could not find any factories that implement

2022-08-10 Thread Dongming WU (Jira)
Dongming WU created FLINK-28914: --- Summary: Could not find any factories that implement Key: FLINK-28914 URL: https://issues.apache.org/jira/browse/FLINK-28914 Project: Flink Issue Type: Bug

Re: [DISCUSS] FLIP-234: Support Retryable Lookup Join To Solve Delayed Updates Issue In External Systems

2022-08-10 Thread Rascal Wu
Hi here, Sorry for digging up this old email. May I consult one question about what's the final behavior we expected after we enabled retryable mechanism. I viewed the FLIP-232 & FLIP-234, but I didn't get a clear answer as lacking of some knowledge. Let me take a example there, let's assume we

[jira] [Created] (FLINK-28913) Fix fail to open HiveCatalog when it's for hive3

2022-08-10 Thread luoyuxia (Jira)
luoyuxia created FLINK-28913: Summary: Fix fail to open HiveCatalog when it's for hive3 Key: FLINK-28913 URL: https://issues.apache.org/jira/browse/FLINK-28913 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28912) Add Part of "Who Use Flink" In ReadMe file and https://flink.apache.org/

2022-08-10 Thread Zhou Yao (Jira)
Zhou Yao created FLINK-28912: Summary: Add Part of "Who Use Flink" In ReadMe file and https://flink.apache.org/ Key: FLINK-28912 URL: https://issues.apache.org/jira/browse/FLINK-28912 Project: Flink

[jira] [Created] (FLINK-28911) Elasticsearch connector fails build

2022-08-10 Thread Niels Basjes (Jira)
Niels Basjes created FLINK-28911: Summary: Elasticsearch connector fails build Key: FLINK-28911 URL: https://issues.apache.org/jira/browse/FLINK-28911 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28910) CDC From Mysql To Hbase Bugs

2022-08-10 Thread TE (Jira)
TE created FLINK-28910: -- Summary: CDC From Mysql To Hbase Bugs Key: FLINK-28910 URL: https://issues.apache.org/jira/browse/FLINK-28910 Project: Flink Issue Type: Bug Components: Connectors / H

[jira] [Created] (FLINK-28909) Add ribbon filter policy option in RocksDBConfiguredOptions

2022-08-10 Thread zlzhang0122 (Jira)
zlzhang0122 created FLINK-28909: --- Summary: Add ribbon filter policy option in RocksDBConfiguredOptions Key: FLINK-28909 URL: https://issues.apache.org/jira/browse/FLINK-28909 Project: Flink Is

[jira] [Created] (FLINK-28908) Coder for LIST type is incorrectly chosen is PyFlink

2022-08-10 Thread Juntao Hu (Jira)
Juntao Hu created FLINK-28908: - Summary: Coder for LIST type is incorrectly chosen is PyFlink Key: FLINK-28908 URL: https://issues.apache.org/jira/browse/FLINK-28908 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-28907) Flink docs does not compile

2022-08-10 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-28907: --- Summary: Flink docs does not compile Key: FLINK-28907 URL: https://issues.apache.org/jira/browse/FLINK-28907 Project: Flink Issue Type: Bug Components: Docum

[jira] [Created] (FLINK-28906) Add AlgoOperator for AgglomerativeClustering

2022-08-10 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28906: - Summary: Add AlgoOperator for AgglomerativeClustering Key: FLINK-28906 URL: https://issues.apache.org/jira/browse/FLINK-28906 Project: Flink Issue Type: Ne

[jira] [Created] (FLINK-28905) Fix HiveCatalog use wrong Flink type when get statistic for Hive timestamp partition column

2022-08-10 Thread luoyuxia (Jira)
luoyuxia created FLINK-28905: Summary: Fix HiveCatalog use wrong Flink type when get statistic for Hive timestamp partition column Key: FLINK-28905 URL: https://issues.apache.org/jira/browse/FLINK-28905 P

[jira] [Created] (FLINK-28904) Add missing connector/format doc for PyFlink

2022-08-10 Thread Juntao Hu (Jira)
Juntao Hu created FLINK-28904: - Summary: Add missing connector/format doc for PyFlink Key: FLINK-28904 URL: https://issues.apache.org/jira/browse/FLINK-28904 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-28903) flink-table-store-hive-catalog could not shade hive-shims-0.23

2022-08-10 Thread Nicholas Jiang (Jira)
Nicholas Jiang created FLINK-28903: -- Summary: flink-table-store-hive-catalog could not shade hive-shims-0.23 Key: FLINK-28903 URL: https://issues.apache.org/jira/browse/FLINK-28903 Project: Flink

[jira] [Created] (FLINK-28902) FileSystemJobResultStoreTestInternal is a unit test that's not following the unit test naming convents

2022-08-10 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-28902: - Summary: FileSystemJobResultStoreTestInternal is a unit test that's not following the unit test naming convents Key: FLINK-28902 URL: https://issues.apache.org/jira/browse/FLINK