Make exception message more clear

apache · Jul 15, 2024 · d5daaff · d5daaff
1 parent 684bfa3
commit d5daaff
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/.../paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkSourceBuilder.java b/.../paimon-flink-common/src/main/java/org/apache/paimon/flink/source/FlinkSourceBuilder.java
@@ -250,11 +250,12 @@ public DataStream<RowData> build() {
         if (env == null) {
             throw new IllegalArgumentException("StreamExecutionEnvironment should not be null.");
         }
-
         if (conf.contains(CoreOptions.CONSUMER_ID)
                 && !conf.contains(CoreOptions.CONSUMER_EXPIRATION_TIME)) {
-            throw new IllegalArgumentException("consumer.expiration-time should be specified.");
+            throw new IllegalArgumentException(
+                    "consumer.expiration-time should be specified when using consumer-id.");
         }
+
         if (sourceBounded) {
             return buildStaticFileSource();
         }