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

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

18.Flink报错org.apache.flink.streaming.connectors.kafka.FlinkKafkaException: Too many ongoing snapshots. Increase kafka producers pool size or decrease number of concurrent checkpoints

19.Flink报错：Incompatible types for sink column 'xxx' at position x.

20.实时计算Flink报错The difference between the request time and the current time is too large

21.Flink报错Can not retract a non-existent record. This should never happen.

22.实时计算Flink报错DateTimeParseException: Text 'xxx' could not be parsed

23.实时计算Flink报错java.io.EOFException: SSL peer shut down incorrectly

24.实时计算Flink报错The connector is trying to read binlog xxx use a snapshot when needed.

25.实时计算Flink报错org.codehaus.janino.CompilerFactory cannot be cast to org.codehaus.commons.compiler.ICompilerFactory

26.实时计算Flink报错org.codehaus.janino.CompilerFactory cannot be cast to org.codehaus.commons.compiler.ICompilerFactory

27.Flink报错doesn't support consuming update and delete changes which is produced by node TableSourceScandoesn't support consuming update and delete changes which is produced by node TableSourceScan

28.Flink报错:org.apache.flink.table.api.ValidationException: SQL validation failed. Unable to create a sink for writing table 'xxx'. The cause is following: Unsupported options found for 'sls'.

29.Flink报错java.lang.ClassCastException: org.codehaus.janino.CompilerFactory cannot be cast to org.codehaus.commons.compiler.ICompilerFactory

30.Flink报错:Table sink 'a' doesn't support consuming update and delete changes which is produced by node

31.实时计算Flink报错Only a single 'INSERT INTO' is supported

32.实时计算Flink报错DELETE command denied to user 'userName'@'...' for table 'table_name'

33.Flink 报错:Caused by: org.apache.flink.table.api.ValidationException: Column types of query result and sink for 'vvp.default.xxx' do not match.

34.实时计算Flink报错The primary key is necessary when enable 'Key: 'scan.incremental.snapshot.enabled' , default: true (fallback keys: [])' to 'true'

35.Flink报错：Invalid data type of time field for watermark definition. The field must be of type TIMESTAMP(p) or TIMESTAMP_LTZ(p), the supported precision 'p' is from 0 to 3, but the time field type is TIMESTAMP(6)

36.Flink报错:Session cluster version 'vvr-x.x.x-flink-1.1x' must be consistent with the SQL version 'vvr-x.x.x-flink-1.1x', please align the session cluster version with the version used in SQL.

37.实时计算Flink报错Column 'ccid' 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.

38.flink有遇到这样的问题吗？任务跑一段时间，突然报错关于checkpoint导致任务停止。是为啥？

39.org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointingStatisticsHandler [] - Exception occurred in REST handler: Job dc0c020140fda687ba5f3442b0ca6d7f not found 这个报错是什么原因？

40.flink消费rabbitmq报错

41.flink在运行job时发现如下报错 Could not allocate all requires slots within timeout of 300000 ms. Slots required: 3, slots allocated: 2

42. flink报错org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
atorg.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:139)

43.Flink这个报错是任务太多了吗？ org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException$NumberQuotaExceedException: KeeperErrorCode = Nodes number exceeds quota limit for /flink2/application_1670910941835_27837/leader

44.flink on k8s 报错读不出kafka数据来,on yarn没问题有大佬知道这什么报错吗？

45.用flink1.13版本写入ES8.5.3版本,数据只能写入一部分,之后报错，为什么？

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

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

48.有大佬碰到过这个报错吗 Caused by: java.lang.IllegalAccessError: tried to access method io.debezium.config.Instantiator.getInstanceWithProvidedConstructorType(Ljava/lang/String;Ljava/util/function/Supplier;Ljava/lang/Class;Ljava/lang/Object;)Ljava/lang/Object; from class io.debezium.connector.oracle.OracleConnectorConfig$ConnectorAdapter$2 at io.debezium.connector.oracle.OracleConnectorConfig$ConnectorAdapter$2.getInstance(OracleConnectorConfig.java:668) at io.debezium.connector.oracle.OracleConnectorConfig.(OracleConnectorConfig.java:425) at io.debezium.connector.oracle.OracleConnectorTask.start(OracleConnectorTask.java:48) at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:130) at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:759) at io.debezium.embedded.ConvertingEngineBuilder$2.run(ConvertingEngineBuilder.java:188) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)

49.请教一下这个报错是什么原因导致的？缺少什么jar包吗？flink sql sink hudi

50.我想问一下我使用 ./flink stop -p 停止任务并触发保存点会报错。

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

实时计算 Flink

相关产品

热门讨论

热门文章

相关课程

相关电子书

相关实验场景

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

实时计算 Flink

相关产品

热门讨论

热门文章

相关课程

相关文章

相关电子书

相关实验场景