drop table rd_company_summary;
create table rd_company_summary
(
     pkId BIGINT PRIMARY KEY auto_increment,
	 id varchar(100) not null UNIQUE,
	 `name` varchar(200) not null,
	 legal varchar(50),
	 registerAddress_name varchar(500) not null,
	 registerAddress_detail varchar(1000) not null,
	 businessAddress_name varchar(500) not null,
	 businessAddress_detail varchar(1000) not null,
	 service_scope varchar(500),
	 lonLat varchar(50),
	 `status` TINYINT not null default 0,
	 serviceStationCount int not null default 0,
     activeSecurityManCount int not null default 0,
	 last_sync_time TIMESTAMP not null default CURRENT_TIMESTAMP,
	 last_updated_time TIMESTAMP not null default CURRENT_TIMESTAMP,
	 region_code varchar(50) not null,
	 supervise_address_id varchar(50) not null
);

drop table rd_employee_summary;
create table rd_employee_summary
(
     pkId BIGINT PRIMARY KEY auto_increment,
	 id varchar(100) not null UNIQUE,#职员Id
	 tenant_user_id varchar(50) not null,
	 `name` varchar(200) not null,
	 `head_photo` varchar(1000),#头像
	 idCard varchar(50),
	 idCard_front_photo varchar(1000),#身份证正面照
	 idCard_reverse_photo varchar(1000),#身份证正面照

	 sex TINYINT not null default 0,
	 telephone varchar(50),
	 checked_status tinyint not null,#核验状态
	 authenticate_status TINYINT not null default 0,#认证状态
	 security_certificate_number varchar(50),#资格证证件号
	 military_status TINYINT not null default 0,
	 lon_lat POINT,
	 employ_status TINYINT not null default 0,
	 dispatch_device_json JSON,
	 occupation_type TINYINT not null default 0,
	 hired_date datetime,
	 leave_date datetime,
	 company_id varchar(200) not null,
     company_name varchar(200) not null,
	 last_sync_time TIMESTAMP not null default CURRENT_TIMESTAMP,
	 last_updated_time TIMESTAMP not null default CURRENT_TIMESTAMP,
	 region_code varchar(50) not null,
	 supervise_address_id varchar(100) not null
);
#入离职记录
drop table rd_employee_summary_history;
create table rd_employee_summary_history
(
     pkId BIGINT PRIMARY KEY auto_increment,
	 id varchar(100) not null unique,#职员Id
	 tenant_user_id varchar(50) not null,
	 employ_status TINYINT not null default 0,
	 hired_date datetime,
	 leave_date datetime,
	 company_id varchar(200) not null,
     company_name varchar(200) not null,
	 last_sync_time TIMESTAMP not null default CURRENT_TIMESTAMP,
	 last_updated_time TIMESTAMP not null default CURRENT_TIMESTAMP,
	 region_code varchar(50) not null,
	 supervise_address_id varchar(100) not null
);

drop table rd_security_service_station_summary;
create table rd_security_service_station_summary
(
     pkId BIGINT PRIMARY KEY auto_increment,
	 id varchar(100) not null UNIQUE,
	 `name` varchar(200) not null,
	 last_sync_time TIMESTAMP not null default CURRENT_TIMESTAMP,
	 last_updated_time TIMESTAMP not null default CURRENT_TIMESTAMP,
	 begin_time TIMESTAMP not null default CURRENT_TIMESTAMP,
	 end_time TIMESTAMP not null default CURRENT_TIMESTAMP,
	 station_type_code varchar(50) not null,
	 company_id varchar(200) not null,
	 company_name varchar(200) not null,
	 master_name varchar(50),
	 master_contact varchar(50),
	 service_scope varchar(500),
	 address varchar(1000),
	 lon_lat POINT,
	 `status` TINYINT not null default 0,
	 relation_securityman_count int not null default 0,
	 region_code varchar(50) not null,
	 supervise_address_id varchar(100) not null
);


drop table rd_security_service_station_relation_employee_summary;
create table rd_security_service_station_relation_employee_summary
(
   pkId BIGINT PRIMARY KEY auto_increment,
   id varchar(200) not null UNIQUE,
   depart_name varchar(100),
   tenant_user_id varchar(100) not null,
   tenant_user_name varchar(100),
   tenant_user_certificated_type TINYINT not null default 0,
   tenant_user_certificated_number varchar(50),
   telephone varchar(50),
   security_service_station_id varchar(100) not null,
   employee_id varchar(100) not null,
   company_id varchar(200) not null,
   last_sync_time TIMESTAMP not null default CURRENT_TIMESTAMP,
   last_updated_time TIMESTAMP not null default CURRENT_TIMESTAMP,
   region_code varchar(50) not null,
   supervise_address_id varchar(100) not null
);











drop table rd_data_relation_manage_summary;
create table rd_data_relation_manage_summary
(
   pkId BIGINT PRIMARY KEY auto_increment,
   id varchar(200) not null UNIQUE,
   last_sync_time TIMESTAMP not null default CURRENT_TIMESTAMP,
   last_updated_time TIMESTAMP not null default CURRENT_TIMESTAMP,
   `code` varchar(100) not null,
   data_type varchar(100) not null,
   data_id varchar(100)
);










select id,DOMAINID,ITEM_companyName,ITEM_registerAddress,ITEM_registerAddressDetail,ITEM_officeAddress,ITEM_officeAddressDetail,ITEM_legalPerson,ITEM_legalPersonPhone,
ITEM_businessScope,LASTMODIFIED,ITEM_companyStatus #ITEM_companyStatus='正常'
from baibaodunflow.tlk_companyinformation;


 create table rd_exec_logs
 (pkId bigint not null primary key auto_increment,
  id varchar(100) not null,
	title varchar(200),
	createdTime TIMESTAMP not null default CURRENT_TIMESTAMP
 )


Caused by: java.lang.OutOfMemoryError: Metaspace. The metaspace out-of-memory error has occurred. This can mean two things: either Flink Master requires a larger size of JVM metaspace to load classes or there is a class loading leak. In the first case 'jobmanager.memory.jvm-metaspace.size' configuration option should be increased. If the error persists (usually in cluster after several job (re-)submissions) then there is probably a class loading leak in user code or some of its dependencies which has to be investigated and fixed. The Flink Master has to be shutdown.