zth1993 opened a new issue, #571: URL: https://github.com/apache/doris-flink-connector/issues/571
### Search before asking - [x] I had searched in the [issues](https://github.com/apache/incubator-doris/issues?q=is%3Aissue) and found no similar issues. ### Version flink-doris-connector-1.20 flink 1.20 doris 3.0.4 ### What's Wrong? Caused by: org.apache.doris.flink.exception.DorisRuntimeException: Index 2 out of bounds for length 2 at org.apache.doris.flink.serialization.RowBatch.readArrow(RowBatch.java:195) at org.apache.doris.flink.source.reader.DorisValueReader.hasNext(DorisValueReader.java:257) at org.apache.doris.flink.source.reader.DorisSourceSplitReader.fetch(DorisSourceSplitReader.java:62) at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165) ... 6 more 测试代码如下（TEST_CASE）： // Table resultTable = tableEnv.sqlQuery("SELECT * FROM dim_parking_scd"); // right // Table resultTable = tableEnv.sqlQuery("SELECT park_name FROM dim_parking_scd"); // right // Table resultTable = tableEnv.sqlQuery("SELECT park_no FROM dim_parking_scd where start_date = '2025-03-03'"); // right // Table resultTable = tableEnv.sqlQuery("SELECT park_no FROM dim_parking_scd where park_no = 'c区停车场'"); // 查询非主键字段 // right // Table resultTable = tableEnv.sqlQuery("SELECT park_name FROM dim_parking_scd where park_no = 'c区停车场'"); // wrong(错误) // Table resultTable = tableEnv.sqlQuery("SELECT park_name FROM dim_parking_scd where start_date = '2025-03-03'"); // wrong(错误) // Table resultTable = tableEnv.sqlQuery("SELECT * FROM dim_parking_scd where start_date = '2025-03-03'"); // wrong(错误) // Table resultTable = tableEnv.sqlQuery("SELECT park_no,start_date,park_name FROM dim_parking_scd where start_date = '2025-03-03'"); ### What You Expected? 能用date类型doris主键字段做过滤条件，过滤出非主键字段的值 ### How to Reproduce? _No response_ ### Anything Else? _No response_ ### Are you willing to submit PR? - [ ] Yes I am willing to submit a PR! ### Code of Conduct - [x] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org
