编译 Nebula Flink Connector

按以下步骤编译 Nebula Flink Connector v1.x:

  1. 克隆 nebula-java 源代码。

    1. git clone -b v1.0 https://github.com/vesoft-inc/nebula-java.git
  2. 切换到 nebula-java 目录,并打包 Nebula Java 1.x。

    1. cd nebula-java
    2. mvn clean install -Dgpg.skip -Dmaven.javadoc.skip=true -Dmaven.test.skip=true
  3. 进入 tools/nebula-flink 目录,并编译 Nebula Flink Connector v1.x。

    1. cd nebula-java/tools/nebula-flink
    2. mvn clean package -Dgpg.skip -Dmaven.javadoc.skip=true -Dmaven.test.skip=true

编译成功后,您可以在当前目录里看到如下目录结构。在 target 目录下,您可以看到 nebula-flink-1.x.y.jar 文件。将这个文件复制到本地 Maven 库的 com/vesoft/nebula-flink/ 目录中。

  1. ├── README.md
  2. ├── pom.xml
  3. ├── src
  4. ├── main
  5. └── test
  6. └── target
  7. ├── classes
  8. ├── generated-sources
  9. ├── generated-test-sources
  10. ├── maven-archiver
  11. ├── maven-status
  12. ├── nebula-flink-1.x.y-sources.jar
  13. ├── nebula-flink-1.x.y-test-sources.jar
  14. ├── nebula-flink-1.x.y-tests.jar
  15. ├── nebula-flink-1.x.y.jar
  16. ├── original-nebula-flink-1.x.y.jar
  17. └── test-classes

说明:JAR 文件版本号会因 Nebula Java Client 的发布版本而异。您可以在 nebula-java 仓库的 Releases 页面 查看最新的 v1.x 版本。