java.lang.RuntimeException: org.apache.beam.sdk.util.UserCodeException: java.lang.OutOfMemoryError: Java heap space
at com.google.cloud.dataflow.worker.GroupAlsoByWindowsParDoFn$1.output (GroupAlsoByWindowsParDoFn.java:182)
at com.google.cloud.dataflow.worker.GroupAlsoByWindowFnRunner$1.outputWindowedValue (GroupAlsoByWindowFnRunner.java:104)
at org.apache.beam.runners.core.ReduceFnRunner$2.output (ReduceFnRunner.java:1061)
at org.apache.beam.runners.core.ReduceFnContextFactory$OnTriggerContextImpl.output (ReduceFnContextFactory.java:428)
at org.apache.beam.runners.core.SystemReduceFn.onTrigger (SystemReduceFn.java:124)
at org.apache.beam.runners.core.ReduceFnRunner.onTrigger (ReduceFnRunner.java:1066)
at org.apache.beam.runners.core.ReduceFnRunner.emit (ReduceFnRunner.java:933)
at org.apache.beam.runners.core.ReduceFnRunner.onTimers (ReduceFnRunner.java:798)
at com.google.cloud.dataflow.worker.StreamingGroupAlsoByWindowViaWindowSetFn.processElement (StreamingGroupAlsoByWindowViaWindowSetFn.java:96)
at com.google.cloud.dataflow.worker.StreamingGroupAlsoByWindowViaWindowSetFn.processElement (StreamingGroupAlsoByWindowViaWindowSetFn.java:42)
at com.google.cloud.dataflow.worker.GroupAlsoByWindowFnRunner.invokeProcessElement (GroupAlsoByWindowFnRunner.java:117)
at com.google.cloud.dataflow.worker.GroupAlsoByWindowFnRunner.processElement (GroupAlsoByWindowFnRunner.java:74)
at org.apache.beam.runners.core.LateDataDroppingDoFnRunner.processElement (LateDataDroppingDoFnRunner.java:74)
at com.google.cloud.dataflow.worker.GroupAlsoByWindowsParDoFn.processElement (GroupAlsoByWindowsParDoFn.java:133)
at com.google.cloud.dataflow.worker.util.common.worker.ParDoOperation.process (ParDoOperation.java:48)
at com.google.cloud.dataflow.worker.util.common.worker.OutputReceiver.process (OutputReceiver.java:52)
at com.google.cloud.dataflow.worker.util.common.worker.ReadOperation.runReadLoop (ReadOperation.java:187)
at com.google.cloud.dataflow.worker.util.common.worker.ReadOperation.start (ReadOperation.java:148)
at com.google.cloud.dataflow.worker.util.common.worker.MapTaskExecutor.execute (MapTaskExecutor.java:68)
at com.google.cloud.dataflow.worker.StreamingDataflowWorker.process (StreamingDataflowWorker.java:1069)
at com.google.cloud.dataflow.worker.StreamingDataflowWorker.access$1000 (StreamingDataflowWorker.java:133)
at com.google.cloud.dataflow.worker.StreamingDataflowWorker$8.run (StreamingDataflowWorker.java:841)
at java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:617)
at java.lang.Thread.run (Thread.java:745)