Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Duplicate
-
1.17.0
-
None
Description
This build failed (not exclusively) because of MySqlCatalogITCase.testWithoutCatalogDB timing out.
Oct 14 02:18:03 "main" #1 prio=5 os_prio=0 tid=0x00007fa9bc00b800 nid=0x3528 waiting on condition [0x00007fa9c54e3000] Oct 14 02:18:03 java.lang.Thread.State: WAITING (parking) Oct 14 02:18:03 at sun.misc.Unsafe.park(Native Method) Oct 14 02:18:03 - parking to wait for <0x00000000aaae6cd0> (a java.util.concurrent.CompletableFuture$Signaller) Oct 14 02:18:03 at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) Oct 14 02:18:03 at java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1707) Oct 14 02:18:03 at java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323) Oct 14 02:18:03 at java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1742) Oct 14 02:18:03 at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908) Oct 14 02:18:03 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:170) Oct 14 02:18:03 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) Oct 14 02:18:03 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) Oct 14 02:18:03 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) Oct 14 02:18:03 at org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) Oct 14 02:18:03 at java.util.Iterator.forEachRemaining(Iterator.java:115) Oct 14 02:18:03 at org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:115) Oct 14 02:18:03 at org.apache.flink.connector.jdbc.catalog.MySqlCatalogITCase.testWithoutCatalogDB(MySqlCatalogITCase.java:309) [...]
Attachments
Issue Links
- duplicates
-
FLINK-32751 DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
- Resolved