[incubator-seatunnel] branch dev updated: [Hotfix] [Canal] Fix CanalJsonFormatFactory Code not Update (#4070)

[wanghailin]

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

wanghailin pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 7ebb909d7 [Hotfix] [Canal] Fix CanalJsonFormatFactory Code not Update 
(#4070)
7ebb909d7 is described below

commit 7ebb909d76e96569af6f6512c44813ecf436f1b7
Author: Hisoka <fanjiaemi...@qq.com>
AuthorDate: Tue Feb 7 10:57:40 2023 +0800

    [Hotfix] [Canal] Fix CanalJsonFormatFactory Code not Update (#4070)
---
 .../org/apache/seatunnel/format/json/canal/CanalJsonFormatFactory.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/canal/CanalJsonFormatFactory.java
 
b/seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/canal/CanalJsonFormatFactory.java
index b2d817ba7..7ce2656a7 100644
--- 
a/seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/canal/CanalJsonFormatFactory.java
+++ 
b/seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/canal/CanalJsonFormatFactory.java
@@ -62,7 +62,7 @@ public class CanalJsonFormatFactory
 
     @Override
     public DeserializationFormat 
createDeserializationFormat(TableFactoryContext context) {
-        Map<String, String> options = context.getOptions();
+        Map<String, String> options = context.getOptions().toMap();
         boolean ignoreParseErrors = 
CanalJsonFormatOptions.getIgnoreParseErrors(options);
         String  databaseInclude = 
CanalJsonFormatOptions.getDatabaseInclude(options);
         String  tableInclude = CanalJsonFormatOptions.getTableInclude(options);