Matthias Pohl created FLINK-36300:
-------------------------------------
Summary:
TableEnvHiveConnectorITCase.testDateTimestampPartitionColumns times out
Key: FLINK-36300
URL: https://issues.apache.org/jira/browse/FLINK-36300
Project: Flink
Issue Type: Bug
Components: Connectors / Hive
Affects Versions: 2.0-preview
Reporter: Matthias Pohl
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=62146&view=logs&j=5cae8624-c7eb-5c51-92d3-4d2dacedd221&t=5acec1b4-945b-59ca-34f8-168928ce5199&l=25538
{code}
"main" #1 prio=5 os_prio=0 tid=0x00007f309e8a2000 nid=0x1b181 waiting on
condition [0x00007f30a2104000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for <0x00000000ff529778> (a
java.util.concurrent.CompletableFuture$Signaller)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at
java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1707)
at
java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323)
at
java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1742)
at
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.isJobTerminated(CollectResultFetcher.java:213)
at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:120)
at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:126)
at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:100)
at
org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:247)
at java.util.Iterator.forEachRemaining(Iterator.java:115)
at
org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:133)
at
org.apache.flink.connectors.hive.TableEnvHiveConnectorITCase.lambda$testDateTimestampPartitionColumns$4(TableEnvHiveConnectorITCase.java:248)
at
org.apache.flink.connectors.hive.TableEnvHiveConnectorITCase$$Lambda$8669/2110765445.call(Unknown
Source)
at
org.apache.flink.connectors.hive.TableEnvExecutorUtil.executeInSeparateDatabase(TableEnvExecutorUtil.java:53)
at
org.apache.flink.connectors.hive.TableEnvExecutorUtil.executeInSeparateDatabase(TableEnvExecutorUtil.java:30)
at
org.apache.flink.connectors.hive.TableEnvHiveConnectorITCase.testDateTimestampPartitionColumns(TableEnvHiveConnectorITCase.java:214)
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
