[ https://issues.apache.org/jira/browse/FLINK-16456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Robert Metzger reassigned FLINK-16456: -------------------------------------- Assignee: Robert Metzger > Heavy deployment end-to-end test fails with OutOfMemoryError on JDK11 > --------------------------------------------------------------------- > > Key: FLINK-16456 > URL: https://issues.apache.org/jira/browse/FLINK-16456 > Project: Flink > Issue Type: Bug > Components: Tests > Reporter: Robert Metzger > Assignee: Robert Metzger > Priority: Major > Labels: test-stability > > Example: > https://dev.azure.com/rmetzger/Flink/_build/results?buildId=5990&view=logs&j=6caf31d6-847a-526e-9624-468e053467d6&t=7d4f7375-52df-5ce0-457f-b2ffbb2289a4 > Full logs: > {code} > 2020-03-06T02:06:40.0854061Z > ============================================================================== > 2020-03-06T02:06:40.0854897Z Running 'Heavy deployment end-to-end test' > 2020-03-06T02:06:40.0855434Z > ============================================================================== > 2020-03-06T02:06:40.0879460Z TEST_DATA_DIR: > /home/vsts/work/1/s/flink-end-to-end-tests/test-scripts/temp-test-directory-40087556829 > 2020-03-06T02:06:42.9071078Z Flink dist directory: > /home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT > 2020-03-06T02:06:43.0165322Z Starting cluster. > 2020-03-06T02:06:43.3033440Z Starting standalonesession daemon on host > fv-az655. > 2020-03-06T02:06:47.4295013Z Starting taskexecutor daemon on host fv-az655. > 2020-03-06T02:06:47.5642249Z Waiting for Dispatcher REST endpoint to come > up... > 2020-03-06T02:06:48.9222210Z Waiting for Dispatcher REST endpoint to come > up... > 2020-03-06T02:06:49.9999171Z Waiting for Dispatcher REST endpoint to come > up... > 2020-03-06T02:06:51.0875110Z Waiting for Dispatcher REST endpoint to come > up... > 2020-03-06T02:06:52.1357983Z Dispatcher REST endpoint is up. > 2020-03-06T02:06:52.1359104Z Start 4 more task managers > 2020-03-06T02:06:54.0539574Z [INFO] 1 instance(s) of taskexecutor are already > running on fv-az655. > 2020-03-06T02:06:54.0555611Z Starting taskexecutor daemon on host fv-az655. > 2020-03-06T02:06:58.3302348Z [INFO] 2 instance(s) of taskexecutor are already > running on fv-az655. > 2020-03-06T02:06:58.3332574Z Starting taskexecutor daemon on host fv-az655. > 2020-03-06T02:07:03.1996934Z [INFO] 3 instance(s) of taskexecutor are already > running on fv-az655. > 2020-03-06T02:07:03.2008989Z Starting taskexecutor daemon on host fv-az655. > 2020-03-06T02:07:08.1889175Z [INFO] 4 instance(s) of taskexecutor are already > running on fv-az655. > 2020-03-06T02:07:08.1924895Z Starting taskexecutor daemon on host fv-az655. > 2020-03-06T02:07:11.4246015Z WARNING: An illegal reflective access operation > has occurred > 2020-03-06T02:07:11.4248047Z WARNING: Illegal reflective access by > org.apache.hadoop.security.authentication.util.KerberosUtil > (file:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/lib/flink-shaded-hadoop-2-uber-2.8.3-10.0.jar) > to method sun.security.krb5.Config.getInstance() > 2020-03-06T02:07:11.4249610Z WARNING: Please consider reporting this to the > maintainers of org.apache.hadoop.security.authentication.util.KerberosUtil > 2020-03-06T02:07:11.4250537Z WARNING: Use --illegal-access=warn to enable > warnings of further illegal reflective access operations > 2020-03-06T02:07:11.4251120Z WARNING: All illegal access operations will be > denied in a future release > 2020-03-06T02:07:19.2044003Z Job has been submitted with JobID > 0e8275e9837d3d8c6af63f96de5a412d > 2020-03-06T02:09:13.1583035Z > 2020-03-06T02:09:13.1588601Z > ------------------------------------------------------------ > 2020-03-06T02:09:13.1591628Z The program finished with the following > exception: > 2020-03-06T02:09:13.1593934Z > 2020-03-06T02:09:13.1598865Z > org.apache.flink.client.program.ProgramInvocationException: The main method > caused an error: org.apache.flink.client.program.ProgramInvocationException: > Job failed (JobID: 0e8275e9837d3d8c6af63f96de5a412d) > 2020-03-06T02:09:13.1602462Z at > org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:335) > 2020-03-06T02:09:13.1618004Z at > org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:205) > 2020-03-06T02:09:13.1621120Z at > org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:138) > 2020-03-06T02:09:13.1624030Z at > org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:664) > 2020-03-06T02:09:13.1627101Z at > org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:213) > 2020-03-06T02:09:13.1633089Z at > org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:895) > 2020-03-06T02:09:13.1636423Z at > org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:968) > 2020-03-06T02:09:13.1639232Z at > java.base/java.security.AccessController.doPrivileged(Native Method) > 2020-03-06T02:09:13.1642291Z at > java.base/javax.security.auth.Subject.doAs(Subject.java:423) > 2020-03-06T02:09:13.1645255Z at > org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1836) > 2020-03-06T02:09:13.1648026Z at > org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) > 2020-03-06T02:09:13.1650561Z at > org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:968) > 2020-03-06T02:09:13.1654121Z Caused by: > java.util.concurrent.ExecutionException: > org.apache.flink.client.program.ProgramInvocationException: Job failed > (JobID: 0e8275e9837d3d8c6af63f96de5a412d) > 2020-03-06T02:09:13.1657096Z at > java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395) > 2020-03-06T02:09:13.1661419Z at > java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1999) > 2020-03-06T02:09:13.1663973Z at > org.apache.flink.streaming.api.environment.StreamContextEnvironment.execute(StreamContextEnvironment.java:83) > 2020-03-06T02:09:13.1666679Z at > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1619) > 2020-03-06T02:09:13.1670258Z at > org.apache.flink.deployment.HeavyDeploymentStressTestProgram.main(HeavyDeploymentStressTestProgram.java:70) > 2020-03-06T02:09:13.1673776Z at > java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > 2020-03-06T02:09:13.1676775Z at > java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > 2020-03-06T02:09:13.1680182Z at > java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > 2020-03-06T02:09:13.1683585Z at > java.base/java.lang.reflect.Method.invoke(Method.java:566) > 2020-03-06T02:09:13.1687024Z at > org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:321) > 2020-03-06T02:09:13.1690459Z ... 11 more > 2020-03-06T02:09:13.1694521Z Caused by: > org.apache.flink.client.program.ProgramInvocationException: Job failed > (JobID: 0e8275e9837d3d8c6af63f96de5a412d) > 2020-03-06T02:09:13.1699478Z at > org.apache.flink.client.deployment.ClusterClientJobClientAdapter.lambda$getJobExecutionResult$6(ClusterClientJobClientAdapter.java:112) > 2020-03-06T02:09:13.1705394Z at > java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:642) > 2020-03-06T02:09:13.1710044Z at > java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) > 2020-03-06T02:09:13.1713603Z at > java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073) > 2020-03-06T02:09:13.1741956Z at > org.apache.flink.client.program.rest.RestClusterClient.lambda$pollResourceAsync$21(RestClusterClient.java:565) > 2020-03-06T02:09:13.1778690Z at > java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859) > 2020-03-06T02:09:13.1780421Z at > java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837) > 2020-03-06T02:09:13.1781249Z at > java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) > 2020-03-06T02:09:13.1782242Z at > java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073) > 2020-03-06T02:09:13.1782931Z at > org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$8(FutureUtils.java:291) > 2020-03-06T02:09:13.1783771Z at > java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859) > 2020-03-06T02:09:13.1784480Z at > java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837) > 2020-03-06T02:09:13.1788206Z at > java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) > 2020-03-06T02:09:13.1789279Z at > java.base/java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:610) > 2020-03-06T02:09:13.1794328Z at > java.base/java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1085) > 2020-03-06T02:09:13.1795887Z at > java.base/java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:478) > 2020-03-06T02:09:13.1799443Z at > java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) > 2020-03-06T02:09:13.1800381Z at > java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) > 2020-03-06T02:09:13.1801261Z at > java.base/java.lang.Thread.run(Thread.java:834) > 2020-03-06T02:09:13.1802541Z Caused by: > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > 2020-03-06T02:09:13.1803488Z at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:147) > 2020-03-06T02:09:13.1805884Z at > org.apache.flink.client.deployment.ClusterClientJobClientAdapter.lambda$getJobExecutionResult$6(ClusterClientJobClientAdapter.java:110) > 2020-03-06T02:09:13.1816696Z ... 18 more > 2020-03-06T02:09:13.1817310Z Caused by: > org.apache.flink.runtime.JobException: Recovery is suppressed by > FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=3, > backoffTimeMS=0) > 2020-03-06T02:09:13.1818478Z at > org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:110) > 2020-03-06T02:09:13.1819521Z at > org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:76) > 2020-03-06T02:09:13.1820834Z at > org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:190) > 2020-03-06T02:09:13.1821764Z at > org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:184) > 2020-03-06T02:09:13.1822544Z at > org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:178) > 2020-03-06T02:09:13.1823296Z at > org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:505) > 2020-03-06T02:09:13.1824014Z at > org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:383) > 2020-03-06T02:09:13.1824823Z at > jdk.internal.reflect.GeneratedMethodAccessor22.invoke(Unknown Source) > 2020-03-06T02:09:13.1831152Z at > java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > 2020-03-06T02:09:13.1831904Z at > java.base/java.lang.reflect.Method.invoke(Method.java:566) > 2020-03-06T02:09:13.1832686Z at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:279) > 2020-03-06T02:09:13.1835462Z at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:194) > 2020-03-06T02:09:13.1836161Z at > org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74) > 2020-03-06T02:09:13.1843413Z at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152) > 2020-03-06T02:09:13.1856462Z at > akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) > 2020-03-06T02:09:13.1859425Z at > akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21) > 2020-03-06T02:09:13.1862822Z at > scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123) > 2020-03-06T02:09:13.1864340Z at > akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21) > 2020-03-06T02:09:13.1865122Z at > scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170) > 2020-03-06T02:09:13.1865885Z at > scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) > 2020-03-06T02:09:13.1866597Z at > scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) > 2020-03-06T02:09:13.1870122Z at > akka.actor.Actor$class.aroundReceive(Actor.scala:517) > 2020-03-06T02:09:13.1874876Z at > akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225) > 2020-03-06T02:09:13.1875638Z at > akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) > 2020-03-06T02:09:13.1876331Z at > akka.actor.ActorCell.invoke(ActorCell.scala:561) > 2020-03-06T02:09:13.1877301Z at > akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) > 2020-03-06T02:09:13.1881571Z at akka.dispatch.Mailbox.run(Mailbox.scala:225) > 2020-03-06T02:09:13.1882249Z at akka.dispatch.Mailbox.exec(Mailbox.scala:235) > 2020-03-06T02:09:13.1889904Z at > akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > 2020-03-06T02:09:13.1894764Z at > akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > 2020-03-06T02:09:13.1921746Z at > akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > 2020-03-06T02:09:13.1936050Z at > akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > 2020-03-06T02:09:13.1940032Z Caused by: > org.apache.flink.runtime.io.network.netty.exception.LocalTransportException: > Sending the partition request to '10.1.0.4/10.1.0.4:45911' failed. > 2020-03-06T02:09:13.1940803Z at > org.apache.flink.runtime.io.network.netty.NettyPartitionRequestClient$1.operationComplete(NettyPartitionRequestClient.java:124) > 2020-03-06T02:09:13.1941473Z at > org.apache.flink.runtime.io.network.netty.NettyPartitionRequestClient$1.operationComplete(NettyPartitionRequestClient.java:115) > 2020-03-06T02:09:13.1964619Z at > org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:500) > 2020-03-06T02:09:13.1965592Z at > org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:474) > 2020-03-06T02:09:13.1966540Z at > org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:413) > 2020-03-06T02:09:13.1967310Z at > org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:538) > 2020-03-06T02:09:13.1967893Z at > org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:531) > 2020-03-06T02:09:13.1968496Z at > org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:111) > 2020-03-06T02:09:13.2061660Z at > org.apache.flink.shaded.netty4.io.netty.util.internal.PromiseNotificationUtil.tryFailure(PromiseNotificationUtil.java:64) > 2020-03-06T02:09:13.2062676Z at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.notifyOutboundHandlerException(AbstractChannelHandlerContext.java:818) > 2020-03-06T02:09:13.2063884Z at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:718) > 2020-03-06T02:09:13.2064648Z at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:708) > 2020-03-06T02:09:13.2065474Z at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.access$1700(AbstractChannelHandlerContext.java:56) > 2020-03-06T02:09:13.2066255Z at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1102) > 2020-03-06T02:09:13.2067091Z at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1149) > 2020-03-06T02:09:13.2068087Z at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1073) > 2020-03-06T02:09:13.2068872Z at > org.apache.flink.shaded.netty4.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163) > 2020-03-06T02:09:13.2069624Z at > org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:416) > 2020-03-06T02:09:13.2070306Z at > org.apache.flink.shaded.netty4.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:331) > 2020-03-06T02:09:13.2070995Z at > org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918) > 2020-03-06T02:09:13.2071682Z at > org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) > 2020-03-06T02:09:13.2074112Z at > java.base/java.lang.Thread.run(Thread.java:834) > 2020-03-06T02:09:13.2080865Z Caused by: java.io.IOException: Error while > serializing message: > PartitionRequest(e31c6619b12f95de209b79116518f862@d8284ea36fe919a6f045c7e3c9d6f8a8:0:2) > 2020-03-06T02:09:13.2084207Z at > org.apache.flink.runtime.io.network.netty.NettyMessage$NettyMessageEncoder.write(NettyMessage.java:177) > 2020-03-06T02:09:13.2087709Z at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:716) > 2020-03-06T02:09:13.2096874Z ... 11 more > 2020-03-06T02:09:13.2102146Z Caused by: java.io.IOException: > java.lang.OutOfMemoryError: Direct buffer memory > 2020-03-06T02:09:13.2108955Z at > org.apache.flink.runtime.io.network.netty.NettyMessage$PartitionRequest.write(NettyMessage.java:497) > 2020-03-06T02:09:13.2112895Z at > org.apache.flink.runtime.io.network.netty.NettyMessage$NettyMessageEncoder.write(NettyMessage.java:174) > 2020-03-06T02:09:13.2115899Z ... 12 more > 2020-03-06T02:09:13.2119089Z Caused by: java.lang.OutOfMemoryError: Direct > buffer memory > 2020-03-06T02:09:13.2123496Z at > java.base/java.nio.Bits.reserveMemory(Bits.java:175) > 2020-03-06T02:09:13.2138944Z at > java.base/java.nio.DirectByteBuffer.<init>(DirectByteBuffer.java:118) > 2020-03-06T02:09:13.2145321Z at > java.base/java.nio.ByteBuffer.allocateDirect(ByteBuffer.java:317) > 2020-03-06T02:09:13.2145859Z at > org.apache.flink.shaded.netty4.io.netty.buffer.PoolArena$DirectArena.allocateDirect(PoolArena.java:772) > 2020-03-06T02:09:13.2153742Z at > org.apache.flink.shaded.netty4.io.netty.buffer.PoolArena$DirectArena.newChunk(PoolArena.java:748) > 2020-03-06T02:09:13.2154327Z at > org.apache.flink.shaded.netty4.io.netty.buffer.PoolArena.allocateNormal(PoolArena.java:245) > 2020-03-06T02:09:13.2154884Z at > org.apache.flink.shaded.netty4.io.netty.buffer.PoolArena.allocate(PoolArena.java:215) > 2020-03-06T02:09:13.2155419Z at > org.apache.flink.shaded.netty4.io.netty.buffer.PoolArena.allocate(PoolArena.java:147) > 2020-03-06T02:09:13.2197616Z at > org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator.newDirectBuffer(PooledByteBufAllocator.java:342) > 2020-03-06T02:09:13.2202548Z at > org.apache.flink.shaded.netty4.io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:187) > 2020-03-06T02:09:13.2203453Z at > org.apache.flink.shaded.netty4.io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:178) > 2020-03-06T02:09:13.2204077Z at > org.apache.flink.runtime.io.network.netty.NettyMessage.allocateBuffer(NettyMessage.java:148) > 2020-03-06T02:09:13.2215990Z at > org.apache.flink.runtime.io.network.netty.NettyMessage.allocateBuffer(NettyMessage.java:111) > 2020-03-06T02:09:13.2216595Z at > org.apache.flink.runtime.io.network.netty.NettyMessage$PartitionRequest.write(NettyMessage.java:482) > 2020-03-06T02:09:13.2217039Z ... 13 more > 2020-03-06T02:09:13.2545683Z [FAIL] Test script contains errors. > 2020-03-06T02:09:13.2641336Z Checking of logs skipped. > 2020-03-06T02:09:13.2641873Z > 2020-03-06T02:09:13.2643137Z [FAIL] 'Heavy deployment end-to-end test' failed > after 2 minutes and 31 seconds! Test exited with exit code 1 > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)