link3280 commented on PR #5960: URL: https://github.com/apache/kyuubi/pull/5960#issuecomment-1902033382
> I'm not very familiar with the streaming process, does Flink/Beam have such a switch to control the behavior of timeout reached but query not completed? Flink SQL Gateway exits the fetch loop and sets `hasMoreResults` to `true` once there's a fetch that returns no data. That's, like we discussed before, senmatically incorrect. See https://github.com/apache/flink/blob/fd673a2f46206ff65978f05fcb96b525696aead2/flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/result/ResultFetcher.java#L265 . I think we could add a option to make fetch timeout as EOS, while keep the current behavior as default. WDTY? @pan3793 @hadoopkandy -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
