[
https://issues.apache.org/jira/browse/FLINK-18243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17130652#comment-17130652
]
Leonard Xu commented on FLINK-18243:
------------------------------------
Hi, [~why198852]
Could you describe more for the issue? It looks like a network connection
problem rather than a *blocker* bug.
> 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: 颖
> Priority: Blocker
>
> 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)
