[server] Oversized lake metadata causes Coordinator disconnections from ZooKeeper and ISR update failures
Los mantenedores suelen responder en 1 día
@hanliu0830 ya está trabajando en esto.
Desde el 15/9/2026.
Evaluación
Este issue todavía no se ha evaluado.
Descripción
Search before asking
- I searched in the issues and found nothing similar.
Fluss version
0.9.0 (latest release)
Please describe the bug 🐞
Environment: Paimon lake tiering with deletion vectors (DV) enabled on the affected table; Fluss on Kubernetes; a three-node ZooKeeper 3.8.4 ensemble on VMs. The Coordinator runs on Linux amd64 with Java 17.0.7.
Observed trigger: During production lake tiering, historical lake snapshot metadata kept accumulating under /<cluster>/tabletservers/tables/<table-id>/laketable. The node held 5,091 snapshot entries (1,048,318 bytes). The next complete setData request was 1,048,596 bytes, exceeding the ZooKeeper server's jute.maxbuffer=1048575.
Expected: Lake snapshot commits complete successfully and ISR updates remain stable.
Actual: ZooKeeper repeatedly closed the Coordinator connection. The Coordinator reported SUSPENDED and lost leadership; Tablets reported NOT_COORDINATOR_LEADER_EXCEPTION when updating ISR. All three ZooKeeper servers logged the following error (address redacted):
java.io.IOException: Len error. A message from <coordinator-address> with advertised length of 1048596 is either a malformed message or too large to process (length is greater than jute.maxbuffer=1048575)
After ZooKeeper connectivity recovered, Tablets continued reporting OPERATION_NOT_ATTEMPTED_EXCEPTION during ISR updates. These failures stopped after the Coordinator was restarted.
Solution
We recovered the cluster with the following temporary workaround:
- Set
-Djute.maxbuffer=104857600on all three ZooKeeper servers and restart them one at a time. - Restart the Coordinator, as ISR failures persisted after ZooKeeper connectivity recovered.
- Restart the lake tiering job.
ISR updates and lake snapshot commits resumed. No TabletServer restart was needed. Increasing the buffer limit restored service but did not resolve the metadata accumulation.
Related documentation issues:
- #4336
- #4338
Are you willing to submit a PR?
- I'm willing to submit a PR!
- Lenguaje dominante
- Java
- Estrellas
- 2.2k
- Forks
- 656
- Merge medio
- 1 d 21 h
- PR fusionados (30 d)
- 127
Preparar el entorno
- Sin Dockerfile ni archivo de Docker Compose
- Tiene una plantilla de pull request
- Sin guía de contribución
Primeros pasos
- Lee el issue completo y luego la guía de contribución del proyecto.
- Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
- Haz un fork del repositorio y trabaja en una rama.
- Abre un pull request que haga referencia al número del issue.
Más de apache/fluss
-
[lake/iceberg] Reserved write-mode properties can be set and reset through their `iceberg.` keyPosiblemente ocupada @aphenix-r7 la tomó hace 1 día. Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 82/100
apache/fluss#4658 · 1 comentario ·
Los mantenedores suelen responder en 1 día
-
[common] Decimal#hashCode is inconsistent with Decimal#equalsPosiblemente ocupada @firasbouzazi la tomó hace 13 días. Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100
apache/fluss#4538 · 1 comentario ·
Los mantenedores suelen responder en 1 día
-
[security] PlainSaslServerProvider conflicts with Hadoop SASL provider causing authentication failurePosiblemente ocupada @xinzhang-hello la tomó hace 18 días. Abierto
Dificultad 1/5 Menos de una hora Aptitud para principiantes 88/100
Los mantenedores suelen responder en 1 día
-
[server] KV snapshot scheduling stops permanently after a transient snapshot-init failurePosiblemente ocupada @zhang-arvin la tomó hace 18 días. Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 88/100
apache/fluss#4489 · 1 comentario ·
Los mantenedores suelen responder en 1 día
-
[docs] Document advertised-resource and ACL principal ignore-case optionsPosiblemente ocupada @EchoLee5 la tomó hace 30 días. Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 84/100
Los mantenedores suelen responder en 1 día
Todos los issues de apache/fluss
Issues similares
-
bug
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100
scylladb/scylla-cdc-source-connector#350 ·
Los mantenedores suelen responder en 1 día
-
agent:working documentation enhancement go:build lane:needs-decision
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100
Sanne/incus-spawn#1435 · 3 comentarios ·
Los mantenedores suelen responder en 1 día
-
area:shuffle bug priority:high requires-triage
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100
apache/datafusion-comet#7062 ·
Los mantenedores suelen responder en 1 día
-
wait for review
Dificultad 2/5 1-3 horas Aptitud para principiantes 68/100
Los mantenedores suelen responder en 1 día
-
enhancement good first issue up-for-grabs
Dificultad 2/5 1-3 horas Aptitud para principiantes 80/100
AnikethTS/ChangeRadar#22 ·
Los mantenedores suelen responder en 1 día