[jira] [Updated] (FLINK-26724) FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer failed on azure due to Container startup failed

2023-08-12 Thread Flink Jira Bot (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-26724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Flink Jira Bot updated FLINK-26724:
---
Labels: auto-deprioritized-major stale-minor test-stability  (was: 
auto-deprioritized-major test-stability)

I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help 
the community manage its development. I see this issues has been marked as 
Minor but is unassigned and neither itself nor its Sub-Tasks have been updated 
for 180 days. I have gone ahead and marked it "stale-minor". If this ticket is 
still Minor, please either assign yourself or give an update. Afterwards, 
please remove the label or in 7 days the issue will be deprioritized.


> FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer failed on azure 
> due to Container startup failed
> ---
>
> Key: FLINK-26724
> URL: https://issues.apache.org/jira/browse/FLINK-26724
> Project: Flink
>  Issue Type: Bug
>  Components: Connectors / Kafka
>Affects Versions: 1.15.0, 1.16.0
>Reporter: Yun Gao
>Priority: Minor
>  Labels: auto-deprioritized-major, stale-minor, test-stability
>
> {code:java}
> 2022-03-17T10:27:56.1372771Z Mar 17 10:27:56 
> org.testcontainers.containers.ContainerLaunchException: Container startup 
> failed
> 2022-03-17T10:27:56.1373469Z Mar 17 10:27:56  at 
> org.testcontainers.containers.GenericContainer.doStart(GenericContainer.java:336)
> 2022-03-17T10:27:56.1376022Z Mar 17 10:27:56  at 
> org.testcontainers.containers.GenericContainer.start(GenericContainer.java:317)
> 2022-03-17T10:27:56.1376901Z Mar 17 10:27:56  at 
> java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
> 2022-03-17T10:27:56.1377769Z Mar 17 10:27:56  at 
> java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
> 2022-03-17T10:27:56.1378489Z Mar 17 10:27:56  at 
> java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
> 2022-03-17T10:27:56.1379198Z Mar 17 10:27:56  at 
> java.util.stream.ForEachOps$ForEachTask.compute(ForEachOps.java:290)
> 2022-03-17T10:27:56.1379892Z Mar 17 10:27:56  at 
> java.util.concurrent.CountedCompleter.exec(CountedCompleter.java:731)
> 2022-03-17T10:27:56.1380595Z Mar 17 10:27:56  at 
> java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
> 2022-03-17T10:27:56.1381267Z Mar 17 10:27:56  at 
> java.util.concurrent.ForkJoinTask.doInvoke(ForkJoinTask.java:401)
> 2022-03-17T10:27:56.1381934Z Mar 17 10:27:56  at 
> java.util.concurrent.ForkJoinTask.invoke(ForkJoinTask.java:734)
> 2022-03-17T10:27:56.1382658Z Mar 17 10:27:56  at 
> java.util.stream.ForEachOps$ForEachOp.evaluateParallel(ForEachOps.java:159)
> 2022-03-17T10:27:56.1383409Z Mar 17 10:27:56  at 
> java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateParallel(ForEachOps.java:173)
> 2022-03-17T10:27:56.1384358Z Mar 17 10:27:56  at 
> java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:233)
> 2022-03-17T10:27:56.1385680Z Mar 17 10:27:56  at 
> java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
> 2022-03-17T10:27:56.1386625Z Mar 17 10:27:56  at 
> java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:650)
> 2022-03-17T10:27:56.1387496Z Mar 17 10:27:56  at 
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl.startKafkaContainerCluster(KafkaTestEnvironmentImpl.java:410)
> 2022-03-17T10:27:56.1388721Z Mar 17 10:27:56  at 
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl.prepare(KafkaTestEnvironmentImpl.java:106)
> 2022-03-17T10:27:56.1389705Z Mar 17 10:27:56  at 
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase.startClusters(KafkaTestBase.java:159)
> 2022-03-17T10:27:56.1390910Z Mar 17 10:27:56  at 
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase.startClusters(KafkaTestBase.java:142)
> 2022-03-17T10:27:56.1392365Z Mar 17 10:27:56  at 
> org.apache.flink.streaming.connectors.kafka.KafkaMigrationTestBase.testRestoreProducer(KafkaMigrationTestBase.java:134)
> 2022-03-17T10:27:56.1393179Z Mar 17 10:27:56  at 
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2022-03-17T10:27:56.1393963Z Mar 17 10:27:56  at 
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2022-03-17T10:27:56.1394714Z Mar 17 10:27:56  at 
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2022-03-17T10:27:56.1395908Z Mar 17 10:27:56  at 
> java.lang.reflect.Method.invoke(Method.java:498)
> 2022-03-17T10:27:56.1397053Z Mar 17 10:27:56  at 
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> 2022-03-17T10:27:56.1398364Z Mar 17 10:27:56  at 
>

