Flink 12支持Nebula

[Mercury]

• flink 版本
  1.12.3

• nebula版本

        <dependency>
            <groupId>com.vesoft</groupId>
            <artifactId>nebula-flink-connector</artifactId>
            <version>2.6.0</version>
            <exclusions>
                <exclusion>
                    <groupId>org.apache.flink</groupId>
                    <artifactId>flink-streaming-scala_2.11</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>org.apache.flink</groupId>
                    <artifactId>flink-streaming-java_2.11</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

Api版本不同的差异导致的编译不通过

Error:(10, 73) trait Context takes type parameters
  override def invoke(elements: Iterable[String], context: SinkFunction.Context): Unit = {

一直无法通过编译，求大佬赐教。

[darionyaphet]

考虑一下 Scala 版本不一致的问题？

[Mercury]

scala版本都是2.11。

[darionyaphet]

请问 您JDK 版本是多少？

[Mercury]

1.8

[darionyaphet]

这我就不清除了 要专业人士来给您解答 麻烦作者 @nicole 来帮忙看一眼吧 谢谢

[nicole]

flink版本不兼容， connector用的1.11

[Mercury]

有计划升级版本吗？

[steam]

你可以去 GitHub - vesoft-inc/nebula-flink-connector: Flink Connector for Nebula Graph 这里提一个 issue 哈，我们可以根据 issue 来进行下一步的规划。