是基于apache不正式支持beam.And的java11。但是,当我在GCP上运行数据流作业并检查作为工作人员使用的vm实例时。我发现容器映像是"gcr.io/cloud-dataflow/v1beta3/beam-java11-batch:beam-2.23.0"".,所以在运行数据流时使用java11作为java运行时的数据流是吗?为什么不使用java8呢?是否存在bug的风险?
“-log_dir=/var/
//tmp”,“-=//tmp”"gcr.io/cloud-dataflow/v1beta3/beam-java11-batch:beam-2.23.0", :“image”
发布于 2020-11-03 17:58:12
"Dataflow Runner“( Apache Beam中将Beam管道转换为Dataflow表示并提交作业的部分)检测用于提交作业的Java版本,并尝试匹配它。因此,如果您使用Java 11启动管道,那么选择的工作人员将是Java 11。
您可以通过传递--workerHarnessContainerImage标志手动选择容器。这不被“支持”,因为它很容易导致作业以Dataflow无法控制的方式失败。
https://stackoverflow.com/questions/64602800
复制相似问题