You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by lz...@apache.org on 2022/09/08 11:33:54 UTC
[flink-table-store] branch release-0.2 updated (7d6be436 -> 1a5836fd)
This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch release-0.2
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git
from 7d6be436 [FLINK-29181] log.system can be congiured by dynamic options
new a52523d4 [hotfix] Fix kafka shade in flink-table-store-dist
new 1a5836fd [hotfix] Fix index in PredicateConverter
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/flink/table/store/file/predicate/PredicateConverter.java | 2 +-
flink-table-store-dist/pom.xml | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
[flink-table-store] 01/02: [hotfix] Fix kafka shade in flink-table-store-dist
Posted by lz...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch release-0.2
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git
commit a52523d4796a72ece22d708eea9239542acb26db
Author: JingsongLi <lz...@aliyun.com>
AuthorDate: Thu Sep 8 19:31:27 2022 +0800
[hotfix] Fix kafka shade in flink-table-store-dist
---
flink-table-store-dist/pom.xml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-table-store-dist/pom.xml b/flink-table-store-dist/pom.xml
index 5c8415ba..36d3317b 100644
--- a/flink-table-store-dist/pom.xml
+++ b/flink-table-store-dist/pom.xml
@@ -115,7 +115,7 @@ under the License.
</excludes>
</filter>
<filter>
- <artifact>org.apache.flink:${flink.sql.connector.kafka}</artifact>
+ <artifact>org.apache.flink:${flink.connector.kafka}</artifact>
<excludes>
<exclude>META-INF/services/**</exclude>
</excludes>
[flink-table-store] 02/02: [hotfix] Fix index in PredicateConverter
Posted by lz...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch release-0.2
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git
commit 1a5836fd5fec8dc447e1645320e571038f7ffe3b
Author: JingsongLi <lz...@aliyun.com>
AuthorDate: Thu Sep 8 19:33:41 2022 +0800
[hotfix] Fix index in PredicateConverter
---
.../org/apache/flink/table/store/file/predicate/PredicateConverter.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-table-store-common/src/main/java/org/apache/flink/table/store/file/predicate/PredicateConverter.java b/flink-table-store-common/src/main/java/org/apache/flink/table/store/file/predicate/PredicateConverter.java
index baaf768d..9791da7d 100644
--- a/flink-table-store-common/src/main/java/org/apache/flink/table/store/file/predicate/PredicateConverter.java
+++ b/flink-table-store-common/src/main/java/org/apache/flink/table/store/file/predicate/PredicateConverter.java
@@ -91,7 +91,7 @@ public class PredicateConverter implements ExpressionVisitor<Predicate> {
for (int i = 1; i < children.size(); i++) {
literals.add(extractLiteral(fieldRefExpr.getOutputDataType(), children.get(i)));
}
- return builder.in(fieldRefExpr.getInputIndex(), literals);
+ return builder.in(fieldRefExpr.getFieldIndex(), literals);
} else if (func == BuiltInFunctionDefinitions.IS_NULL) {
return extractFieldReference(children.get(0))
.map(FieldReferenceExpression::getFieldIndex)