[jira] [Updated] (FLINK-26724) FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer failed on azure due to Container startup failed

2022-07-13 Thread Flink Jira Bot (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-26724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Flink Jira Bot updated FLINK-26724:
---
  Labels: auto-deprioritized-major test-stability  (was: stale-major 
test-stability)
Priority: Minor  (was: Major)

This issue was labeled "stale-major" 7 days ago and has not received any 
updates so it is being deprioritized. If this ticket is actually Major, please 
raise the priority and ask a committer to assign you the issue or revive the 
public discussion.


> FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer failed on azure 
> due to Container startup failed
> ---
>
> Key: FLINK-26724
> URL: https://issues.apache.org/jira/browse/FLINK-26724
> Project: Flink
>  Issue Type: Bug
>  Components: Connectors / Kafka
>Affects Versions: 1.15.0, 1.16.0
>Reporter: Yun Gao
>Priority: Minor
>  Labels: auto-deprioritized-major, test-stability
>
> {code:java}
> 2022-03-17T10:27:56.1372771Z Mar 17 10:27:56 
> org.testcontainers.containers.ContainerLaunchException: Container startup 
> failed
> 2022-03-17T10:27:56.1373469Z Mar 17 10:27:56  at 
> org.testcontainers.containers.GenericContainer.doStart(GenericContainer.java:336)
> 2022-03-17T10:27:56.1376022Z Mar 17 10:27:56  at 
> org.testcontainers.containers.GenericContainer.start(GenericContainer.java:317)
> 2022-03-17T10:27:56.1376901Z Mar 17 10:27:56  at 
> java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
> 2022-03-17T10:27:56.1377769Z Mar 17 10:27:56  at 
> java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
> 2022-03-17T10:27:56.1378489Z Mar 17 10:27:56  at 
> java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
> 2022-03-17T10:27:56.1379198Z Mar 17 10:27:56  at 
> java.util.stream.ForEachOps$ForEachTask.compute(ForEachOps.java:290)
> 2022-03-17T10:27:56.1379892Z Mar 17 10:27:56  at 
> java.util.concurrent.CountedCompleter.exec(CountedCompleter.java:731)
> 2022-03-17T10:27:56.1380595Z Mar 17 10:27:56  at 
> java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
> 2022-03-17T10:27:56.1381267Z Mar 17 10:27:56  at 
> java.util.concurrent.ForkJoinTask.doInvoke(ForkJoinTask.java:401)
> 2022-03-17T10:27:56.1381934Z Mar 17 10:27:56  at 
> java.util.concurrent.ForkJoinTask.invoke(ForkJoinTask.java:734)
> 2022-03-17T10:27:56.1382658Z Mar 17 10:27:56  at 
> java.util.stream.ForEachOps$ForEachOp.evaluateParallel(ForEachOps.java:159)
> 2022-03-17T10:27:56.1383409Z Mar 17 10:27:56  at 
> java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateParallel(ForEachOps.java:173)
> 2022-03-17T10:27:56.1384358Z Mar 17 10:27:56  at 
> java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:233)
> 2022-03-17T10:27:56.1385680Z Mar 17 10:27:56  at 
> java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
> 2022-03-17T10:27:56.1386625Z Mar 17 10:27:56  at 
> java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:650)
> 2022-03-17T10:27:56.1387496Z Mar 17 10:27:56  at 
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl.startKafkaContainerCluster(KafkaTestEnvironmentImpl.java:410)
> 2022-03-17T10:27:56.1388721Z Mar 17 10:27:56  at 
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl.prepare(KafkaTestEnvironmentImpl.java:106)
> 2022-03-17T10:27:56.1389705Z Mar 17 10:27:56  at 
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase.startClusters(KafkaTestBase.java:159)
> 2022-03-17T10:27:56.1390910Z Mar 17 10:27:56  at 
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase.startClusters(KafkaTestBase.java:142)
> 2022-03-17T10:27:56.1392365Z Mar 17 10:27:56  at 
> org.apache.flink.streaming.connectors.kafka.KafkaMigrationTestBase.testRestoreProducer(KafkaMigrationTestBase.java:134)
> 2022-03-17T10:27:56.1393179Z Mar 17 10:27:56  at 
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2022-03-17T10:27:56.1393963Z Mar 17 10:27:56  at 
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2022-03-17T10:27:56.1394714Z Mar 17 10:27:56  at 
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2022-03-17T10:27:56.1395908Z Mar 17 10:27:56  at 
> java.lang.reflect.Method.invoke(Method.java:498)
> 2022-03-17T10:27:56.1397053Z Mar 17 10:27:56  at 
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> 2022-03-17T10:27:56.1398364Z Mar 17 10:27:56  at 
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 2022-03-17T10:27:56.1399604Z Mar 17 10:27:56  at 
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
> 2022-03-17T10:27:56.1400818Z Mar 17 10:27:56

