Flink connector reads Starrocks table error: Failed to open scanner,slot descriptor is null

[372242283]

Steps to reproduce the behavior (Required)

CREATE TABLE IF NOT EXISTS test.student ( idint,name` STRING
);

insert into test.student values(1,"a"); `

Expected behavior (Required)

The code has added filter conditions:
.withProperty("scan.filter", "name='a' ")
I hope the data can be read normally

Real behavior (Required)

(fae79a4d2a318ef6076b10990736f2dd_cbc357ccb763df2852fee8c4fc7d55f2_2_127) switched from INITIALIZING to FAILED with failure cause: java.lang.RuntimeException: Failed to open scanner.INVALID_ARGUMENT[slot descriptor is null] at com.starrocks.connector.flink.table.source.StarRocksSourceBeReader.openScanner(StarRocksSourceBeReader.java:128) ~[blob_p-4ab3a32b85aaf40c92279c5dff8d1e176b28ba38-4f03e7b6f3b80f1ee0eb23da19d088ee:?] at com.starrocks.connector.flink.table.source.StarRocksDynamicSourceFunction.lambda$open$0(StarRocksDynamicSourceFunction.java:150) ~[blob_p-4ab3a32b85aaf40c92279c5dff8d1e176b28ba38-4f03e7b6f3b80f1ee0eb23da19d088ee:?] at java.util.ArrayList.forEach(ArrayList.java:1259) ~[?:1.8.0_382] at com.starrocks.connector.flink.table.source.StarRocksDynamicSourceFunction.open(StarRocksDynamicSourceFunction.java:148) ~[blob_p-4ab3a32b85aaf40c92279c5dff8d1e176b28ba38-4f03e7b6f3b80f1ee0eb23da19d088ee:?] at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34) ~[flink-dist-1.17.0.jar:1.17.0] at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:101) ~[flink-dist-1.17.0.jar:1.17.0] at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107) ~[flink-dist-1.17.0.jar:1.17.0] at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:734) ~[flink-dist-1.17.0.jar:1.17.0] at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.call(StreamTaskActionExecutor.java:100) ~[flink-dist-1.17.0.jar:1.17.0] at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:709) ~[flink-dist-1.17.0.jar:1.17.0] at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:675) ~[flink-dist-1.17.0.jar:1.17.0] at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:952) ~[flink-dist-1.17.0.jar:1.17.0] at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:921) [flink-dist-1.17.0.jar:1.17.0] at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:745) [flink-dist-1.17.0.jar:1.17.0] at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562) [flink-dist-1.17.0.jar:1.17.0] at java.lang.Thread.run(Thread.java:750) [?:1.8.0_382]

StarRocks version (Required)

• flink: 1.17.0
• flink-connector: 1.2.9_flink-1.17
• starrocks: 3.5.6