You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Yun Gao (Jira)" <ji...@apache.org> on 2022/04/13 06:28:05 UTC
[jira] [Updated] (FLINK-24173) BatchFileSystemITCaseBase.testProjectPushDown hangs on azure
[ https://issues.apache.org/jira/browse/FLINK-24173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yun Gao updated FLINK-24173:
----------------------------
Fix Version/s: 1.16.0
> BatchFileSystemITCaseBase.testProjectPushDown hangs on azure
> ------------------------------------------------------------
>
> Key: FLINK-24173
> URL: https://issues.apache.org/jira/browse/FLINK-24173
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Affects Versions: 1.15.0
> Reporter: Xintong Song
> Priority: Major
> Labels: test-stability
> Fix For: 1.15.0, 1.16.0
>
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=23579&view=logs&j=d44f43ce-542c-597d-bf94-b0718c71e5e8&t=ed165f3f-d0f6-524b-5279-86f8ee7d0e2d&l=14779
> {code}
> Sep 06 09:32:51 "main" #1 prio=5 os_prio=0 tid=0x00007f4ae400b800 nid=0x75e9 waiting on condition [0x00007f4aee144000]
> Sep 06 09:32:51 java.lang.Thread.State: WAITING (parking)
> Sep 06 09:32:51 at sun.misc.Unsafe.park(Native Method)
> Sep 06 09:32:51 - parking to wait for <0x000000008ef18ae8> (a java.util.concurrent.CompletableFuture$Signaller)
> Sep 06 09:32:51 at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> Sep 06 09:32:51 at java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1707)
> Sep 06 09:32:51 at java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323)
> Sep 06 09:32:51 at java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1742)
> Sep 06 09:32:51 at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
> Sep 06 09:32:51 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:163)
> Sep 06 09:32:51 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:128)
> Sep 06 09:32:51 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106)
> Sep 06 09:32:51 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80)
> Sep 06 09:32:51 at org.apache.flink.table.api.internal.TableResultImpl$CloseableRowIteratorWrapper.hasNext(TableResultImpl.java:370)
> Sep 06 09:32:51 at java.util.Iterator.forEachRemaining(Iterator.java:115)
> Sep 06 09:32:51 at org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:109)
> Sep 06 09:32:51 at org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:300)
> Sep 06 09:32:51 at org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:140)
> Sep 06 09:32:51 at org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:106)
> Sep 06 09:32:51 at org.apache.flink.table.planner.runtime.batch.sql.BatchFileSystemITCaseBase.check(BatchFileSystemITCaseBase.scala:46)
> Sep 06 09:32:51 at org.apache.flink.table.planner.runtime.FileSystemITCaseBase$class.testProjectPushDown(FileSystemITCaseBase.scala:251)
> Sep 06 09:32:51 at org.apache.flink.table.planner.runtime.batch.sql.BatchFileSystemITCaseBase.testProjectPushDown(BatchFileSystemITCaseBase.scala:33)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)