commits  

Messages by Thread

• (fluss) branch main updated: [spark] Add sparksql lake table catalog DDL suite for paimon (#2438) jark
• (fluss) branch main updated (23d159485 -> 336216cc9) jark
• (fluss) branch main updated: [fs/azure] Support Azure Blob Storage (#1941) jark
• (fluss-rust) branch main updated: chore: Introduce PartitionGetter and Partition utils (#214) yuxia
• (fluss) branch main updated: [test] Add additional assertion to tests for TimestampLtz/Ntz to partition string conversion (#2481) yuxia
• (fluss) branch main updated (81e3f3a54 -> 9ce7ed866) yuxia
• (fluss) branch ci-azure-fs created (now b94cdbf88) jark
  • (fluss) 01/01: use fluss-fs-hadoop-shaded jark
• (fluss-rust) branch main updated: chore: Add blocking poll into python bindings (#154) yuxia
• (fluss-shaded) branch dependabot/maven/tools/ci/fluss-shaded-ci-tools/org.assertj-assertj-core-3.27.7 created (now f09f31b) github-bot
• (fluss) branch main updated: [build] Upgrade GitHub Actions for Node 24 compatibility (#2349) jark
• (fluss-rust) branch main updated (1bc399b -> 9d3917c) yuxia
• (fluss-rust) branch improve-creditial-cache created (now 4c0e3da) yuxia
  • (fluss-rust) 01/01: minor fix yuxia
• (fluss) branch main updated: [hotfix] update messaging on github page (#2478) ipolyzos
• (fluss) branch main updated: [spark] Add Spark SQL ALTER table support for set/remove table properties (#2437) jark
• (fluss) branch main updated: [test] Fix unstable test ReplicaTest.testRestore (#2469) jark
• (fluss-rust) branch main updated: test: add it for produce & scan log for all supported datatypes (#205) yuxia
• (fluss) branch main updated: [doc/website] virtual tables documentation - $changelog for PK/Log Tables (#2476) mehulbatra
• (fluss) branch main updated: [test] Fix flaky AdjustIsrITCase#testIsrShrinkAndExpand by using acks=1 (#2468) jark
• (fluss) branch main updated: [helm] Remove `tablet-server.id` from coordinator configuration options (#2458) yunhong
• (fluss-rust) branch main updated: chore: introduce new with capacity to align generic row with java side (#212) yuxia
• (fluss-rust) branch main updated: feat: Support Arrow append operations for decimals, temporal types in Python (#206) yuxia
• (fluss-rust) branch main updated: chore: add more info for RecordBatches (#211) yuxia
• (fluss) branch main updated: [flink] changelog read support for log table without pushdown optimizations (#2467) jark
• (fluss) branch main updated: [hotfix] Remove unstable "latest" scan startup mode test in ChangelogVirtualTableITCase (#2470) jark
• (fluss-rust) branch main updated: feat: Implement Admin APIs for partitioning (#208) yuxia
• (fluss-rust) branch main updated: feat: introduce priority queue for downloading remote segments (#187) yuxia
• (fluss) branch main updated: [test] Fix failed testPkCompactedPollFromLatestNoRecords. (#2465) jark
• (fluss) branch main updated: [server] Update tablet server metadata cache when TableRegistration changed (#2378) jark
• (fluss) branch main updated: [server] Fix FirstRowMergeEngine hang caused by empty log entries in projection pushdown queries (#2370) jark
• (fluss) branch main updated: [lake] Make FlussLakeTiering pluggable to customize tiering job construct (#2364) jark
• (fluss-rust) branch main updated: test: add it test for put & get kv for all supported datatypes (#204) yuxia
• (fluss) branch main updated: [flink] changelog read support for pk table without pushdown optimizations (#2347) mehulbatra
• (fluss) branch main updated: [coordinator] Refactor SchemaUpdate to delegate schema changes to Schema.Builder (#2416) hongshun
• (fluss) branch main updated: [hotfix][helm] Update image repository to use 'apache/fluss' instead of 'fluss' (#2340) ipolyzos
• (fluss) branch main updated: [lake] report pending records even though no tiering is finished (#2453) yuxia
• (fluss-rust) branch main updated: test: Kv Table Integration tests (#192) yuxia
• (fluss) branch main updated: [docs] Add client feature support matrix documentation (#2445) jark
• (fluss-rust) branch main updated: chore: invalidate leader info on stale metadata error when handling fetch response (#189) yuxia
• (fluss-rust) branch main updated: feat: Arrow serialization for decimal and temporal types (#196) yuxia
• (fluss) branch main updated: [minor][flink] Remove unnecessary java notes (#2444) hongshun
• (fluss) branch main updated: [website] Update Fluss messaging (#2428) jark
• (fluss) branch main updated: [spark] support batch read from fluss cluster (#2377) jark
• (fluss) branch main updated: [test] Support manually trigger and wait for KV snapshots for FlussClusterExtension (#2429) jark
• (fluss) branch main updated: [hotfix] Catalog related lake options should overwrite table lake related options (#2432) yuxia
• (fluss-rust) branch main updated: feat: Fix TableLookup so that SchemaId field bytes are not passed to CompactedRow::from_bytes(), these fields can be skipped as current rust client implementation does not check schema and already passes row_type (#190) yuxia
• (fluss) branch main updated: [client] move OffsetsInitializer to fluss-client (#2424) jark
• (fluss-rust) branch main updated: feat: KvWriteBatch wiring in Sender (#184) yuxia
• (fluss-rust) branch main updated: feat: Introduce Kv table example (#181) yuxia
• (fluss-rust) branch main updated: feat: Introduce UpsertWriter (#169) yuxia
• (fluss) branch main updated: [kv] Add roaring bitmap aggregate function for aggregation merge engine (#2390) jark
• (fluss) branch main updated: [flink] Flink integration with Aggregation Merge Engine (#2307) jark
• (fluss) branch main updated: [lake] Support alter table.datalake.freshness (#2365) yuxia
• (fluss-rust) branch main updated: feat: support all basic datatypes in compacted key encoder(continuation) (#175) yuxia
• (fluss) branch main updated: [docs] Add docs for rebalance (#2382) yunhong
• (fluss) branch main updated: [hotfix] Fix union read fail when from timestamp and projection enabled (#2383) yuxia
• (fluss) branch main updated: [tests] Cleanup ZK state in TableChangeWatcherTest to not let current tests be impacted by leftover events from previous tests. (#2249) hongshun
• (fluss) branch main updated (42ccb873f -> 4f3c4572a) jark
  • (fluss) 02/03: [flink] Optimize sink statistics calculation to run only when necessary jark
  • (fluss) 03/03: [flink] Fix the distribution mode support for FlussSink for DataStream API jark
• (fluss-rust) branch main updated: feat: introduce KvWriteBatch and PutKvRequest (#176) yuxia
• (fluss) branch main updated: [test] Fix unstable test RebalanceITCase#testRebalanceForLogTable (#2407) jark
• (fluss-shaded) branch main updated: [arrow] Add IntObjectHashMap and IntObjectMap implementations to replace dependency on eclipse-collections by arrow (#6) jark
• (fluss-shaded) branch dependabot/maven/fluss-shaded-zookeeper-parent/fluss-shaded-zookeeper-38/org.apache.zookeeper-zookeeper-3.8.4 deleted (was d234b92) jark
• (fluss-shaded) branch main updated: [zookeeper] Bump org.apache.zookeeper:zookeeper from 3.8.3 to 3.8.4 (#1) jark
• (fluss-shaded) branch dependabot/maven/fluss-shaded-zookeeper-parent/fluss-shaded-zookeeper-38/org.apache.zookeeper-zookeeper-3.8.4 updated (2b4b9bf -> d234b92) jark
• (fluss-shaded) branch dependabot/maven/tools/ci/fluss-shaded-ci-tools/org.apache.logging.log4j-log4j-core-2.25.3 deleted (was a901f0e) github-bot
• (fluss-shaded) branch main updated: [log4j] Bump org.apache.logging.log4j:log4j-core (#3) jark
• (fluss-shaded) branch main updated: [netty] Bump netty version to 4.1.130.Final. (#2) jark
• (fluss) branch main updated: Add RocksDB block cache configuration options for index and filter blocks (#2394) yunhong
• (fluss) branch main updated: [spark] Add spark streaming write support (#2357) jark
• (fluss-rust) branch main updated: feat: Introduce KVReadContext and read path wiring (#174) yuxia
• (fluss) branch main updated (be01cffa9 -> a6b0b8587) jark
• (fluss) branch main updated (87993089a -> be01cffa9) jark
  • (fluss) 01/02: [kv] Add basic implementation of AUTO_INCREMENT column (#2161) jark
  • (fluss) 02/02: [kv] Improve the implementation of AUTO_INCREMENT column jark
• (fluss-rust) branch allow-batch-poll created (now 5b63be1) yuxia
  • (fluss-rust) 02/02: allow scan batch yuxia
  • (fluss-rust) 01/02: fix fmt yuxia
• (fluss-rust) branch main updated: chore: correct log record batch checksum bounds (#172) yuxia
• (fluss) branch main updated: [lake/lance] Refactor LanceArrowWriter to reuse fluss-common ArrowWriters (#2345) jark
• (fluss-rust) branch main updated: chore: Improve read path error handling logic (#143) yuxia
• (fluss) branch main updated: [spark] Add Spark show/add/drop partition support (#2314) jark
• (fluss-rust) branch main updated: feat: Introduce python bindings row-based append API (#142) yuxia
• (fluss-rust) branch main updated: feat: introduce lookup support for primary key tables (#159) yuxia
• (fluss-rust) branch main updated: chore: fix read deadlock (#165) yuxia
• (fluss) branch main updated: Change the ListRebalanceProcessProcedure result from String[] to row[] (#2341) yunhong
• (fluss-rust) branch main updated: feat: add column projection support to Python LogScanner (#151) yuxia
• (fluss-rust) branch main updated: feat: Introduce CompactedRowEncoder (#161) yuxia
• (fluss-rust) branch main updated: chore: Introduce WriteFormat and various small changes to unblock Upsert implementation (#158) yuxia
• (fluss) branch main updated: [Flink] Support Partial Updates to the Flink Sink (#2042) mehulbatra
• (fluss) branch main updated: Rebalance procedure docs (#2355) yunhong
• (fluss) branch main updated: [paimon] Add IT case for union read with evolved schema for Paimon (#2368) yuxia
• (fluss-rust) branch main updated: feat: introduce KvRecordBatchBuilder (#156) yuxia
• (fluss) branch main updated: [lake] Re-initial tiering splits for tables if reader failover happen (#1984) yuxia
• (fluss-rust) branch main updated: chore: add DEVELOPMENT.md (#155) yuxia
• (fluss) branch main updated: [doc] fix typo of 'table.datalake.enabled' in options.md (#2366) yuxia
• (fluss) branch main updated: [hotfix] Add authentication to the admin APIs that currently lack it (#2350) yunhong
• (fluss) branch main updated: [docs] Add alter table feature link in getting-started.md (#2348) yunhong
• (fluss-rust) branch main updated: chore: decrement flushes_in_progress counter in await_flush_comp (#147) yuxia
• (fluss) branch main updated: [Task] Enhance tests for cluster rebalancing (#2315) (#2337) yunhong
• (fluss-rust) branch main updated: chore: fix potential deadlock with holding lock during await (#145) yuxia
• (fluss-rust) branch main updated: chore: implement zero copy in CompactedRowReader (#138) yuxia
• (fluss) branch main updated (a1b82043b -> 2b0e2b1b0) jark
• (fluss) branch main updated: [spark] Fix spark desc command output with partition info (#2313) jark
• (fluss) branch main updated: [NOTICE] Update copyright NOTICE year to 2026 (#2343) jark
• (fluss-rust) branch main updated: chore: improve datum, use Cow to reduce verbosity and avoid Box::leak gymnastics (#139) yuxia
• (fluss-rust) branch main updated (4b8c289 -> e01be26) yuxia
• (fluss-rust) branch not-copy-bytes created (now d5b0085) yuxia
  • (fluss-rust) 01/01: chore: implement zero copy in CompactedRowReader yuxia
• (fluss-rust) branch main updated: chore: fix Box leaking and batch API refactor (#136) yuxia
• (fluss-rust) branch main updated: feat: introduce CompactedRowReader, CompactedRow, CompactedRowDeserializer (#131) yuxia
• (fluss-rust) branch main updated: feat: log scanner support poll record batch directly yuxia
• (fluss-rust) branch main updated: feat: introduce CompactedKeyEncoder (#124) yuxia
• (fluss-rust) branch main updated (9873184 -> ff7e869) yuxia
• (fluss) branch main updated: [docs]: updated data type mapping in iceberg (#2336) yuxia
• (fluss) branch main updated (3b74d6b30 -> 227480056) yunhong
• (fluss) branch main updated: [lake/iceberg] Support nested row types for Iceberg tiering (#2278) yuxia
• (fluss) branch main updated: [test] Add BucketingFunctionTest, this allows rust client side to also run the same test and ensures consistency. (#2274) yuxia
• (fluss) branch main updated: [docs] Add MAP type to data types and Paimon integration documentation (#2332) yuxia
• (fluss) branch release-0.8-ali-3.0 created (now 3dc9fa02c) hongshun
  • (fluss) 02/02: exec-maven-plugin async build dist. hongshun
  • (fluss) 01/02: Bump version to 0.8-ali-3.0 hongshun
• (fluss) branch main updated: [hotfix] Fix the rebalance status cannot reach complete when the rebalance plan is empty (#2329) yunhong
• (fluss) branch main updated: [flink] Refactor CALL procedure "sys.xxx_cluster_config" to support multiple conifg keys (#2279) jark
• (fluss) branch main updated: [common] Add field_id for Nested Row. (#2322) jark
• (fluss) branch main updated: [hotfix] Fix union read can't restore issue (#2321) yuxia
• (fluss) branch main updated: [hotfix] use ltz_millis as paimon system column for timestamp datatype (#2320) yuxia
• (fluss) branch main updated: [lake] fix potential dirty commit on re-create table (#2316) yuxia
• (fluss) branch main updated: [server] Servers with PERMANENT_OFFLINE tag are no longer assigned replicas (#1538) yunhong
• (fluss) branch main updated: [server] Fix ConcurrentModificationException when access getTable concurrently (#2319) yuxia
• (fluss-rust) branch main updated: chore: fix append hang issue (#126) yuxia
• (fluss) branch main updated (a4cc966b1 -> 835365d22) yuxia
• (fluss) branch main updated: [server] Not permitted to enable datalake for tables created prior to the cluster being set to datalake format (#2100) yuxia
• (fluss-rust) branch main updated: feat: return error for partitioned tables in FlussConnection#get_table (#115) yuxia
• (fluss) branch main updated: [docs] Document COMPACTED table format (#2264) ipolyzos
• (fluss) branch main updated: [spark] Add unit tests for spark SHOW TABLES command (#2304) jark
• (fluss) branch main updated: [docs] Move 'Merge Engine' to the top-level of 'Table Design' (#2300) jark
• (fluss) branch main updated: [kv] Support to report rocksdb metrics (#2282) jark
• (fluss) branch main updated: [hotfix] Fix compilation error: implement missing getMap method in IcebergArrayAsFlussArray (#2306) yuxia
• (fluss) branch main updated: [lake/iceberg] Support tier array type for iceberg (#2266) yuxia
• (fluss) branch main updated: [hotfix] Fix spotless checkstyle problems jark
• (fluss) branch main updated: [hotfix] Fix compile problem of InternalRow#getMap() interface in Spark connector jark
• (fluss) branch main updated: [spark] support spark batch write (#2277) jark
• (fluss) branch main updated: [docs] update datatypes & paimon datatype mapping document (#2283) yuxia
• (fluss) branch main updated: [hotfix]: Build expected results with partitions value, not hard coded value. (#2295) yuxia
• (fluss-rust) branch main updated: chore: add license header to fix ci (#123) yuxia
• (fluss-rust) branch main updated: feat: implement CompactedRowWriter (#121) yuxia
• (fluss-rust) branch main updated: feat: support bazel build for cpp bindings (#107) yuxia
• (fluss-rust) branch main updated: chore: add integration tests for subscribe_batch and project_by_name (#116) yuxia
• (fluss-rust) branch main updated: chore: rust client to return error when currently unimplemented non-default ZSTD compression is configured (#120) yuxia
• (fluss-rust) branch dependabot/github_actions/actions/cache-5 created (now c3e2117) github-bot
• (fluss) branch main updated (920809f80 -> 7fad656f1) jark
  • (fluss) 01/02: [common] Fix IndexOutOfBoundsException in ArrowArrayWriter when element count exceeds INITIAL_CAPACITY (#2165) jark
  • (fluss) 02/02: [common Improve ArrowArrayWriter performance by replacing hardcoded handleSafe=true with dynamic check based on fieldIndex jark
• (fluss) branch main updated: [flink] Flink Source need to check tableId on recovery in case that table is recreated. (#2154) jark
• (fluss) branch main updated: [hotfix] Use CatalogTableAdapter rather than CatalogTable.newBuilder in flink catalog. (#2275) hongshun
• (fluss-rust) branch main updated: feat: Introduce HashBucketAssigner (#117) yuxia
• (fluss) branch main updated: [client] Change SchemaNotExistException as retriable exception. (#2193) jark
• (fluss) branch main updated (1055e42c4 -> 07aa237da) jark
• (fluss) branch main updated: [flink] Add RuntimeContext adapter for Flink 2.x compatibility (#2241) jark
• (fluss) branch main updated: [Docs] Document the TypedAPI #2230 (#2261) ipolyzos
• (fluss) branch main updated (5c932f132 -> 6868157aa) jark
• (fluss) branch main updated: [docs] Use the "docker compose ps" to show the running containers (#2229) jark
• (fluss) branch main updated (4a627623c -> d6524d2f4) jark
• (fluss) branch main updated: [lake] Support ADD COLUMN AT LAST for dataLake enabled tables (#2189) jark
• (fluss) branch main updated: [common] switch to at.yawk.lz4:lz4-java due to CVE-2025-12183 (#2136) jark
• (fluss) branch main updated: [docs] Add document about ADD COLUMN AT LAST (#2203) jark
• (fluss) branch main updated: [spark] Initiate fluss-spark and introduce spark catalog and table (#2219) jark
• (fluss) branch main updated: [flink] Replace CLIENT_SCANNER_IO_TMP_DIR with flink's TMP_DIRS in runtime rather then compile phase. (#2259) hongshun
• (fluss-rust) branch main updated: chore: add integration test for list offsets (#52) yuxia
• (fluss-rust) branch main updated: chore: scanner should retry when bucket lead is not available (#102) yuxia
• (fluss) branch main updated (a908690ed -> 3be2f3d02) jark
• (fluss) branch main updated: [common] Support COMPACTED format for log tables (#1605) jark
• (fluss) branch main updated: [website] Improve typography by adopting Inter font (#2232) jark
• (fluss) branch main updated: [flink] Fix NPE for Flink HistogramStatistics that wraps Fluss histogram (#2195) jark
• (fluss) branch main updated: [tests] Fix unstable test CoordinatorEventProcessorTest.testSchemaChange. (#2240) hongshun
• (fluss) branch main updated: [flink] Fix creating table from Flink will make all table properties in custom properties (#1748) jark
• (fluss) branch main updated: [server] Added thread-safety to CoordinatorEventProcessor for Completed Snapshots (#2221) jark
• (fluss) branch main updated: [server] Add null safety for TimerTaskEntry removal (#1872) jark
• (fluss) branch main updated: [flink] Support Flink 2.2 and remove Flink 2.1 (#2167) jark
• (fluss) branch main updated: [flink] Always return all filters to flink when trying to apply filters in FlinkTableSource (#1934) hongshun
• (fluss) branch main updated (9e6f6a4de -> d1ae5b59a) jark
  • (fluss) 02/02: [common] Add IntObjectHashMap and IntObjectMap implementations to replace dependency on eclipse-collections by arrow jark
• (fluss) branch ci-2080 deleted (was 5535697d4) jark
• (fluss) branch ci-2079 deleted (was cfc1a30cb) jark
• (fluss) branch main updated: [kv] Support shared RocksDB rate limiter (#2178) jark
• (fluss) branch ci-2079 created (now cfc1a30cb) jark
  • (fluss) 05/05: revert all the license and pom changes jark
  • (fluss) 02/05: use the same row format in nested row (like, row<array<row>>) jark
  • (fluss) 03/05: fix failed cases jark
  • (fluss) 04/05: fix failed cases jark
• (fluss) branch main updated: [client] Add Pojo API support for read and write operations (#1992) jark
• (fluss) branch main updated: [flink] Fix not compatible with Flink 1.18 and 1.19 (java.lang.NoSuchFieldError: MATERIALIZED_TABLE) (#2083) hongshun
• (fluss-rust) branch main updated: chore: fix bug where column prune won't work when compression is enabled (#108) yuxia
• (fluss) branch main updated: [lake] Move parse offsets from snapshot property to common method (#2208) yuxia
• (fluss) branch main updated: [flink] Union read supports reading partition data that exists in the lake but is expired in Fluss (#2197) yuxia
• (fluss) branch main updated: [client] Check whether request is removed from inflight requests to avoid NullPointerException when connection is closed. (#2127) hongshun
• (fluss) branch main updated: [lake] Support auto snapshot expiration for paimon lake table (#2184) yuxia

• Earlier messages
• Later messages