Skip to content

Commit e00128d

Browse files
committed
[flink]some fix
1 parent c216a15 commit e00128d

File tree

2 files changed

+3
-164
lines changed

2 files changed

+3
-164
lines changed

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/source/PredicateConverter.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,11 +18,11 @@
1818

1919
package com.alibaba.fluss.flink.source;
2020

21-
import com.alibaba.fluss.connector.flink.utils.TypeUtils;
2221
import com.alibaba.fluss.flink.utils.FlinkConversions;
2322
import com.alibaba.fluss.predicate.Predicate;
2423
import com.alibaba.fluss.predicate.PredicateBuilder;
2524
import com.alibaba.fluss.row.BinaryString;
25+
import com.alibaba.fluss.utils.TypeUtils;
2626

2727
import org.apache.flink.table.data.conversion.DataStructureConverters;
2828
import org.apache.flink.table.expressions.CallExpression;
@@ -243,6 +243,8 @@ private Object extractLiteral(DataType expectedType, Expression expression) {
243243
DataStructureConverters.getConverter(expectedType)
244244
.toInternalOrNull(value),
245245
expectedLogicalType);
246+
} else if (isStringType(actualLogicalType) || isStringType(expectedLogicalType)) {
247+
return value.toString();
246248
} else if (supportsImplicitCast(actualLogicalType, expectedLogicalType)) {
247249
try {
248250
return TypeUtils.castFromString(

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/utils/TypeUtils.java

Lines changed: 0 additions & 163 deletions
This file was deleted.

0 commit comments

Comments
 (0)