要回答此问题,必须先知道这个问题是什么。如果您能提供更多的上下文或错误消息,则可能会更容易确定。
当然,在 Apache Flink 发布的每个新版本中,都可能已解决许多问题。如果您能提供与特定版本相关的详细信息,则可以更容易地回答此问题。
以下是可能有用的代码示例,可以帮助您确定您的应用程序是否在特定版本中受到影响。它打印出使用 Apache Flink 执行的任务的配置信息。
import org.apache.flink.configuration.Configuration;
import org.apache.flink.configuration.CoreOptions;
public class PrintFlinkConfig {
public static void main(String[] args) {
Configuration configuration = new Configuration();
configuration.addAll(CoreOptions.getInternalConfiguration());
System.out.println(configuration.toDebugString());
}
}
请注意,在上面的示例中,我们需要使用CoreOptions.getInternalConfiguration()
,因为此方法获取了所有 Flink 配置的默认值和额外的内部设置。