Messages by Thread
-
[I] [server] Add authorization to Remote Log & Tiering RPCs (commitRemoteLogManifest, notifyRemoteLogOffsets, lakeTieringHeartbeat) [fluss]
via GitHub
-
[I] [server] Add authorization to Snapshot Management RPCs (commitKvSnapshot, notifyKvSnapshotOffset, commitLakeTableSnapshot, notifyLakeTableOffset) [fluss]
via GitHub
-
[I] [server] Add authorization to Snapshot Read Operations (getLatestKvSnapshots, getKvSnapshotMetadata, getLatestLakeSnapshot) [fluss]
via GitHub
-
[I] [server] Add authorization to Replication Control RPCs (notifyLeaderAndIsr, updateMetadata, stopReplica, adjustIsr) [fluss]
via GitHub
-
[I] [server] Add authorization to Table Metadata Read Operations (getTableSchema, listPartitionInfos, listOffsets) [fluss]
via GitHub
-
[I] [server] Add authorization to databaseExists and tableExists RPC call [fluss]
via GitHub
-
[PR] feat: implement FlussMap support for compacted rows and binary encoding [fluss-rust]
via GitHub
-
[PR] docs: add FIP contribution guide for substantial proposals [fluss]
via GitHub
-
[PR] docs: add blog contribution guide for website contributors [fluss]
via GitHub
-
[PR] [chore] reduce workers to 2 with loadfile distribution [fluss-rust]
via GitHub
-
[I] [rust] Introduce SchemaId newtype to replace i32/i16 schema id passing [fluss-rust]
via GitHub
-
[PR] chore: fix context_manager in python for async handling [fluss-rust]
via GitHub
-
[PR] [client] Fix tiering hang on first_row merge engine empty batches [fluss]
via GitHub
-
[I] [rust] Support alter table request [fluss-rust]
via GitHub
-
Re: [PR] Update prost-build requirement from 0.13.5 to 0.14.1 [fluss-rust]
via GitHub
-
Re: [PR] Update ordered-float requirement from 4 to 5 [fluss-rust]
via GitHub
-
Re: [PR] Update arrow-schema requirement from 55.1.0 to 56.2.0 [fluss-rust]
via GitHub
-
Re: [PR] Update prost requirement from 0.13.5 to 0.14.1 [fluss-rust]
via GitHub
-
Re: [PR] Update arrow requirement from 55.1.0 to 56.2.0 [fluss-rust]
via GitHub
-
Re: [PR] Bump apache/skywalking-eyes from 0.6.0 to 0.8.0 [fluss-rust]
via GitHub
-
Re: [PR] Bump actions/checkout from 4 to 6 [fluss-rust]
via GitHub
-
Re: [PR] Bump actions/setup-python from 5 to 6 [fluss-rust]
via GitHub
-
Re: [PR] chore(deps): bump actions/cache from 4 to 5 [fluss-rust]
via GitHub
-
[PR] [c++] Add nullability support for data type in c++ [fluss-rust]
via GitHub
-
[I] Support FixedSizeBinary in schema conversion in python [fluss-rust]
via GitHub
-
[PR] [tests] Add integration tests for array data type [fluss-rust]
via GitHub
-
[PR] [python]: Add nullability support for data type in python [fluss-rust]
via GitHub
-
[I] [spark] partition filter pushdown for non-lake log and kv tables [fluss]
via GitHub
-
[PR] [spark] partition filter pushdown for non-lake log and kv tables [fluss]
via GitHub
-
[I] [spark] lake table predicate pushdown [fluss]
via GitHub
-
[PR] [spark] lake table predicate pushdown [fluss]
via GitHub
-
[PR] build(deps): bump actions/upload-artifact from 4 to 7 [fluss-rust]
via GitHub
-
[I] [bindings] map RpcError to NetworkException for Java parity [fluss-rust]
via GitHub
-
[PR] [bindings] map RpcError to NetworkException for Java parity [fluss-rust]
via GitHub
-
[PR] chore: regenerate Cargo.lock for declared metrics deps [fluss-rust]
via GitHub
-
[PR] [docs] Add Lakekeeper catalog reference [fluss]
via GitHub
-
Re: [I] [Lake/Iceberg] create doc to integrate fluss + Iceberg via flink with Lakekeeper (IRC) [fluss]
via GitHub
-
[PR] [rust] lookup decoding schema_id e2e [fluss-rust]
via GitHub
-
[PR] [lake/iceberg] Remove unused includeColumnStats to reduce memory usage [fluss]
via GitHub
-
[PR] [flink] union read from lake with startup timestamp filter [fluss]
via GitHub
-
[I] [Umbrella] Umbrella issue for System Tables [fluss]
via GitHub
-
Re: [PR] [spark] Fix empty projection issue in Spark batch read to avoid Arrow metadata errors with COUNT(*)/COUNT(1) [fluss]
via GitHub
-
Re: [PR] [hotfix] Update paimon version to 1.3.1 in fluss quickstart [fluss]
via GitHub
-
Re: [I] Tiering may stuck for first row merge engine table [fluss]
via GitHub
-
[PR] [server] table buckets system view [fluss]
via GitHub
-
[PR] [server] Support altering table.log.ttl table option [fluss]
via GitHub
-
[PR] [server] Add request queue size metric per processor [fluss]
via GitHub
-
[I] Support alter table.log.ttl [fluss]
via GitHub
-
[I] Streaming union read from the lake and Fluss log table using a specified offset timestamp [fluss]
via GitHub
-
[PR] [server] Add metrics of log startOffset [fluss]
via GitHub
-
[I] Possible OutOfRangeException when reading the stream log table after resuming from a long interruption [fluss]
via GitHub
-
[PR] [spark] Fix empty projection causing Invalid metadata length for COUNT(*)/COUNT(1) [fluss]
via GitHub
-
[PR] [Docs] Website Redesign [fluss]
via GitHub
-
[PR] [server] Skip bucket recovery for non-existent partitions [fluss]
via GitHub
-
[I] Recovery failure when the tablet server shuts down due to 'No space left on device' [fluss]
via GitHub
-
[I] Skip bucket recovery for non-existent partitions [fluss]
via GitHub
-
[PR] [server] Respect the option of 'table.log.ttl' for local segments [fluss]
via GitHub
-
[PR] [client] limit scan use DeepFieldGetter to avoid memory release when … [fluss]
via GitHub
-
[PR] [client] Fix IndexOutOfBoundsException in limit scan for log table with complex types [fluss]
via GitHub
-
[I] Limit scan for log table with complex type will thrown exception. [fluss]
via GitHub
-
[I] [test] Unstable test BatchScannerITCase.testKvSnapshotLease [fluss]
via GitHub
-
Re: [I] [Bug] ArrayIndexOutOfBoundsException when calling toDoubleArray() with arrays larger than a few elements [fluss]
via GitHub
-
[PR] [website] Publish Apache Fluss 0.9.1-incubating [fluss]
via GitHub
-
[PR] Revert "[fluss/ai agent] enable ai doc agent on website (#3152)" [fluss]
via GitHub
-
[I] [spark] Add config to split input partition by input size [fluss]
via GitHub
-
[I] predicate pushdown, log table and pk table, union read [fluss]
via GitHub
-
[I] [spark] Umbrella issue for scan optimization [fluss]
via GitHub
-
[PR] [metrics] Add filter-label-value-characters option for Prometheus reporter [fluss]
via GitHub
-
[I] Support UTF-8 characters in Prometheus label values [fluss]
via GitHub
-
[I] Support API_VERSIONS in rust [fluss-rust]
via GitHub
-
[PR] [client] Implement BatchScanner with limit-based scan [fluss-rust]
via GitHub
-
[PR] [test] Fixing flaky test CoordinatorEventManagerTest.testMetricsUpdatedImmediatelyOnStartup [fluss]
via GitHub