Re: Encountering scala.matchError in Flink 1.18.1 Query

2024-07-17 Thread Norihiro FUKE
Hi Xuyang, Thank you for the information regarding the bug fix. I will proceed with the method of joining input_table and udtf first. Thank you for the suggestion. Best regards, Norihiro Fuke. 2024年7月15日(月) 10:43 Xuyang : > Hi, this is a bug fixed in > https://github.com/apache/flin

Encountering scala.matchError in Flink 1.18.1 Query

2024-07-08 Thread Norihiro FUKE
Hi, community I encountered a scala.matchError when trying to obtain the table plan for the following query in Flink 1.18.1. The input data is read from Kafka, and the query is intended to perform a typical WordCount operation. The query is as follows. SPLIT_STRING is a Table Function UDF that sp