请稍等 ...

java.lang.OutOfMemoryError: Java heap space

java.lang.OutOfMemoryError: Java heap space
at java.util.Arrays.copyOf(Arrays.java:3236)
at java.io.ByteArrayOutputStream.grow(ByteArrayOutputStream.java:118)
at java.io.ByteArrayOutputStream.ensureCapacity(ByteArrayOutputStream.java:93)
at java.io.ByteArrayOutputStream.write(ByteArrayOutputStream.java:153)
at java.io.ObjectOutputStream $B l o c k D a t a O u t p u t S t r e a m . d r a i n (O b j e c t O u t p u t S t r e a m . j a v a : 1877) a t j a v a . i o . O b j e c t O u t p u t S t r e a m$ BlockDataOutputStream.setBlockDataMode(ObjectOutputStream.java:1786)
at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1189)
at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:348)
at org.apache.flink.util.InstantiationUtil.serializeObject(InstantiationUtil.java:534)
at org.apache.flink.util.SerializedValue.(SerializedValue.java:52)
at org.apache.flink.runtime.accumulators.AccumulatorSnapshot.(AccumulatorSnapshot.java:51)
at org.apache.flink.runtime.accumulators.AccumulatorRegistry.getSnapshot(AccumulatorRegistry.java:57)
at org.apache.flink.runtime.taskexecutor.TaskExecutor.unregisterTaskAndNotifyFinalState(TaskExecutor.java:1352)
at org.apache.flink.runtime.taskexecutor.TaskExecutor.access $2200 (T a s k E x e c u t o r . j a v a : 138) a t o r g . a p a c h e . f l i n k . r u n t i m e . t a s k e x e c u t o r . T a s k E x e c u t o r$ TaskManagerActionsImpl.lambda$updateTaskExecutionState $1 (T a s k E x e c u t o r . j a v a : 1591) a t o r g . a p a c h e . f l i n k . r u n t i m e . t a s k e x e c u t o r . T a s k E x e c u t o r$ TaskManagerActionsImpl $KaTeX parse error: $ within math mode$ anonfun$receive $1 . a p p l y O r E l s e (U n t y p e d A c t o r . s c a l a : 165) a t a k k a . a c t o r . A c t o r$ class.aroundReceive(Actor.scala:502)
at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:95)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
at akka.actor.ActorCell.invoke(ActorCell.scala:495)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
at akka.dispatch.Mailbox.run(Mailbox.scala:224)
at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)