automq

automq copied to clipboard

[Enhancement] Add quota for low-priority controller mutations

3

### Who is this for and what problem do they have today? A large number of compaction or delete object requests may overload the controller event loop. We should add...

ShadowySpirits

feat(metadata): adding ControllerTimeoutDecorator to prevent overloading of the main Controller

4

PR solves the issue https://github.com/AutoMQ/automq/issues/1446 Added a unit test to test a new functionality ### Committer Checklist (excluded from commit message) - [x] Verify design and implementation - [x] Verify...

DaniilRoman

feat(wal): reduce concurrent conflicts between block write operations and poll operations

12

[issue](https://github.com/AutoMQ/automq/issues/1550)

CLFutureX

[Enhancement] Reduce concurrent conflicts between block write operations and poll operations

3

**Background:** Currently, there exists intense concurrent competition between the write and poll operations of the block, which affects the write performance of the Write-Ahead Logging (WAL). path: com.automq.stream.s3.wal.impl.block.SlidingWindowService **Current Status:**...

CLFutureX

### Who is this for and what problem do they have today? ### Why is solving this problem impactful? ### Additional notes

vintagewang

[BUG] The localstack container can't be started when I install the automq with install_run.sh

1

### Version & Environment ### What went wrong? I can't install the automq in my vmware's virtual host。 ### What should have happened instead? ### How to reproduce the issue?...

xuqingkang

Refactored data clumps with the help of LLMs (research project)

3

Hello maintainers, I am conducting a master thesis project focused on enhancing code quality through automated refactoring of data clumps, assisted by Large Language Models (LLMs). Data clump definition A...

compf

# Why this patch we want to optimize the partition failover time. and we found the main part in partition clean shutdown failover is stream close. and the stream close...

lifepuzzlefun

log ```java [2024-07-22 10:30:21,309] ERROR Uncaught exception in scheduled task 'delete-file' (org.apache.kafka.server.util.KafkaScheduler) java.lang.OutOfMemoryError: Java heap space at com.fasterxml.jackson.core.util.ByteArrayBuilder.toByteArray(ByteArrayBuilder.java:163) at com.fasterxml.jackson.databind.ObjectWriter.writeValueAsBytes(ObjectWriter.java:1164) at kafka.log.streamaspect.ElasticLogMeta.encode(ElasticLogMeta.java:53) at kafka.log.streamaspect.ElasticLogSegmentManager.asyncPersistLogMeta(ElasticLogSegmentManager.java:80) at kafka.log.streamaspect.ElasticLogSegmentManager$EventListener.onEvent(ElasticLogSegmentManager.java:153) at kafka.log.streamaspect.ElasticLogSegment.deleteIfExists(ElasticLogSegment.java:410) at kafka.log.LocalLog$.$anonfun$deleteSegmentFiles$5(LocalLog.scala:950)...

lifepuzzlefun

llzcx