From 8dfad8c78966273e207a5026dd776d63395d651f Mon Sep 17 00:00:00 2001 From: aiwenmo <32723967+aiwenmo@users.noreply.github.com> Date: Thu, 23 Nov 2023 23:31:01 +0800 Subject: [PATCH] [Optimization-2567][core] Merge dinky-executor into dinky-core (#2568) * [Optimization-2567][core] Merge dinky-executor into dinky-core * fix pom * fix pom --------- Co-authored-by: wenmo <32723967+wenmo@users.noreply.github.com> --- dinky-admin/pom.xml | 4 - .../java/org/dinky/service/TaskService.java | 3 +- dinky-app/dinky-app-base/pom.xml | 2 +- dinky-core/pom.xml | 51 +++++- .../sink/PrintNetDynamicTableSink.java | 0 .../sink/PrintNetDynamicTableSinkFactory.java | 0 .../printnet/sink/PrintNetSinkFunction.java | 0 .../org/dinky/constant/FlinkConstant.java | 0 .../org/dinky/constant/FlinkSQLConstant.java | 0 .../org/dinky/exception/FlinkException.java | 0 .../org/dinky/executor/AppBatchExecutor.java | 0 .../org/dinky/executor/AppStreamExecutor.java | 0 .../CustomExtendedOperationExecutorImpl.java | 0 .../java/org/dinky/executor/Executor.java | 0 .../org/dinky/executor/ExecutorConfig.java | 0 .../org/dinky/executor/ExecutorFactory.java | 0 .../dinky/executor/LocalBatchExecutor.java | 0 .../dinky/executor/LocalStreamExecutor.java | 0 .../dinky/executor/RemoteBatchExecutor.java | 0 .../dinky/executor/RemoteStreamExecutor.java | 0 .../org/dinky/executor/VariableManager.java | 0 .../dinky/interceptor/FlinkInterceptor.java | 0 .../interceptor/FlinkInterceptorResult.java | 0 .../parser/CreateCDCSourceSqlParser.java | 0 .../java/org/dinky/parser/SetSqlParser.java | 0 .../org/dinky/parser/ShowFragmentParser.java | 0 .../dinky/parser/SingleSqlParserFactory.java | 0 .../main/java/org/dinky/trans/Operation.java | 0 .../main/java/org/dinky/trans/Operations.java | 0 .../java/org/dinky/trans/ddl/CDCSource.java | 0 .../trans/ddl/CreateCDCSourceOperation.java | 0 .../trans/show/ShowFragmentOperation.java | 0 .../trans/show/ShowFragmentsOperation.java | 0 .../java/org/dinky/utils/KerberosUtil.java | 0 .../org.apache.flink.table.factories.Factory | 0 .../dinky/executor/ExecutorConfigTest.java | 0 .../org/dinky/interceptor/CdcSourceTests.java | 0 .../interceptor/FlinkInterceptorTest.java | 0 .../java/org/dinky/parse/SqlTypeTest.java | 0 ...emporalTableFunctionParseStrategyTest.java | 0 dinky-executor/pom.xml | 164 ------------------ pom.xml | 6 - 42 files changed, 49 insertions(+), 181 deletions(-) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/connector/printnet/sink/PrintNetDynamicTableSink.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/connector/printnet/sink/PrintNetDynamicTableSinkFactory.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/connector/printnet/sink/PrintNetSinkFunction.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/constant/FlinkConstant.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/constant/FlinkSQLConstant.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/exception/FlinkException.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/executor/AppBatchExecutor.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/executor/AppStreamExecutor.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/executor/CustomExtendedOperationExecutorImpl.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/executor/Executor.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/executor/ExecutorConfig.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/executor/ExecutorFactory.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/executor/LocalBatchExecutor.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/executor/LocalStreamExecutor.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/executor/RemoteBatchExecutor.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/executor/RemoteStreamExecutor.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/executor/VariableManager.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/interceptor/FlinkInterceptor.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/interceptor/FlinkInterceptorResult.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/parser/CreateCDCSourceSqlParser.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/parser/SetSqlParser.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/parser/ShowFragmentParser.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/parser/SingleSqlParserFactory.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/trans/Operation.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/trans/Operations.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/trans/ddl/CDCSource.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/trans/ddl/CreateCDCSourceOperation.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/trans/show/ShowFragmentOperation.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/trans/show/ShowFragmentsOperation.java (100%) rename {dinky-executor => dinky-core}/src/main/java/org/dinky/utils/KerberosUtil.java (100%) rename {dinky-executor/src/main/resources => dinky-core/src/main/resource}/META-INF/services/org.apache.flink.table.factories.Factory (100%) rename {dinky-executor => dinky-core}/src/test/java/org/dinky/executor/ExecutorConfigTest.java (100%) rename {dinky-executor => dinky-core}/src/test/java/org/dinky/interceptor/CdcSourceTests.java (100%) rename {dinky-executor => dinky-core}/src/test/java/org/dinky/interceptor/FlinkInterceptorTest.java (100%) rename {dinky-executor => dinky-core}/src/test/java/org/dinky/parse/SqlTypeTest.java (100%) rename {dinky-executor => dinky-core}/src/test/java/org/dinky/trans/CreateTemporalTableFunctionParseStrategyTest.java (100%) delete mode 100644 dinky-executor/pom.xml diff --git a/dinky-admin/pom.xml b/dinky-admin/pom.xml index 7de6bf8477..c0db8d5a2d 100644 --- a/dinky-admin/pom.xml +++ b/dinky-admin/pom.xml @@ -194,10 +194,6 @@ com.alibaba.fastjson2 fastjson2 - - org.dinky - dinky-executor - org.dinky dinky-alert-base diff --git a/dinky-admin/src/main/java/org/dinky/service/TaskService.java b/dinky-admin/src/main/java/org/dinky/service/TaskService.java index 8e97456a6f..376503b5e8 100644 --- a/dinky-admin/src/main/java/org/dinky/service/TaskService.java +++ b/dinky-admin/src/main/java/org/dinky/service/TaskService.java @@ -66,8 +66,7 @@ public interface TaskService extends ISuperService { /** * Submit the given task and return the job result. * - * @param id The ID of the task to submit. - * @param savePointPath The path of the save point for the job execution. + * @param submitDto The param of the task to submit. * @return A {@link JobResult} object representing the result of the submitted task. * @throws ExcuteException If there is an error executing the task. */ diff --git a/dinky-app/dinky-app-base/pom.xml b/dinky-app/dinky-app-base/pom.xml index 907b550bdc..24785cd6b9 100644 --- a/dinky-app/dinky-app-base/pom.xml +++ b/dinky-app/dinky-app-base/pom.xml @@ -43,7 +43,7 @@ org.dinky - dinky-executor + dinky-core com.github.xiaoymin diff --git a/dinky-core/pom.xml b/dinky-core/pom.xml index c9deb1f061..b16dd95be2 100644 --- a/dinky-core/pom.xml +++ b/dinky-core/pom.xml @@ -28,16 +28,30 @@ dinky-core jar Dinky : Core - + + 3.1.0 + - + + + org.dinky + dinky-common + + + org.dinky + dinky-cdc-core org.dinky - dinky-executor + dinky-gateway + + + org.dinky + dinky-metadata-base ${scope.runtime} @@ -179,6 +193,36 @@ junit-jupiter test + + org.reflections + reflections + + + org.slf4j + slf4j-log4j12 + test + + + org.apache.hadoop + hadoop-common + ${hadoop.version} + provided + + + com.google.guava + guava + + + javax.servlet + servlet-api + + + + + + org.apache.commons + commons-jexl3 + @@ -230,7 +274,6 @@ dinky-flink-1.14 ${scope.runtime} - org.dinky dinky-client-1.15 diff --git a/dinky-executor/src/main/java/org/dinky/connector/printnet/sink/PrintNetDynamicTableSink.java b/dinky-core/src/main/java/org/dinky/connector/printnet/sink/PrintNetDynamicTableSink.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/connector/printnet/sink/PrintNetDynamicTableSink.java rename to dinky-core/src/main/java/org/dinky/connector/printnet/sink/PrintNetDynamicTableSink.java diff --git a/dinky-executor/src/main/java/org/dinky/connector/printnet/sink/PrintNetDynamicTableSinkFactory.java b/dinky-core/src/main/java/org/dinky/connector/printnet/sink/PrintNetDynamicTableSinkFactory.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/connector/printnet/sink/PrintNetDynamicTableSinkFactory.java rename to dinky-core/src/main/java/org/dinky/connector/printnet/sink/PrintNetDynamicTableSinkFactory.java diff --git a/dinky-executor/src/main/java/org/dinky/connector/printnet/sink/PrintNetSinkFunction.java b/dinky-core/src/main/java/org/dinky/connector/printnet/sink/PrintNetSinkFunction.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/connector/printnet/sink/PrintNetSinkFunction.java rename to dinky-core/src/main/java/org/dinky/connector/printnet/sink/PrintNetSinkFunction.java diff --git a/dinky-executor/src/main/java/org/dinky/constant/FlinkConstant.java b/dinky-core/src/main/java/org/dinky/constant/FlinkConstant.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/constant/FlinkConstant.java rename to dinky-core/src/main/java/org/dinky/constant/FlinkConstant.java diff --git a/dinky-executor/src/main/java/org/dinky/constant/FlinkSQLConstant.java b/dinky-core/src/main/java/org/dinky/constant/FlinkSQLConstant.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/constant/FlinkSQLConstant.java rename to dinky-core/src/main/java/org/dinky/constant/FlinkSQLConstant.java diff --git a/dinky-executor/src/main/java/org/dinky/exception/FlinkException.java b/dinky-core/src/main/java/org/dinky/exception/FlinkException.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/exception/FlinkException.java rename to dinky-core/src/main/java/org/dinky/exception/FlinkException.java diff --git a/dinky-executor/src/main/java/org/dinky/executor/AppBatchExecutor.java b/dinky-core/src/main/java/org/dinky/executor/AppBatchExecutor.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/executor/AppBatchExecutor.java rename to dinky-core/src/main/java/org/dinky/executor/AppBatchExecutor.java diff --git a/dinky-executor/src/main/java/org/dinky/executor/AppStreamExecutor.java b/dinky-core/src/main/java/org/dinky/executor/AppStreamExecutor.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/executor/AppStreamExecutor.java rename to dinky-core/src/main/java/org/dinky/executor/AppStreamExecutor.java diff --git a/dinky-executor/src/main/java/org/dinky/executor/CustomExtendedOperationExecutorImpl.java b/dinky-core/src/main/java/org/dinky/executor/CustomExtendedOperationExecutorImpl.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/executor/CustomExtendedOperationExecutorImpl.java rename to dinky-core/src/main/java/org/dinky/executor/CustomExtendedOperationExecutorImpl.java diff --git a/dinky-executor/src/main/java/org/dinky/executor/Executor.java b/dinky-core/src/main/java/org/dinky/executor/Executor.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/executor/Executor.java rename to dinky-core/src/main/java/org/dinky/executor/Executor.java diff --git a/dinky-executor/src/main/java/org/dinky/executor/ExecutorConfig.java b/dinky-core/src/main/java/org/dinky/executor/ExecutorConfig.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/executor/ExecutorConfig.java rename to dinky-core/src/main/java/org/dinky/executor/ExecutorConfig.java diff --git a/dinky-executor/src/main/java/org/dinky/executor/ExecutorFactory.java b/dinky-core/src/main/java/org/dinky/executor/ExecutorFactory.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/executor/ExecutorFactory.java rename to dinky-core/src/main/java/org/dinky/executor/ExecutorFactory.java diff --git a/dinky-executor/src/main/java/org/dinky/executor/LocalBatchExecutor.java b/dinky-core/src/main/java/org/dinky/executor/LocalBatchExecutor.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/executor/LocalBatchExecutor.java rename to dinky-core/src/main/java/org/dinky/executor/LocalBatchExecutor.java diff --git a/dinky-executor/src/main/java/org/dinky/executor/LocalStreamExecutor.java b/dinky-core/src/main/java/org/dinky/executor/LocalStreamExecutor.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/executor/LocalStreamExecutor.java rename to dinky-core/src/main/java/org/dinky/executor/LocalStreamExecutor.java diff --git a/dinky-executor/src/main/java/org/dinky/executor/RemoteBatchExecutor.java b/dinky-core/src/main/java/org/dinky/executor/RemoteBatchExecutor.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/executor/RemoteBatchExecutor.java rename to dinky-core/src/main/java/org/dinky/executor/RemoteBatchExecutor.java diff --git a/dinky-executor/src/main/java/org/dinky/executor/RemoteStreamExecutor.java b/dinky-core/src/main/java/org/dinky/executor/RemoteStreamExecutor.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/executor/RemoteStreamExecutor.java rename to dinky-core/src/main/java/org/dinky/executor/RemoteStreamExecutor.java diff --git a/dinky-executor/src/main/java/org/dinky/executor/VariableManager.java b/dinky-core/src/main/java/org/dinky/executor/VariableManager.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/executor/VariableManager.java rename to dinky-core/src/main/java/org/dinky/executor/VariableManager.java diff --git a/dinky-executor/src/main/java/org/dinky/interceptor/FlinkInterceptor.java b/dinky-core/src/main/java/org/dinky/interceptor/FlinkInterceptor.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/interceptor/FlinkInterceptor.java rename to dinky-core/src/main/java/org/dinky/interceptor/FlinkInterceptor.java diff --git a/dinky-executor/src/main/java/org/dinky/interceptor/FlinkInterceptorResult.java b/dinky-core/src/main/java/org/dinky/interceptor/FlinkInterceptorResult.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/interceptor/FlinkInterceptorResult.java rename to dinky-core/src/main/java/org/dinky/interceptor/FlinkInterceptorResult.java diff --git a/dinky-executor/src/main/java/org/dinky/parser/CreateCDCSourceSqlParser.java b/dinky-core/src/main/java/org/dinky/parser/CreateCDCSourceSqlParser.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/parser/CreateCDCSourceSqlParser.java rename to dinky-core/src/main/java/org/dinky/parser/CreateCDCSourceSqlParser.java diff --git a/dinky-executor/src/main/java/org/dinky/parser/SetSqlParser.java b/dinky-core/src/main/java/org/dinky/parser/SetSqlParser.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/parser/SetSqlParser.java rename to dinky-core/src/main/java/org/dinky/parser/SetSqlParser.java diff --git a/dinky-executor/src/main/java/org/dinky/parser/ShowFragmentParser.java b/dinky-core/src/main/java/org/dinky/parser/ShowFragmentParser.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/parser/ShowFragmentParser.java rename to dinky-core/src/main/java/org/dinky/parser/ShowFragmentParser.java diff --git a/dinky-executor/src/main/java/org/dinky/parser/SingleSqlParserFactory.java b/dinky-core/src/main/java/org/dinky/parser/SingleSqlParserFactory.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/parser/SingleSqlParserFactory.java rename to dinky-core/src/main/java/org/dinky/parser/SingleSqlParserFactory.java diff --git a/dinky-executor/src/main/java/org/dinky/trans/Operation.java b/dinky-core/src/main/java/org/dinky/trans/Operation.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/trans/Operation.java rename to dinky-core/src/main/java/org/dinky/trans/Operation.java diff --git a/dinky-executor/src/main/java/org/dinky/trans/Operations.java b/dinky-core/src/main/java/org/dinky/trans/Operations.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/trans/Operations.java rename to dinky-core/src/main/java/org/dinky/trans/Operations.java diff --git a/dinky-executor/src/main/java/org/dinky/trans/ddl/CDCSource.java b/dinky-core/src/main/java/org/dinky/trans/ddl/CDCSource.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/trans/ddl/CDCSource.java rename to dinky-core/src/main/java/org/dinky/trans/ddl/CDCSource.java diff --git a/dinky-executor/src/main/java/org/dinky/trans/ddl/CreateCDCSourceOperation.java b/dinky-core/src/main/java/org/dinky/trans/ddl/CreateCDCSourceOperation.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/trans/ddl/CreateCDCSourceOperation.java rename to dinky-core/src/main/java/org/dinky/trans/ddl/CreateCDCSourceOperation.java diff --git a/dinky-executor/src/main/java/org/dinky/trans/show/ShowFragmentOperation.java b/dinky-core/src/main/java/org/dinky/trans/show/ShowFragmentOperation.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/trans/show/ShowFragmentOperation.java rename to dinky-core/src/main/java/org/dinky/trans/show/ShowFragmentOperation.java diff --git a/dinky-executor/src/main/java/org/dinky/trans/show/ShowFragmentsOperation.java b/dinky-core/src/main/java/org/dinky/trans/show/ShowFragmentsOperation.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/trans/show/ShowFragmentsOperation.java rename to dinky-core/src/main/java/org/dinky/trans/show/ShowFragmentsOperation.java diff --git a/dinky-executor/src/main/java/org/dinky/utils/KerberosUtil.java b/dinky-core/src/main/java/org/dinky/utils/KerberosUtil.java similarity index 100% rename from dinky-executor/src/main/java/org/dinky/utils/KerberosUtil.java rename to dinky-core/src/main/java/org/dinky/utils/KerberosUtil.java diff --git a/dinky-executor/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory b/dinky-core/src/main/resource/META-INF/services/org.apache.flink.table.factories.Factory similarity index 100% rename from dinky-executor/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory rename to dinky-core/src/main/resource/META-INF/services/org.apache.flink.table.factories.Factory diff --git a/dinky-executor/src/test/java/org/dinky/executor/ExecutorConfigTest.java b/dinky-core/src/test/java/org/dinky/executor/ExecutorConfigTest.java similarity index 100% rename from dinky-executor/src/test/java/org/dinky/executor/ExecutorConfigTest.java rename to dinky-core/src/test/java/org/dinky/executor/ExecutorConfigTest.java diff --git a/dinky-executor/src/test/java/org/dinky/interceptor/CdcSourceTests.java b/dinky-core/src/test/java/org/dinky/interceptor/CdcSourceTests.java similarity index 100% rename from dinky-executor/src/test/java/org/dinky/interceptor/CdcSourceTests.java rename to dinky-core/src/test/java/org/dinky/interceptor/CdcSourceTests.java diff --git a/dinky-executor/src/test/java/org/dinky/interceptor/FlinkInterceptorTest.java b/dinky-core/src/test/java/org/dinky/interceptor/FlinkInterceptorTest.java similarity index 100% rename from dinky-executor/src/test/java/org/dinky/interceptor/FlinkInterceptorTest.java rename to dinky-core/src/test/java/org/dinky/interceptor/FlinkInterceptorTest.java diff --git a/dinky-executor/src/test/java/org/dinky/parse/SqlTypeTest.java b/dinky-core/src/test/java/org/dinky/parse/SqlTypeTest.java similarity index 100% rename from dinky-executor/src/test/java/org/dinky/parse/SqlTypeTest.java rename to dinky-core/src/test/java/org/dinky/parse/SqlTypeTest.java diff --git a/dinky-executor/src/test/java/org/dinky/trans/CreateTemporalTableFunctionParseStrategyTest.java b/dinky-core/src/test/java/org/dinky/trans/CreateTemporalTableFunctionParseStrategyTest.java similarity index 100% rename from dinky-executor/src/test/java/org/dinky/trans/CreateTemporalTableFunctionParseStrategyTest.java rename to dinky-core/src/test/java/org/dinky/trans/CreateTemporalTableFunctionParseStrategyTest.java diff --git a/dinky-executor/pom.xml b/dinky-executor/pom.xml deleted file mode 100644 index 6990357073..0000000000 --- a/dinky-executor/pom.xml +++ /dev/null @@ -1,164 +0,0 @@ - - - - 4.0.0 - - org.dinky - dinky - ${revision} - ../pom.xml - - dinky-executor - - jar - - Dinky : Executor - - - 3.1.0 - - - - - org.dinky - dinky-common - - - org.dinky - dinky-metadata-base - ${scope.runtime} - - - org.slf4j - slf4j-log4j12 - test - - - org.dinky - dinky-metadata-mysql - test - - - org.reflections - reflections - - - org.apache.hadoop - hadoop-common - ${hadoop.version} - provided - - - com.google.guava - guava - - - javax.servlet - servlet-api - - - - - org.projectlombok - lombok - provided - - - - org.junit.vintage - junit-vintage-engine - test - - - org.assertj - assertj-core - test - - - org.mockito - mockito-core - jar - test - - - org.powermock - powermock-module-junit4 - jar - test - - - org.powermock - powermock-api-mockito2 - jar - test - - - org.mockito - mockito-core - - - - - org.hamcrest - hamcrest-all - jar - test - - - org.testcontainers - junit-jupiter - test - - - org.dinky - dinky-client-${dinky.flink.version} - ${scope.runtime} - - - org.dinky - dinky-flink-${dinky.flink.version} - ${scope.runtime} - - - org.dinky - dinky-cdc-core - - - org.dinky - dinky-gateway - - - org.apache.commons - commons-jexl3 - - - - - - flink-all - - - com.fasterxml.jackson.datatype - jackson-datatype-jsr310 - test - - - - - diff --git a/pom.xml b/pom.xml index a2c35a82a6..4290850f6c 100644 --- a/pom.xml +++ b/pom.xml @@ -38,7 +38,6 @@ dinky-function dinky-metadata dinky-connectors - dinky-executor dinky-extends dinky-alert dinky-daemon @@ -507,11 +506,6 @@ dinky-gateway ${project.version} - - org.dinky - dinky-executor - ${project.version} - org.dinky dinky-client-hadoop