diff --git a/src/datasource-service/src/main/java/org/apache/kylin/rest/service/InternalTableService.java b/src/datasource-service/src/main/java/org/apache/kylin/rest/service/InternalTableService.java index 23980b506fe..c474672c3fb 100644 --- a/src/datasource-service/src/main/java/org/apache/kylin/rest/service/InternalTableService.java +++ b/src/datasource-service/src/main/java/org/apache/kylin/rest/service/InternalTableService.java @@ -223,7 +223,7 @@ public void updateInternalTable(String project, String table, String database, S internalTable.setTblProperties(tblProperties); internalTable.optimizeTblProperties(); internalTable.setStorageType(storageType); - suicideRunningInternalTableJob(project, table); + suicideRunningInternalTableJob(project, dbTblName); deleteMetaAndDataInFileSystem(internalTable); createDeltaSchema(internalTable); internalTableManager.saveOrUpdateInternalTable(internalTable);