从sql-client.sh提交的Flink作业,如何从保存点恢复



我从apache-flink-sql客户端提交了一个作业,并创建了一个保存点。问题是元数据不包含jar和类名,更不用说参数了。如何重新启动?

flink run-shdfs://ns/flink/flink-checkpoints/savepoint-c5dade-af74904ab30c-m yarn cluster-yid application_1539849585041_0459-c org.apache.flink.table.client.SqlClient opt/flink-sql-client-1.1.6.1.jar embedded-e/opt/flink/flink-bin/yarn app/a/sql-client-kafka-json.yaml--library/opt/flink/flink-bin//lib-u'插入testjsonSink SELECT*FROM testjsonSource;'`

调整jars lib。它像以前一样被解决了。文件不完善。

官方使用1.12.1和scala 1.12:flink run-shdfs://dbt1caw005.webex.com:9000/flink-检查点/保存点-dad7c-05d66b098493-Cfile:///opt/flink/jars/flink-python_2.12-1.12.1.jar-c org.apache.flink.table.client.SqlClient/opt/flink/opt/flick-sql-client_2.12-1.12.1.jar嵌入式-e/vdb/sql.yml-l/opt/flink/jars-u";插入CALL_DURATION_USER SELECT orgId,userId,window_start,window_end,total_minutes,total_calls FROM,CAST(sum(CAST(legDuration as bigint(/60(as bigint(total_minutes,CAST(count((as BIgin(total_calls FROM callduration_ts GROUP BY HOP(ts,INTERVAL'1'DAY,INTERVAL'30'DAY(,orgId,userId((其中rownum<101〃;

相关内容

  • 没有找到相关文章