This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new b6c0603e0dd [fix](mtmv)Fix show mtmv time should wrapped in double
quotation mark… (#41501)
b6c0603e0dd is described below
commit b6c0603e0dd947680a3f64233f8af266c942d6e5
Author: zhangdong <493738...@qq.com>
AuthorDate: Wed Oct 9 12:19:28 2024 +0800
[fix](mtmv)Fix show mtmv time should wrapped in double quotation mark…
(#41501)
pick: https://github.com/apache/doris/pull/41419
---
.../org/apache/doris/mtmv/MTMVRefreshSchedule.java | 3 ++-
.../test/java/org/apache/doris/mtmv/MTMVTest.java | 2 +-
.../suites/mtmv_p0/test_show_create_mtmv.groovy | 23 ++++++++++++++++++++++
3 files changed, 26 insertions(+), 2 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVRefreshSchedule.java
b/fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVRefreshSchedule.java
index 17123a3235e..da873ea968c 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVRefreshSchedule.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVRefreshSchedule.java
@@ -93,8 +93,9 @@ public class MTMVRefreshSchedule {
builder.append(" ");
builder.append(timeUnit);
if (!StringUtils.isEmpty(startTime)) {
- builder.append(" STARTS ");
+ builder.append(" STARTS \"");
builder.append(startTime);
+ builder.append("\"");
}
return builder.toString();
}
diff --git a/fe/fe-core/src/test/java/org/apache/doris/mtmv/MTMVTest.java
b/fe/fe-core/src/test/java/org/apache/doris/mtmv/MTMVTest.java
index 64f0958beb8..37493e88e54 100644
--- a/fe/fe-core/src/test/java/org/apache/doris/mtmv/MTMVTest.java
+++ b/fe/fe-core/src/test/java/org/apache/doris/mtmv/MTMVTest.java
@@ -49,7 +49,7 @@ public class MTMVTest {
@Test
public void testToInfoString() {
String expect
- = "MTMV{refreshInfo=BUILD IMMEDIATE REFRESH COMPLETE ON
SCHEDULE EVERY 2 SECOND STARTS ss, "
+ = "MTMV{refreshInfo=BUILD IMMEDIATE REFRESH COMPLETE ON
SCHEDULE EVERY 2 SECOND STARTS \"ss\", "
+ "querySql='select * from xxx;', "
+ "status=MTMVStatus{state=INIT, schemaChangeDetail='null',
refreshState=INIT}, "
+ "envInfo=EnvInfo{ctlId='1', dbId='2'}, "
diff --git a/regression-test/suites/mtmv_p0/test_show_create_mtmv.groovy
b/regression-test/suites/mtmv_p0/test_show_create_mtmv.groovy
index 34cda2f6ffd..eb4fd44160f 100644
--- a/regression-test/suites/mtmv_p0/test_show_create_mtmv.groovy
+++ b/regression-test/suites/mtmv_p0/test_show_create_mtmv.groovy
@@ -99,6 +99,29 @@ suite("test_show_create_mtmv","mtmv") {
assertTrue(showCreateMTMVResult.toString().contains("BUILD IMMEDIATE
REFRESH COMPLETE ON COMMIT"))
assertTrue(showCreateMTMVResult.toString().contains("DISTRIBUTED BY RANDOM
BUCKETS AUTO"))
+
+ sql """drop materialized view if exists ${mvName};"""
+ sql """
+ CREATE MATERIALIZED VIEW ${mvName}
+ BUILD DEFERRED REFRESH AUTO ON SCHEDULE EVERY 10 DAY starts
"9999-01-01 10:10:10"
+ partition by (`k2`)
+ DISTRIBUTED BY hash(k1) BUCKETS 2
+ PROPERTIES (
+ 'replication_num' = '1'
+ )
+ AS
+ SELECT * FROM ${tableName};
+ """
+ showCreateMTMVResult = sql """show CREATE MATERIALIZED VIEW ${mvName}"""
+ logger.info("showCreateMTMVResult: " + showCreateMTMVResult.toString())
+ sql """drop materialized view if exists ${mvName};"""
+ sql """
+ ${showCreateMTMVResult[0][1]}
+ """
+ def showCreateMTMVResultAgain = sql """show CREATE MATERIALIZED VIEW
${mvName}"""
+ logger.info("showCreateMTMVAgainResult: " +
showCreateMTMVResultAgain.toString())
+ assertEquals(showCreateMTMVResult.toString(),
showCreateMTMVResultAgain.toString())
+
sql """drop table if exists `${tableName}`"""
sql """drop materialized view if exists ${mvName};"""
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
