FlinkSinkWriterTest.testSinkMetrics is unstable

[wuchong]

Search before asking

• I searched in the issues and found nothing similar.

Fluss version

main (development)

Please describe the bug 🐞

https://github.com/alibaba/fluss/actions/runs/13721569801/job/38378010397?pr=548

Error:  Tests run: 2, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 14.698 s <<< FAILURE! - in com.alibaba.fluss.connector.flink.sink.FlinkSinkWriterTest
Error:  com.alibaba.fluss.connector.flink.sink.FlinkSinkWriterTest.testSinkMetrics(String)[1]  Time elapsed: 0.08 s  <<< FAILURE!
java.lang.AssertionError: 

Expecting actual:
  0L
to be greater than:
  0L

	at com.alibaba.fluss.connector.flink.sink.FlinkSinkWriterTest.testSinkMetrics(FlinkSinkWriterTest.java:109)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:4[98](https://github.com/alibaba/fluss/actions/runs/13721569801/job/38378010397?pr=548#step:4:99))
	at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:727)
	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:[95](https://github.com/alibaba/fluss/actions/runs/13721569801/job/38378010397?pr=548#step:4:96))
	at org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
	at java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:189)
	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
	at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)

[INFO] Running com.alibaba.fluss.connector.flink.row.FlinkAsFlussRowTest
[INFO] Tests run: 16, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.013 s - in com.alibaba.fluss.connector.flink.row.FlinkAsFlussRowTest
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 17.53 s - in com.alibaba.fluss.connector.flink.source.lookup.FlinkLookupFunctionTest
[INFO] 
[INFO] Results:
[INFO] 
Error:  Failures: 
Error:    FlinkSinkWriterTest.testSinkMetrics:109 
Expecting actual:
  0L
to be greater than:
  0L

[INFO] 
Error:  Tests run: 60, Failures: 1, Errors: 0, Skipped: 0

Solution

No response

Are you willing to submit a PR?

• I'm willing to submit a PR!

[wuchong]

Another 2 instance:

https://github.com/alibaba/fluss/actions/runs/13722228288/job/38380151235?pr=548
https://github.com/alibaba/fluss/actions/runs/13722228288/job/38380151238?pr=548

[wuchong]

The reason is the duration of ProduceLog RPC is too short and it maybe 0 ms. I'm going to fix it.