Apache Flink를 어떻게 디버깅합니까?

Question

필자는 Java API와 더 잘 어울리는 Apache Flink Python API를 확장하기 위해 노력해 왔으며 현재 작업중인 데이터 유형에 관한 이상한 오류가 발생합니다. Flink 자체를 디버깅하기 위해 Java 디버거 (예 : Intellij IDEA)를 첨부 할 수 있습니까?

Answer 1

Svetlin Zarev으로 원격 Java 디버깅을 지적했습니다. 다음은 묻기 전에 알아야 할 유용한 것들입니다.

1. IDE/디버거 등에서 원격 디버깅을 설정합니다. 원격 디버깅을 설정하고 사용자 환경에 JVM_ARGS 세트 bin/flink를 사용하여 작업을 실행 원격 디버깅

또는 FLINK 작업 주자를 디버깅하기위한 적절한 설정을 사용하여 setting env.java.opts in the configuration하여 IntelliJ IDEA

수정 아파치 FLINK JVM 인수에 대해. Flick 작업 관리자 (예 : bin/start-local.sh)가 아닌 bin/flink에만 JVM_ARGS을 설정해야 포트가 충돌합니다.

Flink 작업을 실행하여 적절한 인수가 here으로 설정되어있는 약간의 fish 쉘 함수를 만들었습니다.