Flink CDC里flink 能获取的当前任务运行的jar 名称吗？

在Flink中，你可以通过以下方式获取当前任务运行的jar名称：

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
String jarName = env.getClass().getResource("/" + env.getJarName()).toString();
System.out.println("当前任务运行的jar名称为：" + jarName);

这里首先获取了执行环境的实例，然后通过getJarName()方法获取到当前任务正在执行的jar包的名称。最后，我们打印出这个jar包的名称。

Flink CDC中，可以通过以下方式获取当前任务运行的jar名称：

String jarName = YourClass.class.getProtectionDomain().getCodeSource().getLocation().getFile();

其中，YourClass为当前类的名称。通过上述代码可以获取到当前任务运行的jar文件路径，然后可以使用.getName()方法获取jar名称。