我如何获得工作提交时间并在Flink应用程序中使用它？

Question

我目前正在开发流处理应用程序，其中一项功能是获取在时区[提交作业的时间，提交作业的时间+ T时发生的事件]。

如何使用Flink中的流处理API访问特定变量（提交作业的时间）？

谢谢。

Answer 1

https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/best_practices.html#getting-your-configuration-values-into-the-parametertool

ParameterTool parameters = ParameterTool.fromArgs(args);

// set up the execution environment
final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
env.getConfig().setGlobalJobParameters(parameters);

您可以通过CLI参数传递时间戳，也可以直接使用Java代码获取系统时间。使用GlobalJobParameters，您可以通过context访问任何运算符中的时间。