根据Beam的官方文档，已经采用了log4j-core 2.16.0版本，并指出此版本对log4j漏洞进行了修复。但Flink版本的支持也要根据相应的Beam版本进行选择。

例如，Beam 2.33及以上版本支持Flink 1.13.3及以上版本，并建议使用Flink 1.14.x版本。要使用此版本，请按照以下步骤进行：

1.添加Beam和Flink的依赖项：

org.apache.beam beam-runners-flink-1.14.0 2.33.0

org.apache.flink flink-core 1.14.3

2. 在应用程序中进行相应的导入：

import org.apache.beam.runners.flink.FlinkRunner;

import org.apache.flink.api.java.ExecutionEnvironment; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

PipelineOptions options = PipelineOptionsFactory.create(); options.setRunner(FlinkRunner.class);

Pipeline pipeline = Pipeline.create(options);

// batch ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment(); Pipeline pipelineBatch = Pipeline.create();

// stream StreamExecutionEnvironment envStream = StreamExecutionEnvironment.getExecutionEnvironment(); Pipeline pipelineStream = Pipeline.create();

请注意：如果使用的是旧版本的Beam，则需要更新相应的Beam版本并相应地更改Flink版本。