贡献代码

调试 Kyuubi

师成师成· 更新于 2026-09-29· 阅读 4 分钟· 0 次阅读

登录后可跨设备保存划线和私人笔记登录

你可以使用 Java 调试线协议(JDWP),通过你喜欢的 IDE 工具(例如 IntelliJ IDEA)来调试 Kyuubi。

调试服务端

我们可以在 KYUUBI_JAVA_OPTS 中配置 JDWP 代理来进行调试。

例如:

KYUUBI_JAVA_OPTS=-agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5005 \
bin/kyuubi start

在 IDE 中,在调试配置里设置相应的参数(主机和端口),例如

../../_images/idea_debug.png

调试引擎

我们可以通过配置 Kyuubi 属性来启用调试引擎。

Flink 引擎

kyuubi.engine.flink.java.options -agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5005

Trino 引擎

kyuubi.engine.trino.java.options -agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5005

Hive 引擎

kyuubi.engine.hive.java.options -agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5005

调试应用

Spark 引擎

  • Spark Driver
spark.driver.extraJavaOptions   -agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5005
  • Spark Executor
spark.executor.extraJavaOptions   -agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5005

Flink 引擎

  • Flink 进程
env.java.opts   -agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5005
  • Flink JobManager
env.java.opts.jobmanager   -agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5005
  • Flink TaskManager
env.java.opts.taskmanager   -agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5005
  • Flink HistoryServer
env.java.opts.historyserver   -agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5005
  • Flink 客户端
env.java.opts.client   -agentlib:jdwp=transport=dt_socket,server=y,suspend=y,address=5005

评论

登录后参与评论

正在加载评论…