This is an automated email from the ASF dual-hosted git repository.
liaoxin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 311e1d39ce2 [chore](information schema) rename routine_load_job system
table to routine_load_jobs (#49515)
311e1d39ce2 is described below
commit 311e1d39ce2f316e39bb6a815ca9da8f36516b4e
Author: hui lai <lai...@selectdb.com>
AuthorDate: Thu Mar 27 09:52:38 2025 +0800
[chore](information schema) rename routine_load_job system table to
routine_load_jobs (#49515)
---
be/src/exec/schema_scanner.cpp | 2 +-
be/src/exec/schema_scanner/schema_routine_load_job_scanner.cpp | 2 +-
.../src/main/java/org/apache/doris/analysis/SchemaTableType.java | 4 ++--
fe/fe-core/src/main/java/org/apache/doris/catalog/SchemaTable.java | 4 ++--
gensrc/thrift/Descriptors.thrift | 2 +-
.../routine_load/test_routine_load_job_info_system_table.groovy | 2 +-
6 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/be/src/exec/schema_scanner.cpp b/be/src/exec/schema_scanner.cpp
index 40b0616c9a5..0940eadb495 100644
--- a/be/src/exec/schema_scanner.cpp
+++ b/be/src/exec/schema_scanner.cpp
@@ -229,7 +229,7 @@ std::unique_ptr<SchemaScanner>
SchemaScanner::create(TSchemaTableType::type type
return SchemaCatalogMetaCacheStatsScanner::create_unique();
case TSchemaTableType::SCH_BACKEND_KERBEROS_TICKET_CACHE:
return SchemaBackendKerberosTicketCacheScanner::create_unique();
- case TSchemaTableType::SCH_ROUTINE_LOAD_JOB:
+ case TSchemaTableType::SCH_ROUTINE_LOAD_JOBS:
return SchemaRoutineLoadJobScanner::create_unique();
default:
return SchemaDummyScanner::create_unique();
diff --git a/be/src/exec/schema_scanner/schema_routine_load_job_scanner.cpp
b/be/src/exec/schema_scanner/schema_routine_load_job_scanner.cpp
index e061ab790cf..11f5fb376bc 100644
--- a/be/src/exec/schema_scanner/schema_routine_load_job_scanner.cpp
+++ b/be/src/exec/schema_scanner/schema_routine_load_job_scanner.cpp
@@ -59,7 +59,7 @@ std::vector<SchemaScanner::ColumnDesc>
SchemaRoutineLoadJobScanner::_s_tbls_colu
};
SchemaRoutineLoadJobScanner::SchemaRoutineLoadJobScanner()
- : SchemaScanner(_s_tbls_columns,
TSchemaTableType::SCH_ROUTINE_LOAD_JOB) {}
+ : SchemaScanner(_s_tbls_columns,
TSchemaTableType::SCH_ROUTINE_LOAD_JOBS) {}
SchemaRoutineLoadJobScanner::~SchemaRoutineLoadJobScanner() {}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/SchemaTableType.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/SchemaTableType.java
index 5c5bdeb832c..7bb9e44412a 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/SchemaTableType.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/SchemaTableType.java
@@ -91,8 +91,8 @@ public enum SchemaTableType {
TSchemaTableType.SCH_CATALOG_META_CACHE_STATISTICS),
SCH_BACKEND_KERBEROS_TICKET_CACHE("BACKEND_KERBEROS_TICKET_CACHE",
"BACKEND_KERBEROS_TICKET_CACHE",
TSchemaTableType.SCH_BACKEND_KERBEROS_TICKET_CACHE),
- SCH_ROUTINE_LOAD_JOB("ROUTINE_LOAD_JOB", "ROUTINE_LOAD_JOB",
- TSchemaTableType.SCH_ROUTINE_LOAD_JOB);
+ SCH_ROUTINE_LOAD_JOBS("ROUTINE_LOAD_JOBS", "ROUTINE_LOAD_JOBS",
+ TSchemaTableType.SCH_ROUTINE_LOAD_JOBS);
private static final String dbName = "INFORMATION_SCHEMA";
private static SelectList fullSelectLists;
diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/SchemaTable.java
b/fe/fe-core/src/main/java/org/apache/doris/catalog/SchemaTable.java
index 36992833639..e358f9566f0 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/catalog/SchemaTable.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/SchemaTable.java
@@ -597,8 +597,8 @@ public class SchemaTable extends Table {
.column("REFRESH_INTERVAL_SECOND",
ScalarType.createType(PrimitiveType.BIGINT))
.build())
)
- .put("routine_load_job",
- new SchemaTable(SystemIdGenerator.getNextId(),
"routine_load_job", TableType.SCHEMA,
+ .put("routine_load_jobs",
+ new SchemaTable(SystemIdGenerator.getNextId(),
"routine_load_jobs", TableType.SCHEMA,
builder().column("JOB_ID",
ScalarType.createStringType())
.column("JOB_NAME",
ScalarType.createStringType())
.column("CREATE_TIME",
ScalarType.createStringType())
diff --git a/gensrc/thrift/Descriptors.thrift b/gensrc/thrift/Descriptors.thrift
index 502246052da..3a50a36c28d 100644
--- a/gensrc/thrift/Descriptors.thrift
+++ b/gensrc/thrift/Descriptors.thrift
@@ -140,7 +140,7 @@ enum TSchemaTableType {
SCH_FILE_CACHE_STATISTICS = 51,
SCH_CATALOG_META_CACHE_STATISTICS = 52,
SCH_BACKEND_KERBEROS_TICKET_CACHE = 53,
- SCH_ROUTINE_LOAD_JOB = 54;
+ SCH_ROUTINE_LOAD_JOBS = 54;
}
enum THdfsCompression {
diff --git
a/regression-test/suites/load_p0/routine_load/test_routine_load_job_info_system_table.groovy
b/regression-test/suites/load_p0/routine_load/test_routine_load_job_info_system_table.groovy
index 3fa360bf281..bfe170b7520 100644
---
a/regression-test/suites/load_p0/routine_load/test_routine_load_job_info_system_table.groovy
+++
b/regression-test/suites/load_p0/routine_load/test_routine_load_job_info_system_table.groovy
@@ -131,7 +131,7 @@ suite("test_routine_load_job_info_system_table","p0") {
sleep(1000)
count++
}
- def res = sql "SELECT JOB_NAME FROM
information_schema.routine_load_job WHERE CURRENT_ABORT_TASK_NUM > 0 OR
IS_ABNORMAL_PAUSE = TRUE"
+ def res = sql "SELECT JOB_NAME FROM
information_schema.routine_load_jobs WHERE CURRENT_ABORT_TASK_NUM > 0 OR
IS_ABNORMAL_PAUSE = TRUE"
log.info("res: ${res}".toString())
assertTrue(res.toString().contains("${jobName}"))
} finally {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
