found : org.apache.flink.configuration.ConfigOption[Boolean] [INFO] required: org.apache.flink.configuration.ConfigOption[Any] [INFO] Note: Boolean <: Any, but Java-defined class ConfigOption is invariant in type T. [INFO] You may wish to investigate a wildcard type such as `_ <: Any`. (SLS 3.2.10) [INFO] config.set(ExecutionCheckpointingOptions.ENABLE_CHECKPOINTS_AFTER_TASKS_FINISH, true:Boolean)

这个错误是因为在设置配置选项时，类型不匹配。具体来说，你尝试将一个布尔类型的值传递给一个期望接受任何类型的配置选项。为了解决这个问题，你可以将布尔值转换为 `Any` 类型，或者将配置选项的类型改为布尔类型。例如，将 `ExecutionCheckpointingOptions.ENABLE_CHECKPOINTS_AFTER_TASKS_FINISH` 的类型从 `ConfigOption[Boolean]` 更改为 `ConfigOption[Any]`，或者使用以下代码进行设置：

config.set(ExecutionCheckpointingOptions.ENABLE_CHECKPOINTS_AFTER_TASKS_FINISH, true.asInstanceOf[Any])

这将使用 `asInstanceOf` 方法将布尔值转换为 `Any` 类型。

相关问题

Caused by: java.lang.NoClassDefFoundError: Could not initialize class org.apache.flink.table.planner.plan.rules.FlinkStreamRuleSets$ at org.apache.flink.table.planner.plan.optimize.program.FlinkStreamProgram$.buildProgram(FlinkStreamProgram.scala:56) at org.apache.flink.table.planner.plan.optimize.StreamCommonSubGraphBasedOptimizer.$anonfun$optimizeTree$1(StreamCommonSubGraphBasedOptimizer.scala:158) at scala.Option.getOrElse(Option.scala:121) at org.apache.flink.table.planner.plan.optimize.StreamCommonSubGraphBasedOptimizer.optimizeTree(StreamCommonSubGraphBasedOptimizer.scala:158) at org.apache.flink.table.planner.plan.optimize.StreamCommonSubGraphBasedOptimizer.doOptimize(StreamCommonSubGraphBasedOptimizer.scala:83) at org.apache.flink.table.planner.plan.optimize.CommonSubGraphBasedOptimizer.optimize(CommonSubGraphBasedOptimizer.scala:77) at org.apache.flink.table.planner.delegation.PlannerBase.optimize(PlannerBase.scala:287) at org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:160) at org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1329) at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:676) at org.apache.flink.table.api.internal.StatementSetImpl.execute(StatementSetImpl.java:98) at com.dtstack.chunjun.util.SqlTaskUtil.executeSql(SqlTaskUtil.java:117) at com.dtstack.chunjun.util.SqlTaskUtil.executeSqlJob(SqlTaskUtil.java:97) at com.dtstack.chunjun.Main.main(Main.java:59) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:366) at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:235) at org.apache.flink.client.program.PackagedProgramUtils.getPipelineFromProgram(PackagedProgramUtils.java:158) ... 14 more

这是一个 Java 异常，具体原因是找不到类 org.apache.flink.table.planner.plan.rules.FlinkStreamRuleSets，可能是因为缺少相关的依赖库或者版本不匹配。您需要检查您的代码中是否引入了正确的依赖库，并且确认版本是否正确。如果仍然存在问题，建议您查看详细的异常信息，了解更多的上下文信息，以更好地定位问题。

Receiver class org.apache.flink.client.deployment.executors.LocalExecutor does not define or inherit an implementation of the resolved method 'abstract java.util.concurrent.CompletableFuture execute(org.apache.flink.api.dag.Pipeline, org.apache.flink.configuration.Configuration, java.lang.ClassLoader)' of interface org.apache.flink.core.execution.PipelineExecutor.

这个问题是由于 `LocalExecutor` 类没有实现 `PipelineExecutor` 接口的 `execute` 方法引起的。根据报错信息，`execute` 方法的签名应该是 `CompletableFuture execute(Pipeline, Configuration, ClassLoader)`。你可以检查一下 `LocalExecutor` 类是否正确实现了接口，并确保方法签名与接口定义一致。另外，你还可以查看一下 Flink 版本是否与你的代码兼容，可能需要更新或切换到适合的版本。