commits  

Messages by Thread

• (fluss-rust) branch main updated: chore: introduce deny to check licenses (#267) yuxia
• (fluss-rust) branch introduce-deny created (now 1eb28b7) yuxia
  • (fluss-rust) 01/01: chore: introduce deny to check licenses yuxia
• (fluss-rust) branch main updated: chore: Fire-and-forget behaviour for effecient batching (#258) yuxia
• (fluss-rust) branch main updated: chore: python binding cleanup and bit of refactor (#264) yuxia
• (fluss) annotated tag v0.9.0-incubating-rc0 updated (c1bb29f56 -> 2aea1e5fa) yuxia
• svn commit: r82325 - in dev/incubator/fluss: fluss-0.9.0-incubating-rc0 helm-chart helm-chart/0.9.0-incubating-rc0 yuxia
• (fluss) branch main updated: [helm] Allow templating listeners (internal, client) from values (#2460) ipolyzos
• (fluss) branch main updated (0e2d71f72 -> 74ee888fc) yuxia
  • (fluss) 03/03: [docs] update compatibility table between versions yuxia
  • (fluss) 02/03: [helm] Bump helm version to 0.10.0 yuxia
  • (fluss) 01/03: [docs] Add version item for 0.10.0-incubating in fluss-versions.json yuxia
• (fluss) branch main updated (9a8514097 -> 0e2d71f72) yuxia
  • (fluss) 01/01: [helm] Bump helm version to 0.10.0 yuxia
• (fluss) branch main updated: [helm] Bump helm version to x.y.z yuxia
• (fluss) branch main updated: [docs] Add version item for 0.9.0-incubating in fluss-versions.json yuxia
• (fluss) branch main updated: [hotfix][dist] Don't print jindo log when deploy on console mode (#2577) yunhong
• (fluss) branch main updated: [docs] Create upgrade notes for 0.10 yuxia
• (fluss) branch main updated: Update version to 0.10-SNAPSHOT yuxia
• (fluss) branch release-0.9 created (now fbf50fdb7) yuxia
• svn commit: r82321 - release/incubator/fluss yuxia
• (fluss) branch main updated: [hotfix] Fix docker file build exception (#1802) yuxia
• (fluss) branch main updated: [docs] update quickstart paimon to align to latest branch yuxia
• (fluss) branch main updated: [flink] unify the behavior of different startup mode for lake table (#2572) yuxia
• (fluss-rust) branch main updated: feat: introduce list partitions in cpp binding (#260) yuxia
• (fluss-rust) branch main updated: feat: support unsubscribe partition (#257) yuxia
• (fluss-rust) branch unsubscribe-partition deleted (was ec6b68c) yuxia
• (fluss-rust) branch get_char_optimize deleted (was a41456b) yuxia
• (fluss-rust) branch improve-creditial-cache deleted (was 4c0e3da) yuxia
• (fluss-rust) branch improve-log-poll deleted (was 9653f81) yuxia
• (fluss-rust) branch not-copy-bytes deleted (was d5b0085) yuxia
• (fluss-rust) branch allow-batch-poll deleted (was 5b63be1) yuxia
• (fluss-rust) branch support-list-partition-offset-in-cpp deleted (was e61bdcd) yuxia
• (fluss-rust) branch main updated: feat: Support drop_table, partitions and offsets methods in python bindings (#150) yuxia
• (fluss-rust) branch main updated: chore: rename subscribe_batch to subscribe_buckets (#255) yuxia
• (fluss-rust) branch main updated: chore: refator to builder pattern to create log scanner for CPP (#249) yuxia
• (fluss-rust) branch unsubscribe-partition created (now ec6b68c) yuxia
  • (fluss-rust) 01/01: feat: support unsubscribe partition yuxia
• (fluss-rust) branch main updated: chore: Change upsert and delete to use read only self reference by using mutex to guard mutable encoders (#247) yuxia
• (fluss-rust) branch main updated: feat: Support different poll methods (#246) yuxia
• (fluss) branch main updated: [client] Support list database summaries (#2515) jark
• (fluss) branch main updated: [doc/build] Fix iceberg quickstart to build on flink standard image (#2555) mehulbatra
• (fluss) branch main updated (2ab3ce215 -> 4fb59735c) jark
• (fluss-website) branch asf-site updated: Deploy website - based on 4fb59735c497728add06dbcaafb7729cc02011a8 github-bot
• (fluss) branch main updated: [server] print snapshot size in snapshot finish log (#2516) jark
• (fluss) branch main updated: [spark] Add startup mode for batch read (#2532) jark
• (fluss) branch main updated: [docs] Add documentation for $binlog virtual table (#2565) jark
• (fluss-website) branch asf-site updated: Deploy website - based on 1b674ca77d412e889af751f5f42ea97a47aa00c2 github-bot
• (fluss) branch main updated (fb6765a35 -> 1b674ca77) jark
  • (fluss) 02/02: [flink] Add and improve Delta Join IT tests (#2546) jark
  • (fluss) 01/02: [flink] Delta Join additional IT tests and docs improvement (#2546) jark
• (fluss) branch main updated (f2c44179d -> fb6765a35) jark
• (fluss) branch revert-2546-fluss-delta-joins-tests-docs created (now 3effa3fcf) jark
  • (fluss) 01/01: Revert "[flink] Delta Join additional IT tests and docs improvement (#2546)" jark
• (fluss) branch revert-2546-fluss-delta-joins-tests-docs deleted (was 3effa3fcf) jark
• (fluss) branch main updated: [flink] Delta Join additional IT tests and docs improvement (#2546) jark
• (fluss) branch main updated: [iceberg] Bump Iceberg version to 1.10.1 (#2415) yuxia
• (fluss) branch main updated (bdb44c710 -> 73d804205) jark
• (fluss) branch main updated: [server] Fix rebalance may cause remote file deleted error (#2570) yunhong
• (fluss-rust) branch main updated: feat: introduce kv tables support in python (#239) yuxia
• (fluss-rust) branch main updated: chore: Reject table scan for INDEXED format or KV table (#238) yuxia
• (fluss) branch main updated: [lake/lance] Add Array type support for Lance (#2537) jark
• (fluss-rust) branch main updated: feat: support subscribe partition in cpp binding (#236) yuxia
• (fluss-rust) branch main updated: feat: add table partition scanning (#222) yuxia
• (fluss) branch main updated: [test] Fix FlinkTableSinkITCase#testWalModeWithAutoIncrement to correct assert changelogs of WAL image mode (#2568) jark
• (fluss-rust) branch main updated: chore: accept Into<String> to improve api usage (#234) yuxia
• (fluss) branch main updated (4408d2c2d -> 84b204421) jark
  • (fluss) 01/02: [kv] Implement lookup with insertIfNotExists on tablet server (#2485) jark
  • (fluss) 02/02: [kv] Improve validation for target columns on auto-increment tables jark
• (fluss-rust) branch main updated (e5adc3d -> 0cf25e6) yuxia
• (fluss-rust) branch main updated: feat: introduce scan record batch in cpp (#230) yuxia
• (fluss-rust) branch main updated: feat: support list partition offset in cpp binding (#231) yuxia
• (fluss) branch main updated: [hotfix][docs] Revert documentation link changes to remove "next" version references jark
• (fluss) branch main updated (ff3cab9dd -> a8b38a6df) jark
  • (fluss) 02/02: [spark] Rename parser to FlussSqlExtension and add generated class into source code jark
  • (fluss) 01/02: [spark] Support Spark CALL procedure command framework (#2408) jark
• (fluss) branch main updated: [helm] Add `tabletServer.count` configuration option (#2456) yunhong
• (fluss) branch main updated: [docker] Upgrade base image to Eclipse Temurin 17-jre-noble version (#2520) ipolyzos
• (fluss-rust) branch support-list-partition-offset-in-cpp created (now e61bdcd) yuxia
  • (fluss-rust) 01/01: feat: support list partition offset in cpp binding yuxia
• (fluss) branch main updated: [lake] Add metric of LAKE_TABLE_COUNT (#2528) yuxia
• (fluss) branch main updated: [flink] Basic $binlog read support without pushdown optimizations for pk table (#2525) jark
• (fluss) branch main updated: fix image urls (#2547) ipolyzos
• (fluss) branch main updated: [website] feat blog: fraud detection with fluss flink and iceberg (#2535) ipolyzos
• (fluss) branch main updated: [lake/iceberg] Support MAP type in Iceberg tables (#2367) yuxia
• (fluss) branch main updated: [flink] Bump flink 1.19 minor version to 1.19.3 (#1969) jark
• (fluss) branch main updated: [docs] Add docs for rack-aware rebalance goal (#2540) jark
• (fluss) branch main updated: [kv] Return log end offset in UpsertResult and DeleteResult for exactly-once semantics (#2530) jark
• (fluss) branch main updated: [kv] Add RocksDB memory metrics by component type (#2392) jark
• (fluss-rust) branch main updated: feat: support list offset for partitioned table (#229) yuxia
• (fluss) branch main updated: [spark] support merge-read between kv snapshot and log for primary-key table (#2523) jark
• (fluss) branch main updated: [server] Support RackAwareGoal for rebalance (#2380) jark
• (fluss) branch main updated: [script] Improve "local-cluster.sh" script to bind hostnames defined in "server.yaml" (#2284) jark
• (fluss) branch release-0.8-ali-3.0 deleted (was 3dc9fa02c) jark
• (fluss) branch ci-azure-fs deleted (was b94cdbf88) jark
• (fluss) branch main updated: [test] Improve testing time for FlinkRecordEmitterTest by removing unnecessary FlinkTestBase dependency (#2533) jark
• (fluss-rust) branch main updated: feat: support produce partitioned table (#228) yuxia
• (fluss) branch main updated: [website] Fix css style for 'code' in list (#1949) jark
• (fluss) branch main updated: [kv] Add OVERWRITE MergeMode support for undo recovery in aggregation tables (#2492) jark
• (fluss-rust) branch main updated: feat: Implement partitioning in Upsert / Lookup (#220) yuxia
• (fluss) branch main updated (ffe7da0e2 -> 3a803dfd8) jark
• (fluss-rust) branch main updated: feat: support scan from oss (#217) yuxia
• (fluss) branch main updated: docs: updated Flink SQL Client startup and cluster shutdown instructions (#2522) mehulbatra
• (fluss) branch main updated: [docs] Add Azure Blob Storage documentation (#2507) jark
• (fluss) branch main updated: [lake/paimon] Compare paimon schema and Fluss schema before alter table. (#2331) jark
• (fluss) branch main updated (215bd2102 -> e16f625bc) jark
• (fluss) branch main updated: [observability] Introduce prometheus-push metric report (#2317) jark
• (fluss) branch main updated: [FLUSS-2473][server][test] Fix flaky test FlussAuthorizationITCase.testRebalance (#2487) yunhong
• (fluss-rust) branch main updated: chore: support estimated_size_in_bytes for write batch (#219) yuxia
• (fluss-rust) branch main updated: chore: Fix async fn panic in CancellationSafeFuture when future completes yuxia
• (fluss-rust) branch main updated: chore: minor fix for rust code (#218) yuxia
• (fluss-rust) branch main updated: [chore] Implement is_auto_partitioned method in table.rs (#48) yuxia
• (fluss) branch main updated (087a05bbb -> 9252e1004) yuxia
• (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

• Earlier messages