(paimon) branch master updated: [hotfix] Fix failed tests in CatalogTableITCase about consumer expiration

[czweng]

This is an automated email from the ASF dual-hosted git repository.

czweng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 2d05f1acb [hotfix] Fix failed tests in CatalogTableITCase about 
consumer expiration
2d05f1acb is described below

commit 2d05f1acb1c9bf3b23972d528b1d97fc090c45b8
Author: tsreaper <tsreape...@gmail.com>
AuthorDate: Mon Jul 15 14:52:57 2024 +0800

    [hotfix] Fix failed tests in CatalogTableITCase about consumer expiration
---
 .../src/test/java/org/apache/paimon/flink/CatalogTableITCase.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/CatalogTableITCase.java
 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/CatalogTableITCase.java
index a9ce8135b..cb39ae3c0 100644
--- 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/CatalogTableITCase.java
+++ 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/CatalogTableITCase.java
@@ -767,7 +767,7 @@ public class CatalogTableITCase extends CatalogITCaseBase {
                                         "SELECT * FROM T /*+ 
OPTIONS('consumer-id' = 'test-id') */ WHERE a = 1"))
                 .rootCause()
                 .isInstanceOf(IllegalArgumentException.class)
-                .hasMessage("consumer.expiration-time should be specified.");
+                .hasMessage("consumer.expiration-time should be specified when 
using consumer-id.");
     }
 
     @Test
@@ -780,7 +780,7 @@ public class CatalogTableITCase extends CatalogITCaseBase {
                                 streamSqlIter(
                                         "SELECT * FROM T /*+ 
OPTIONS('consumer-id'='test-id') */"))
                 .isInstanceOf(IllegalArgumentException.class)
-                .hasMessage("consumer.expiration-time should be specified.");
+                .hasMessage("consumer.expiration-time should be specified when 
using consumer-id.");
     }
 
     @Test