[jira] [Created] (FLINK-18243) Flink SQL (1.10.0) to elasticsearch 5.6

[Shang Yuanchun (Jira)]

颖 created FLINK-18243:
-------------------------

             Summary: Flink SQL (1.10.0) to elasticsearch 5.6
                 Key: FLINK-18243
                 URL: https://issues.apache.org/jira/browse/FLINK-18243
             Project: Flink
          Issue Type: Bug
          Components: Connectors / ElasticSearch
    Affects Versions: 1.10.0
         Environment: flink 1.10.0 elasticsearch 5.6.3
            Reporter: 颖


When Flink 1.10.0 Consumer Kafka writes ELASticSearch 5.6.3 through SQL data, the following problems occur:
2020-06-10 17:48:00,526 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-3, groupId=cop.inke_owt.data_pdl.Flink_SQL_yangxu01_2es] Discovered group coordinator c2-dsj-hadoop185.bj:9092 (id: 2147483643 rack: null)
2020-06-10 17:48:00,526 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-4, groupId=cop.inke_owt.data_pdl.Flink_SQL_yangxu01_2es] Discovered group coordinator c2-dsj-hadoop185.bj:9092 (id: 2147483643 rack: null)
2020-06-10 17:48:35,907 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-3, groupId=cop.inke_owt.data_pdl.Flink_SQL_yangxu01_2es] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 2: org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException.
2020-06-10 17:48:35,947 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-4, groupId=cop.inke_owt.data_pdl.Flink_SQL_yangxu01_2es] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 3: org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException.
2020-06-10 17:49:16,279 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-3, groupId=cop.inke_owt.data_pdl.Flink_SQL_yangxu01_2es] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 2: org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException.
2020-06-10 17:49:55,533 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-3, groupId=cop.inke_owt.data_pdl.Flink_SQL_yangxu01_2es] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 2: org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException.
2020-06-10 17:49:58,308 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-4, groupId=cop.inke_owt.data_pdl.Flink_SQL_yangxu01_2es] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 3: org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException.
2020-06-10 17:50:33,664 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-4, groupId=cop.inke_owt.data_pdl.Flink_SQL_yangxu01_2es] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 3: org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException.
2020-06-10 17:50:34,052 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-3, groupId=cop.inke_owt.data_pdl.Flink_SQL_yangxu01_2es] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 2: org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException.
2020-06-10 17:51:19,134 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-4, groupId=cop.inke_owt.data_pdl.Flink_SQL_yangxu01_2es] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 1: org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException.
2020-06-10 17:51:25,762 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-4, groupId=cop.inke_owt.data_pdl.Flink_SQL_yangxu01_2es] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 3: org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException.
2020-06-10 17:52:00,037 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-3, groupId=cop.inke_owt.data_pdl.Flink_SQL_yangxu01_2es] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 2: org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException.
2020-06-10 17:52:11,706 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-4, groupId=cop.inke_owt.data_pdl.Flink_SQL_yangxu01_2es] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 3: org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException.
2020-06-10 17:52:44,064 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-4, groupId=cop.inke_owt.data_pdl.Flink_SQL_yangxu01_2es] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 1: org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException.
2020-06-10 17:52:46,585 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-3, groupId=cop.inke_owt.data_pdl.Flink_SQL_yangxu01_2es] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 2: org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException.
2020-06-10 17:52:56,288 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-4, groupId=cop.inke_owt.data_pdl.Flink_SQL_yangxu01_2es] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 3: org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException.
2020-06-10 17:53:34,340 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-4, groupId=cop.inke_owt.data_pdl.Flink_SQL_yangxu01_2es] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 3: org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException.
2020-06-10 17:53:36,133 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-3, groupId=cop.inke_owt.data_pdl.Flink_SQL_yangxu01_2es] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 4: org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException.
2020-06-10 17:54:15,317 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-3, groupId=cop.inke_owt.data_pdl.Flink_SQL_yangxu01_2es] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 2: org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException.
2020-06-10 17:54:50,583 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-3, groupId=cop.inke_owt.data_pdl.Flink_SQL_yangxu01_2es] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 2: org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException.
 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)