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

Question

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

Answer 1

flink运行hdfs://ns/flink/flink-checkpoints/savepoint-c5dade-af74904ab30c /opt/flink/flink-bin/yarn-app/a/sql-client-kafka-json.yaml yarn-cluster application_1539849585041_0459 -c client opt/flink-sql- org.apache.flink.table.client.SqlClient -1.6.1.jar embedded -e /opt/flink/flink-bin/yarn-app/a/sql-client-kafka-json.yaml--库/opt/flink/flink-bin//lib -u 'INSERT INTO testjsonSink SELECT * FROM testjsonSource;'`

调整jars库。它已经像以前一样解决了。糟糕的文档。

Answer 2

官方使用1.12.1和scala 1.12: flink run hdfs://dbt1caw005.webex.com:9000/flink-checkpoints/savepoint-dafd7c-05d66b098493 file:///opt/flink/jars/flink-python_2.12-1.12.1.jar -C org.apache.flink.table.client.SqlClient -e embedded -e /vdb/sql.yml -l /opt/flink/jars -u "INSERT -u CALL_DURATION_USER SELECT orgId，userId，window_start，window_end，total_minutes，total_calls FROM ( SELECT，ROW_NUMBER() OVER (PARTITION BY orgId，window_end ORDER BY total_minutes desc) as rownum FROM ( SELECT orgId，userId，HOP_START(ts，间隔'1‘天，间隔'30’天) window_start，HOP_END(ts，间隔'1‘天，间隔'30’天) window_end，CAST(sum(cast(legDuration AS bigint)/60) AS BIGINT) total_minutes，CAST(count() AS BIGINT)从callduration_ts分组逐跳(ts，间隔'1‘天，间隔'30’天)的total_calls，orgId，userId )) WHERE rownum < 101“