[Fix][Engine] Fix error data sink bug in local engine

datavane · Nov 28, 2023 · 5da3b38 · 5da3b38
1 parent 2196102
commit 5da3b38
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...-config/src/main/java/io/datavines/engine/local/config/LocalSingleTableMetricBuilder.java b/...-config/src/main/java/io/datavines/engine/local/config/LocalSingleTableMetricBuilder.java
@@ -76,10 +76,9 @@ public void buildSinkConfigs() throws DataVinesException {
                     errorDataSinkConfig.setType(SinkType.ERROR_DATA.getDescription());
 
                     Map<String, Object> connectorParameterMap = new HashMap<>(JSONUtils.toMap(jobExecutionInfo.getErrorDataStorageParameter(),String.class, Object.class));
-                    ConnectorParameter connectorParameter = jobExecutionParameter.getConnectorParameter();
                     ConnectorFactory connectorFactory = PluginLoader
                             .getPluginLoader(ConnectorFactory.class)
-                            .getNewPlugin(connectorParameter.getType());
+                            .getNewPlugin(jobExecutionInfo.getErrorDataStorageType());
 
                     if (connectorFactory == null) {
                         return;