[jira] [Updated] (FLINK-26724) FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer failed on azure due to Container startup failed

2022-07-05 Thread Flink Jira Bot (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-26724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Flink Jira Bot updated FLINK-26724:
---
Labels: stale-major test-stability  (was: test-stability)

I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help 
the community manage its development. I see this issues has been marked as 
Major but is unassigned and neither itself nor its Sub-Tasks have been updated 
for 60 days. I have gone ahead and added a "stale-major" to the issue". If this 
ticket is a Major, please either assign yourself or give an update. Afterwards, 
please remove the label or in 7 days the issue will be deprioritized.


> FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer failed on azure 
> due to Container startup failed
> ---
>
> Key: FLINK-26724
> URL: https://issues.apache.org/jira/browse/FLINK-26724
> Project: Flink
>  Issue Type: Bug
>  Components: Connectors / Kafka
>Affects Versions: 1.15.0, 1.16.0
>Reporter: Yun Gao
>Priority: Major
>  Labels: stale-major, test-stability
>
> {code:java}
> 2022-03-17T10:27:56.1372771Z Mar 17 10:27:56 
> org.testcontainers.containers.ContainerLaunchException: Container startup 
> failed
> 2022-03-17T10:27:56.1373469Z Mar 17 10:27:56  at 
> org.testcontainers.containers.GenericContainer.doStart(GenericContainer.java:336)
> 2022-03-17T10:27:56.1376022Z Mar 17 10:27:56  at 
> org.testcontainers.containers.GenericContainer.start(GenericContainer.java:317)
> 2022-03-17T10:27:56.1376901Z Mar 17 10:27:56  at 
> java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
> 2022-03-17T10:27:56.1377769Z Mar 17 10:27:56  at 
> java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
> 2022-03-17T10:27:56.1378489Z Mar 17 10:27:56  at 
> java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
> 2022-03-17T10:27:56.1379198Z Mar 17 10:27:56  at 
> java.util.stream.ForEachOps$ForEachTask.compute(ForEachOps.java:290)
> 2022-03-17T10:27:56.1379892Z Mar 17 10:27:56  at 
> java.util.concurrent.CountedCompleter.exec(CountedCompleter.java:731)
> 2022-03-17T10:27:56.1380595Z Mar 17 10:27:56  at 
> java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
> 2022-03-17T10:27:56.1381267Z Mar 17 10:27:56  at 
> java.util.concurrent.ForkJoinTask.doInvoke(ForkJoinTask.java:401)
> 2022-03-17T10:27:56.1381934Z Mar 17 10:27:56  at 
> java.util.concurrent.ForkJoinTask.invoke(ForkJoinTask.java:734)
> 2022-03-17T10:27:56.1382658Z Mar 17 10:27:56  at 
> java.util.stream.ForEachOps$ForEachOp.evaluateParallel(ForEachOps.java:159)
> 2022-03-17T10:27:56.1383409Z Mar 17 10:27:56  at 
> java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateParallel(ForEachOps.java:173)
> 2022-03-17T10:27:56.1384358Z Mar 17 10:27:56  at 
> java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:233)
> 2022-03-17T10:27:56.1385680Z Mar 17 10:27:56  at 
> java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
> 2022-03-17T10:27:56.1386625Z Mar 17 10:27:56  at 
> java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:650)
> 2022-03-17T10:27:56.1387496Z Mar 17 10:27:56  at 
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl.startKafkaContainerCluster(KafkaTestEnvironmentImpl.java:410)
> 2022-03-17T10:27:56.1388721Z Mar 17 10:27:56  at 
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl.prepare(KafkaTestEnvironmentImpl.java:106)
> 2022-03-17T10:27:56.1389705Z Mar 17 10:27:56  at 
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase.startClusters(KafkaTestBase.java:159)
> 2022-03-17T10:27:56.1390910Z Mar 17 10:27:56  at 
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase.startClusters(KafkaTestBase.java:142)
> 2022-03-17T10:27:56.1392365Z Mar 17 10:27:56  at 
> org.apache.flink.streaming.connectors.kafka.KafkaMigrationTestBase.testRestoreProducer(KafkaMigrationTestBase.java:134)
> 2022-03-17T10:27:56.1393179Z Mar 17 10:27:56  at 
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2022-03-17T10:27:56.1393963Z Mar 17 10:27:56  at 
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2022-03-17T10:27:56.1394714Z Mar 17 10:27:56  at 
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2022-03-17T10:27:56.1395908Z Mar 17 10:27:56  at 
> java.lang.reflect.Method.invoke(Method.java:498)
> 2022-03-17T10:27:56.1397053Z Mar 17 10:27:56  at 
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> 2022-03-17T10:27:56.1398364Z Mar 17 10:27:56  at 
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 2022-03-17T10:27:56.1399604Z Mar 17

