Dian Fu created FLINK-19054:
-------------------------------
Summary: KafkaTableITCase.testKafkaSourceSink hangs
Key: FLINK-19054
URL: https://issues.apache.org/jira/browse/FLINK-19054
Project: Flink
Issue Type: Bug
Components: Connectors / Kafka, Table SQL / API
Affects Versions: 1.11.2
Reporter: Dian Fu
[https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=5844&view=logs&j=c5f0071e-1851-543e-9a45-9ac140befc32&t=684b1416-4c17-504e-d5ab-97ee44e08a20]
{code}
2020-08-25T09:04:57.3569768Z "Kafka Fetcher for Source: KafkaTableSource(price,
currency, log_date, log_time, log_ts) ->
SourceConversion(table=[default_catalog.default_database.kafka, source:
[KafkaTableSource(price, currency, log_date, log_time, log_ts)]],
fields=[price, currency, log_date, log_time, log_ts]) -> Calc(select=[(price +
1.0:DECIMAL(2, 1)) AS computed-price, price, currency, log_date, log_time,
log_ts, (log_ts + 1000:INTERVAL SECOND) AS ts]) ->
WatermarkAssigner(rowtime=[ts], watermark=[ts]) -> Calc(select=[ts, log_date,
log_time, CAST(ts) AS ts0, price]) (1/1)" #1501 daemon prio=5 os_prio=0
tid=0x00007f250000b800 nid=0x22b8 runnable [0x00007f2127efd000]
2020-08-25T09:04:57.3571373Z java.lang.Thread.State: RUNNABLE
2020-08-25T09:04:57.3571672Z at sun.nio.ch.FileDispatcherImpl.read0(Native
Method)
2020-08-25T09:04:57.3572191Z at
sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
2020-08-25T09:04:57.3572921Z at
sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
2020-08-25T09:04:57.3573419Z at sun.nio.ch.IOUtil.read(IOUtil.java:197)
2020-08-25T09:04:57.3573957Z at
sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:377)
2020-08-25T09:04:57.3574809Z - locked <0x00000000fde5a308> (a
java.lang.Object)
2020-08-25T09:04:57.3575448Z at
org.apache.kafka.common.network.PlaintextTransportLayer.read(PlaintextTransportLayer.java:103)
2020-08-25T09:04:57.3576309Z at
org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:117)
2020-08-25T09:04:57.3577086Z at
org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:424)
2020-08-25T09:04:57.3577727Z at
org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:385)
2020-08-25T09:04:57.3578403Z at
org.apache.kafka.common.network.Selector.attemptRead(Selector.java:651)
2020-08-25T09:04:57.3579486Z at
org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:572)
2020-08-25T09:04:57.3580240Z at
org.apache.kafka.common.network.Selector.poll(Selector.java:483)
2020-08-25T09:04:57.3580880Z at
org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:547)
2020-08-25T09:04:57.3581756Z at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:262)
2020-08-25T09:04:57.3583015Z at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233)
2020-08-25T09:04:57.3583847Z at
org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1300)
2020-08-25T09:04:57.3584555Z at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1240)
2020-08-25T09:04:57.3585197Z at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1168)
2020-08-25T09:04:57.3585961Z at
org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerThread.run(KafkaConsumerThread.java:253)
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
