Hacktoberfest 2026: những issue maintainer đã đánh dấu cho tháng Mười, đang mở và phù hợp người mới. Xem issue Hacktoberfest

flinkx1.12.7 在恢复checkpoint没起效

Đang mở
  • Có gì không ổn?
#2 0 bình luận 0 reaction 0 người được giao Xem trên GitHub

Chưa có ai nhận issue này.

Đánh giá

Độ khó
4/5
Thời gian dự kiến
3-5 ngày
Mức phù hợp với người mới
25/100
Loại issue
Lỗi
Độ rõ ràng
Cần làm rõ
Mức độ hoạt động
Đình trệ
Lĩnh vực
distributed-systems

Hướng nghiên cứu

Tái hiện lệnh từ ./bin/flinkx bằng cách sử dụng flinkx-examples/sql/develp/cp.sql và Flink 1.12.7. Trước tiên, hãy kiểm tra cách tùy chọn -s và các giá trị được truyền qua -confProp được phân tích cú pháp và áp dụng. Hoàn thành có nghĩa là xác định quy trình được hỗ trợ để khởi động lại từ savepoint hoặc checkpoint và xác nhận quy trình đó bằng cấu hình được báo cáo.

Do mô hình lập chỉ mục viết ra từ nội dung của issue.

Mô tả

example: execute the command as follows:

  1. 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

  1. 另外一种方式
    ./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 自带的任务挂了，重启实现断点续传功能？

Ngôn ngữ chính
Không có dữ liệu ngôn ngữ
Star
55
Fork
13
Không có pull request nào được merge trong 30 ngày

Chuẩn bị môi trường

Chúng tôi chưa kiểm tra các tệp thiết lập môi trường của dự án này. Hãy bắt đầu từ README và xem hướng dẫn đóng góp lần đầu của chúng tôi để biết các bước chung.

Bắt đầu từ đâu

  1. Đọc hết issue, rồi đọc hướng dẫn đóng góp của dự án.
  2. Bình luận trên issue rằng bạn sẽ nhận — tránh hai người làm cùng một việc.
  3. Fork repository và làm thay đổi trên một nhánh.
  4. Mở pull request có tham chiếu số hiệu của issue.

Issue khác của DTStack/flinkx

Tất cả issue của DTStack/flinkx

Issue tương tự

Thêm issue về Distributed Systems

Nhận issue mới trong hộp thư của bạn

Bản tóm tắt ngắn những issue GitHub phù hợp với người mới.