issues  

Messages by Thread

• [PR] [common] Remove MapUtils.newConcurrentMap() to avoid dependencies conflict. [fluss] via GitHub
• [PR] [dependencies] Bump com.google.protobuf:protobuf-java from 2.5.0 to 3.25.5 [fluss] via GitHub
  • Re: [PR] [dependencies] Bump com.google.protobuf:protobuf-java from 2.5.0 to 3.25.5 [fluss] via GitHub
• [PR] [release-0.9] Bump org.apache.kafka:kafka-clients from 3.9.1 to 3.9.2 in /fluss-kafka [fluss] via GitHub
  • Re: [PR] [release-0.9] Bump org.apache.kafka:kafka-clients from 3.9.1 to 3.9.2 in /fluss-kafka [fluss] via GitHub
• Re: [PR] Bump com.google.protobuf:protobuf-java from 2.5.0 to 3.25.5 in /fluss-filesystems/fluss-fs-hdfs [fluss] via GitHub
• [PR] Bump org.apache.logging.log4j:log4j-core from 2.17.1 to 2.25.4 [fluss] via GitHub
• [PR] Bump org.apache.logging.log4j:log4j-1.2-api from 2.17.1 to 2.25.4 [fluss] via GitHub
• [PR] [server][netty] Introduce netty.server.max-request-size to limit the request size (#3050) [fluss] via GitHub
• [PR] Handle coordinator disconnect in TieringSourceEnumerator [fluss] via GitHub
  • Re: [PR] Handle coordinator disconnect in TieringSourceEnumerator [fluss] via GitHub
• [I] TieringSource should fail over when coordinator IP changes and heartbeat retries a stale endpoint [fluss] via GitHub
• [PR] Bump org.apache.kafka:kafka-clients from 3.9.1 to 3.9.2 in /fluss-kafka [fluss] via GitHub
  • Re: [PR] Bump org.apache.kafka:kafka-clients from 3.9.1 to 3.9.2 in /fluss-kafka [fluss] via GitHub
• [PR] [client] Catch throwable to avoid slient failure on remote file download [fluss] via GitHub
  • Re: [PR] [client] Catch throwable to avoid slient failure on remote file download [fluss] via GitHub
• [I] Java.lang.NoSuchFieldError: JAVA_9 [fluss] via GitHub
• [PR] [client] release the resource of record accumulator only when sender thread is stopped. [fluss] via GitHub
  • Re: [PR] [client] release the resource of record accumulator only when sender thread is stopped. [fluss] via GitHub
  • Re: [PR] [client] release the resource of record accumulator only when sender thread is stopped. [fluss] via GitHub
  • Re: [PR] [client] release the resource of record accumulator only when sender thread is stopped. [fluss] via GitHub
  • Re: [PR] [client] release the resource of record accumulator only when sender thread is stopped. [fluss] via GitHub
  • Re: [PR] [client] release the resource of record accumulator only when sender thread is stopped. [fluss] via GitHub
  • Re: [PR] [client] release the resource of record accumulator only when sender thread is stopped. [fluss] via GitHub
• [I] java.lang.IllegalArgumentException: Accounted size went negative. [fluss] via GitHub
• [I] [test] Unstable test IcebergRewriteITCase.testPkTableCompaction [fluss] via GitHub
• [PR] [ci/cd] fix python tests with more strict scoping [fluss-rust] via GitHub
  • Re: [PR] [ci/cd] fix python tests with more strict scoping [fluss-rust] via GitHub
  • Re: [PR] [ci/cd] fix python tests with more strict scoping [fluss-rust] via GitHub
  • Re: [PR] [ci/cd] fix python tests with more strict scoping [fluss-rust] via GitHub
• [PR] [WIP][spark] Add spark tiering service [fluss] via GitHub
• [PR] [helm] Support injecting environment variables and external secrets [fluss] via GitHub
  • Re: [PR] [helm] Support injecting environment variables and external secrets [fluss] via GitHub
  • Re: [PR] [helm] Support injecting environment variables and external secrets [fluss] via GitHub
  • Re: [PR] [helm] Support injecting environment variables and external secrets [fluss] via GitHub
  • Re: [PR] [helm] Support injecting environment variables and external secrets [fluss] via GitHub
  • Re: [PR] [helm] Support injecting environment variables and external secrets [fluss] via GitHub
  • Re: [PR] [helm] Support injecting environment variables and external secrets [fluss] via GitHub
  • Re: [PR] [helm] Support injecting environment variables and external secrets [fluss] via GitHub
  • Re: [PR] [helm] Support injecting environment variables and external secrets [fluss] via GitHub
• [I] [helm] Support injecting environment variables and external secrets [fluss] via GitHub
  • Re: [I] [helm] Support injecting environment variables and external secrets [fluss] via GitHub
• [I] [server] Add timeout mechanism for rebalance tasks to prevent indefinite blocking on missing completion events [fluss] via GitHub
• Re: [PR] [docs] Add Lakekeeper catalog reference [fluss] via GitHub
• [I] [flink] Skip emitting update events when only non-projected columns are modified in source connector [fluss] via GitHub
  • Re: [I] [flink] Skip emitting update events when only non-projected columns are modified in source connector [fluss] via GitHub
  • Re: [I] [flink] Skip emitting update events when only non-projected columns are modified in source connector [fluss] via GitHub
• [PR] [filesystem] Support default AWS credential chain for S3 delegation (… [fluss] via GitHub
  • Re: [PR] [backport][release-0.9][filesystem] Support default AWS credential chain for S3 delegation (… [fluss] via GitHub
• [I] [docs] Fix table cell overflow into sidebar [fluss] via GitHub
  • Re: [I] [docs] Fix table cell overflow into sidebar [fluss] via GitHub
• [PR] [docs] chore: fix overlapping table and sidebar in docs [fluss] via GitHub
  • Re: [PR] [docs] chore: fix overlapping table and sidebar in docs [fluss] via GitHub
• [I] RemoteLogFetcher optimize to async downloading [fluss] via GitHub
  • Re: [I] RemoteLogFetcher optimize to async downloading [fluss] via GitHub
• [PR] [server] Fix OOB in partial update/delete after ADD COLUMN (#3000) [fluss] via GitHub
  • Re: [PR] [release-0.9][backport] Fix OOB in partial update/delete after ADD COLUMN [fluss] via GitHub
• Re: [I] Support Kafka Protocol Compatibility [fluss] via GitHub
• Re: [I] Support Kafka Protocol 4: Add utils to convert Kafka MemoryRecords [fluss] via GitHub
• [PR] [hotfix[ blog title [fluss] via GitHub
  • Re: [PR] [hotfix[ blog title [fluss] via GitHub
• [PR] [Blog] Column Pruning [fluss] via GitHub
  • Re: [PR] [Blog] Column Pruning [fluss] via GitHub
  • Re: [PR] [Blog] Column Pruning [fluss] via GitHub
  • Re: [PR] [Blog] Column Pruning [fluss] via GitHub
• [PR] [ISSUE-3073] Add documentation for how contributors can become committers [fluss] via GitHub
  • Re: [PR] [docs] Add documentation for how contributors can become committers [fluss] via GitHub
  • Re: [PR] [docs] Add documentation for how contributors can become committers [fluss] via GitHub
  • Re: [PR] [docs] Add documentation for how contributors can become committers [fluss] via GitHub
• [I] [elixir] Support fine-grained errors like in other bindings [fluss-rust] via GitHub
• [PR] [website] Hide left sidebar for blog page and improve the fonts [fluss] via GitHub
  • Re: [PR] [website] Hide left sidebar for blog page and improve the fonts [fluss] via GitHub
• [I] Remote log consumption is stuck because the semaphore permit cannot be acquired [fluss] via GitHub
  • Re: [I] Remote log consumption is stuck because the semaphore permit cannot be acquired [fluss] via GitHub
  • Re: [I] Remote log consumption is stuck because the semaphore permit cannot be acquired [fluss] via GitHub
  • Re: [I] Remote log consumption is stuck because the semaphore permit cannot be acquired [fluss] via GitHub
• [I] Flink log table consumer threw an out-of-range offset exception [fluss] via GitHub
• [I] [test] Unstable test RemoteLogITCase.testRemoteLogTTLWithDynamicLakeToggle [fluss] via GitHub
• [PR] Add fluss-microbench module with YAML-driven perf framework and JMH b… [fluss] via GitHub
• [PR] Rocksdb Perf Demo [fluss] via GitHub
  • Re: [PR] Rocksdb Perf Demo [fluss] via GitHub
• [I] Add fluss-microbench module: YAML-driven performance testing framework with JMH benchmarks [fluss] via GitHub
• [PR] [Blog] Realtime UV Dedup [fluss] via GitHub
  • Re: [PR] [Blog] Realtime UV Dedup [fluss] via GitHub
  • Re: [PR] [Blog] Realtime UV Dedup [fluss] via GitHub
• [PR] [server] Add authorization to databaseExists and tableExists RPC call… [fluss] via GitHub
• [PR] [blog] taobaro realtime decisions [fluss] via GitHub
  • Re: [PR] [blog] taobao realtime decisions [fluss] via GitHub
  • Re: [PR] [blog] taobao realtime decisions [fluss] via GitHub
• [PR] [lake/tiering] add tiering table pending time and freshness metrics [fluss] via GitHub
  • Re: [PR] [lake/tiering] add tiering table pending time and freshness metrics [fluss] via GitHub
  • Re: [PR] [lake/tiering] add tiering table pending time and freshness metrics [fluss] via GitHub
• [I] [lake/tiering] Add pendingTime and freshness metrics for lake tiering tables [fluss] via GitHub
  • Re: [I] [lake/tiering] Add pendingTime and freshness metrics for lake tiering tables [fluss] via GitHub
• [I] add a page for reporting security issue [fluss] via GitHub
• [I] add document for how contributors can be granted more rights such as commit access or decision power is clearly documented [fluss] via GitHub
  • Re: [I] add document for how contributors can be granted more rights such as commit access or decision power is clearly documented [fluss] via GitHub
  • Re: [I] add document for how contributors can be granted more rights such as commit access or decision power is clearly documented [fluss] via GitHub
  • Re: [I] add document for how contributors can be granted more rights such as commit access or decision power is clearly documented [fluss] via GitHub
• [I] Csp_check is warning [fluss] via GitHub
• [PR] [server] Make leader-only rebalance tasks execute sequentially [fluss] via GitHub
  • Re: [PR] [server] Make leader-only rebalance tasks execute sequentially [fluss] via GitHub
  • Re: [PR] [server] Make leader-only rebalance tasks execute sequentially [fluss] via GitHub
  • Re: [PR] [server] Make leader-only rebalance tasks execute sequentially [fluss] via GitHub
  • Re: [PR] [server] Make leader-only rebalance tasks execute sequentially [fluss] via GitHub
• [I] Leader-only rebalance tasks should wait for tablet server acknowledgment before proceeding to the next migration [fluss] via GitHub
• [PR] [client] Add validation for client.scanner.log.max-poll-records and client.connect-timeout [fluss] via GitHub
  • Re: [PR] [client] Add validation for client.scanner.log.max-poll-records and client.connect-timeout [fluss] via GitHub
  • Re: [PR] [client] Add validation for client.scanner.log.max-poll-records and client.connect-timeout [fluss] via GitHub
  • Re: [PR] [client] Add validation for client.scanner.log.max-poll-records and client.connect-timeout [fluss] via GitHub
  • Re: [PR] [client] Add validation for client.scanner.log.max-poll-records and client.connect-timeout [fluss] via GitHub
  • Re: [PR] [client] Add validation for client.scanner.log.max-poll-records and client.connect-timeout [fluss] via GitHub
  • Re: [PR] [client] Add validation for client.scanner.log.max-poll-records and client.connect-timeout [fluss] via GitHub
  • Re: [PR] [client] Add validation for client.scanner.log.max-poll-records and client.connect-timeout [fluss] via GitHub
  • Re: [PR] [client] Add validation for client.scanner.log.max-poll-records and client.connect-timeout [fluss] via GitHub
  • Re: [PR] [client] Add validation for client.scanner.log.max-poll-records and client.connect-timeout [fluss] via GitHub
• [I] [client] Add validation for client.scanner.log.max-poll-records and client.connect-timeout config options [fluss] via GitHub
• [PR] [filesystem] Support default AWS credential chain for S3 delegation [fluss] via GitHub
  • Re: [PR] [filesystem] Support default AWS credential chain for S3 delegation [fluss] via GitHub
  • Re: [PR] [filesystem] Support default AWS credential chain for S3 delegation [fluss] via GitHub
  • Re: [PR] [filesystem] Support default AWS credential chain for S3 delegation [fluss] via GitHub
  • Re: [PR] [filesystem] Support default AWS credential chain for S3 delegation [fluss] via GitHub
  • Re: [PR] [filesystem] Support default AWS credential chain for S3 delegation [fluss] via GitHub
  • Re: [PR] [filesystem] Support default AWS credential chain for S3 delegation [fluss] via GitHub
  • Re: [PR] [filesystem] Support default AWS credential chain for S3 delegation [fluss] via GitHub
  • Re: [PR] [filesystem] Support default AWS credential chain for S3 delegation [fluss] via GitHub
  • Re: [PR] [filesystem] Support default AWS credential chain for S3 delegation [fluss] via GitHub
  • Re: [PR] [filesystem] Support default AWS credential chain for S3 delegation [fluss] via GitHub
  • Re: [PR] [filesystem] Support default AWS credential chain for S3 delegation [fluss] via GitHub
• [I] [filesystem] S3 credential delegation requires static keys, blocking IRSA/IAM role usage [fluss] via GitHub
  • Re: [I] [filesystem] S3 credential delegation requires static keys, blocking IRSA/IAM role usage [fluss] via GitHub
• [PR] Chore/rustfs assume role fixes release 0.9 [fluss] via GitHub
  • Re: [PR] Chore/rustfs assume role fixes release 0.9 [fluss] via GitHub
  • Re: [PR] [release-0.9] chore: rustfs assume role fixes [fluss] via GitHub
  • Re: [PR] [release-0.9] chore: rustfs assume role fixes [fluss] via GitHub
  • Re: [PR] [release-0.9] chore: rustfs assume role fixes and docusaurus fix [fluss] via GitHub
• [I] [Feature] Support secondary index on `user_id` / (`user_id`, `order_date`) for detail tables used by Flink SQL [fluss] via GitHub
• Re: [I] Use default chunk size as 4 MB than than 16Mb in arrow's rolling policy. [fluss] via GitHub
• [I] [ci] Python CI run 3.11 runs into timeout [fluss-rust] via GitHub
  • Re: [I] [ci] Python CI run 3.11 runs into timeout [fluss-rust] via GitHub
  • Re: [I] [ci] Python CI run 3.11 runs into timeout [fluss-rust] via GitHub
  • Re: [I] [ci] Python CI run 3.11 runs into timeout [fluss-rust] via GitHub
  • Re: [I] [ci] Python CI run 3.11 runs into timeout [fluss-rust] via GitHub
  • Re: [I] [ci] Python CI run 3.11 runs into timeout [fluss-rust] via GitHub
• [PR] [ci] Upgrade checkout@v4 to v6 and setup-python@v5 to v6 [fluss-rust] via GitHub
  • Re: [PR] [ci] Upgrade checkout@v4 to v6 and setup-python@v5 to v6 [fluss-rust] via GitHub
• [I] [CI] Upgrade checkout@v4 and setup-python@v5 to migrate from deprecated node v20 [fluss-rust] via GitHub
  • Re: [I] [CI] Upgrade checkout@v4 and setup-python@v5 to migrate from deprecated node v20 [fluss-rust] via GitHub
• [I] [benchmark] Rust core benchmark [fluss-rust] via GitHub
• [I] [test] Unstable test RebalanceManagerITCase.testBuildClusterModel [fluss] via GitHub
• [I] [flink] CI compilation failure in FlinkTableSourceFilterPushDownTest after #3054 [fluss] via GitHub
  • Re: [I] [flink] CI compilation failure in FlinkTableSourceFilterPushDownTest after #3054 [fluss] via GitHub
• [PR] [flink] Fix CI compilation error: adapt test to int[] nullCounts signature [fluss] via GitHub
  • Re: [PR] [flink] Fix CI compilation error: adapt test to int[] nullCounts signature [fluss] via GitHub
• [PR] chore: fix main with Long[] -> int[] issue [fluss] via GitHub
  • Re: [PR] chore: fix broken main with Long[] -> int[] issue [fluss] via GitHub
• [PR] [metrics] Fix pendingRecords metric to return actual row count for primary key tables when lake tiering hasn't started [fluss] via GitHub
  • Re: [PR] [metrics] Fix pendingRecords metric to return actual row count for primary key tables when lake tiering hasn't started [fluss] via GitHub
  • Re: [PR] [metrics] Fix pendingRecords metric to return actual row count for primary key tables when lake tiering hasn't started [fluss] via GitHub
  • Re: [PR] [metrics] Fix pendingRecords metric to return actual row count for primary key tables when lake tiering hasn't started [fluss] via GitHub
  • Re: [PR] [metrics] Fix pendingRecords metric to return actual row count for primary key tables when lake tiering hasn't started [fluss] via GitHub
  • Re: [PR] [metrics] Fix pendingRecords metric to return actual row count for primary key tables when lake tiering hasn't started [fluss] via GitHub
• Re: [PR] [client] Clear VectorSchemaRoot to release buffer as soon as possible after a batch read finished. [fluss] via GitHub
• Re: [PR] [common] A custom rounding policy that reduces Arrow's chunk size fm 16MB to 4MB which same as netty arena. [fluss] via GitHub
  • Re: [PR] [common] A custom rounding policy that reduces Arrow's chunk size fm 16MB to 4MB which same as netty arena. [fluss] via GitHub
• Re: [I] Clear VectorSchemaRoot to release buffer as soon as possible after a batch read finined. [fluss] via GitHub
• Re: [I] Iceberg support union read for primary key table in batch mode [fluss] via GitHub
• Re: [I] Support tier map type for iceberg [fluss] via GitHub
• [PR] Bump org.apache.logging.log4j:log4j-core from 2.25.3 to 2.25.4 in /tools/ci/fluss-shaded-ci-tools [fluss-shaded] via GitHub
• [PR] chore: fix docs for RustFS AssumeRole [fluss] via GitHub
  • Re: [PR] chore: fix docs for RustFS AssumeRole [fluss] via GitHub
  • Re: [PR] chore: fix docs for RustFS AssumeRole [fluss] via GitHub
  • Re: [PR] chore: fix docs for RustFS AssumeRole [fluss] via GitHub
  • Re: [PR] chore: fix docs for RustFS AssumeRole [fluss] via GitHub
  • Re: [PR] chore: fix docs for RustFS AssumeRole [fluss] via GitHub
• [PR] [spark] Fix column projection on log/upsert read path [fluss] via GitHub
  • Re: [PR] [spark] Fix column projection on log/upsert read path [fluss] via GitHub
  • Re: [PR] [spark] Fix column projection on log/upsert read path [fluss] via GitHub
  • Re: [PR] [spark] Fix column projection on log/upsert read path [fluss] via GitHub
  • Re: [PR] [spark] Fix column projection on log/upsert read path [fluss] via GitHub
• [PR] [python] chore: fix python 3.11 bug with async wait_for [fluss-rust] via GitHub
  • Re: [PR] [python] chore: fix python 3.11 bug with async wait_for [fluss-rust] via GitHub
  • Re: [PR] [python] chore: fix python 3.11 bug with async wait_for [fluss-rust] via GitHub
  • Re: [PR] [python] chore: fix python 3.11 bug with async wait_for [fluss-rust] via GitHub
  • Re: [PR] [python] chore: fix python 3.11 bug with async wait_for [fluss-rust] via GitHub
• [PR] [fix] fix: add lakeSource check in batch mode [fluss] via GitHub
• [I] [flink] Fix NPE then flink reading in batch mode and "scan.startup.mode" is not "FULL". [fluss] via GitHub
• [PR] [common] Optimize getNullCounts() to return int[] instead of Long[] [fluss] via GitHub
  • Re: [PR] [common] Optimize getNullCounts() to return int[] instead of Long[] [fluss] via GitHub
  • Re: [PR] [common] Optimize getNullCounts() to return int[] instead of Long[] [fluss] via GitHub
• [PR] feat: (Python) Add async context manager [fluss-rust] via GitHub
  • Re: [PR] feat: (Python) Add async context manager [fluss-rust] via GitHub
  • Re: [PR] feat: (Python) Add async context manager [fluss-rust] via GitHub
  • Re: [PR] feat: (Python) Add async context manager [fluss-rust] via GitHub
  • Re: [PR] feat: (Python) Add async context manager [fluss-rust] via GitHub
  • Re: [PR] feat: (Python) Add async context manager [fluss-rust] via GitHub
  • Re: [PR] feat: (Python) Add async context manager [fluss-rust] via GitHub
• [I] [client] LogFetchCollector uses immutable fetchOffset for staleness check, causing cross-poll CompletedFetch to be drained [fluss] via GitHub
  • Re: [I] [client] LogFetchCollector uses immutable fetchOffset for staleness check, causing cross-poll CompletedFetch to be drained [fluss] via GitHub
• [PR] Fix stale fetch detection across poll boundaries [fluss] via GitHub

• Earlier messages