[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759851#comment-17759851 ] Matthias Pohl commented on FLINK-32751: --- All from the same CI run: * https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52741=logs=f2c100be-250b-5e85-7bbe-176f68fcddc5=05efd11e-5400-54a4-0d27-a4663be008a9=13816 * https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52741=logs=de826397-1924-5900-0034-51895f69d4b7=f311e913-93a2-5a37-acab-4a63e1328f94=15359 * https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52741=logs=0c940707-2659-5648-cbe6-a1ad63045f0a=075c2716-8010-5565-fe08-3c4bb45824a4=14788 > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759849#comment-17759849 ] Matthias Pohl commented on FLINK-32751: --- https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52740=logs=3e4dd1a2-fe2f-5e5d-a581-48087e718d53=b4612f28-e3b5-5853-8a8b-610ae894217a=29248 > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759518#comment-17759518 ] Sergey Nuyanzin commented on FLINK-32751: - 1.17: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52694=logs=f2c100be-250b-5e85-7bbe-176f68fcddc5=05efd11e-5400-54a4-0d27-a4663be008a9=13268 > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759516#comment-17759516 ] Sergey Nuyanzin commented on FLINK-32751: - 1.16: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52693=logs=0c940707-2659-5648-cbe6-a1ad63045f0a=075c2716-8010-5565-fe08-3c4bb45824a4=16951 > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759515#comment-17759515 ] Sergey Nuyanzin commented on FLINK-32751: - https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52692=logs=f2c100be-250b-5e85-7bbe-176f68fcddc5=05efd11e-5400-54a4-0d27-a4663be008a9=12799 > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759512#comment-17759512 ] Sergey Nuyanzin commented on FLINK-32751: - 1.17: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52682=logs=a9db68b9-a7e0-54b6-0f98-010e0aff39e2=cdd32e0b-6047-565b-c58f-14054472f1be=12892 > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759511#comment-17759511 ] Sergey Nuyanzin commented on FLINK-32751: - 1.16: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52681=logs=0c940707-2659-5648-cbe6-a1ad63045f0a=075c2716-8010-5565-fe08-3c4bb45824a4=14351 > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759508#comment-17759508 ] Sergey Nuyanzin commented on FLINK-32751: - https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52680=logs=bf5e383b-9fd3-5f02-ca1c-8f788e2e76d3=85189c57-d8a0-5c9c-b61d-fc05cfac62cf=28413 > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759494#comment-17759494 ] Sergey Nuyanzin commented on FLINK-32751: - https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52666=logs=0c940707-2659-5648-cbe6-a1ad63045f0a=075c2716-8010-5565-fe08-3c4bb45824a4=12115 > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759493#comment-17759493 ] Sergey Nuyanzin commented on FLINK-32751: - 1.16: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52667=logs=9cada3cb-c1d3-5621-16da-0f718fb86602=c67e71ed-6451-5d26-8920-5a8cf9651901=28282 > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759491#comment-17759491 ] Sergey Nuyanzin commented on FLINK-32751: - 1.16: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52644=logs=0c940707-2659-5648-cbe6-a1ad63045f0a=075c2716-8010-5565-fe08-3c4bb45824a4=14472 > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759093#comment-17759093 ] Matthias Pohl commented on FLINK-32751: --- I provided a PR with the fix (see https://github.com/apache/flink/pull/23296) > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758986#comment-17758986 ] Matthias Pohl commented on FLINK-32751: --- There's a race condition between closing the coordinator (which closes the socket and set the corresponding field to {{null}}) and handling a request where a socket is opened again if the corresponding socket field is null. If the close call happens after a new request is submitted but before the null check in the request handling happens, a new Socket will be created that's never closed but doesn't get any data, anymore. That results in the response never returning. This race condition was also able to happen prior to the changes we introduced in the merges documented in [the comment above|https://issues.apache.org/jira/browse/FLINK-32751?focusedCommentId=17756703=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-17756703]. I'm still puzzled why this issue starts to appear more frequently now. The main difference (besides the log output refactoring) was to change from {{shutdown}} to {{shutdownNow}} for the executor service and when the {{closeConnection}} call happened (before or after the shutdown). I would have expected that we run into this issue more often with the {{closeConnection}} call happening before the shutdown of the {{ExecutorService}} (which is how it was implemented before the recent changes) because there's a higher chance for the socket to be recreated. I still have to investigate that one. But I'm working on a fix now with more elaborate unit testing of the class. > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at >
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758983#comment-17758983 ] Sergey Nuyanzin commented on FLINK-32751: - https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52634=logs=0c940707-2659-5648-cbe6-a1ad63045f0a=075c2716-8010-5565-fe08-3c4bb45824a4=15261 > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758878#comment-17758878 ] Sergey Nuyanzin commented on FLINK-32751: - 1.16: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52623=logs=a57e0635-3fad-5b08-57c7-a4142d7d6fa9=2ef0effc-1da1-50e5-c2bd-aab434b1c5b7=13839 > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758846#comment-17758846 ] Matthias Pohl commented on FLINK-32751: --- 1.16: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52582=logs=0c940707-2659-5648-cbe6-a1ad63045f0a=075c2716-8010-5565-fe08-3c4bb45824a4=14446 > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758569#comment-17758569 ] Sergey Nuyanzin commented on FLINK-32751: - 1.16: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52513=logs=a9db68b9-a7e0-54b6-0f98-010e0aff39e2=cdd32e0b-6047-565b-c58f-14054472f1be=14143 > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758568#comment-17758568 ] Sergey Nuyanzin commented on FLINK-32751: - https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52512=logs=bf5e383b-9fd3-5f02-ca1c-8f788e2e76d3=85189c57-d8a0-5c9c-b61d-fc05cfac62cf > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758567#comment-17758567 ] Sergey Nuyanzin commented on FLINK-32751: - 1.16: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52479=logs=a9db68b9-a7e0-54b6-0f98-010e0aff39e2=cdd32e0b-6047-565b-c58f-14054472f1be=14155 > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758565#comment-17758565 ] Sergey Nuyanzin commented on FLINK-32751: - 1.17: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52514=logs=4eda0b4a-bd0d-521a-0916-8285b9be9bb5=2ff6d5fa-53a6-53ac-bff7-fa524ea361a9=13893 > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758562#comment-17758562 ] Sergey Nuyanzin commented on FLINK-32751: - https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52543=logs=0c940707-2659-5648-cbe6-a1ad63045f0a=075c2716-8010-5565-fe08-3c4bb45824a4=12436 > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758560#comment-17758560 ] Sergey Nuyanzin commented on FLINK-32751: - another from today's master https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52591=logs=0c940707-2659-5648-cbe6-a1ad63045f0a=075c2716-8010-5565-fe08-3c4bb45824a4 > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758494#comment-17758494 ] Matthias Pohl commented on FLINK-32751: --- Ok, I'm raising this issue to become a blocker again. The amount of time it appears now is worrying. > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Critical > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758489#comment-17758489 ] Matthias Pohl commented on FLINK-32751: --- The {{BuiltInAggregateFunctionTestBase}} failure in 1.17 mentioned in [Sergey's comment|https://issues.apache.org/jira/browse/FLINK-32751?focusedCommentId=17758482=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-17758482] and the {{MySqlCatalogITCase}} failure that happened in Oct 2022 (mentioned in [this comment|https://issues.apache.org/jira/browse/FLINK-32751?focusedCommentId=17754085=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-17754085]) might indicate that it's at least not a blocker for 1.18. Even though it is concerning that the error appears three times in a short period now. And the fix that was applied should cancel all requests while shutting down the {{executorService}}. I'm gonna have another look. > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.16.3, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Priority: Critical > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758486#comment-17758486 ] Sergey Nuyanzin commented on FLINK-32751: - and for 1.16: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52565=logs=f2c100be-250b-5e85-7bbe-176f68fcddc5=05efd11e-5400-54a4-0d27-a4663be008a9=15322 {noformat} Aug 24 03:18:51 "main" #1 prio=5 os_prio=0 tid=0x7f9da400b800 nid=0x72f5 waiting on condition [0x7f9dad338000] Aug 24 03:18:51java.lang.Thread.State: WAITING (parking) Aug 24 03:18:51 at sun.misc.Unsafe.park(Native Method) Aug 24 03:18:51 - parking to wait for <0xc2cc4b60> (a java.util.concurrent.CompletableFuture$Signaller) Aug 24 03:18:51 at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) Aug 24 03:18:51 at java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1707) Aug 24 03:18:51 at java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323) Aug 24 03:18:51 at java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1742) Aug 24 03:18:51 at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908) Aug 24 03:18:51 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:170) Aug 24 03:18:51 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) Aug 24 03:18:51 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) Aug 24 03:18:51 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) Aug 24 03:18:51 at org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) Aug 24 03:18:51 at java.util.Iterator.forEachRemaining(Iterator.java:115) Aug 24 03:18:51 at org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:115) Aug 24 03:18:51 at org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:308) Aug 24 03:18:51 at org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:144) Aug 24 03:18:51 at org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:108) Aug 24 03:18:51 at org.apache.flink.table.planner.runtime.batch.sql.agg.AggregateReduceGroupingITCase.testAggWithCube(AggregateReduceGroupingITCase.scala:523) Aug 24 03:18:51 {noformat} > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.17.2, 1.19.0 >Reporter: Sergey Nuyanzin >Priority: Critical > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at >
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758482#comment-17758482 ] Sergey Nuyanzin commented on FLINK-32751: - also happened for 1.17 https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52566=logs=a9db68b9-a7e0-54b6-0f98-010e0aff39e2=cdd32e0b-6047-565b-c58f-14054472f1be=12876 > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0, 1.19.0 >Reporter: Sergey Nuyanzin >Priority: Critical > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758464#comment-17758464 ] Matthias Pohl commented on FLINK-32751: --- It happened again: [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=52570=logs=0c940707-2659-5648-cbe6-a1ad63045f0a=075c2716-8010-5565-fe08-3c4bb45824a4=15116] > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0 >Reporter: Sergey Nuyanzin >Priority: Critical > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756703#comment-17756703 ] Matthias Pohl commented on FLINK-32751: --- I merged the changes into the branches: master (1.18): b5b1340f91d6cd2deb563eb67d8cbb3d1852544d 1.17: 8da9d50235776e41901b19c0f226f2826f03650e 1.16: ee6fbd0c4a9e3ee1b30872389829a284b1c6e215 It's not a fix but rather a change in how issues are logged in production for the {{CollectSinkOperatorCoordinator}}. I'm gonna keep this issue open in case we run into this problem again. > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Critical > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754085#comment-17754085 ] Matthias Pohl commented on FLINK-32751: --- There was another test error with FLINK-29642 reported that has the same stacktrace: [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=42011=logs=dbe51908-4958-5c8c-9557-e10952d4259d=55d11a16-067d-538d-76a3-4c096a3a8e24=15625] {code:java} [...] Oct 14 02:18:03 "main" #1 prio=5 os_prio=0 tid=0x7fa9bc00b800 nid=0x3528 waiting on condition [0x7fa9c54e3000] Oct 14 02:18:03java.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 <0xaaae6cd0> (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) [...] {code} > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Critical > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at >
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752444#comment-17752444 ] Matthias Pohl commented on FLINK-32751: --- I checked whether {{Socket#connect}} (see [CollectSinkOperatorCoordinator:165|https://github.com/apache/flink/blob/e110b0318d66c741ca0f609ec661ddaea599379c/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorCoordinator.java#L165] might block the thread execution if there's no \{{ServerSocket}} waiting for a connection. But the call still fails with a {{ConnectException}} if there's no {{ServerSocket}} listening on the given port. That would have been the only guess why the request didn't complete. > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Critical > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752393#comment-17752393 ] Matthias Pohl commented on FLINK-32751: --- Some other findings: * The thread dump doesn't contain the {{collect-sink-operator-coordinator-executor-thread-pool}} thread pool which gives the indication that the {{CollectSinkOperatorCoordinator}} executorService was actually shut down. * The Socket is never established (i.e. "Sink connection established" doesn't show up in the logs; see [CollectSinkOperatorCoordinator:136|https://github.com/apache/flink/blob/bedcc3f7b5c0fc184953d3c1a969f03887db2cae/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorCoordinator.java#L136]) which might indicate that the connect call could have also been blocked. The {{connect}} itself is called without a timeout (value: 0) which makes the connect possibly block forever. But that contradicts the item above where we claimed that the corresponding thread {{collect-sink-operator-coordinator-executor-thread-pool}} isn't listed in the thread dump anymore. I'm gonna go ahead and provide the PR that hopefully improves the logging of this scenario a bit more. > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Critical > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752373#comment-17752373 ] Matthias Pohl commented on FLINK-32751: --- I played around a bit more with the test and I'm not convinced that the issue is the shutdown procedure. AFAIU, {{CollectSinkOperatorCoordinator#handleRequestImpl}} would immediately fail if the {{CollectSinkOperatorCoordinator#close}} is triggered because it closes the socket connection which would cause an error while reading from the socket's inputstream. The future should be completed in the catch block of {{CollectSinkOperatorCoordinator#handleRequestImpl}} (even if the cluster is shut down in the mean time). Enabling more logs in the local test execution also reveals that the response is rarely filed with data. But the test itself succeeds anyway. That seems odd: I'm wondering whether there's another path that sends out the data to the client. [~renqs] do you have someone who can look into that issue from the runtime perspective? > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0 >Reporter: Sergey Nuyanzin >Assignee: Matthias Pohl >Priority: Critical > Labels: pull-request-available, test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for 1.11.0 and closed because of lack of > occurrences > FLINK-16923 > and another similar one FLINK-22100 which was marked as a duplicate of > FLINK-21996 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752017#comment-17752017 ] Matthias Pohl commented on FLINK-32751: --- [~chesnay] had another guess: {{CollectResultFetcher.sendRequest}} (which is the call that doesn't get back even while the cluster is shutdown) triggers the {{Dispatcher#deliverCoordinationRequestToCoordinator > JobMaster#deliverCoordinationRequestToCoordinator > JobMaster#sendRequestToCoordinator > SchedulerNG#deliverCoordinationRequestToCoordinator > OperatorCoordinatorHandler#deliverCoordinationRequestToCoordinator > CollectSinkOperatorCoordinator#handleCoordinationRequest}}. The latter one submits the request handling to an {{executorService}} which is owned by the coordinator. This {{executorService}} is shut down as part of the coordinator's close mechanism using the {{shutdown}} call. Any already submitted task is not stopped but continues to operator while the MiniCluster shutdown is happening (where the RPC system is shut down as well in the end). There is some chance that the task got executed but the RPC system is shut down in the mean time. Any completion of future within {{CollectSinkOperatorCoordinator#handleRequestImpl}} might be lost when the RPC system is shut down. I'm gonna go ahead and try to come up with a test scenario for this issue. If we conclude that this reasoning makes sense, it would mean that Jira issue isn't blocking the 1.18 release. That problem exists also in older versions of Flink. > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0 >Reporter: Sergey Nuyanzin >Priority: Critical > Labels: test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.batch.sql.agg.DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn(DistinctAggregateITCaseBase.scala:97) > ~~ > {noformat} > it is very likely that it is an old issue > the similar case was mentioned for
[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751105#comment-17751105 ] Matthias Pohl commented on FLINK-32751: --- The actual test failure happened in {{SortDistinctAggregateITCase#testMultiDistinctAggOnDifferentColumn}} which derives the test from {{DistinctAggregateITCaseBase}}. FYI: This can be determined by looking at the surefire reporting which prints that {{HashDistinctAggregateITCase}} completed but {{SortDistinctAggregateITCase}} didn't. {code} [...] Aug 04 02:12:29 02:12:29.073 [INFO] Running org.apache.flink.table.planner.runtime.batch.sql.agg.SortDistinctAggregateITCase [...] Aug 04 02:19:04 02:19:04.720 [INFO] Running org.apache.flink.table.planner.runtime.batch.sql.agg.HashDistinctAggregateITCase Aug 04 02:20:38 02:20:38.255 [INFO] Tests run: 23, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 93.527 s - in org.apache.flink.table.planner.runtime.batch.sql.agg.HashDistinctAggregateITCase [...] {code} The issue we're seeing seems to be independent of the actual test, though. The timeout happens when the {{CollectDynamicSink}} tries to request more data through the Dispatcher which forwards the request. Unfortunately, we don't have any logs from the Dispatcher side of that request. Therefore, we cannot reliably say where the request halted. [~Sergey Nuyanzin] had a point when pointing out that there are multiple other past Jira issues (FLINK-20254, FLINK-22129, FLINK-22181, FLINK-22100) that had a similar stacktrace. These Jiras were handled as duplicates of FLINK-21996 which was a bug in RPC layer with messages being swallowed. In the end, it's strange that the request wasn't completed in some way due to the {{MiniCluster}} having been shut down. > DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck > on AZP > -- > > Key: FLINK-32751 > URL: https://issues.apache.org/jira/browse/FLINK-32751 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.18.0 >Reporter: Sergey Nuyanzin >Priority: Critical > Labels: test-stability > > This build hangs > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=51955=logs=ce3801ad-3bd5-5f06-d165-34d37e757d90=5e4d9387-1dcc-5885-a901-90469b7e6d2f=14399 > {noformat} > Aug 04 03:03:47 "ForkJoinPool-1-worker-51" #28 daemon prio=5 os_prio=0 > cpu=49342.66ms elapsed=3079.49s tid=0x7f67ccdd nid=0x5234 waiting on > condition [0x7f6791a19000] > Aug 04 03:03:47java.lang.Thread.State: WAITING (parking) > Aug 04 03:03:47 at > jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method) > Aug 04 03:03:47 - parking to wait for <0xad3b1fb8> (a > java.util.concurrent.CompletableFuture$Signaller) > Aug 04 03:03:47 at > java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796) > Aug 04 03:03:47 at > java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823) > Aug 04 03:03:47 at > java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sendRequest(CollectResultFetcher.java:171) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:129) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > Aug 04 03:03:47 at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > Aug 04 03:03:47 at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > Aug 04 03:03:47 at > java.util.Iterator.forEachRemaining(java.base@11.0.19/Iterator.java:132) > Aug 04 03:03:47 at > org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145) > Aug 04 03:03:47 at > org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109) > Aug 04 03:03:47 at >