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
@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
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
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
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
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
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
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
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 /
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
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:
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:
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:
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
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:
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
Matthias Pohl created FLINK-28902:
-
Summary: FileSystemJobResultStoreTestInternal is a unit test
that's not following the unit test naming convents
Key: FLINK-28902
URL:
Xingbo Huang created FLINK-28901:
Summary: CassandraSinkBaseTest.testTimeoutExceptionOnInvoke failed
with TestTimedOutException
Key: FLINK-28901
URL: https://issues.apache.org/jira/browse/FLINK-28901
Xingbo Huang created FLINK-28900:
Summary: RecreateOnResetOperatorCoordinatorTest compile failed in
jdk11
Key: FLINK-28900
URL: https://issues.apache.org/jira/browse/FLINK-28900
Project: Flink
lincoln lee created FLINK-28899:
---
Summary: Fix LOOKUP hint with retry option on async lookup mode
Key: FLINK-28899
URL: https://issues.apache.org/jira/browse/FLINK-28899
Project: Flink
Issue
Hi everyone,
The deadline for merging new features for Flink 1.16 has passed.
* From now on, only bug-fixes and documentation fixes / improvements are
allowed to be merged into the master branch.
* New features merged after this point can be reverted. If you need an
exception to this rule,
21 matches
Mail list logo
