[
https://issues.apache.org/jira/browse/FLINK-18243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17130741#comment-17130741
]
Jark Wu commented on FLINK-18243:
---------------------------------
The logs shows the connection to kafka is not stable, it is not relative to
elsaticsearch. Could you share the exception or error about elsaticsearch?
Besides, it would be better if you can share your code, because as far as I
know, Flink didn't provide elsaticsearch-5 sql connector. So it maybe a
incompatible client-server problem.
> 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: Major
>
> 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)
