How can I get the right TaskExecutor in ProcessFunction
Hi all I want to get the right TaskExecutor where the ProcessFunction run at. Is there any way to get it from getRuntimeContext() . Or any other solution?? Best wishes,
How to use my custom log4j.properties when running minicluster in idea
Hi, I am running flink job in the Intellij IDEA with mini cluster (not submit it to the flink cluster ) for convenience . Now I have put my custom log config file ( both log4j.properties and logback.xml) in src/main/resources/. But it does not work. Is there any solutions?