Compile error for Flink translation

2018-03-01T21:22:58.234 [INFO] — maven-compiler-plugin:3.7.0:compile (default-compile) @ beam-runners-flink_2.11 —
2018-03-01T21:22:58.258 [INFO] Changes detected - recompiling the module!
2018-03-01T21:22:58.259 [INFO] Compiling 75 source files to /home/jenkins/jenkins-slave/workspace/beam_PreCommit_Java_MavenInstall@2/src/runners/flink/target/classes
2018-03-01T21:22:59.555 [INFO] /home/jenkins/jenkins-slave/workspace/beam_PreCommit_Java_MavenInstall@2/src/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/DedupingOperator.java: Some input files use or override a deprecated API.
2018-03-01T21:22:59.556 [INFO] /home/jenkins/jenkins-slave/workspace/beam_PreCommit_Java_MavenInstall@2/src/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/DedupingOperator.java: Recompile with -Xlint:deprecation for details.
2018-03-01T21:22:59.556 [INFO] /home/jenkins/jenkins-slave/workspace/beam_PreCommit_Java_MavenInstall@2/src/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/SideInputInitializer.java: Some input files use unchecked or unsafe operations.
2018-03-01T21:22:59.556 [INFO] /home/jenkins/jenkins-slave/workspace/beam_PreCommit_Java_MavenInstall@2/src/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/SideInputInitializer.java: Recompile with -Xlint:unchecked for details.
2018-03-01T21:22:59.556 [INFO] -------------------------------------------------------------
2018-03-01T21:22:59.556 [ERROR] COMPILATION ERROR :
2018-03-01T21:22:59.556 [INFO] -------------------------------------------------------------
2018-03-01T21:22:59.557 [ERROR] /home/jenkins/jenkins-slave/workspace/beam_PreCommit_Java_MavenInstall@2/src/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java:[359,11] cannot infer type arguments for org.apache.beam.runners.core.ProcessFnRunner<>
reason: cannot infer type-variable(s) InputT,OutputT,RestrictionT
(argument mismatch; org.apache.beam.runners.core.DoFnRunner cannot be converted to org.apache.beam.runners.core.SimpleDoFnRunner<org.apache.beam.runners.core.KeyedWorkItem<java.lang.String,org.apache.beam.sdk.values.KV<InputT,RestrictionT>>,OutputT>)