使用JDK 11或JDK 12运行Beam管道,因为这些版本已经得到了测试并与Beam兼容。
更新Beam版本为2.32.0或更高版本,因为这些版本已经修复了JDK 16兼容性问题。
在构建时使用Java 11或12注释掉以下代码以跳过编译期间的JDK版本检查:
enforce-java-versions
enforce
Beam SDK requires JDK Version 8 or 11 for building
[1.8,1.13)
mvn clean install -DskipTests
mvn clean install -DskipTests -P java8
或
mvn clean install -DskipTests -P java11
下一篇:BeamPythonDataflow在提供模式的情况下写入BigQuery表时,抛出“AttributeError:Maynotassignarbitraryvaluetpetomessage”错误。