2025-12-03 17:35:14,660 [Source: cayde_test_fluss_1202_t2[1] (1/1)#77] WARN  org.apache.flink.metrics.prometheus.PrometheusReporter        - There was a problem registering metric bytesPerRequest.
java.lang.NullPointerException: Cannot invoke "org.apache.flink.metrics.HistogramStatistics.getMin()" because "statistics" is null
	at org.apache.flink.metrics.prometheus.AbstractPrometheusReporter$HistogramSummaryProxy.addSamples(AbstractPrometheusReporter.java:404)
	at org.apache.flink.metrics.prometheus.AbstractPrometheusReporter$HistogramSummaryProxy.collect(AbstractPrometheusReporter.java:369)
	at io.prometheus.client.CollectorRegistry.collectorNames(CollectorRegistry.java:100)
	at io.prometheus.client.CollectorRegistry.register(CollectorRegistry.java:50)
	at io.prometheus.client.Collector.register(Collector.java:139)
	at org.apache.flink.metrics.prometheus.AbstractPrometheusReporter.notifyOfAddedMetric(AbstractPrometheusReporter.java:155)
	at org.apache.flink.runtime.metrics.MetricRegistryImpl.forAllReporters(MetricRegistryImpl.java:475)
	at org.apache.flink.runtime.metrics.MetricRegistryImpl.register(MetricRegistryImpl.java:395)
	at org.apache.flink.runtime.metrics.groups.AbstractMetricGroup.addMetric(AbstractMetricGroup.java:421)
	at org.apache.flink.runtime.metrics.groups.AbstractMetricGroup.histogram(AbstractMetricGroup.java:374)
	at org.apache.fluss.flink.metrics.FlinkMetricRegistry.registerMetric(FlinkMetricRegistry.java:128)
	at org.apache.fluss.flink.metrics.FlinkMetricRegistry.register(FlinkMetricRegistry.java:88)
	at org.apache.fluss.metrics.groups.AbstractMetricGroup.addMetric(AbstractMetricGroup.java:298)
	at org.apache.fluss.metrics.groups.AbstractMetricGroup.histogram(AbstractMetricGroup.java:250)
	at org.apache.fluss.client.metrics.ScannerMetricGroup.<init>(ScannerMetricGroup.java:76)
	at org.apache.fluss.client.table.scanner.log.LogScannerImpl.<init>(LogScannerImpl.java:94)
	at org.apache.fluss.client.table.scanner.TableScan.createLogScanner(TableScan.java:106)
	at org.apache.fluss.flink.source.reader.FlinkSourceSplitReader.<init>(FlinkSourceSplitReader.java:135)
	at org.apache.fluss.flink.source.reader.FlinkSourceReader.lambda$new$0(FlinkSourceReader.java:69)
	at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.createSplitFetcher(SplitFetcherManager.java:196)
	at org.apache.flink.connector.base.source.reader.fetcher.SingleThreadFetcherManager.addSplits(SingleThreadFetcherManager.java:107)
	at org.apache.flink.connector.base.source.reader.SourceReaderBase.addSplits(SourceReaderBase.java:242)
	at org.apache.flink.streaming.api.operators.SourceOperator.open(SourceOperator.java:349)
	at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:740)
	at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:715)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:681)
	at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:962)
	at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:928)
	at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:750)
	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:564)
	at java.base/java.lang.Thread.run(Thread.java:833)