Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-26335

prometheus/metrics - java.lang.OutOfMemoryError: Java heap space

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 1.14.3
    • None
    • Runtime / Metrics
    • None

    Description

       

      2022-02-22 14:39:33.782 INFO [org.apache.flink.streaming.runtime.operators.sink.AbstractStreamingCommitterHandler] - Committing the state for checkpoint 4
      2022-02-22 14:39:47.367 ERROR [org.apache.flink.runtime.util.ClusterUncaughtExceptionHandler] - WARNING: Thread 'prometheus-http-1-6' produced an uncaught exception. If you want to fail on uncaught exceptions, then configure cluster.uncaught-exception-handling accordingly
      java.lang.OutOfMemoryError: Java heap space
          at java.util.Arrays.copyOf(Unknown Source) ~[?:?]
          at java.io.ByteArrayOutputStream.grow(Unknown Source) ~[?:?]
          at java.io.ByteArrayOutputStream.ensureCapacity(Unknown Source) ~[?:?]
          at java.io.ByteArrayOutputStream.write(Unknown Source) ~[?:?]
          at sun.nio.cs.StreamEncoder.writeBytes(Unknown Source) ~[?:?]
          at sun.nio.cs.StreamEncoder.implWrite(Unknown Source) ~[?:?]
          at sun.nio.cs.StreamEncoder.implWrite(Unknown Source) ~[?:?]
          at sun.nio.cs.StreamEncoder.write(Unknown Source) ~[?:?]
          at sun.nio.cs.StreamEncoder.write(Unknown Source) ~[?:?]
          at java.io.OutputStreamWriter.write(Unknown Source) ~[?:?]
          at java.io.Writer.append(Unknown Source) ~[?:?]
          at io.prometheus.client.exporter.common.TextFormat.writeEscapedLabelValue(TextFormat.java:88) ~[flink-metrics-prometheus-1.14.3.jar:1.14.3]
          at io.prometheus.client.exporter.common.TextFormat.write004(TextFormat.java:42) ~[flink-metrics-prometheus-1.14.3.jar:1.14.3]
          at io.prometheus.client.exporter.HTTPServer$HTTPMetricHandler.handle(HTTPServer.java:60) ~[flink-metrics-prometheus-1.14.3.jar:1.14.3]
          at com.sun.net.httpserver.Filter$Chain.doFilter(Unknown Source) ~[jdk.httpserver:?]
          at sun.net.httpserver.AuthFilter.doFilter(Unknown Source) ~[jdk.httpserver:?]
          at com.sun.net.httpserver.Filter$Chain.doFilter(Unknown Source) ~[jdk.httpserver:?]
          at sun.net.httpserver.ServerImpl$Exchange$LinkHandler.handle(Unknown Source) ~[jdk.httpserver:?]
          at com.sun.net.httpserver.Filter$Chain.doFilter(Unknown Source) ~[jdk.httpserver:?]
          at sun.net.httpserver.ServerImpl$Exchange.run(Unknown Source) ~[jdk.httpserver:?]
          at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) ~[?:?]
          at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) ~[?:?]
          at java.lang.Thread.run(Unknown Source) [?:?]
      2022-02-22 14:40:32.668 INFO [org.apache.flink.connector.kafka.sink.FlinkKafkaInternalProducer] - Flushing new partitions// code placeholder
      

      Attachments

        Activity

          People

            Unassigned Unassigned
            mlnogueira Marcelo Nogueira
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: