【百问百答】Flink SQL 报错问题汇总_问答-阿里云开发者社区

本文罗列了Flink SQL 报错的相关问答，希望对有相同问题的技术人有所帮助。

1、flinksql报错Could not find any factory for identifier 'elasticsearch-6' that implements 'org.apache.flink.table.factories.DynamicTableSinkFactory' in the classpath. hello 我在使用flinksql连接器时当我将flink-sql-connector-elasticsearch6_2.11-1.11.1.jar放在lib下，程序正常执行，但是当我在pom中进行配置时会产生如下报错，同样的问题会产生在hbase、jdbc的connector中，请问下这可能是什么造成的

2、flinksql例子建表的，没有报错就自动结束FAILED了是正常的嘛？

3、使用flinksql mongodb-cdc执行报错怎么办？

4、启动flinksql,然后随便执行一个sql报错，为什么？

5、大佬们Flink 用SQL API sink到 Doris，中间不做处理，直接CDC 到Doris. job不报错， Doris表里没数据，这有可能是什么原因呢？

6、在使用flink-sql-connnect-hbase的时候老是出现这个报错是什么原因呢

7、这个用flink sql 读取也是报错是为什么？

8、请问flink sql 写oss有个报错该怎么办？

9、大佬们flink-sql写hdfs这个报错是什么情况啊？flink版本：1.14.6

10、请问flink-sql写hive这个报错是什么情况啊？配置没问题啊，重跑任务就会成功，偶发性的失败

11、请问一下，我已经使用Flink的SQL Client通过JDBC连接模式将数据从SQL Server导入到Hudi表中然后将数据从hudi导入到SQL Server另一个表中报错

12、请问flink sql cdc pg或者mysql 报这个错的原因是什么，报错： Exception in thread "main" org.apache.flink.table.api.ValidationException: Unable to create a source for reading table 'default_catalog.default_database.pgsql_source'

13、各位大侠，flink sql cdc pg或者mysql报这个错的原因是什么，报错： Exception in thread "main" org.apache.flink.table.api.ValidationException: Unable to create a source for reading table 'default_catalog.default_database.pgsql_source'

14、用代码执行flink sql 报错

15、flink sql 读取rocketmq的数据，但是提示如下报错，请问这是啥原因？

16、Flink如下报错怎么办？ Flink-1.15.2 Standalone oracle-connector-2.3 8核 32G 16 Slots state.backend=rocksdb checkpointDir=file:///... savepointDir=file:///... Environment In Streaming Mode SQL 定义Source和Sink 同时采集16张静态表（无新增数据），全量阶段同步正常，资源充足；然而全量阶段结束后TaskManager内存占用比率依然不停增加，直到内存因此而爆满。是我哪里设置不对吗？请教各位大佬

17、flinksql 写mysql 然后mysql超过八小时超时导致任务报错了。请教大家一下flinksql 有相关的配置吗？

18、flinksql写入starrocks，结果starrocks看不到数据，为什么？

19、我flinksql 连接oracle时间长 Closed Connection报错这个怎么设置？

20、flinksql使用内置函数，报no match found for function signature xxx ，这种要怎么排错呢?

21、使用flinkSQL将数据写入hudi，而hudi的数据存储在s3上，提交程序运行报错是怎么回事？

22、我在flinksql客户端执行sql出现这个字段过多的一个报错需要调节什么解决呢?

23、各位帮忙看个问题，flink sql从hive 读数据报错，能不能不改配置文件改sql就可以跑

24、大佬们，flinksql CDC建表后，执行select 的时候报错，麻烦看看是什么原因。 Column ‘dt’ is NOT NULL, however, a null value is being written into it. You can set job configuration ‘table.exec.sink.not-null-enforcer’=‘drop’ to suppress this exception and drop such records silently.

25、flink sql cdc 同步sqlserver 报错什么原因啊

26、flinksql 连接oracle时间长 Closed Connection报错有方案解决不？

27、Flink 我在sql cli执行连接kafka建表sql（该kafka接收csv数据），然后有一条数据造的不符合字段格式，导致报错，然后该flink作业就无法继续running了，请问该如何处理呢？

28、问一下各位大佬，flink sql写入ES报错，但是相关的jar已经导入，怎么办？

29、flink sql 写入drds，报错，显示分库分表键无法做更新操作

30、各位大佬请问FlinkCDC 用sql方式同步的时候，sql有一些聚合操作用的是数据库的内存还是flink集群的内存我抽取oracle，一段时间后报错ORA-04036: 实例使用的 PGA 内存超出 PGA_AGGREGATE_LIMIT

31、大佬们，flink sql job往yarn提交作业，报不能执行sql错误，本地执行不报错，服务器报错，相关的jar都放lib下了。是什么原因呢？

32、在flinksql里用STRING 类型代替GEOMETRY类型，还是会报错吗？

33、flink sql 配置 kafka 连锁一个多分区的topic 一直没连上也没报错，单分区的没问题，这个是有什么坑吗？

34、flink sql rownumber 报错。谁遇到过啊？怎么解决？

35、flink sql连接HBase报错

36、写了个flink-sql程序，然后通过webUI提交执行报错，请问这个问题该怎么解决呢？ flink：1.13.6 flink-cdc：2.2.1

37、在执行flink sql的时候报错,有见过的吗 Flink1.9的 org.apache.flink.table.api.ValidationException: SQL validation failed. From line 1, column 121 to line 1, column 157: Cannot apply 'TUMBLE' to arguments of type 'TUMBLE(<VARCHAR(65536)>, )'. Supported form(s): 'TUMBLE( , <DATETIME_INTERVAL>)' 'TUMBLE( , <DATETIME_INTERVAL>, )' 我指定了时间戳也不行, #Flink

38、flinksql连接kafka报错如何解决？

39、使用flink-sql写入mysql的时候，只指定插入的字段，但是会报错id字段错误，没有默认值，创建时间和修改时间，但是ddl我已经都是设置了默认值，请问这种情况怎么处理

40、用flink sql 关联数据报错怎么解决？

41、使用 SQL Client，进行hive查询时报错：命名有了flink-connector-hive_2.11-1.12.0.jar，还是报java.lang.ClassNotFoundException: org.apache.flink.connectors.hive.HiveSource 麻烦看一下

42、flink-sql 客户端，咋回事我show tables 报错

43、Flink Sql不支持executeSql多次select into语句吗？

44、flink sql client数据插入文件报错，请教各位大佬，这个该怎么解决?

45、我使用flink sql cdc取连接 mysql表的时候，当我的mysql表type这个字段类型是tinyint类型时使用type in（1,2,3,4,5）会报以下的错误，只有当我把字段类型改成int的时候才能使用in，这是符合预期的吗，当字段类型不匹配的时候 flink sql不会自动转换类型吗？

46、请教个问题，按照快速上手的来，flink SQL 建表后查询，出来表结构，但是有个超时报错，怎么办

47、Flink SQL使用Tumble窗口函数报错

48、Flinksql通过phoenix查询维表，报错

49、flinksql 1.12.1 row中字段访问报错怎么办

50、在使用flink sql ddl语句向hbase中写的时候出现报错怎么解决？

51、FlinkSQL新增operatoer后基于savepoint重启报错怎么办？

52、flink sql jdbc 只要含有group by 语句就会报错怎么办？

53、FlinkSql 插入hbase group by 多个字段的时候发现报错

54、flink sql 使用自定义函数返回嵌套行，查询报错 scala.MatchError，为什么？

55、flink 1.11 sql作业提交JM报错

【百问百答】Flink SQL 报错问题汇总

实时计算 Flink

相关产品

热门讨论

热门文章

相关课程

相关电子书

相关实验场景

【百问百答】Flink SQL 报错问题汇总

实时计算 Flink

相关产品

热门讨论

热门文章

相关课程

相关文章

相关电子书

相关实验场景