From 1b2b83a58550cdb61abef0b39d7da0f8a4a823cc Mon Sep 17 00:00:00 2001 From: lklhdu Date: Tue, 22 Nov 2022 12:49:13 +0800 Subject: [PATCH] =?UTF-8?q?1.=20=E4=BF=AE=E6=94=B9readme=E7=9B=B8=E5=85=B3?= =?UTF-8?q?=E8=AF=B4=E6=98=8E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- README.md | 2 +- .../com/netease/arctic/benchmark/ingestion/MainRunner.java | 5 ----- 2 files changed, 1 insertion(+), 6 deletions(-) diff --git a/README.md b/README.md index 7b91601..d104311 100644 --- a/README.md +++ b/README.md @@ -70,5 +70,5 @@ 3. Hudi ## 相关说明 -* 本项目使用的arctic-flink-runtime-1.14依赖需要基于Arctic工程进行源码编译，请下载[Arctic工程](https://github.com/NetEase/arctic)的代码，然后切换到0.3.x分支，执行命令`mvn clean install -DskipTests`进行构建 +* 本项目使用的arctic-flink-runtime-1.14依赖需要基于Arctic工程进行源码编译，请下载[Arctic工程](https://github.com/NetEase/arctic)的代码，然后切换到master分支，执行命令`mvn clean install -DskipTests`进行构建 * 本项目使用的hudi-flink1.14-bundle_2.12依赖需要基于Hudi工程进行源码编译，请下载[Hudi工程](https://github.com/apache/hudi)的代码，然后切换到release-0.11.1，执行命令`mvn clean install -DskipTests -Dflink1.14 -Dscala-2.12`进行构建 \ No newline at end of file diff --git a/src/main/java/com/netease/arctic/benchmark/ingestion/MainRunner.java b/src/main/java/com/netease/arctic/benchmark/ingestion/MainRunner.java index 80a7a14..8c0ac83 100644 --- a/src/main/java/com/netease/arctic/benchmark/ingestion/MainRunner.java +++ b/src/main/java/com/netease/arctic/benchmark/ingestion/MainRunner.java @@ -86,11 +86,6 @@ public static void main(String[] args) createSinkCatalog(sinkType, props); call(sinkType, sinkDatabase, configuration, CallContext.builder() .args(ParameterTool.fromArgs(args)).env(env).tableEnv(tableEnv).build()); - // try { - // env.execute(); - // } catch (Exception e) { - // throw new RuntimeException(e); - // } } private static void call(String sinkType, String sinkDatabase, Configuration configuration,