2026-04-23 11:59:45.634 StreamPark [streampark-flink-app-watching-7] ERROR o.a.s.c.c.task.FlinkAppHttpWatcher:330 - get flink jobOverview error: Expected one result (or null) to be returned by selectOne(), but found: 721
org.apache.ibatis.exceptions.TooManyResultsException: Expected one result (or null) to be returned by selectOne(), but found: 721
at com.baomidou.mybatisplus.core.mapper.BaseMapper.selectOne(BaseMapper.java:177)
at java.base/java.lang.invoke.MethodHandle.invokeWithArguments(MethodHandle.java:710)
at com.baomidou.mybatisplus.core.override.MybatisMapperProxy$DefaultMethodInvoker.invoke(MybatisMapperProxy.java:162)
at com.baomidou.mybatisplus.core.override.MybatisMapperProxy.invoke(MybatisMapperProxy.java:89)
at com.sun.proxy.$Proxy111.selectOne(Unknown Source)
at com.baomidou.mybatisplus.extension.conditions.query.ChainQuery.lambda$one$cd9f9c92$1(ChainQuery.java:48)
at com.baomidou.mybatisplus.extension.conditions.ChainWrapper.execute(ChainWrapper.java:63)
at com.baomidou.mybatisplus.extension.conditions.query.ChainQuery.one(ChainQuery.java:48)
at org.apache.streampark.console.core.service.impl.SavepointServiceImpl.getLatest(SavepointServiceImpl.java:239)
at org.apache.streampark.console.core.service.impl.SavepointServiceImpl$$FastClassBySpringCGLIB$$5fcde58d.invoke(<generated>)
at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163)
at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763)
at org.springframework.transaction.interceptor.TransactionInterceptor$1.proceedWithInvocation(TransactionInterceptor.java:123)
at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:388)
at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:119)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763)
at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:708)
at org.apache.streampark.console.core.service.impl.SavepointServiceImpl$$EnhancerBySpringCGLIB$$415b0796.getLatest(<generated>)
at org.apache.streampark.console.core.task.CheckpointProcessor.lambda$getLatestCheckpointId$1(CheckpointProcessor.java:163)
at com.github.benmanes.caffeine.cache.BoundedLocalCache.lambda$doComputeIfAbsent$14(BoundedLocalCache.java:2343)
at java.base/java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1908)
at com.github.benmanes.caffeine.cache.BoundedLocalCache.doComputeIfAbsent(BoundedLocalCache.java:2341)
at com.github.benmanes.caffeine.cache.BoundedLocalCache.computeIfAbsent(BoundedLocalCache.java:2324)
at com.github.benmanes.caffeine.cache.LocalCache.computeIfAbsent(LocalCache.java:108)
at com.github.benmanes.caffeine.cache.LocalManualCache.get(LocalManualCache.java:62)
at org.apache.streampark.console.core.task.CheckpointProcessor.getLatestCheckpointId(CheckpointProcessor.java:160)
at org.apache.streampark.console.core.task.CheckpointProcessor.process(CheckpointProcessor.java:96)
at org.apache.streampark.console.core.task.CheckpointProcessor.lambda$process$0(CheckpointProcessor.java:76)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1541)
at org.apache.streampark.console.core.task.CheckpointProcessor.process(CheckpointProcessor.java:76)
at org.apache.streampark.console.core.task.FlinkAppHttpWatcher.handleCheckPoints(FlinkAppHttpWatcher.java:390)
at org.apache.streampark.console.core.task.FlinkAppHttpWatcher.getFromFlinkRestApi(FlinkAppHttpWatcher.java:328)
at org.apache.streampark.console.core.task.FlinkAppHttpWatcher.lambda$watch$2(FlinkAppHttpWatcher.java:220)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
Search before asking
Java Version
jdk 11.0.27
streampark 2.1.7
Scala Version
2.12.x
StreamPark Version
2.1.5
Flink Version
flink 1.19.3
Deploy mode
None
What happened
后台会重复刷类似的错误日志
Error Exception
Screenshots
No response
Are you willing to submit PR?
Code of Conduct