(rocketmq-flink) branch main updated: [ISSUE #101] Fix bug, the optional param 'startup.offset.timestamp' is not set, a NPE will be thrown. (#102)

[lizhimin]

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

lizhimin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git


The following commit(s) were added to refs/heads/main by this push:
     new 48e88d7  [ISSUE #101] Fix bug, the optional param 
'startup.offset.timestamp' is not set, a NPE will be thrown. (#102)
48e88d7 is described below

commit 48e88d7b471bf430278f469f37327ea3428cbb5c
Author: leosanqing <liurongtong...@qq.com>
AuthorDate: Wed Nov 15 17:48:24 2023 +0800

    [ISSUE #101] Fix bug, the optional param 'startup.offset.timestamp' is not 
set, a NPE will be thrown. (#102)
---
 .../apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java
 
b/src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java
index 85eb71b..22992fd 100644
--- 
a/src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java
+++ 
b/src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSourceOptions.java
@@ -86,7 +86,7 @@ public class RocketMQSourceOptions extends RocketMQOptions {
     public static final ConfigOption<Long> OPTIONAL_STARTUP_OFFSET_TIMESTAMP =
             ConfigOptions.key(CONSUMER_PREFIX + "startup.offset.timestamp")
                     .longType()
-                    .noDefaultValue();
+                    .defaultValue(RocketMQConfig.DEFAULT_START_MESSAGE_OFFSET);
 
     public static final ConfigOption<String> OPTIONAL_STOP_OFFSET_TIMESTAMP =
             ConfigOptions.key(CONSUMER_PREFIX + "stop.offset.timestamp")