flinkx1.12.7 在恢复checkpoint没起效
Nadie ha tomado este issue todavía.
Evaluación
- Dificultad
- 4/5
- Tiempo estimado
- 3-5 días
- Aptitud para principiantes
- 25/100
- Tipo de issue
- Error
- Claridad
- Necesita aclaración
- Estado de actividad
- Estancado
- Área
- distributed-systems
Línea de trabajo
Reproduce el comando de ./bin/flinkx usando flinkx-examples/sql/develp/cp.sql y Flink 1.12.7. Primero inspecciona cómo se analizan y aplican la opción -s y los valores pasados mediante -confProp. Se considera terminado cuando se haya identificado el procedimiento compatible para reiniciar desde un savepoint o checkpoint y se haya confirmado con la configuración indicada.
Escrito por el modelo de indexación a partir del texto del issue.
Descripción
example: execute the command as follows:
- savepoint 使用
./bin/flinkx -mode standalone -jobType sql -flinkxDistDir flinkx-dist -job flinkx-examples/sql/develp/cp.sql -flinkLibDir ../flink-1.12.7/lib -flinkConfDir ../flink-1.12.7/conf -confProp "{"sql.checkpoint.mode":"EXACTLY_ONCE","execution.checkpointing.interval":"6000"}" -s hdfs://dswhhadoop-3:8020/warehouse/tablespace/managed/checkpoint/0aa6ad6d5daafd265bebb8de6c2d8bd4
结果报错! 显示没有-s这个参数选项，无法恢复savepoint
- 另外一种方式
./bin/flinkx -mode standalone -jobType sql -flinkxDistDir flinkx-dist -job flinkx-examples/sql/develp/cp.sql -flinkLibDir ../flink-1.12.7/lib -flinkConfDir ../flink-1.12.7/conf -confProp "{"sql.checkpoint.mode":"EXACTLY_ONCE","execution.checkpointing.interval":"6000","flink.checkpoint.interval":8000,"sql.checkpoint.timeout":"200000","state.backend":"FILESYSTEM","state.savepoints.dir":"hdfs://dswhhadoop-3:8020/warehouse/tablespace/managed/savepoint","state.checkpoints.dir":"hdfs://dswhhadoop-3:8020/warehouse/tablespace/managed/checkpoint"}"
通过在配置-confProp中 配置"state.savepoints.dir 也没有起作用 ，bi站官方视频上面是之前的版本，支持-s ,1.12版不支持了,
不知道如何使用flinkx 自带的任务挂了，重启实现断点续传功能？
- Lenguaje dominante
- Sin datos de lenguaje
- Estrellas
- 55
- Forks
- 13
- Métricas de merge de PR
- Sin PR fusionados en 30 d
Preparar el entorno
Aún no hemos revisado los archivos de configuración de este proyecto. Empieza por su README y consulta nuestra guía para la primera contribución para los pasos generales.
Primeros pasos
- Lee el issue completo y luego la guía de contribución del proyecto.
- Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
- Haz un fork del repositorio y trabaja en una rama.
- Abre un pull request que haga referencia al número del issue.
Más de DTStack/flinkx
-
Dificultad 3/5 1-2 días Aptitud para principiantes 35/100
-
flinkx1.11 hdfs->其他数据源flink无日志Abierto
Dificultad 4/5 3-5 días Aptitud para principiantes 25/100
-
Dificultad 3/5 1-2 días Aptitud para principiantes 25/100
Todos los issues de DTStack/flinkx
Issues similares
-
check_program_status() ignores errors on ranks other than 0, and calls Abort() with errorcode 0Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 84/100
NCAR/WrfHydroForcing#132 ·
-
bug P2 reliability workers
Dificultad 2/5 1-3 horas Aptitud para principiantes 86/100
afreidah/s3-orchestrator#1563 ·
Los mantenedores suelen responder en 1 día
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 84/100
ergoplatform/ergo#2579 ·
Los mantenedores suelen responder en 2 días
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100
apache/incubator-seata#8263 ·
Los mantenedores suelen responder en 1 día
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 88/100
apache/incubator-seata-go#1201 ·
Los mantenedores suelen responder en 1 día