[Bug]: MongoDB写入starrocks报错

[beat4ocean]

What happened?

addax v4.1.4

当读取mongodb 写入 starrocks：

{
  "job": {
    "setting": {
      "speed": {
        "channel": 3,
        "byte": 1048576
      },
      "errorLimit": {
        "record": 0,
        "percentage": 0.02
      }
    },
    "content": [
      {
        "reader": {
          "name": "mongodbreader",
          "parameter": {
            "connection": {
              "address": [
                "10.81.14.17:20001"
              ],
              "database": "database",
              "collection": "collection",
              "authDb": "admin"
            },
            "username": "username",
            "password": "password",
            "column": [
              {
                "name": "_id",
                "type": "ObjectId"
              },
              {
                "name": "APP_ID",
                "type": "Integer"
              }
            ]
          }
        },
        "writer": {
          "name": "starrockswriter",
          "parameter": {
            "username": "root",
            "password": "password",
            "database": "database",
            "table": "table",
            "column": [
              "`_id`",
              "`app_id`"
            ],
            "jdbcUrl": "jdbc:mysql://172.31.10.40:6033/",
            "loadUrl": [
              "172.31.10.40:8030"
            ],
            "loadProps": {
              "column_separator": "\\x01",
              "row_delimiter": "\\x02"
            }
          }
        }
      }
    ]
  }
}

执行报错

Version

4.1.3 (Default)

OS Type

Linux (Default)

Java JDK Version

Oracle JDK 1.8.0

Relevant log output

Caused by: java.lang.ClassCastException: com.alibaba.fastjson2.JSONObject cannot be cast to java.util.List
	at com.wgzhao.addax.common.util.Configuration.getList(Configuration.java:515)
	at com.wgzhao.addax.plugin.reader.mongodbreader.MongoDBReader$Job.init(MongoDBReader.java:91)
	at com.wgzhao.addax.core.job.JobContainer.initJobReader(JobContainer.java:588)
	at com.wgzhao.addax.core.job.JobContainer.init(JobContainer.java:265)
	at com.wgzhao.addax.core.job.JobContainer.start(JobContainer.java:122)
	... 3 more

[beat4ocean]

mongodbreader 这样写一样报错：
"column": [
"_id",
"APP_ID"
]

读取mysql 到 starrocks是正常的

[wgzhao]

json 文件不正确， connection 对应的值应该是列表，而不是字典，应该写成这样：

"connection": [{
  "address": [ "10.81.14.17:20001"],
  "database": "database",
   "collection": "collection",
  "authDb": "admin"
}],

具体可以参考 https://wgzhao.github.io/Addax/develop/reader/mongodbreader/