Skip to content

Commit 3546641

Browse files
lihaoskyfsk119
authored andcommitted
[FLINK-38767][table] Fix vector search execnode transform name (#27304)
1 parent 3f79fac commit 3546641

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecVectorSearchTableFunction.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,6 @@
2828
import org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecVectorSearchTableFunction;
2929
import org.apache.flink.table.planner.plan.nodes.exec.spec.VectorSearchSpec;
3030
import org.apache.flink.table.planner.plan.nodes.exec.spec.VectorSearchTableSourceSpec;
31-
import org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecMLPredictTableFunction;
3231
import org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecVectorSearchTableFunction;
3332
import org.apache.flink.table.planner.plan.utils.FunctionCallUtil;
3433
import org.apache.flink.table.types.logical.RowType;
@@ -50,7 +49,7 @@
5049
"table.exec.async-vector-search.timeout",
5150
"table.exec.async-vector-search.output-mode"
5251
},
53-
producedTransformations = StreamExecMLPredictTableFunction.ML_PREDICT_TRANSFORMATION,
52+
producedTransformations = CommonExecVectorSearchTableFunction.VECTOR_SEARCH_TRANSFORMATION,
5453
minPlanVersion = FlinkVersion.v2_2,
5554
minStateVersion = FlinkVersion.v2_2)
5655
public class BatchExecVectorSearchTableFunction extends CommonExecVectorSearchTableFunction

flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecVectorSearchTableFunction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@
4949
"table.exec.async-vector-search.timeout",
5050
"table.exec.async-vector-search.output-mode"
5151
},
52-
producedTransformations = StreamExecMLPredictTableFunction.ML_PREDICT_TRANSFORMATION,
52+
producedTransformations = CommonExecVectorSearchTableFunction.VECTOR_SEARCH_TRANSFORMATION,
5353
minPlanVersion = FlinkVersion.v2_2,
5454
minStateVersion = FlinkVersion.v2_2)
5555
public class StreamExecVectorSearchTableFunction extends CommonExecVectorSearchTableFunction

0 commit comments

Comments
 (0)