[rocketmq-streams] branch main updated: fix(commons) type inconsistency

[ka...@apache.org]

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

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


The following commit(s) were added to refs/heads/main by this push:
     new 6758976e fix(commons) type inconsistency
     new 27df81c7 Merge pull request #185 from ni-ze/main-type
6758976e is described below

commit 6758976e8f51179dda129151ba1e9dc535ac2292
Author: 维章 <un...@gmail.com>
AuthorDate: Mon Jun 27 11:30:36 2022 +0800

    fix(commons) type inconsistency
---
 .../apache/rocketmq/streams/common/context/UserDefinedMessage.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/context/UserDefinedMessage.java b/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/context/UserDefinedMessage.java
index 1b989fb5..faeedffc 100644
--- a/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/context/UserDefinedMessage.java
+++ b/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/context/UserDefinedMessage.java
@@ -317,12 +317,12 @@ public class UserDefinedMessage extends JSONObject implements Serializable {
     }
 
     @Override
-    public java.sql.Date getSqlDate(String key) {
+    public Object getSqlDate(String key) {
         return super.getSqlDate(key);
     }
 
     @Override
-    public Timestamp getTimestamp(String key) {
+    public Object getTimestamp(String key) {
         return super.getTimestamp(key);
     }