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 (67, '捕获obpm.tenant_users-tenant-employees-baibaodunflow-tlkcompanyinformation及驻勤信息 kafka', 0, '{\n  \"param1\": \"{\\\"job.name\\\":\\\"捕获obpm.tenant_users-tenant-employees-baibaodunflow-tlkcompanyinformation及驻勤信息到kafka\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/cdc-obpm2-baibaodunflow\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"kafka.bootstrap.server\\\":\\\"117.78.39.204:9092\\\",\\\"kafka.cdc.topic.prefix\\\":\\\"[dbName].binlog-cdc.topic.data.[tableName]\\\",\\\"kafka.consumer.group.id\\\":\\\"cdc-binlog-flink-kafka-events\\\"}\",\n  \"param2\": \"{\\\"source.name\\\":\\\"mysql-cdc-flink-source\\\",\\\"source.database.host\\\":\\\"49.4.21.141\\\",\\\"source.database.port\\\":\\\"2111\\\",\\\"source.database.username\\\":\\\"bcx\\\",\\\"source.database.password\\\":\\\"Wstestv5qy#2022\\\",\\\"source.database.connectionTimeZone\\\":\\\"GMT+8\\\",\\\"source.database.serverId\\\":\\\"6001-6200\\\",\\\"source.database.connectTimeout\\\":\\\"60000\\\",\\\"source.database.db.list\\\":\\\"obpm2;baibaodunflow;\\\",\\\"source.database.table.list\\\":\\\"obpm2.tenant_users;obpm2.tenant_user_credentials;obpm2.tenant_employees;obpm2.tenant_organizations;obpm2.tenant_departments;baibaodunflow.TLK_COMPANYINFORMATION;baibaodunflow.TLK_ATTENDANCE_SITE_BASE_INFO;baibaodunflow.tlk_attendance_site_person_info;baibaodunflow.tlk_attendance_site_person_info;baibaodunflow.tlk_SetSupervise;\\\"}\"\n}', 'flink从obpm2+baibaodunflow的binlog捕获数据推到kafka', 1, '2023-04-05 06:14:52', '2023-03-05 20:21:59', NULL, NULL, NULL, 'xxxx', 0);
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 (72, 'cp-consume-tlkcompany-tenant-users-employees-data-72-2023-03-08T09:03:34.204Z', 1, '{\"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\\\"}\",\"param2\":\"{\\\"kafka2JdbcDefinitions\\\":[{\\\"jdbcDefinitions\\\":[{\\\"name\\\":\\\"执行proc_rd_company_summary存储过程: 归集企业信息\\\",\\\"url\\\":\\\"jdbc:mysql://49.4.21.141:45611/securityflow?characterEncoding=UTF-8&connectionTimeZone=GMT%2B8\\\",\\\"username\\\":\\\"bcx\\\",\\\"password\\\":\\\"Wstestv5qy#2022\\\",\\\"connectionTimeZone\\\":\\\"GMT-8\\\",\\\"driver\\\":\\\"com.mysql.cj.jdbc.Driver\\\",\\\"sqlTemplate\\\":\\\"call proc_rd_company_summary(:after.DOMAINID,:before.ITEM_companyName,:after.ITEM_companyName,:after.ITEM_legalPerson,:after.ITEM_registerAddress,:after.ITEM_registerAddressDetail,:after.ITEM_officeAddress,:after.ITEM_officeAddressDetail,:after.ITEM_businessScope,:after.ITEM_companyStatus,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:cp-consume-tlkcompany-tenant-users-employees-data\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"cp-consume-tlkcompany-tenant-users-employees-data\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_companyinformation\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}},{\\\"jdbcDefinitions\\\":[{\\\"name\\\":\\\"执行proc_rd_employee_summary存储过程: 归集职员人员信息\\\",\\\"url\\\":\\\"jdbc:mysql://49.4.21.141:45611/securityflow?characterEncoding=UTF-8&connectionTimeZone=GMT%2B8\\\",\\\"username\\\":\\\"bcx\\\",\\\"password\\\":\\\"Wstestv5qy#2022\\\",\\\"connectionTimeZone\\\":\\\"GMT-8\\\",\\\"driver\\\":\\\"com.mysql.cj.jdbc.Driver\\\",\\\"sqlTemplate\\\":\\\"call proc_rd_employee_summary(:after.id,:after.tenant_user_id,:after.status,:after.occupation_type,:after.hired_date,:after.leave_date,:after.organization_id,:after.last_sync_time)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:cp-consume-tlkcompany-tenant-users-employees-data\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"cp-consume-tlkcompany-tenant-users-employees-data\\\",\\\"topic\\\":\\\"obpm2.binlog-cdc.topic.data.tenant_employees\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}},{\\\"jdbcDefinitions\\\":[{\\\"name\\\":\\\"执行proc_refresh_tenant_user存储过程: 更新人的信息\\\",\\\"url\\\":\\\"jdbc:mysql://49.4.21.141:45611/securityflow?characterEncoding=UTF-8&connectionTimeZone=GMT%2B8\\\",\\\"username\\\":\\\"bcx\\\",\\\"password\\\":\\\"Wstestv5qy#2022\\\",\\\"connectionTimeZone\\\":\\\"GMT-8\\\",\\\"driver\\\":\\\"com.mysql.cj.jdbc.Driver\\\",\\\"sqlTemplate\\\":\\\"call proc_refresh_tenant_user(:after.id)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:cp-consume-tlkcompany-tenant-users-employees-data\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"cp-consume-tlkcompany-tenant-users-employees-data\\\",\\\"topic\\\":\\\"obpm2.binlog-cdc.topic.data.tenant_users\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}}],\\\"name\\\":\\\"cp-consume-tlkcompany-tenant-users-employees-data\\\",\\\"description\\\":\\\"简化版本-CheckPoint-归集人员,职员,企业信息到调度平台-3.0.\\\",\\\"id\\\":\\\"cp-consume-tlkcompany-tenant-users-employees-data\\\"}\"}', '简化版本-CheckPoint-归集人员,职员,企业信息到调度平台-3.0.', 1, '2023-03-08 17:06:38', '2023-03-05 20:45:54', NULL, NULL, NULL, 'dddd', 0);
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 (73, 'CheckPoint-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables-73-2023-03-08T09:04:03.462Z', 1, '{\"param1\":\"{\\\"job.name\\\":\\\"简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/CheckPoint-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\"}\",\"param2\":\"{\\\"kafka2JdbcDefinitions\\\":[{\\\"jdbcDefinitions\\\":[{\\\"name\\\":\\\"执行proc_rd_employee_summary存储过程: 归集驻勤信息\\\",\\\"url\\\":\\\"jdbc:mysql://49.4.21.141:45611/securityflow?characterEncoding=UTF-8&connectionTimeZone=GMT%2B8\\\",\\\"username\\\":\\\"bcx\\\",\\\"password\\\":\\\"Wstestv5qy#2022\\\",\\\"connectionTimeZone\\\":\\\"GMT-8\\\",\\\"driver\\\":\\\"com.mysql.cj.jdbc.Driver\\\",\\\"sqlTemplate\\\":\\\"call securityflow.proc_rd_security_service_station_summary(:after.ID,:after.ITEM_ATTENDANCESITENAME,:after.DOMAINID,:after.ITEM_PRINCIPALNAME,:after.ITEM_PRINCIPALPHONENO,:after.ITEM_ATTENDANCESITEFULLADDRESS,:after.ITEM_ATTENDANCESITETYPE,:after.ITEM_SERVEOBJECTTYPE,:after.ITEM_ATTENDANCESITELONGITUDE,:after.ITEM_ATTENDANCESITELATITUDE,:after.ITEM_CONTRACTSTARTDATE,:after.ITEM_CONTRACTENDDATE,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_base_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}},{\\\"jdbcDefinitions\\\":[{\\\"name\\\":\\\"执行proc_rd_security_service_station_relation_employee_summary存储过程: 归集驻勤人员信息\\\",\\\"url\\\":\\\"jdbc:mysql://49.4.21.141:45611/securityflow?characterEncoding=UTF-8&connectionTimeZone=GMT%2B8\\\",\\\"username\\\":\\\"bcx\\\",\\\"password\\\":\\\"Wstestv5qy#2022\\\",\\\"connectionTimeZone\\\":\\\"GMT-8\\\",\\\"driver\\\":\\\"com.mysql.cj.jdbc.Driver\\\",\\\"sqlTemplate\\\":\\\"call securityflow.proc_rd_security_service_station_relation_employee_summary(:after.ID,:after.ITEM_SECURITYID,:after.ITEM_PHONE,:after.ITEM_DEPTNAME,:after.ITEM_ATTENDANCESITEID,:after.DOMAINID,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_person_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}}],\\\"name\\\":\\\"CheckPoint-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\",\\\"description\\\":\\\"简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.\\\",\\\"id\\\":\\\"CheckPoint-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\"}\"}', '简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.', 1, '2023-03-08 17:06:40', '2023-03-05 20:46:07', NULL, NULL, NULL, 'aaaaa', 0);
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 (74, 'CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables', 1, '{\"param1\":\"{\\\"job.name\\\":\\\"简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\"}\",\"param2\":\"{\\\"kafka2JdbcDefinitions\\\":[{\\\"jdbcDefinitions\\\":[{\\\"jdbcId\\\":1632676329051136000,\\\"sqlTemplate\\\":\\\"call securityflow.proc_rd_security_service_station_summary(:after.ID,:after.ITEM_ATTENDANCESITENAME,:after.DOMAINID,:after.ITEM_PRINCIPALNAME,:after.ITEM_PRINCIPALPHONENO,:after.ITEM_ATTENDANCESITEFULLADDRESS,:after.ITEM_ATTENDANCESITETYPE,:after.ITEM_SERVEOBJECTTYPE,:after.ITEM_ATTENDANCESITELONGITUDE,:after.ITEM_ATTENDANCESITELATITUDE,:after.ITEM_CONTRACTSTARTDATE,:after.ITEM_CONTRACTENDDATE,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_base_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}},{\\\"jdbcDefinitions\\\":[{\\\"jdbcId\\\":1632676329051136000,\\\"sqlTemplate\\\":\\\"call securityflow.proc_rd_security_service_station_relation_employee_summary(:after.ID,:after.ITEM_SECURITYID,:after.ITEM_PHONE,:after.ITEM_DEPTNAME,:after.ITEM_ATTENDANCESITEID,:after.DOMAINID,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_person_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}}],\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\",\\\"description\\\":\\\"简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.\\\",\\\"id\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\"}\"}', '简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.', 1, '2023-03-08 17:01:03', '2023-03-06 18:03:48', NULL, NULL, NULL, 'dddd', 0);
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 (76, 'CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables', 1, '{\"param1\":\"{\\\"job.name\\\":\\\"简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables\\\"}\",\"param2\":\"{\\\"kafka2JdbcDefinitions\\\":[{\\\"jdbcDefinitions\\\":[{\\\"jdbcId\\\":1632676329051136002,\\\"sqlTemplate\\\":\\\"call securityflow.proc_rd_security_service_station_summary(:after.ID,:after.ITEM_ATTENDANCESITENAME,:after.DOMAINID,:after.ITEM_PRINCIPALNAME,:after.ITEM_PRINCIPALPHONENO,:after.ITEM_ATTENDANCESITEFULLADDRESS,:after.ITEM_ATTENDANCESITETYPE,:after.ITEM_SERVEOBJECTTYPE,:after.ITEM_ATTENDANCESITELONGITUDE,:after.ITEM_ATTENDANCESITELATITUDE,:after.ITEM_CONTRACTSTARTDATE,:after.ITEM_CONTRACTENDDATE,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_base_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}},{\\\"jdbcDefinitions\\\":[{\\\"jdbcId\\\":1632676329051136002,\\\"sqlTemplate\\\":\\\"call securityflow.proc_rd_security_service_station_relation_employee_summary(:after.ID,:after.ITEM_SECURITYID,:after.ITEM_PHONE,:after.ITEM_DEPTNAME,:after.ITEM_ATTENDANCESITEID,:after.DOMAINID,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_person_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}}],\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables\\\",\\\"description\\\":\\\"简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.\\\",\\\"id\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables\\\"}\"}', '简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.', 1, '2023-03-08 17:01:02', '2023-03-06 18:06:11', NULL, NULL, NULL, 'cccc', 0);
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 (78, 'CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_3-78-2023-03-09T06:18:38.681Z', 1, '{\"param1\":\"{\\\"job.name\\\":\\\"简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_3\\\"}\",\"param2\":\"{\\\"kafka2JdbcDefinitions\\\":[{\\\"jdbcDefinitions\\\":[{\\\"jdbcId\\\":1632676329051136002,\\\"sqlTemplate\\\":\\\"call securityflow.proc_rd_security_service_station_summary(:after.ID,:after.ITEM_ATTENDANCESITENAME,:after.DOMAINID,:after.ITEM_PRINCIPALNAME,:after.ITEM_PRINCIPALPHONENO,:after.ITEM_ATTENDANCESITEFULLADDRESS,:after.ITEM_ATTENDANCESITETYPE,:after.ITEM_SERVEOBJECTTYPE,:after.ITEM_ATTENDANCESITELONGITUDE,:after.ITEM_ATTENDANCESITELATITUDE,:after.ITEM_CONTRACTSTARTDATE,:after.ITEM_CONTRACTENDDATE,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_3\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_3\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_base_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}},{\\\"jdbcDefinitions\\\":[{\\\"jdbcId\\\":1632676329051136002,\\\"sqlTemplate\\\":\\\"call securityflow.proc_rd_security_service_station_relation_employee_summary(:after.ID,:after.ITEM_SECURITYID,:after.ITEM_PHONE,:after.ITEM_DEPTNAME,:after.ITEM_ATTENDANCESITEID,:after.DOMAINID,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_3\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_3\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_person_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}}],\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_3\\\",\\\"description\\\":\\\"简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.\\\",\\\"id\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_3\\\"}\"}', '简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.', 1, '2023-03-09 14:18:39', '2023-03-07 09:49:24', NULL, NULL, NULL, 'xxxxxx', 1);
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 (79, 'CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_5', 1, '{\"param1\":\"{\\\"job.name\\\":\\\"简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_5\\\"}\",\"param2\":\"{\\\"kafka2JdbcDefinitions\\\":[{\\\"jdbcDefinitions\\\":[{\\\"jdbcId\\\":1632676329051136002,\\\"sqlTemplate\\\":\\\"call securityflow.proc_rd_security_service_station_summary(:after.ID,:after.ITEM_ATTENDANCESITENAME,:after.DOMAINID,:after.ITEM_PRINCIPALNAME,:after.ITEM_PRINCIPALPHONENO,:after.ITEM_ATTENDANCESITEFULLADDRESS,:after.ITEM_ATTENDANCESITETYPE,:after.ITEM_SERVEOBJECTTYPE,:after.ITEM_ATTENDANCESITELONGITUDE,:after.ITEM_ATTENDANCESITELATITUDE,:after.ITEM_CONTRACTSTARTDATE,:after.ITEM_CONTRACTENDDATE,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_5\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_5\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_base_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}},{\\\"jdbcDefinitions\\\":[{\\\"jdbcId\\\":1632676329051136002,\\\"sqlTemplate\\\":\\\"call securityflow.proc_rd_security_service_station_relation_employee_summary(:after.ID,:after.ITEM_SECURITYID,:after.ITEM_PHONE,:after.ITEM_DEPTNAME,:after.ITEM_ATTENDANCESITEID,:after.DOMAINID,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_5\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_5\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_person_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}}],\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_5\\\",\\\"description\\\":\\\"简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.\\\",\\\"id\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_5\\\"}\"}', '简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.', 1, '2023-03-07 18:02:40', '2023-03-07 18:02:40', NULL, NULL, NULL, '简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.', 0);