INSERT INTO `obpm2`.`flink_jobs`(`id`, `name`, `job_type`, `parameter_json`, `description`, `is_online`, `last_updated_time`, `created_time`, `flink_job_id`, `flink_job_started_time`, `flink_job_started_response`, `title`, `is_deleted`) VALUES (194, '简化版本-CheckPoint-同步企业到子站到调度平台-3.0', 2, '{\r\n  \"param1\": \"{\\\"job.name\\\":\\\"简化版本-CheckPoint-同步企业到子站到调度平台-3.0\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/cp-consume-tlkcompany-tenant-users-employees-data\\\"}\",\r\n  \"param2\": \"{\\n  \\\"name\\\": \\\"WebHookAPI演示\\\",\\n  \\\"topicDefinition\\\": {\\n    \\\"name\\\": \\\"cp-dispatch\\\",\\n    \\\"topic\\\": \\\"\\\",\\n    \\\"consumerGroupId\\\": \\\"dispatch.webhook.api\\\",\\n    \\\"enableAutoCommit\\\": true,\\n    \\\"scanStartupMode\\\": \\\"group-offsets\\\",\\n    \\\"primaryKeyName\\\": \\\"ID\\\",\\n    \\\"autoOffsetRest\\\": \\\"earliest\\\",\\n    \\\"bootstrapServer\\\": \\\"117.78.39.204:9092\\\"\\n  },\\n  \\\"webHookConfigs\\\": [\\n    {\\n      \\\"title\\\": \\\"同步企业信息到RedisJson\\\",\\n      \\\"topic\\\": \\\"dispatch.binlog-cdc.topic.rd_company_summary\\\",\\n      \\\"apiDefinition\\\": {\\n        \\\"api\\\": \\\"https://v5qy.te.baibaodun.com.cn/v2/dispatch/flush/request\\\",\\n        \\\"method\\\": \\\"POST\\\",\\n        \\\"isBodyCollection\\\": true,\\n        \\\"bodyJsonTemplate\\\": \\\"{\\\\\\\"contents\\\\\\\":[{\\\\\\\"ids\\\\\\\":[\\\\\\\"#{after.id}\\\\\\\"],\\\\\\\"dataType\\\\\\\":\\\\\\\"Company\\\\\\\"}]}\\\",\\n        \\\"headerJsonTemplate\\\": \\\"{\\\\\\\"Content-Type\\\\\\\":\\\\\\\"application/json\\\\\\\"}\\\"\\n      }\\n    }\\n  ]\\n}\"\r\n}', 'flink从obpm2+baibaodunflow的binlog捕获数据推到kafka', 1, '2023-04-19 18:34:00', '2023-03-05 20:21:59', NULL, NULL, NULL, 'xxxx', 0);