You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by yu...@apache.org on 2022/06/02 08:58:24 UTC

[rocketmq-connect] 07/10: update validate

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

yukon pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git

commit c621ebb96bc961486d51fdb1949777ede732f4e7
Author: zh378814 <wb...@alibaba-inc.com>
AuthorDate: Tue May 31 14:02:36 2022 +0800

    update validate
---
 .../rocketmq/connect/eventbridge/sink/EventBridgeSinkConnector.java      | 1 -
 1 file changed, 1 deletion(-)

diff --git a/connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/EventBridgeSinkConnector.java b/connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/EventBridgeSinkConnector.java
index 7a22997..76899ce 100644
--- a/connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/EventBridgeSinkConnector.java
+++ b/connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/EventBridgeSinkConnector.java
@@ -73,7 +73,6 @@ public class EventBridgeSinkConnector extends SinkConnector {
                 || StringUtils.isBlank(config.getString(EventBridgeConstant.ACCOUNT_ENDPOINT))
                 || StringUtils.isBlank(config.getString(EventBridgeConstant.ROLE_ARN))
                 || StringUtils.isBlank(config.getString(EventBridgeConstant.ROLE_SESSION_NAME))
-                || StringUtils.isBlank(config.getString(EventBridgeConstant.EVENT_TIME))
                 || StringUtils.isBlank(config.getString(EventBridgeConstant.ALIYUN_EVENT_BUS_NAME))
                 || StringUtils.isBlank(config.getString(EventBridgeConstant.STS_ENDPOINT))) {
             throw new RuntimeException("EventBridge required parameter is null !");