| Batch savepoint output through DirectByteBuffer | 13 天前 |
| [fix] Rollback InternalMapState, unknown error occurred. | 1 个月前 |
| fix 安全扫描问题 | 15 天前 |
| SQL CP 功能相关 Co-authored-by: TideMacro<TideMacro@outlook.com> (cherry picked from commit eef068d1b495c0ea519ed235e5ad07b1e1e51fb0) | 1 个月前 |
| fix JD wordcount consistency | 6 天前 |
| [optimize] Optimize session window memory and performance. | 1 个月前 |
| Support for unaligned checkpoint restore with flink mode | 3 个月前 |
| serializer json | 3 个月前 |
| Sql场景rocksdb状态后端，kafka数据源，SP恢复性能优化 | 21 天前 |
| remove sensitive info | 5 天前 |
| update with yellow zone | 7 个月前 |
| fix review comments | 2 个月前 |
| support Rocksdb/PQ | 1 个月前 |
| update with yellow zone | 7 个月前 |
| 检视意见修改 | 1 个月前 |
| 创建savepoint | 4 个月前 |
| update with yellow zone | 7 个月前 |
| fix: add exception logging, capacity limit, include order, bit shift per PR review - Add INFO_RELEASE before all throw in WriteSavepointOutputStream, CreateSavepointOutputDirectBuffer, requireActivePatch/requireNoActivePatch - Add warning log in ReleaseSavepointOutputDirectBuffer when JNI attach fails - Add 4MB max capacity check in CreateSavepointOutputDirectBuffer - Add warning logs in releaseDirectBuffer/growBuffer catch blocks - Reorder includes: system headers before project headers - Replace multiply/divide by 2 with bit shift (<< 1 / >> 1) - Add 'Error:' prefix to INFO_RELEASE in growBuffer failure | 12 天前 |
| update with yellow zone | 7 个月前 |
| fix inflightbuffers persistence | 3 个月前 |
| sp数据存储问题解决 | 3 个月前 |
| sp数据存储问题解决 | 3 个月前 |
| sp数据存储问题解决 | 3 个月前 |
| sp数据存储问题解决 | 3 个月前 |
| sp数据存储问题解决 | 3 个月前 |
| fix inflightbuffers persistence | 3 个月前 |
| update with yellow zone | 7 个月前 |
| 创建savepoint | 4 个月前 |
| update with yellow zone | 7 个月前 |
| [fix] Fix the creation logic and implementation logic of priority queue and timer. | 1 个月前 |
| update with yellow zone | 7 个月前 |
| enable hash optimization, and set total_order_seek as true when performing savepoint | 1 个月前 |
| [fix] Fix rocksDB column family config. | 2 个月前 |
| update with yellow zone | 7 个月前 |
| NexmarkSourceFunction support CP&SP | 26 天前 |
| Skip empty operator state snapshots | 13 天前 |
| 检视意见修改 | 1 个月前 |
| SQL CP 功能相关 Co-authored-by: TideMacro<TideMacro@outlook.com> (cherry picked from commit eef068d1b495c0ea519ed235e5ad07b1e1e51fb0) | 1 个月前 |
| 删除多余日志 | 1 个月前 |
| 本地恢复适配 | 4 个月前 |
| update with yellow zone | 7 个月前 |
| SQL CP 功能相关 Co-authored-by: TideMacro<TideMacro@outlook.com> (cherry picked from commit eef068d1b495c0ea519ed235e5ad07b1e1e51fb0) | 1 个月前 |
| feat: add UTs for ByteView, CheckpointStateOutputStreamProxy, and SavepointKvStreamWriter - Extract SavepointKvStreamWriter to header for testability - ByteViewTest: 13 cases covering construct/copy/move/iterator/boundary - CheckpointStateOutputStreamProxyTest: 16 cases covering BytePatch guard state machine, flush, DirectBuffer/fallback paths - SavepointKvStreamWriterTest: 8 cases covering writeFirst/writeNext/finish sequence and keyGroup/kvState transitions | 12 天前 |
| serializer sp json | 3 个月前 |
| 增加一致性校验日志 | 1 个月前 |
| update with yellow zone | 7 个月前 |
| 检视意见修改 | 1 个月前 |
| 修复dataStream互相恢复场景的core问题 | 17 天前 |
| 增加一致性校验日志开关 | 1 个月前 |
| update with yellow zone | 7 个月前 |
| 本地恢复适配 | 4 个月前 |
| clean code | 6 个月前 |
| 增加日志 | 1 个月前 |
| fix inflightbuffers persistence | 3 个月前 |
| update with yellow zone | 7 个月前 |
| window op changes Signed-off-by: jojolu_1de3 <jojo.lu1@h-partners.com> | 2 个月前 |
| [fix] Fix the creation logic and implementation logic of priority queue and timer. | 1 个月前 |
| [fix] Fix the creation logic and implementation logic of priority queue and timer. | 1 个月前 |
| add trait to aviod using keyselector | 30 天前 |
| sql 场景支持保存cp sp (cherry picked from commit ce04c3c23f73d9787c12044d9b85aaf6dcddaae6) | 1 个月前 |
| [optimize] Optimize session window memory and performance. | 1 个月前 |
| fix flink sp canonical - omni | 1 个月前 |
| SP恢复 | 4 个月前 |
| support Rocksdb/PQ | 1 个月前 |
| fix: restore virtual next() in KeyValueStateIterator base class | 13 天前 |
| [fix] Fix the creation logic and implementation logic of priority queue and timer. | 1 个月前 |
| 增加日志 | 1 个月前 |
| update with yellow zone | 7 个月前 |
| update with yellow zone | 7 个月前 |
| 本地恢复适配 | 4 个月前 |
| 本地恢复适配 | 4 个月前 |
| SQL CP 功能相关 Co-authored-by: TideMacro<TideMacro@outlook.com> (cherry picked from commit eef068d1b495c0ea519ed235e5ad07b1e1e51fb0) | 1 个月前 |
| fix the kacc build bug | 1 个月前 |
| fix the kacc build bug | 1 个月前 |
| fix 检视意见 | 4 天前 |
| -log | 17 天前 |
| 检视意见修改 | 1 个月前 |
| fix inflightbuffers persistence | 3 个月前 |
| Support for unaligned checkpoint restore with flink mode | 3 个月前 |
| [fix] Fix the creation logic and implementation logic of priority queue and timer. | 1 个月前 |
| SQL CP 功能相关 Co-authored-by: TideMacro<TideMacro@outlook.com> (cherry picked from commit eef068d1b495c0ea519ed235e5ad07b1e1e51fb0) | 1 个月前 |
| SQL CP 功能相关 Co-authored-by: TideMacro<TideMacro@outlook.com> (cherry picked from commit eef068d1b495c0ea519ed235e5ad07b1e1e51fb0) | 1 个月前 |
| serializer json | 3 个月前 |
| [fix] Fix the creation logic and implementation logic of priority queue and timer. | 1 个月前 |
| SQL CP 功能相关 Co-authored-by: TideMacro<TideMacro@outlook.com> (cherry picked from commit eef068d1b495c0ea519ed235e5ad07b1e1e51fb0) | 1 个月前 |
| SQL CP 功能相关 Co-authored-by: TideMacro<TideMacro@outlook.com> (cherry picked from commit eef068d1b495c0ea519ed235e5ad07b1e1e51fb0) | 1 个月前 |
| fix rocksdb native pq sp-restore coredump | 1 个月前 |
| fix rocksdb native pq sp-restore coredump | 1 个月前 |
| SQL CP 功能相关 Co-authored-by: TideMacro<TideMacro@outlook.com> (cherry picked from commit eef068d1b495c0ea519ed235e5ad07b1e1e51fb0) | 1 个月前 |
| update with yellow zone | 7 个月前 |
| fix inflightbuffers persistence | 3 个月前 |
| add switch for falcon optimization | 1 个月前 |
| add switch for falcon optimization | 1 个月前 |
| 增加一致性校验日志 | 1 个月前 |
| 增加一致性校验日志 | 1 个月前 |
| update with yellow zone | 7 个月前 |
| Optimize RocksDB savepoint write path | 13 天前 |
| fix sp native fail & remove some md | 1 个月前 |
| [fix] Receive rocksdb memory config from adaptor. | 2 个月前 |
| Optimize RocksDB savepoint write path | 13 天前 |
| [fix] Fix the creation logic and implementation logic of priority queue and timer. | 1 个月前 |
| update with yellow zone | 7 个月前 |
| SQL CP 功能相关 Co-authored-by: TideMacro<TideMacro@outlook.com> (cherry picked from commit eef068d1b495c0ea519ed235e5ad07b1e1e51fb0) | 1 个月前 |
| Optimize RocksDB savepoint write path | 13 天前 |
| update with yellow zone | 7 个月前 |
| Optimize RocksDB savepoint write path | 13 天前 |
| Fix RocksdbKeyedStateBackend HEAP/ROCKSDB PQ Consistency | 1 个月前 |
| feat: add UTs for ByteView, CheckpointStateOutputStreamProxy, and SavepointKvStreamWriter - Extract SavepointKvStreamWriter to header for testability - ByteViewTest: 13 cases covering construct/copy/move/iterator/boundary - CheckpointStateOutputStreamProxyTest: 16 cases covering BytePatch guard state machine, flush, DirectBuffer/fallback paths - SavepointKvStreamWriterTest: 8 cases covering writeFirst/writeNext/finish sequence and keyGroup/kvState transitions | 12 天前 |
| 创建savepoint | 4 个月前 |
| support Rocksdb/PQ | 1 个月前 |
| update with yellow zone | 7 个月前 |
| update with yellow zone | 7 个月前 |
| update with yellow zone | 7 个月前 |
| update with yellow zone | 7 个月前 |
| NexmarkSourceFunction support CP&SP | 26 天前 |
| update with yellow zone | 7 个月前 |
| serializer sp json | 3 个月前 |
| NexmarkSourceFunction support CP&SP | 26 天前 |
| SQL CP 功能相关 Co-authored-by: TideMacro<TideMacro@outlook.com> (cherry picked from commit eef068d1b495c0ea519ed235e5ad07b1e1e51fb0) | 1 个月前 |
| SQL CP 功能相关 Co-authored-by: TideMacro<TideMacro@outlook.com> (cherry picked from commit eef068d1b495c0ea519ed235e5ad07b1e1e51fb0) | 1 个月前 |
| update with yellow zone | 7 个月前 |
| NexmarkSourceFunction support CP&SP | 26 天前 |
| update with yellow zone | 7 个月前 |
| SQL CP 功能相关 Co-authored-by: TideMacro<TideMacro@outlook.com> (cherry picked from commit eef068d1b495c0ea519ed235e5ad07b1e1e51fb0) | 1 个月前 |
| SQL CP 功能相关 Co-authored-by: TideMacro<TideMacro@outlook.com> (cherry picked from commit eef068d1b495c0ea519ed235e5ad07b1e1e51fb0) | 1 个月前 |
| update with yellow zone | 7 个月前 |
| update with yellow zone | 7 个月前 |
| fix inflightbuffers persistence | 3 个月前 |
| fix flink cp omni restore core | 22 天前 |
| update with yellow zone | 7 个月前 |
| update with yellow zone | 7 个月前 |
| 检视意见修改 | 1 个月前 |
| fix ut | 1 个月前 |
| 增加一致性校验日志开关 | 1 个月前 |
| fix inflightbuffers persistence | 3 个月前 |
| update with yellow zone | 7 个月前 |
| Timer 定时器序列化问题 | 2 个月前 |
| Timer 定时器序列化问题 | 2 个月前 |
| Timer 定时器序列化问题 | 2 个月前 |
| Timer 定时器序列化问题 | 2 个月前 |
| Timer 定时器序列化问题 | 2 个月前 |
