flink-sql

英文: Pyflink->Elastic converts Varchar to Long? 问题 I started working with Pyflink last week and fo...

英文: Flink TableAPI: PartitionedBy columns missing in Parquet files 问题 我使用filesystem连接器将数据以parquet格式汇...

英文: Reading Parquet files in FlinkSQL without Hadoop? 问题 从这里下载jar文件：https://nightlies.apache.org/fli...

英文: Using flink sql client to submit sql query. How to I restore from checkpoint or savepoint 问题 I h...

英文: Using CTE in apache flink sql 问题 以下是要翻译的内容： 我正在尝试编写一个在Flink中使用CTE的SQL语句。 我有一个定义的表 CREATE TABLE t...

英文: Caused by: java.lang.ClassNotFoundException: org.apache.orc.storage.ql.exec.vector.VectorizedRow...

英文: Write the result of SQL Query to file by Apache Flink 问题 以下是翻译好的内容： 我有以下任务： 创建一个带有 Hive 表 SQL 请求...

英文: Apache Flink Table query result as string values 问题 我正在使用 Flink 的表 API 编写一个查询来检索一条记录。然后检查是否找到记录，...

英文: Flink: Left joining a stream with a static list 问题 我想将Attempts的流式数据加入到一个静态的被封锁邮箱列表中，并且按照IP对结果进行分...