开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

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

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

1.Flink报错Stopping SessionDispatcherLeaderProcess

2.Flink报错undefined

3.实时计算Flink报错SubscriptionSessionInvalidException

4.Flink报错akka.pattern.AskTimeoutException

5.Flink报错No space left on device

6.实时计算Flink报错versionName is not configured

7.实时计算Flink报错java.lang.IllegalArgumentException

8.实时计算Flink报错AccessKeyId invalid or expire

9.实时计算Flink报错Exceeded checkpoint tolerable failure threshold

10.实时计算Flink报错Could not execute CreateTable in path

11.Flink报错remaining connection slots are reserved for non-replication superuser connections

12.Flink报错java.lang.IllegalArgumentException: Illegal Capacity: -1

13.实时计算Flink报错INFOorg.apache.flink.fs.osshadoop.shaded.com.aliyun.oss

14.实时计算Flink报错Waiting for a cluster to become ready

15.Flink报错Encountered change event for table yhtplus.organization whose schema isn't known to this connector

16.Flink报错Has not enough ip address: abnormal event detected from kubernetes

17.Flink报错k8s LeaderElection renew loop gets interrupted java.lang.InterruptedException: sleep interrupted

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 停止任务并触发保存点会报错。

展开
收起
提个问题 2023-12-29 16:54:14 151 0
0 条回答
写回答
取消 提交回答

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 热门讨论

    热门文章

    相关电子书

    更多
    基于 Flink SQL + Paimon 构建流式湖仓新方 立即下载
    基于 Flink CDC 打造 企业级实时数据集成方案 立即下载
    李劲松|Flink Table Store 典型应用场景 立即下载