chore

fishTsai20 · fishTsai20 · commit 2f1ce09ebeb8 · 2025-03-25T18:58:25.000+08:00
diff --git a/flink/runner/src/main/java/com/chainbase/etl/flink/ETLProcessor.java b/flink/runner/src/main/java/com/chainbase/etl/flink/ETLProcessor.java
@@ -103,7 +103,7 @@ private Table castTableColumns(Table sourceTable) {
     }
 
     public static void main(String[] args) {
-         String configPath = args.length > 0 ? args[0] : "eth_blocks_pg_manuscript.yaml";
+         String configPath = args.length > 0 ? args[0] : "manuscript.yaml";
          ETLProcessor processor = new ETLProcessor(configPath);
          processor.execute();
     }

Original file line number	Diff line number	Diff line change
`@@ -103,7 +103,7 @@ private Table castTableColumns(Table sourceTable) {`
`103`	`103`	`}`
`104`	`104`
`105`	`105`	`public static void main(String[] args) {`
`106`		`- String configPath = args.length > 0 ? args[0] : "eth_blocks_pg_manuscript.yaml";`
	`106`	`+ String configPath = args.length > 0 ? args[0] : "manuscript.yaml";`
`107`	`107`	`ETLProcessor processor = new ETLProcessor(configPath);`
`108`	`108`	`processor.execute();`
`109`	`109`	`}`