CREATE TABLE sink_es_table (
    `field01` STRING,
    `field02` BIGINT,
    `field03` FLOAT,
    `field04` BINARY,
    `field05` INT,
    `field06` TINYINT,
    `field07` BOOLEAN,
    `field08` DATA,
    `field09` DOUBLE,
    `field10` SMALLINT
) WITH (
    'connector.type' = 'ES',
    'connector.version' = '6.5.3',
    'connector.cluster-id' = 'xxxxxxxxxxxxx',
    'connector.host'  = '192.168.11.208',
    'connector.port'  = '8200',
    'connector.index' = 'bsc_test',
    'connector.document-type' = 'doc_type',
    'connector.username' = 'superuser',
    'connector.password' = 'bsc_1234'
);