📝 11 新 Issues
✅ 4 关闭
✨ 2 新 PRs
🎉 3 合并
⚠️ 重点关注
- ⚠️ Issue #2941 TabletServer 非正常关闭后因 EOFException 无法重启，建议提高优先级
💬 Issue/PR 动态
Issue 讨论
Issue #3254 FIP-24: Support tiering Fluss data to Hudi
- @fhan688: 创建子任务 #3258 实现 Hudi 模块
- @MaheshS08: 希望参与协作学习 Hudi 和 Fluss
Issue #3245 [test] Unstable test CoordinatorEventManagerTest.testMetricsUpdatedImmediatelyOnStartup
- @wuchong: 指出 #3210 修复未生效，请求查看
- @swuferhong: 表示将查看此不稳定测试问题
Issue #2829 [kv] Support elect standby replicas for primary key table
- @wuchong: 建议为旧表引入配置项保持向后兼容
- @swuferhong: 创建关联 issue #3253 跟踪兼容性
Issue #2007 Add missing authentication for RPC calls
- @vaibhavk1992: 已创建所有子任务，请求帮忙转换格式
Issue #3078 [server] Add authorization to databaseExists and tableExists RPC call…
- @vaibhavk1992: 感谢修复，计划周末处理其他 RPC 调用
- @wuchong: 建议先创建子任务再分别开 PR
Issue #2941 [server] TabletServer fails to restart after unclean shutdown due to EOFException in log recovery
- @fresh-borzoni: K8s 环境常见触发场景，建议提高优先级
Issue #3246 [server] Add authorization to databaseExists and tableExists RPC call
- @wuchong: 已在 PR #3078 中实现
Issue #3252 [test] Fix flaky CoordinatorEventManagerTest by isolating metric group instance
Issue #3237 [lake/iceberg] Remove unused includeColumnStats to reduce memory usage
- @zuston: 请求 @luoyuxia 帮助审阅
Issue #2972 [flink] Implement SupportsWatermarkPushDown for FlinkTableSource
- @loserwang1024: 询问合并前是否需要 rebase
Issue #3069 [client] Add validation for client.scanner.log.max-poll-records and client.connect-timeout
- @Prajwal-banakar: 关联 fluss-rust PR，请求审阅
Issue #3255 [test] Unstable test CoordinatorEventManagerTest.testMetricsUpdatedImmediatelyOnStartup
- @swuferhong: 已通过 #3252 修复，rebase main 即可
Issue #3132 [server] Optimize RemoteLogFetcher with async prefetch for recovery
- @Kaixuan-Duan: 感谢审阅，已处理所有评论并 rebase
Issue #3030 [server] Implement JBOD Phase 1 Local Multi-Directory Support
- @wuchong: 发现 InterruptedException 处理会抛 NPE
PR Review
PR #3151 [KV] Kvscan Server Side
- @wuchong: 多处改进：ScannerManager 应不可变、线程安全注解、领导权竞态、volatile 修饰符等
PR #3132 [server] Optimize RemoteLogFetcher with async prefetch for recovery
- @fresh-borzoni: 建议使用 fetchLogDataBarrier 钩子、修复取消竞态、添加中断检查
- @Kaixuan-Duan: 已采纳建议：添加中断检查、提取清理 helper
PR #3030 [server] Implement JBOD Phase 1 Local Multi-Directory Support
- @wuchong: 建议避免重复线程池、重构命名、处理目录锁定失败、优化 cacheSize 位置
PR #2942 [server] Fix TabletServer fails to restart after unclean shutdown due to EOFException in log recovery
- @fresh-borzoni: 指出顺序已反转、建议 Math.min 处理 recoveryPointCheckpoint
PR #3240 [spark] partition filter pushdown for non-lake log and kv tables
- @Yohahaha: 建议追加分区过滤信息、提取 description 到 FlussScan
PR #3238 [spark] lake table predicate pushdown
- @Yohahaha: 建议使用 Spark Logging 接口、更新 pushedPredicate
📝 新建 Issue/PR
Issues
- #3258 Introduce fluss-lake-hudi module and HudiLakeStorage @fhan688
- #3255 [test] Unstable test CoordinatorEventManagerTest.testMetricsUpdatedImmediatelyOnStartup @app/github-actions
- #3254 FIP-24: Support tiering Fluss data to Hudi @fhan688
- #3253 [kv] Add table configuration option to control standby replicas for backward compatibility @swuferhong
- #3251 [server] Add authorization to Remote Log & Tiering RPCs (commitRemoteLogManifest, notifyRemoteLogOffsets, lakeTieringHeartbeat) @vaibhavk1992
- #3250 [server] Add authorization to Snapshot Management RPCs (commitKvSnapshot, notifyKvSnapshotOffset, commitLakeTableSnapshot, notifyLakeTableOffset) @vaibhavk1992
- #3249 [server] Add authorization to Replication Control RPCs (notifyLeaderAndIsr, updateMetadata, stopReplica, adjustIsr) @vaibhavk1992
- #3248 [server] Add authorization to Snapshot Read Operations (getLatestKvSnapshots, getKvSnapshotMetadata, getLatestLakeSnapshot) @vaibhavk1992
- #3247 [server] Add authorization to Table Metadata Read Operations (getTableSchema, listPartitionInfos, listOffsets) @vaibhavk1992
- #3246 [server] Add authorization to databaseExists and tableExists RPC call @wuchong
- #3245 [test] Unstable test CoordinatorEventManagerTest.testMetricsUpdatedImmediatelyOnStartup @app/github-actions
Pull Requests
- #3257 [server] Add table-level config for standby replica with ALTER TABLE support @swuferhong
- #3256 [lake/hudi] Introduce fluss-lake-hudi module and HudiLakeStorage @fhan688
✅ 关闭 Issue/PR
已关闭 Issues
- #3255 [test] Unstable test CoordinatorEventManagerTest.testMetricsUpdatedImmediatelyOnStartup @app/github-actions
- #3246 [server] Add authorization to databaseExists and tableExists RPC call @wuchong
- #3245 [test] Unstable test CoordinatorEventManagerTest.testMetricsUpdatedImmediatelyOnStartup @app/github-actions
- #2828 Support elect standby replicas for primary key table @swuferhong
已合并 PRs
- #3252 [test] Fix flaky CoordinatorEventManagerTest by isolating metric group instance @swuferhong
- #3078 [server] Add authorization to databaseExists and tableExists RPC call… @vaibhavk1992
- #2829 [kv] Support elect standby replicas for primary key table @swuferhong