请问Flink CDC这个命令有啥问题,在服务器上执行失败了,告诉我参数错误?

请问Flink CDC这个命令有啥问题,在服务器上执行失败了,告诉我参数错误?/home/data/flink/flink-1.16.2/bin/flink run -d -m 192.168.2.252:28081 -stateBackendType 2 -enableIncremental true -checkpointInterval 900000 -checkpointDir oss://test-flink-point/checkpoint/ -c pig.flink.streaming.core.task.FlinkDemo /home/data/flink/web/flink-streaming-platform-web/upload_jars/flink-streaming-core.jar

展开
收起
真的很搞笑 2023-07-02 17:40:43 128 分享 版权
2 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    -stateBackendType 参数错误:-stateBackendType 参数的值应该是一个字符串,用来指定状态后端的类型。在您的命令中,-stateBackendType 2 的参数值不正确。通常情况下,Flink 支持的状态后端类型包括 filesystem、rocksdb、memory 等。因此,您需要将 -stateBackendType 参数的值设置为其中的一个,例如 -stateBackendType rocksdb。
    -enableIncremental 参数错误:-enableIncremental 参数用来指定是否启用增量 checkpoint。在您的命令中,-enableIncremental true 的参数值不正确。正确的参数值应该是一个布尔值,例如 -enableIncremental true 或 -enableIncremental false。如果不需要启用增量 checkpoint,可以将该参数设置为 false。
    -checkpointInterval 参数错误:-checkpointInterval 参数的值应该是一个数字,用来指定 checkpoint 的时间间隔,单位是毫秒。在您的命令中,-checkpointInterval 900000 的参数值不正确。正确的参数值应该是一个数字,例如 -checkpointInterval 60000 表示每隔一分钟创建一个 checkpoint。
    -checkpointDir 参数错误:-checkpointDir 参数的值应该是一个字符串,用来指定 checkpoint 的保存路径。在您的命令中,-checkpointDir oss://test-flink-point/checkpoint/ 的参数值不正确。正确的参数值应该是一个本地文件系统或分布式文件系统的路径,例如 -checkpointDir /tmp/checkpoint 或 -checkpointDir hdfs://localhost:9000/checkpoint。
    -c 参数错误:-c 参数的值应该是一个字符串,用来指定 Flink 程序的入口类。在您的命令中,-c pig.flink.streaming.core.task.FlinkDemo 的参数值不正确。正确的参数值应该是一个包含 main 函数的 Flink 程序的类名,例如 -c com.example.MyFlinkProgram。

    2023-07-30 09:36:46
    赞同 展开评论
  • 根据你提供的命令,有几个可能导致参数错误的问题:

    1. 参数顺序错误:请确保命令中各个参数的顺序正确。例如,-stateBackendType 2 应该放在 -m 192.168.2.252:28081 之前,而不是之后。

    2. 参数格式错误:请检查每个参数的格式是否正确。例如,参数值是否缺少引号或双引号等。

    3. 参数名称错误:请确认命令中使用的参数名称和 Flink 版本是否匹配。不同版本的 Flink 可能会使用不同的参数名称。

    4. 参数未识别:如果命令执行时出现 "参数错误" 的提示,可能是因为该命令中包含了 Flink 不认识的参数。请检查你所使用的 Flink 版本和对应文档,确保使用的参数是有效的。

    请仔细检查以上问题,并尝试调整命令中的参数顺序、格式和名称。另外,建议查看相关日志文件以获得更详细的错误信息,这有助于准确定位问题所在。

    2023-07-30 09:39:44
    赞同 展开评论

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

还有其他疑问?
咨询AI助理