[jira] [Updated] (FLINK-26724) FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer failed on azure due to Container startup failed

2022-03-30 Thread Matthias Pohl (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-26724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Matthias Pohl updated FLINK-26724:
--
Affects Version/s: 1.16.0

> FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer failed on azure 
> due to Container startup failed
> ---
>
> Key: FLINK-26724
> URL: https://issues.apache.org/jira/browse/FLINK-26724
> Project: Flink
>  Issue Type: Bug
>  Components: Connectors / Kafka
>Affects Versions: 1.15.0, 1.16.0
>Reporter: Yun Gao
>Priority: Major
>  Labels: test-stability
>
> {code:java}
> 2022-03-17T10:27:56.1372771Z Mar 17 10:27:56 
> org.testcontainers.containers.ContainerLaunchException: Container startup 
> failed
> 2022-03-17T10:27:56.1373469Z Mar 17 10:27:56  at 
> org.testcontainers.containers.GenericContainer.doStart(GenericContainer.java:336)
> 2022-03-17T10:27:56.1376022Z Mar 17 10:27:56  at 
> org.testcontainers.containers.GenericContainer.start(GenericContainer.java:317)
> 2022-03-17T10:27:56.1376901Z Mar 17 10:27:56  at 
> java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
> 2022-03-17T10:27:56.1377769Z Mar 17 10:27:56  at 
> java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
> 2022-03-17T10:27:56.1378489Z Mar 17 10:27:56  at 
> java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
> 2022-03-17T10:27:56.1379198Z Mar 17 10:27:56  at 
> java.util.stream.ForEachOps$ForEachTask.compute(ForEachOps.java:290)
> 2022-03-17T10:27:56.1379892Z Mar 17 10:27:56  at 
> java.util.concurrent.CountedCompleter.exec(CountedCompleter.java:731)
> 2022-03-17T10:27:56.1380595Z Mar 17 10:27:56  at 
> java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
> 2022-03-17T10:27:56.1381267Z Mar 17 10:27:56  at 
> java.util.concurrent.ForkJoinTask.doInvoke(ForkJoinTask.java:401)
> 2022-03-17T10:27:56.1381934Z Mar 17 10:27:56  at 
> java.util.concurrent.ForkJoinTask.invoke(ForkJoinTask.java:734)
> 2022-03-17T10:27:56.1382658Z Mar 17 10:27:56  at 
> java.util.stream.ForEachOps$ForEachOp.evaluateParallel(ForEachOps.java:159)
> 2022-03-17T10:27:56.1383409Z Mar 17 10:27:56  at 
> java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateParallel(ForEachOps.java:173)
> 2022-03-17T10:27:56.1384358Z Mar 17 10:27:56  at 
> java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:233)
> 2022-03-17T10:27:56.1385680Z Mar 17 10:27:56  at 
> java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
> 2022-03-17T10:27:56.1386625Z Mar 17 10:27:56  at 
> java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:650)
> 2022-03-17T10:27:56.1387496Z Mar 17 10:27:56  at 
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl.startKafkaContainerCluster(KafkaTestEnvironmentImpl.java:410)
> 2022-03-17T10:27:56.1388721Z Mar 17 10:27:56  at 
> org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl.prepare(KafkaTestEnvironmentImpl.java:106)
> 2022-03-17T10:27:56.1389705Z Mar 17 10:27:56  at 
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase.startClusters(KafkaTestBase.java:159)
> 2022-03-17T10:27:56.1390910Z Mar 17 10:27:56  at 
> org.apache.flink.streaming.connectors.kafka.KafkaTestBase.startClusters(KafkaTestBase.java:142)
> 2022-03-17T10:27:56.1392365Z Mar 17 10:27:56  at 
> org.apache.flink.streaming.connectors.kafka.KafkaMigrationTestBase.testRestoreProducer(KafkaMigrationTestBase.java:134)
> 2022-03-17T10:27:56.1393179Z Mar 17 10:27:56  at 
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2022-03-17T10:27:56.1393963Z Mar 17 10:27:56  at 
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2022-03-17T10:27:56.1394714Z Mar 17 10:27:56  at 
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2022-03-17T10:27:56.1395908Z Mar 17 10:27:56  at 
> java.lang.reflect.Method.invoke(Method.java:498)
> 2022-03-17T10:27:56.1397053Z Mar 17 10:27:56  at 
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> 2022-03-17T10:27:56.1398364Z Mar 17 10:27:56  at 
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 2022-03-17T10:27:56.1399604Z Mar 17 10:27:56  at 
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
> 2022-03-17T10:27:56.1400818Z Mar 17 10:27:56  at 
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> 2022-03-17T10:27:56.1402257Z Mar 17 10:27:56  at 
> org.apache.flink.testutils.junit.RetryRule$RetryOnFailureStatement.evaluate(RetryRule.java:135)
> 2022-03-17T10:27:56.1403727Z Mar 17 10:27:56  at 
> org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
>