This is an automated email from the ASF dual-hosted git repository.
jlfsdtc pushed a commit to branch kylin5
in repository https://gitbox.apache.org/repos/asf/kylin.git
The following commit(s) were added to refs/heads/kylin5 by this push:
new 8a7dee0040 KYLIN-6086 Fix Incorrect Data Range Display on Job Page
8a7dee0040 is described below
commit 8a7dee004087a577d650f967736c75887fe30adf
Author: jlf <[email protected]>
AuthorDate: Tue Dec 2 15:24:42 2025 +0800
KYLIN-6086 Fix Incorrect Data Range Display on Job Page
---
.../org/apache/kylin/rest/service/InternalTableLoadingService.java | 3 ++-
.../java/org/apache/kylin/engine/spark/job/InternalTableLoadJob.java | 3 +--
.../org/apache/kylin/engine/spark/job/InternalTableLoadingJob.java | 3 +--
.../apache/kylin/engine/spark/job/InternalTableUpdateMetadataStep.java | 3 +--
4 files changed, 5 insertions(+), 7 deletions(-)
diff --git
a/src/datasource-service/src/main/java/org/apache/kylin/rest/service/InternalTableLoadingService.java
b/src/datasource-service/src/main/java/org/apache/kylin/rest/service/InternalTableLoadingService.java
index db551f4f5a..211e2c2774 100644
---
a/src/datasource-service/src/main/java/org/apache/kylin/rest/service/InternalTableLoadingService.java
+++
b/src/datasource-service/src/main/java/org/apache/kylin/rest/service/InternalTableLoadingService.java
@@ -82,7 +82,8 @@ public class InternalTableLoadingService extends BasicService
{
logger.info(
"create internal table loading job for table: {},
isIncrementBuild: {}, startTime: {}, endTime: {}",
internalTable.getIdentity(), isIncremental, startDate,
endDate);
- String partitionValues = null == partitions ? "" :
Arrays.toString(partitions);
+ String partitionValues = null == partitions ? ""
+ : Arrays.toString(partitions).replace("[",
"").replace("]", "");
JobParam jobParam = new
JobParam().withProject(project).withTable(internalTable.getIdentity())
.withYarnQueue(yarnQueue).withJobTypeEnum(jobType).withOwner(BasicService.getUsername())
.addExtParams(NBatchConstants.P_INCREMENTAL_BUILD,
String.valueOf(isIncremental))
diff --git
a/src/spark-project/engine-spark/src/main/java/org/apache/kylin/engine/spark/job/InternalTableLoadJob.java
b/src/spark-project/engine-spark/src/main/java/org/apache/kylin/engine/spark/job/InternalTableLoadJob.java
index a6347ae760..1e3ae2cf29 100644
---
a/src/spark-project/engine-spark/src/main/java/org/apache/kylin/engine/spark/job/InternalTableLoadJob.java
+++
b/src/spark-project/engine-spark/src/main/java/org/apache/kylin/engine/spark/job/InternalTableLoadJob.java
@@ -72,8 +72,7 @@ public class InternalTableLoadJob extends SparkApplication {
boolean incrementalBuild =
"true".equals(getParam(NBatchConstants.P_INCREMENTAL_BUILD));
String startDate = getParam(NBatchConstants.P_START_DATE);
String endDate = getParam(NBatchConstants.P_END_DATE);
- String refreshPartitions =
getParam(NBatchConstants.P_REFRESH_PARTITION_VALUES).replace("[",
"").replace("]",
- "");
+ String refreshPartitions =
getParam(NBatchConstants.P_REFRESH_PARTITION_VALUES);
String[] partitions = new String[] {};
if (StringUtils.isNotEmpty(refreshPartitions)) {
partitions = StringUtils.isEmpty(refreshPartitions) ? new String[]
{} : refreshPartitions.split(", ");
diff --git
a/src/spark-project/engine-spark/src/main/java/org/apache/kylin/engine/spark/job/InternalTableLoadingJob.java
b/src/spark-project/engine-spark/src/main/java/org/apache/kylin/engine/spark/job/InternalTableLoadingJob.java
index 3a5ad9973d..ae4747b22e 100644
---
a/src/spark-project/engine-spark/src/main/java/org/apache/kylin/engine/spark/job/InternalTableLoadingJob.java
+++
b/src/spark-project/engine-spark/src/main/java/org/apache/kylin/engine/spark/job/InternalTableLoadingJob.java
@@ -113,8 +113,7 @@ public class InternalTableLoadingJob extends
DefaultExecutableOnTable {
String tableName = getParam(NBatchConstants.P_TABLE_NAME);
String startDate = getParam(NBatchConstants.P_START_DATE);
String endDate = getParam(NBatchConstants.P_END_DATE);
- String refreshPartitions =
getParam(NBatchConstants.P_REFRESH_PARTITION_VALUES).replace("[", "")
- .replace("]", "");
+ String refreshPartitions =
getParam(NBatchConstants.P_REFRESH_PARTITION_VALUES);
boolean isIncremental =
"true".equals(getParam(NBatchConstants.P_INCREMENTAL_BUILD));
InternalTablePartition tablePartition =
internalTable.getTablePartition();
// merge latest partition_range
diff --git
a/src/spark-project/engine-spark/src/main/java/org/apache/kylin/engine/spark/job/InternalTableUpdateMetadataStep.java
b/src/spark-project/engine-spark/src/main/java/org/apache/kylin/engine/spark/job/InternalTableUpdateMetadataStep.java
index da5d1cbd69..e0903937dd 100644
---
a/src/spark-project/engine-spark/src/main/java/org/apache/kylin/engine/spark/job/InternalTableUpdateMetadataStep.java
+++
b/src/spark-project/engine-spark/src/main/java/org/apache/kylin/engine/spark/job/InternalTableUpdateMetadataStep.java
@@ -94,8 +94,7 @@ public class InternalTableUpdateMetadataStep extends
AbstractExecutable {
String project = getParam(NBatchConstants.P_PROJECT_NAME);
String startDate = getParam(NBatchConstants.P_START_DATE);
String endDate = getParam(NBatchConstants.P_END_DATE);
- String refreshPartitions =
getParam(NBatchConstants.P_REFRESH_PARTITION_VALUES).replace("[", "")
- .replace("]", "");
+ String refreshPartitions =
getParam(NBatchConstants.P_REFRESH_PARTITION_VALUES);
boolean isIncremental =
"true".equals(getParam(NBatchConstants.P_INCREMENTAL_BUILD));
// fetch delta partition info
InternalTableManager internalTableManager =
InternalTableManager.getInstance(config, project);
