大体的作业内容就是如下,临时表的数据是有一条的,es的版本是6.x,自搭的非阿里云的产品,作业开发验证执行上线都成功了,但是es的建的测试索引数据一直是写不进去的。
新手没有用过,不知道何处有错,路过的看看能不能给个提示或者方向。
CREATE TEMPORARY TABLE union_test (
id BIGINT,
orderNumber STRING,
bookingNO STRING,
PRIMARY KEY (id) NOT ENFORCED
) WITH (
'connector' ='elasticsearch',
'endPoint' = 'http://1.1.1.1:9200;http://2.2.2.2:9200',
'indexName' = 'union_order_test',
'typeNames' = 'union_order_test_type'
);
CREATE TEMPORARY TABLE blackhole_sink (
id BIGINT,
orderNumber STRING,
bookingNO STRING
) WITH (
'connector' = 'blackhole'
);
INSERT INTO blackhole_sink
SELECT id, order_number, booking_no
FROM test_orders_new where order_number='10005495851809939';