commits  

Messages by Thread

• (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
• (fluss) branch main updated: [metric] Add user-level metrics for byteIn and byteOut (#2080) jark
• (fluss) branch main updated: [tests] Add integration test for WAL image mode change log of Primary Key (#2217) jark
• (fluss-rust) branch main updated: chore: introduce prefetch to improve log poll performance (#103) yuxia
• (fluss-rust) branch main updated: feat: support ListOffset/SubscribeBatch/DropTable for cpp bindings (#100) yuxia
• (fluss-rust) branch main updated: chore: optimize get_char method (#105) yuxia
• (fluss-rust) branch get_char_optimize updated (be108f6 -> a41456b) yuxia
• (fluss-rust) branch get_char_optimize created (now be108f6) yuxia
  • (fluss-rust) 01/01: chore: optimize get_char method yuxia
• (fluss-rust) branch main updated: chore: Update the InternalRow Trait: get_binary, get_bytes to return &[u8] (#104) yuxia
• (fluss-rust) branch improve-log-poll updated (58cd526 -> 9653f81) yuxia
• (fluss-rust) branch improve-log-poll updated (1e175d9 -> 58cd526) yuxia
• (fluss-rust) branch improve-log-poll updated (f664daa -> 1e175d9) yuxia
  • (fluss-rust) 01/01: improve fetch logic yuxia
• (fluss-rust) branch improve-log-poll created (now f664daa) yuxia
  • (fluss-rust) 02/02: improve fetch logic yuxia
  • (fluss-rust) 01/02: improve log poll yuxia
• (fluss) branch main updated: [flink] Revert unstable test case FlinkTableSinkITCase.testWalModeWithDefaultMergeEngineAndAggregation (#2215) jark
• (fluss-rust) branch main updated: chore: Improve error (#77) yuxia
• (fluss-rust) branch main updated: chore: parse_ipc_message should return exception instead of return None if parse failed (#97) yuxia
• (fluss-rust) branch main updated: feat: support s3 as remote segment (#93) yuxia
• (fluss-shaded) branch dependabot/maven/tools/ci/fluss-shaded-ci-tools/org.apache.logging.log4j-log4j-core-2.25.3 created (now a901f0e) github-bot
• (fluss) branch dependabot/maven/org.apache.logging.log4j-log4j-core-2.25.3 created (now 8559053f8) github-bot
• (fluss) branch main updated: [kv] Support "table.changelog.image" configuration and WAL image mode for Primary Key Tables (#2105) jark
• (fluss) branch release-0.8 updated: [flink] Fix MultipleParameterTool ClassNotFoundException in tiering service (#2210) jark
• (fluss) branch ci-2080 created (now 5535697d4) jark
  • (fluss) 01/01: WIP jark
• (fluss) branch main updated: [flink] Fix MultipleParameterTool ClassNotFoundException in tiering service (#2063) jark
• (fluss) branch main updated: [test][flink] Fix Unstable test FlinkTableSinkITCase.testVersionMergeEngineWithTypeTimestampLTZ9 (#2139) hongshun
• (fluss) branch main updated: [hotfix] Flink catalog should pass to lake properties to lake table (#2205) yuxia
• (fluss) branch main updated: [Helm] ServiceAccount for TabletServer, CoordinatorServer (#2142) yunhong
• (fluss) branch main updated: [Client] Fix LogFetcher doesn't update bucket metadata when receive NotLeaderOrFollowerException in bucket level (#1885) yunhong
• (fluss) branch main updated: [hotfix] Fix flink batch read won't finish issue (#2200) yuxia
• (fluss) branch main updated: [hotfix] Add the missing ',' for HybridSnapshotLogSplit#toString() (#2196) yunhong
• (fluss) branch main updated: [paimon] Fix union read paimon issue (#2170) yuxia
• (fluss) branch main updated: [test] Add test for recovering coordinator server with schema evolution (#2176) hongshun
• (fluss) branch main updated: [flink] Allow pass lake catalog property info when create flink catalog (#1937) yuxia
• (fluss) branch main updated: [server] Skip batch sequence validation during writer state rebuilding (#2188) yunhong
• (fluss) branch main updated: [common] Remove TableInfo from Cluster (#2068) yunhong
• (fluss) branch main updated: [flink] Get table info of primary lake table. (#2152) hongshun
• (fluss) branch main updated: [kv] Supports compacted row as change log (#2108) yuxia
• (fluss-rust) branch main updated: chore: use log over tracing (#96) yuxia
• (fluss) branch main updated: [hotfix] Fix data lake catalog connection resource is not closed in flink catalog. (#2087) yuxia
• (fluss-rust) branch tracing-to-log updated (35b4b40 -> eedb8ca) tison
• (fluss-rust) branch tracing-to-log updated (feae500 -> 35b4b40) tison
• (fluss-rust) branch tracing-to-log updated (3011a70 -> feae500) tison
• (fluss-rust) branch tracing-to-log updated (1e8b443 -> 3011a70) tison
• (fluss-rust) branch tracing-to-log created (now 1e8b443) tison
  • (fluss-rust) 01/01: chore: use log over tracing tison
• (fluss-rust) branch adopt-jiff deleted (was 0165b4e) tison
• (fluss-rust) branch main updated: chore: upgrade opendal and adopt jiff (#95) yuxia
• (fluss-rust) branch adopt-jiff created (now 0165b4e) tison
  • (fluss-rust) 01/01: chore: upgrade opendal and adopt jiff tison
• (fluss) branch release-0.8 updated (5209501b1 -> 7e04485fc) jark
  • (fluss) 02/03: [docs] Add warning message in "Deploying Local Cluster" page (#2156) jark
  • (fluss) 03/03: [docs] Update Java version requirements in deployment documentation for clarity (#2131) jark
  • (fluss) 01/03: Fix invalid link in datalake iceberg document. (#2148) jark
• (fluss) branch main updated: [docs] Update Java version requirements in deployment documentation for clarity (#2131) jark
• (fluss) branch main updated: [docs] Add warning message in "Deploying Local Cluster" page (#2156) jark
• (fluss) branch main updated: [coordinator] Log the reason for failures in bucket or replica state changes (#2145) jark
• (fluss) branch main updated: [iceberg] support altering table properties (#2043) mehulbatra
• (fluss-rust) branch main updated: chore: update readme to mark it as official rust client (#88) yuxia
• (fluss-rust) branch main updated: feat: introduce cpp bindings (#83) yuxia
• (fluss) branch main updated: [server] Fix ISR state leak causing permanent deadlock during rolling upgrades (#2147) jark
• (fluss) branch main updated: [FLUSS-2137][docs] Added Recent Conference Talks and Sessions to Videos Area (#2143) ipolyzos
• (fluss-rust) branch main updated: chore: Implement datatype conversion for all types in arrow.rs (#81) yuxia
• (fluss) branch main updated: fix typo in metadata manage (#2159) yunhong
• (fluss-rust) branch main updated: chore: fix GenericRow null detection (#86) yuxia
• (fluss) branch main updated: [iceberg] Use DataFileSet / DeleteFileSet instead of normal collections (#2155) yuxia
• (fluss-rust) branch main updated: chore: implemented all get methods for GenericRow (#82) yuxia
• (fluss) branch main updated: [lake] Forbidden schema evolution for lake enabled tables. (#2150) yuxia
• (fluss) branch main updated: date update (#2153) ipolyzos
• (fluss) branch main updated (8f69bcc09 -> f11b43b6e) jark
• (fluss) branch main updated: fluss-iceberg blog part-1 (#2057) ipolyzos
• (fluss) branch main updated (872554b32 -> 65666f4c5) ipolyzos
• (fluss) branch main updated: [kv/auto increment column] constrain upsert behavior for auto increment column (#2117) chengwang
• (fluss) branch main updated: [test] Fix unstable test FlinkSinkWriterTest.testFlussSchemaChange. (#2116) hongshun
• (fluss) branch main updated: [kv/auto increment column] add auto increment column in Fluss schema (#1887) chengwang
• (fluss) branch main updated: [paimon] Align error msg when altering table properties (#2046) yuxia
• (fluss) branch main updated: [iceberg] Fix iceberg aws glue catalog class not found. (#2038) yuxia
• (fluss) branch main updated: [doc] use standard Flink docker image in QuickStart (#1997) yuxia
• (fluss-rust) branch main updated: feat: Implement JsonSerde for all datatypes (#53) yuxia
• (fluss) branch main updated: [client] Add unavailable tabletServer set for MetadataUpdater to avoid serverNode info of all tabletServers are invalid (#2098) jark
• (fluss) branch main updated: [client] Change the default value of 'client.lookup.max-retries' to Integer.MAX_VALUE (#2096) jark
• (fluss) branch main updated: [client] LookupSender get table info from LookupQuery (#2093) jark
• (fluss-rust) branch main updated: feat: support ColumnPruning (#57) yuxia
• (fluss) branch main updated: [docs] Fixed Language Discrepancy in build_versioned_docs.sh Script (#2090) jark
• (fluss) branch main updated: [FLUSS-2062][docs] Added Redirect for Latest Stable Version Docs (#2085) leonard
• (fluss) branch exec-plugin created (now 75f13ca41) hongshun
  • (fluss) 01/01: Bump exec-maven-plugin to 3.1.0 hongshun
• (fluss) branch main updated: [rpc] Prevent EventLoop blocking and implement TCP-level backpressure in RequestChannel (#2065) jark
• (fluss) branch main updated: [server] Avoid ReplicaFetcher busy loop retry storm during leader election or bucket migration (#2075) jark
• (fluss-website) branch main updated: [github] Upgrade node version to 20 jark
• (fluss) branch release-0.8 updated: [docs] Clarify the supported flink versions for delta join (#2030) jark
• (fluss) branch main updated (07721fe6e -> f1a75ca0a) jark
• (fluss) branch ci-array-flink deleted (was 209d6eda6) jark
• (fluss) branch ci-array-flink updated (43fd9f74e -> 209d6eda6) jark
  • (fluss) 02/02: [common] Deep copy ColumnarArray in CompletedFetch#fetchRecords() to fix Arrow IndexOutOfBoundsException jark
  • (fluss) 01/02: [flink] Remove unnecessary fixVectorBuffers and add more ArrayType IT cases jark
• (fluss) branch main updated (543c703fb -> 07721fe6e) jark
• (fluss) branch main updated: [FLUSS-1961][docs] Upgrade Docusaurus to 3.9.2 (#1962) leonard
• (fluss-rust) branch dependabot/github_actions/actions/checkout-6 created (now 3bc4ab3) github-bot
• (fluss-rust) branch dependabot/github_actions/actions/checkout-5 deleted (was ddf5777) github-bot
• (fluss) branch ci-array-flink updated (ac9ca8bff -> 43fd9f74e) jark
  • (fluss) 01/02: [flink] Support Array type in Flink connector jark
  • (fluss) 02/02: [flink] Cleanup the Array type implementation jark
• (fluss) branch ci-add-column deleted (was 9be3ebcac) jark
• (fluss) branch ci-array-flink created (now ac9ca8bff) jark
  • (fluss) 01/01: test jark
• (fluss) branch ci-add-column updated: revert source changes jark
• (fluss) branch ci-add-column updated (1e3ecf289 -> 205b7261a) jark
  • (fluss) 02/02: fix failed case jark
  • (fluss) 01/02: WIP jark
• (fluss) branch ci-add-column updated (8660164b0 -> 1e3ecf289) jark
  • (fluss) 02/03: WIP jark
  • (fluss) 01/03: ServerSchemaCache TablePath -> tableId jark
  • (fluss) 03/03: WIP jark
• (fluss) branch ci-add-column updated: KvTablet jark
• (fluss) branch main updated: [client] Lookup sender need retry to send when leader not found in metadata cache (#2052) jark
• (fluss) branch ci-add-column updated: fix lookup jark
• (fluss) branch ci-add-column updated: fix sink jark
• (fluss) branch ci-add-column updated: add javadoc jark
• (fluss) branch ci-add-column created (now ff3db43d4) jark
  • (fluss) 05/07: WIP2 jark
  • (fluss) 04/07: WIP jark
  • (fluss) 03/07: server projection cache jark
  • (fluss) 01/07: WIP jark
  • (fluss) 06/07: revert FlinkAsFlussRow changes jark
  • (fluss) 07/07: WIP3 jark
  • (fluss) 02/07: WIP1 jark
• (fluss) branch main updated: [client] Fix NPE thrown by MetadataUpdater when getting bucket count (#2054) jark
• (fluss) branch main updated: [hotfix][client] Retry to initial cluster when encounter TimeoutException (#2055) jark
• (fluss-rust) branch main updated: chore: fix ci (#69) yuxia
• (fluss-rust) branch main updated: feat: implement Display trait for DataType and related types (#50) yuxia
• (fluss-rust) branch main updated: feat: implement get_long for GenericRow (#49) yuxia
• (fluss) branch main updated: [client] Get TableInfo via the Admin API instead of via metadata updater (#2016) jark
• (fluss) branch main updated: [server] Recover log and index file for unclean shutdown and optimize log recovery time (#2044) jark
• (fluss) branch main updated: [hotfix][docs] Fix typo in downloads.md: hhttps -> https (#2050) ipolyzos
• (fluss) branch main updated: [client] Support initial cluster with retries to avoid initial failed when bootstrap server only contains one available address (#2024) jark
• (fluss) branch main updated: [zk] Allow to set jute.maxbuffer for zk client (#2048) jark
• (fluss) branch main updated: [iceberg] Bump iceberg version to 1.10.0 (#2008) yuxia
• (fluss) branch main updated: [dependencies] Bump Hadoop to 3.4.0 (#2009) yuxia
• (fluss) branch main updated: [common] Fix thread-safety problem of PrimaryKeyLoookuper and PrefixKeyLookuper (#1915) jark
• (fluss) branch main updated: Revert "[server] Recover log and index file for unclean shutdown (#1749)" (#2036) yunhong
• (fluss) branch main updated: [lake/paimon] Bump Paimon version to 1.3.1 (#2035) yuxia
• (fluss) branch main updated: [hotfix] fix typo in tiering enumerator (#2034) yuxia
• (fluss) branch main updated (590e91c0c -> fa1999d95) yunhong
• (fluss) branch main updated: Make README consistent with developer guide regarding minimum Java version (#1944) ipolyzos
• (fluss) branch main updated: [flink] Upgrade Flink dependency to 1.20.3 and 2.1.1 (#1988) jark
• (fluss) branch main updated: [website] remove kafka compatibility from the roadmap (#2027) jark
• (fluss) branch main updated: [server] Set the waiting time of executing server shutdown hook to 120s to avoid an unclean server shutdown (#2026) jark
• (fluss) branch main updated: [docs] Clarify the supported flink versions for delta join (#2000) jark
• (fluss) branch main updated: [server] Close ZooKeeperClient only after all dependent components have been shut down to prevent exceptions (#2023) yunhong
• (fluss) branch main updated: [server] Last close ZookeeperClient to prevent exceptions (#2018) yunhong
• (fluss-rust) branch main updated: [chore] Fix build fail on mac os (#61) yuxia
• (fluss) branch main updated: [server] Register signal handlers to log termination due to SIGTERM, SIGHUP and SIGINT (#2012) yunhong
• (fluss) branch main updated: [iceberg] minor improvements (#2015) yuxia
• (fluss-rust) branch main updated: [chore] Add ipc_compression feature to arrow dependency (#59) yuxia
• (fluss) branch main updated (ae84521aa -> 05a5db964) jark
• (fluss-rust) branch main updated: chore: add integration test for scan records after append (#51) yuxia
• (fluss-rust) branch main updated: [chore] Bump arrow version to 57 (#58) yuxia
• (fluss) branch main updated: [lake] Tiering job name as per lake format (#2003) jark
• (fluss) branch main updated: [website] Hero section update (#2002) jark
• (fluss) branch main updated: [docs] Fix Lakehouse diagrams (#2001) jark
• (fluss) branch main updated: [lake/paimon] Support passing Fluss table comment through to the Paimon table (#1999) yuxia
• (fluss) branch main updated: [lake/paimon] Tolerate Paimon lake table existent with different insignificant options (#1995) yuxia
• (fluss) branch main updated: [hotfix] Set finish before notifying load in LanceArrowWriter setFinished method (#1985) yuxia
• (fluss) branch main updated: [github] Upgrade Fluss version 0.8.0 in BUG issue template jark
• (fluss) branch main updated: [lake] Tolerate Paimon lake table existent if the schema and properties matches (#1847) yuxia
• (fluss) branch release-0.8 updated: [hotfix] Fix iceberg quickstart sql (#1964) (#1968) yuxia
• (fluss) branch main updated: [hotfix] Fix iceberg quickstart sql (#1964) yuxia
• (fluss) branch main updated (8faff0ea8 -> 9c7c3ad2a) jark
• (fluss) branch release-0.8 updated: [doc] Separate Quickstart into "Building a Streaming Lakehouse" and "Real-Time Analytics with Flink" (#1924) jark
• (fluss) branch main updated: [doc] Separate Quickstart into "Building a Streaming Lakehouse" and "Real-Time Analytics with Flink" (#1924) jark
• (fluss) branch main updated: [hotfix] add lake jars in the download page (#1960) jark
• (fluss) branch main updated: [server] Recover log and index file for unclean shutdown (#1749) jark
• (fluss) branch main updated: [Client] Fix LookupSender doesn't update bucket metadata when receive NotLeaderOrFollowerException in bucket level (#1928) yunhong
• (fluss) branch main updated: [release] Update the release documentation jark
• (fluss) branch main updated: [release] Fix missing LICENSE and DISCLAIMER in binary distribution (#1922) jark
• (fluss) branch main updated: [website] Release 0.8 blog post and update Download page (#1868) jark
• (fluss) branch main updated: [metric] Update metric group infix to meet document (#1942) yunhong
• svn commit: r80534 - dev/incubator/fluss/helm-chart jark
• (fluss) branch main updated: [release] Publish the v0.8 documentation as released version jark
• (fluss) annotated tag v0.8.0-incubating updated (c18e53ed0 -> 1bc519c9f) jark
• svn commit: r80524 - release/incubator/fluss/helm-chart jark
• svn commit: r80522 - dev/incubator/fluss/helm-chart/0.8.0-incubating-rc1 release/incubator/fluss/helm-chart/0.8.0-incubating jark
• svn commit: r80521 - release/incubator/fluss/helm-chart jark
• svn commit: r80520 - dev/incubator/fluss/fluss-0.8.0-incubating-rc1 release/incubator/fluss/fluss-0.8.0-incubating jark
• (fluss) branch main updated: [lake] Avoid to generate empty split in tiering source enumerator (#1925) yuxia
• (fluss) branch main updated: [client] Aggregate Fluss client connection metrics to reduce the number of metrics (#1896) jark
• (fluss) branch main updated: Fix timestamp precision (#1931) ipolyzos
• (fluss) branch main updated: [client][hotfix] Invoke `RowType#getFieldNames` only once in `ConverterCommons` (#1920) ipolyzos
• (fluss) branch main updated: [hotfix] Make paimonConfig of PaimonLakeStorage protected in case a subclass needs to use it (#1916) yuxia
• (fluss) branch main updated (f9b007259 -> e402fbc11) yuxia
• (fluss) branch main updated: [release] Update release documentation for the new directory of helm jark
• (fluss) branch release-0.8 updated (a876cf80e -> 029a39d2c) jark
  • (fluss) 11/17: [lake/lance] add Flink memory usage note (#1909) jark
  • (fluss) 04/17: [hotfix] fix sidebar naming conversion (#1898) jark
  • (fluss) 03/17: [hotfix][client] Fix potential metadata inconsistency by deduplicating getBucketLocation call (#1897) jark

• Earlier messages
• Later messages