When I implement CustomStreamGrouping, one component of the task id WorkerTopologyContext contextcan tell me getThisWorkerTasks().
But how can I get not only ThisWorkertasks, but I want to know every information about the working file of the task.
It seems not worker idto identify a working instance. So is there a way to get all working hosts and ports? Is a working person a way to find out one task identifier?
source
share