1. add jar hdfs:///eslib/elasticsearch-hadoop-8.1.0.jar;
    2. add jar hdfs:///eslib/commons-httpclient-3.1.jar;
    3. DROP TABLE if  exists default.es_lables;
    4. CREATE EXTERNAL TABLE default.es_lables(
    5. address STRING COMMENT '',
    6. lables STRING COMMENT ''
    7. )STORED BY 'org.elasticsearch.hadoop.hive.EsStorageHandler'
    8. TBLPROPERTIES(
    9. --改这
    10. 'es.resource'='user_lables',
    11. 'es.nodes'='10.10.1.107',
    12. 'es.port' = '9200',
    13. 'es.index.auto.create'='TRUE',
    14. 'es.batch.write.refresh' = 'FALSE',
    15. 'es.index.number_of_replicas' = '0',
    16. 'es.batch.write.retry.count' = '10',
    17. 'es.batch.write.retry.wait' = '60s',
    18. 'es.net.http.auth.user' = 'elastic',
    19. --50mb或者3万条，哪个先满足哪个刷，另外mb只能小写
    20. 'es.batch.size.bytes' = '50mb',
    21. 'es.batch.size.entries' = '30000',
    22. 'es.net.http.auth.pass' = '123456',
    23. --true只会找es.nodes指定的节点，false则会找到可用的所有节点
    24. 'es.nodes.wan.only' = 'TRUE',
    25. 'es.internal.es.version' = '8.1.0',
    26. --改这
    27. 'es.mapping.id' = 'address',
    28. --改这
    29. 'es.mapping.name' = 'address:address,lables:lables'
    30. );