查看operatorId和operatorName

每个算子都会继承org.apache.flink.streaming.api.operators.AbstractStreamOperator
如果input有两个就会实现接口org.apache.flink.streaming.api.operators.TwoInputStreamOperator
如果input只有一个会实现接口org.apache.flink.streaming.api.operators.OneInputStreamOperatorAbstractStreamOperator这个类中有一个字段config保存了这个算子相关的配置信息,在这个里面可以看到operatorId和operatorName的相关信息
可以通过下面的Arthas命令查看具体的值

  1. watch -x 3 -n 20 org.apache.flink.streaming.api.operators.OneInputStreamOperator processElement '{target.config.getOperatorID().toHexString(),target.config.getOperatorName()}'