查询报错StackOverflowError: null

[yangluhang]

2025-07-18 16:16:08.486 | ERROR | org.springframework.kafka.KafkaListenerEndpointContainer#5-0-C-1 | o.s.k.l.KafkaMessageListenerContainer$ListenerConsumer: 149 | Stopping container due to an Error
java.lang.StackOverflowError: null
at com.dji.auto.infra.asset.domain.lineage.service.AssetLineageService.findAllResultAssetIdsByRebuildAssetId(AssetLineageService.java:106) ~[classes!/:3.9.54]
at com.dji.auto.infra.asset.domain.indicators.service.RebuildAssetIndexCalculationService.calculateGenerateResultAssetActivity(RebuildAssetIndexCalculationService.java:135) ~[classes!/:3.9.54]
at com.dji.auto.infra.asset.domain.indicators.service.RebuildAssetIndexCalculationService.process(RebuildAssetIndexCalculationService.java:57) ~[classes!/:3.9.54]
at com.dji.auto.infra.asset.application.event.subscribe.AssetIndexCalculationConsumer.handleRebuildDataIndexCalculation(AssetIndexCalculationConsumer.java:31) ~[classes!/:3.9.54]
at sun.reflect.GeneratedMethodAccessor285.invoke(Unknown Source) ~[?:?]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_111]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_111]
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) ~[spring-messaging-5.3.9.jar!/:5.3.9]
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) ~[spring-messaging-5.3.9.jar!/:5.3.9]
at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:330) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:87) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:52) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2139) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2120) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2039) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1967) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1853) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1543) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1190) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1087) [spring-kafka-2.6.9.jar!/:2.6.9]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_111]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_111]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_111]
2025-07-18 16:16:08.503 | INFO | org.springframework.kafka.KafkaListenerEndpointContainer#5-0-C-1 | o.a.k.c.c.i.ConsumerCoordinator: 307 | [Consumer clientId=consumer-data-asset-group-lifecycle-63, groupId=data-asset-group-lifecycle] Revoke previously assigned partitions rebuild.data.index.calculate.trigger-0
2025-07-18 16:16:08.503 | INFO | org.springframework.kafka.KafkaListenerEndpointContainer#5-0-C-1 | o.a.k.c.c.i.AbstractCoordinator: 1025 | [Consumer clientId=consumer-data-asset-group-lifecycle-63, groupId=data-asset-group-lifecycle] Member consumer-data-asset-group-lifecycle-63-fed8bcf6-1b44-41df-80ce-a76697db4a23 sending LeaveGroup request to coordinator 10.225.218.62:9092 (id: 2147483546 rack: null) due to the consumer unsubscribed from all topics
2025-07-18 16:16:08.504 | INFO | org.springframework.kafka.KafkaListenerEndpointContainer#5-0-C-1 | o.a.k.c.c.KafkaConsumer: 1074 | [Consumer clientId=consumer-data-asset-group-lifecycle-63, groupId=data-asset-group-lifecycle] Unsubscribed all topics or patterns and assigned partitions
2025-07-18 16:16:08.516 | ERROR | org.springframework.kafka.KafkaListenerEndpointContainer#5-0-C-1 | o.s.k.l.KafkaMessageListenerContainer: 149 | Error while stopping the container:
java.lang.StackOverflowError: null
at com.dji.auto.infra.asset.domain.lineage.service.AssetLineageService.findAllResultAssetIdsByRebuildAssetId(AssetLineageService.java:106) ~[classes!/:3.9.54]
at com.dji.auto.infra.asset.domain.indicators.service.RebuildAssetIndexCalculationService.calculateGenerateResultAssetActivity(RebuildAssetIndexCalculationService.java:135) ~[classes!/:3.9.54]
at com.dji.auto.infra.asset.domain.indicators.service.RebuildAssetIndexCalculationService.process(RebuildAssetIndexCalculationService.java:57) ~[classes!/:3.9.54]
at com.dji.auto.infra.asset.application.event.subscribe.AssetIndexCalculationConsumer.handleRebuildDataIndexCalculation(AssetIndexCalculationConsumer.java:31) ~[classes!/:3.9.54]
at sun.reflect.GeneratedMethodAccessor285.invoke(Unknown Source) ~[?:?]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_111]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_111]
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) ~[spring-messaging-5.3.9.jar!/:5.3.9]
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) ~[spring-messaging-5.3.9.jar!/:5.3.9]
at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:330) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:87) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:52) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2139) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2120) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2039) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1967) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1853) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1543) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1190) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1087) ~[spring-kafka-2.6.9.jar!/:2.6.9]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_111]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_111]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_111]
2025-07-18 16:16:10.238 | INFO | org.springframework.kafka.KafkaListenerEndpointContainer#4-

[yangluhang]

SQL就是一个单步查询，消费线程也是一个，跑着跑着就报错了

[CorvusYe]

版本号不是最新的吧

[CorvusYe]

#344

可能这一条的修复方式，跟底下的issue提到的临时解决方案会有一些帮助

[yangluhang]

使用的是1.3.0版本