search

infinyon / fluvio

Lean and mean distributed stream processing system written in rust and web assembly. Alternative to Kafka + Flink in one.
https://www.fluvio.io/
Apache License 2.0
3.79k stars 500 forks source link

feat: upgrade cluster for local #4138

Closed fraidev closed 1 month ago

fraidev commented 1 month ago

Related:

Before:

▷ flvd cluster upgrade
SPU monitoring socket  /tmp/fluvio-spu.sock, can't be removed: No such file or directory (os error 2)
Uninstalled fluvio local components
📝 Running pre-flight checks
    ✅ Local Fluvio is not installed
    ❌ Check Clean Fluvio Local Installation failed Local Fluvio cluster wasn't deleted. Use 'resume' to resume created cluster or 'delete' before starting a new one
💔 Some pre-flight check failed!
Preflight check failed

After

Upgrade Local Fluvio cluster to version 0.11.12-dev-1? yes
Uninstalled fluvio local components
📝 Checking All Metadatas
✅ Checked All Metadata
🚀 Upgrading Local Fluvio cluster to 0.11.12-dev-1
🎉 Successfully upgraded Local Fluvio cluster to 0.11.12-dev-1
Run: fluvio cluster resume to start the cluster again,

Failure case:

Upgrade Local Fluvio cluster to version 0.11.12-dev-1? yes                                                                                                         
📝 Checking All Metadatas
💔 Failed to check metadata: loading metadata 'Mirror' from /Users/frai/.fluvio/data/metadata/Mirror/mac.yaml

New CI got one bug (fixed in the last commit):

image