flinkx????????????????

[??????]

??
??2021??flinkx??
flnkx??jsonbegin1??end1begin2??reader??end2??writer??

{
"job": {
    "content": [
      {
        "reader": {
          "parameter": {
            "username": "root",
            "password": "123456",
            "connection": [{
              "jdbcUrl": 
["jdbc:mysql://localhost:3306/flinkx1?useUnicode=true&characterEncoding=utf8"],
              "table": ["begin1","begin2"]
            }],
            "column": [
                {
                "name": "id",
                "type": "int"
                },
                {
                "name": "name",
                "type": "varchar"
                }
            ],
            "customSql": "",
            "splitPk": "id",
            "queryTimeOut": 1000,
            "requestAccumulatorInterval": 2,
            "increColumn": "id",
            "startLocation": ""
          },
          "name": "mysqlreader"
        },
"writer": {
          "name": "mysqlwriter",
          "parameter": {
            "username": "root",
            "password": "123456",
            "connection": [
              {
                "jdbcUrl": 
"jdbc:mysql://localhost:3306/flinkx1?useUnicode=true&characterEncoding=utf8",
                "table": ["end1","end2"]
              }
            ],
            "writeMode": "insert",
            "column": [

           {
                "name": "id",
                "type": "int"
                },
                {
                "name": "name",
                "type": "varchar"
                }
            ],
            "batchSize": 1024
          }
        }
      }
    ],
    "setting": {
      "speed": {
        "channel": 2,
        "bytes": 1000
      },
      "errorLimit": {
        "record": 0
      },
      "restore": {
        "maxRowNumForCheckpoint": 0,
        "isRestore": false,
        "restoreColumnName": "",
        "restoreColumnIndex": 0
      },
      "log" : {
        "isLogger": false,
        "level" : "debug",
        "path" : " /data/flinkx/flinkxconf/log/",
        "pattern":""
      }
    }
  }
}

flinkx????????

[??????]

??
??2021??flinkx??
flnkx??jsonbegin1??end1begin2??reader??end2??writer??

{
"job": {
    "content": [
      {
        "reader": {
          "parameter": {
            "username": "root",
            "password": "123456",
            "connection": [{
              "jdbcUrl": 
["jdbc:mysql://localhost:3306/flinkx1?useUnicode=true&characterEncoding=utf8"],
              "table": ["begin1","begin2"]
            }],
            "column": [
                {
                "name": "id",
                "type": "int"
                },
                {
                "name": "name",
                "type": "varchar"
                }
            ],
            "customSql": "",
            "splitPk": "id",
            "queryTimeOut": 1000,
            "requestAccumulatorInterval": 2,
            "increColumn": "id",
            "startLocation": ""
          },
          "name": "mysqlreader"
        },
"writer": {
          "name": "mysqlwriter",
          "parameter": {
            "username": "root",
            "password": "123456",
            "connection": [
              {
                "jdbcUrl": 
"jdbc:mysql://localhost:3306/flinkx1?useUnicode=true&characterEncoding=utf8",
                "table": ["end1","end2"]
              }
            ],
            "writeMode": "insert",
            "column": [

           {
                "name": "id",
                "type": "int"
                },
                {
                "name": "name",
                "type": "varchar"
                }
            ],
            "batchSize": 1024
          }
        }
      }
    ],
    "setting": {
      "speed": {
        "channel": 2,
        "bytes": 1000
      },
      "errorLimit": {
        "record": 0
      },
      "restore": {
        "maxRowNumForCheckpoint": 0,
        "isRestore": false,
        "restoreColumnName": "",
        "restoreColumnIndex": 0
      },
      "log" : {
        "isLogger": false,
        "level" : "debug",
        "path" : " /data/flinkx/flinkxconf/log/",
        "pattern":""
      }
    }
  }
}