diff --git a/pom.xml b/pom.xml
index 14acd47..3bad7ea 100644
--- a/pom.xml
+++ b/pom.xml
@@ -52,6 +52,9 @@
1.13.3
1.13.3
10.4.0
+ 5.1.0
+ 2.8.0
+ 5.7.16
@@ -210,17 +213,17 @@
cn.hutool
hutool-all
- 5.7.16
+ ${hutool.version}
org.apache.pulsar
pulsar-client
- 2.8.0
+ ${pulsar.version}
org.apache.pulsar
pulsar-client-admin
- 2.8.0
+ ${pulsar.version}
org.apache.hadoop
@@ -232,6 +235,11 @@
juicefs-hadoop
2.0.1
+
+ org.apache.parquet
+ parquet-format
+ 2.4.0
+
com.cronutils
cron-utils
@@ -294,20 +302,85 @@
flink-metrics-prometheus_${scala.major.version}
${flink.version}
+
+ org.apache.flink
+ flink-core
+ ${flink.version}
+
+
+ org.apache.flink
+ flink-runtime_${scala.major.version}
+ ${flink.version}
+
+
+ org.apache.flink
+ flink-runtime-web_${scala.major.version}
+ ${flink.version}
+
+
+ org.apache.flink
+ flink-optimizer_${scala.major.version}
+ ${flink.version}
+
+
+ org.apache.flink
+ flink-streaming-scala_${scala.major.version}
+ ${flink.version}
+
+
+ org.apache.flink
+ flink-metrics-core
+ ${flink.version}
+
+
+ org.apache.flink
+ flink-container_${scala.major.version}
+ ${flink.version}
+
+
+ org.apache.flink
+ flink-yarn_${scala.major.version}
+ ${flink.version}
+
+
+ org.apache.flink
+ flink-hadoop-fs
+ ${flink.version}
+
+
+ org.apache.flink
+ flink-table-uber_${scala.major.version}
+ ${flink.version}
+
+
+ org.apache.flink
+ flink-table-uber-blink_${scala.major.version}
+ ${flink.version}
+
+
+ org.apache.flink
+ flink-state-processor-api_${scala.major.version}
+ ${flink.version}
+
org.apache.flink
flink-shaded-guava
30.1.1-jre-15.0
+
+ org.apache.flink
+ flink-shaded-hadoop-3-uber
+ 3.1.1.7.2.9.0-173-9.0
+
org.apache.curator
curator-recipes
- 5.1.0
+ ${curator.version}
org.apache.curator
curator-framework
- 5.1.0
+ ${curator.version}
diff --git a/utils/executor/pom.xml b/utils/executor/pom.xml
index 1a9d379..005dd14 100644
--- a/utils/executor/pom.xml
+++ b/utils/executor/pom.xml
@@ -15,62 +15,50 @@
org.apache.flink
flink-core
- ${flink.version}
org.apache.flink
flink-java
- ${flink.version}
org.apache.flink
flink-runtime_${scala.major.version}
- ${flink.version}
org.apache.flink
flink-runtime-web_${scala.major.version}
- ${flink.version}
org.apache.flink
flink-optimizer_${scala.major.version}
- ${flink.version}
org.apache.flink
flink-clients_${scala.major.version}
- ${flink.version}
org.apache.flink
flink-streaming-java_${scala.major.version}
- ${flink.version}
org.apache.flink
flink-streaming-scala_${scala.major.version}
- ${flink.version}
org.apache.flink
flink-metrics-core
- ${flink.version}
org.apache.flink
flink-metrics-prometheus_${scala.major.version}
- ${flink.version}
org.apache.flink
flink-container_${scala.major.version}
- ${flink.version}
org.apache.flink
flink-yarn_${scala.major.version}
- ${flink.version}
org.apache.hadoop
@@ -81,27 +69,22 @@
org.apache.flink
flink-hadoop-fs
- ${flink.version}
org.apache.flink
flink-table-uber_${scala.major.version}
- ${flink.version}
org.apache.flink
flink-table-uber-blink_${scala.major.version}
- ${flink.version}
org.apache.flink
flink-state-processor-api_${scala.major.version}
- ${flink.version}
org.apache.flink
flink-shaded-hadoop-3-uber
- 3.1.1.7.2.9.0-173-9.0
cn.hutool
@@ -110,7 +93,10 @@
org.apache.parquet
parquet-format
- 2.4.0
+
+
+ io.juicefs
+ juicefs-hadoop