huhao0926

[PipelineOutputEmitter] kryo.serialize java.lang.OutOfMemoryError

7

**Describe the bug** LocalMode，consume kafka stream, exit with OutOfMemoryError 2025-04-10 14:16:44,143 [shuffle-writer-14-Message] ERROR ComponentUncaughtExceptionHandler:30 - FATAL exception in thread: shuffle-writer-14-Message com.antgroup.geaflow.common.exception.GeaflowRuntimeException: java.lang.OutOfMemoryError at com.antgroup.geaflow.cluster.collector.PipelineOutputEmitter$EmitterTask.run(PipelineOutputEmitter.java:200) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:750)...

**Describe the bug** A clear and concise description of what the bug is. when execute following gql: match (a:alert_6 where a.id='50988a0e257c6f8b0795da2ccf77c825')-[e1]->(m1:metric_6) let m1.contribution_metrics = metrics_contribution_rate((m1)-[e11 where type = 1]->(m11) =>...

[Console] The task has been STARTING and cannot be restarted or exited

1

**Describe the bug** I started an interactive query service, but my geaflow console service unexpectedly exited. After restarting the console process, the task status remained 'starting' and could not be...

### Initial Checks - [x] I have searched GitHub for a duplicate issue and I'm sure this is something new - [x] I have read and followed [the docs &...

[Agent] TypeError in Plan.replace_task(): takes 2 positional arguments but 3 were given

1

### Initial Checks - [x] I have searched GitHub for a duplicate issue and I'm sure this is something new - [x] I have read and followed [the docs &...

### Initial Checks - [x] I have searched GitHub for a duplicate issue and I'm sure this is something new - [x] I have read and followed [the docs &...

### Initial Checks - [ ] I have searched GitHub for a duplicate issue and I'm sure this is something new - [ ] I have read and followed [the...

在生产环境使用Brpc服务，启动多个Server，监听不同端口，代理相同的endpoint。 public class EchoServiceImpl implements EchoService { private static final Logger LOG = LoggerFactory.getLogger(EchoServiceImpl.class); private String name; public EchoServiceImpl(String name) {this.name = name;} @Override public Echo.EchoResponse echo(Echo.EchoRequest request) { LOG.info("my...