env {
  execution.parallelism = 1
  job.mode = "STREAMING"
  checkpoint.interval = 2000
  #execution.checkpoint.interval = 10000
  #execution.checkpoint.data-uri = "hdfs://localhost:9000/checkpoint"
}

source {
  MySQL-CDC{
    result_table_name = "mysqlcdc"
    server-id = 5656
    username = "root"
    password = "root"
    table-names = ["test_db.blade_log_usual"]
    base-url = "jdbc:mysql://localhost:33066/test_db"
    server-time-zone = "Asia/Shanghai"
    debezium = {
      column.truncate.to.2000.chars = "test_db.blade_log_usual.params,test_db.blade_log_usual.log_data"
      include.schema.changes = true
    }
  }
}

sink {
  Jdbc {
    source_table_name = ["mysqlcdc"]
    url = "jdbc:oracle:thin:@121.204.249.37:1521/helowin"
    driver = "oracle.jdbc.OracleDriver"
    user = "YYOS2"
    password = "R68PNA-4LRTWl~BmGwh"
    query = "insert into ODS_BLADE_LOG_USUAL(ID, TENANT_ID, SERVICE_ID, SERVER_HOST, SERVER_IP, ENV, LOG_LEVEL, LOG_ID, LOG_DATA, METHOD, REQUEST_URI, REMOTE_IP, METHOD_CLASS, METHOD_NAME, USER_AGENT, PARAMS, CREATE_BY, CREATE_TIME) values(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"
    batch_size = 1000
  }
}
