颖 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)
