issues  

Messages by Thread

• [PR] [lake/iceberg] add iceberg pk table integration test [fluss] via GitHub
• [I] [Client] Support prefix lookup without partition key columns [fluss] via GitHub
• [PR] [server] Add cluster_id tag for client metric group [fluss] via GitHub
• [I] Add IT for Iceberg files compaction for log table [fluss] via GitHub
  • Re: [I] Add IT for Iceberg files compaction for log table [fluss] via GitHub
• [I] Add IT for Iceberg files compaction for primary key table [fluss] via GitHub
• [I] Add cluster_id tag for TabletServer client metrics [fluss] via GitHub
• [PR] [client] Change the default value of 'netty.client.num-network-threads' to 3 to avoid netty channel congestion [fluss] via GitHub
  • Re: [PR] [client] Change the default value of 'netty.client.num-network-threads' to 3 to avoid netty channel congestion [fluss] via GitHub
• [PR] [lake/iceberg] implement Iceberg log table compaction IT [fluss] via GitHub
  • Re: [PR] [lake/iceberg] implement Iceberg log table compaction IT [fluss] via GitHub
  • Re: [PR] [lake/iceberg] implement Iceberg log table compaction IT [fluss] via GitHub
  • Re: [PR] [lake/iceberg] implement Iceberg log table compaction IT [fluss] via GitHub
  • Re: [PR] [lake/iceberg] implement Iceberg log table compaction IT [fluss] via GitHub
  • Re: [PR] [lake/iceberg] implement Iceberg log table compaction IT [fluss] via GitHub
• [PR] [hotfix] Don't print waiting info in FlinkRowAssertionsUtils.waitForN… [fluss] via GitHub
  • Re: [PR] [hotfix] Don't print waiting info in FlinkRowAssertionsUtils.waitForN… [fluss] via GitHub
  • Re: [PR] [hotfix] Don't print waiting info in FlinkRowAssertionsUtils.waitForN… [fluss] via GitHub
• [PR] [lake] Avoid cast to KeyValueFileStore to get keyComparator in paimon [fluss] via GitHub
  • Re: [PR] [lake] Avoid cast to KeyValueFileStore to get keyComparator in paimon [fluss] via GitHub
• [I] Don't cast to KeyValueFileStore to get keyComparator [fluss] via GitHub
  • Re: [I] Don't cast to KeyValueFileStore to get keyComparator in paimon [fluss] via GitHub
  • Re: [I] Don't cast to KeyValueFileStore to get keyComparator in paimon [fluss] via GitHub
  • Re: [I] Don't cast to KeyValueFileStore to get keyComparator in paimon [fluss] via GitHub
• [I] Iceberg support union read [fluss] via GitHub
• [I] [lake] table.datalake.format only appears when the table has lake enabled [fluss] via GitHub
  • Re: [I] [lake] table.datalake.format only appears when the table has lake enabled [fluss] via GitHub
  • Re: [I] [lake] table.datalake.format only appears when the table has lake enabled [fluss] via GitHub
  • Re: [I] [lake] table.datalake.format only appears when the table has lake enabled [fluss] via GitHub
  • Re: [I] [lake] table.datalake.format only appears when the table has lake enabled [fluss] via GitHub
• [I] Add restore test for streaming union read [fluss] via GitHub
  • Re: [I] Add restore test for streaming union read [fluss] via GitHub
• [PR] [log] Support filter pushdown for log tables [fluss] via GitHub
• [I] why lookup join condition must include all primary keys of the dimension table [fluss] via GitHub
  • Re: [I] why lookup join condition must include all primary keys of the dimension table [fluss] via GitHub
  • Re: [I] why lookup join condition must include all primary keys of the dimension table [fluss] via GitHub
• [I] LogScanner's consumption latency keeps increasing during cluster upgrades [fluss] via GitHub
  • Re: [I] LogScanner's consumption latency keeps increasing during cluster upgrades [fluss] via GitHub
• [PR] [lake/iceberg] Add iceberg documenst for lakehouse support in fluss [fluss] via GitHub
  • Re: [PR] [lake/iceberg] Add iceberg documents for lakehouse support in fluss [fluss] via GitHub
  • Re: [PR] [lake/iceberg] Add iceberg documents for lakehouse support in fluss [fluss] via GitHub
  • Re: [PR] [lake/iceberg] Add iceberg documents for lakehouse support in fluss [fluss] via GitHub
  • Re: [PR] [lake/iceberg] Add iceberg documents for lakehouse support in fluss [fluss] via GitHub
  • Re: [PR] [lake/iceberg] Add iceberg documents for lakehouse support in fluss [fluss] via GitHub
  • Re: [PR] [lake/iceberg] Add iceberg documents for lakehouse support in fluss [fluss] via GitHub
  • Re: [PR] [lake/iceberg] Add iceberg documents for lakehouse support in fluss [fluss] via GitHub
  • Re: [PR] [lake/iceberg] Add iceberg documents for lakehouse support in fluss [fluss] via GitHub
  • Re: [PR] [lake/iceberg] Add iceberg documents for lakehouse support in fluss [fluss] via GitHub
  • Re: [PR] [lake/iceberg] Add iceberg documents for lakehouse support in fluss [fluss] via GitHub
  • Re: [PR] [lake/iceberg] Add iceberg documents for lakehouse support in fluss [fluss] via GitHub
  • Re: [PR] [lake/iceberg] Add iceberg documents for lakehouse support in fluss [fluss] via GitHub
  • Re: [PR] [lake/iceberg] Add iceberg documents for lakehouse support in fluss [fluss] via GitHub
  • Re: [PR] [lake/iceberg] Add iceberg documents for lakehouse support in fluss [fluss] via GitHub
  • Re: [PR] [lake/iceberg] Add iceberg documents for lakehouse support in fluss [fluss] via GitHub
  • Re: [PR] [lake/iceberg] Add iceberg documents for lakehouse support in fluss [fluss] via GitHub
  • Re: [PR] [lake/iceberg] Add iceberg documents for lakehouse support in fluss [fluss] via GitHub
  • Re: [PR] [lake/iceberg] Add iceberg documents for lakehouse support in fluss [fluss] via GitHub
  • Re: [PR] [lake/iceberg] Add iceberg documents for lakehouse support in fluss [fluss] via GitHub
  • Re: [PR] [lake/iceberg] Add iceberg documents for lakehouse support in fluss [fluss] via GitHub
• [PR] [server] Fix ReplicaFetcherThread keeps throwing OutOfOrderSequenceException because of writer id expire [fluss] via GitHub
• [PR] [flink] Improve TableAlreadyExistException message for LakeCatalog.createTable() [fluss] via GitHub
  • Re: [PR] [flink] Improve TableAlreadyExistException message for LakeCatalog.createTable() [fluss] via GitHub
  • Re: [PR] [flink] Improve TableAlreadyExistException message for LakeCatalog.createTable() [fluss] via GitHub
  • Re: [PR] [flink] Improve TableAlreadyExistException message for LakeCatalog.createTable() [fluss] via GitHub
  • Re: [PR] [flink] Improve TableAlreadyExistException message for LakeCatalog.createTable() [fluss] via GitHub
  • Re: [PR] [flink] Improve TableAlreadyExistException message for LakeCatalog.createTable() [fluss] via GitHub
• [I] Improve TableAlreadyExistException message for LakeCatalog.createTable() [fluss] via GitHub
  • Re: [I] Improve TableAlreadyExistException message for LakeCatalog.createTable() [fluss] via GitHub
• [PR] [spark] Support spark catalog and introduce some basic classes [fluss] via GitHub
  • Re: [PR] [spark] Support spark catalog and introduce some basic classes [fluss] via GitHub
• [I] org.apache.paimon.privilege.PrivilegedFileStore cannot be cast to org.apache.paimon.KeyValueFileStore [fluss] via GitHub
  • Re: [I] org.apache.paimon.privilege.PrivilegedFileStore cannot be cast to org.apache.paimon.KeyValueFileStore [fluss] via GitHub
  • Re: [I] org.apache.paimon.privilege.PrivilegedFileStore cannot be cast to org.apache.paimon.KeyValueFileStore [fluss] via GitHub
  • Re: [I] org.apache.paimon.privilege.PrivilegedFileStore cannot be cast to org.apache.paimon.KeyValueFileStore [fluss] via GitHub
  • Re: [I] org.apache.paimon.privilege.PrivilegedFileStore cannot be cast to org.apache.paimon.KeyValueFileStore [fluss] via GitHub
  • Re: [I] org.apache.paimon.privilege.PrivilegedFileStore cannot be cast to org.apache.paimon.KeyValueFileStore [fluss] via GitHub
  • Re: [I] org.apache.paimon.privilege.PrivilegedFileStore cannot be cast to org.apache.paimon.KeyValueFileStore [fluss] via GitHub
• [I] “CREATE TABLE IF NOT EXISTS ” do not work [fluss] via GitHub
  • Re: [I] “CREATE TABLE IF NOT EXISTS ” do not work [fluss] via GitHub
  • Re: [I] “CREATE TABLE IF NOT EXISTS ” do not work [fluss] via GitHub
• [PR] [flink] Fluss enumerator partition discovery in fixed delay rather than fixed rate. [fluss] via GitHub
• [I] Fluss enumerator partition discovery in fixed delay rather than fixed rate. [fluss] via GitHub
• [I] [server] Drop table (partition) may fail when tablet server crashs [fluss] via GitHub
  • Re: [I] [server] Drop table (partition) may fail when tablet server crashs [fluss] via GitHub
• [PR] [kv] Implement tableDescriptor based RocksDB conf - WIP [fluss] via GitHub
  • Re: [PR] [kv] Implement tableDescriptor based RocksDB conf - WIP [fluss] via GitHub
• [PR] [server] Support rebalance for PrimaryKey Table [fluss] via GitHub
• [PR] [docs] Refactor Java Client documentation for clarity and structure [fluss] via GitHub
• [I] [fluss-client] Missing fluss-client JAR in Maven Central [fluss] via GitHub
• [I] [Feature] Support spark catalog(base spark 3.3.3) [fluss] via GitHub
  • Re: [I] [Feature] Support spark catalog(base spark 3.3.3) [fluss] via GitHub
• Re: [PR] [connector] support spark catalog [fluss] via GitHub
• [PR] [docs] Update security documentation for clarity and detail [fluss] via GitHub
• [I] ReplicaFetcherThread keeps throwing OutOfOrderSequenceException [fluss] via GitHub
  • Re: [I] ReplicaFetcherThread keeps throwing OutOfOrderSequenceException [fluss] via GitHub
  • Re: [I] ReplicaFetcherThread keeps throwing OutOfOrderSequenceException [fluss] via GitHub
• [PR] [hotfix] Fix README [fluss] via GitHub
  • Re: [PR] [hotfix] Fix README [fluss] via GitHub
• Re: [I] Implement obtainSecurityToken for google filesystem [fluss] via GitHub
  • Re: [I] Implement obtainSecurityToken for google filesystem [fluss] via GitHub
• [I] Collect flink rows should always be with timeout [fluss] via GitHub
  • Re: [I] Collect flink rows should always be with timeout [fluss] via GitHub
• [PR] [test/flink] Collect flink rows should always be with timeout [fluss] via GitHub
  • Re: [PR] [test/flink] Collect flink rows should always be with timeout [fluss] via GitHub
  • Re: [PR] [test/flink] Collect flink rows should always be with timeout [fluss] via GitHub
  • Re: [PR] [test/flink] Collect flink rows should always be with timeout [fluss] via GitHub
  • Re: [PR] [test/flink] Collect flink rows should always be with timeout [fluss] via GitHub
  • Re: [PR] [test/flink] Collect flink rows should always be with timeout [fluss] via GitHub
• [PR] Introduce BinaryRowData for row data encoding [fluss] via GitHub
• [I] [coordinator] Coordinator server may fail to create partition by auto partition when restart [fluss] via GitHub
  • Re: [I] [coordinator] Coordinator server may fail to create partition by auto partition when restart [fluss] via GitHub
  • Re: [I] [coordinator] Coordinator server may fail to create partition by auto partition when restart [fluss] via GitHub
• [PR] [hotfix] Enhance the log of rebuildWriterState [fluss] via GitHub
• [PR] [hotfix] Use 'writer' instead of 'producer' in log [fluss] via GitHub
• [PR] [proto] Support generate toString() method for the proto messages [fluss] via GitHub
• [I] Introduce BinaryRowData for row data encoding [fluss] via GitHub
• [PR] [hotfix] Fix jar download links to alibaba path [fluss] via GitHub
  • Re: [PR] [hotfix] Fix jar download links to alibaba path [fluss] via GitHub
• [PR] Union read support primary key table in streaming mode [fluss] via GitHub
  • Re: [PR] Union read support primary key table in streaming mode [fluss] via GitHub
  • Re: [PR] Union read support primary key table in streaming mode [fluss] via GitHub
  • Re: [PR] Union read support primary key table in streaming mode [fluss] via GitHub
  • Re: [PR] Union read support primary key table in streaming mode [fluss] via GitHub
  • Re: [PR] Union read support primary key table in streaming mode [fluss] via GitHub
  • Re: [PR] Union read support primary key table in streaming mode [fluss] via GitHub
• [PR] add table.datalake.auto-compaction options [fluss] via GitHub
  • Re: [PR] add table.datalake.auto-compaction options [fluss] via GitHub
  • Re: [PR] add table.datalake.auto-compaction options [fluss] via GitHub
  • Re: [PR] add table.datalake.auto-compaction options [fluss] via GitHub
  • Re: [PR] add table.datalake.auto-compaction options [fluss] via GitHub
  • Re: [PR] add table.datalake.auto-compaction options [fluss] via GitHub
  • Re: [PR] add table.datalake.auto-compaction options [fluss] via GitHub
• [PR] [docs] Add FETCH_LOG monitoring metrics to Fluss monitor-metrics docu… [fluss] via GitHub
  • Re: [PR] [docs] Add FETCH_LOG monitoring metrics to Fluss monitor-metrics doc [fluss] via GitHub
  • Re: [PR] [docs] Add FETCH_LOG monitoring metrics to Fluss monitor-metrics doc [fluss] via GitHub
• [I] Add FETCH_LOG monitoring metrics to Fluss monitor-metrics documentation [fluss] via GitHub
  • Re: [I] Add FETCH_LOG monitoring metrics to Fluss monitor-metrics documentation [fluss] via GitHub
• [PR] Pk tables blog post [fluss] via GitHub
  • Re: [PR] Pk tables blog post [fluss] via GitHub
  • Re: [PR] Pk tables blog post [fluss] via GitHub
• [I] Add examples and stub files for Python bindings [fluss-rust] via GitHub
• [PR] Throw Exception If catalog default database is not existed or authorized. [fluss] via GitHub
• [I] Create Python bindings for table writing and reading [fluss-rust] via GitHub
• [I] Create Python bindings for Fluss Admin [fluss-rust] via GitHub
• [I] Throw Exception If catalog default database is unexisted or unauthorization. [fluss] via GitHub
• [I] Create Python bindings for metadata [fluss-rust] via GitHub
• [I] Set up the Python binding project [fluss-rust] via GitHub
• [I] Add more functions to the Rust Admin [fluss-rust] via GitHub
• [I] Introduce a per-table configuration to enable/disable auto table maintenance [fluss] via GitHub
  • Re: [I] Introduce a per-table configuration to enable/disable auto table maintenance [fluss] via GitHub
  • Re: [I] Introduce a per-table configuration to enable/disable auto table maintenance [fluss] via GitHub
• [PR] Support Compacted LogFormat [fluss] via GitHub
  • Re: [PR] Support Compacted LogFormat [fluss] via GitHub
  • Re: [PR] Support Compacted LogFormat [fluss] via GitHub
• [I] Add e2e for fluss lake tiering jar [fluss] via GitHub
  • Re: [I] Add e2e for fluss lake tiering jar [fluss] via GitHub
  • Re: [I] Add e2e for fluss lake tiering jar [fluss] via GitHub
  • Re: [I] Add e2e for fluss lake tiering jar [fluss] via GitHub
• [PR] Pr/examples and stub files [fluss-rust] via GitHub
• [PR] create bindings for table writing and reading [fluss-rust] via GitHub
• [PR] create metadata wrapping [fluss-rust] via GitHub
• [PR] Pr/basic settings [fluss-rust] via GitHub
• [I] [KV/LOG] Support Compacted Log Format For KVStore [fluss] via GitHub
• [I] Update datalake related doc since we already support paimon,lance,iceberg [fluss] via GitHub
  • Re: [I] Update datalake related doc since we already support paimon,lance,iceberg [fluss] via GitHub
• [I] Commit kv snapshot to zk should be done asynchronously, not blocking coordinator [fluss] via GitHub
• [I] [KV] Support Full Scan on PK Table [fluss] via GitHub
  • Re: [I] [KV] Support Full Scan on PK Table [fluss] via GitHub
  • Re: [I] [KV] Support Full Scan on PK Table [fluss] via GitHub
  • Re: [I] [KV] Support Full Scan on PK Table [fluss] via GitHub
  • Re: [I] [KV] Support Full Scan on PK Table [fluss] via GitHub
• [PR] Pr/bindings admin [fluss-rust] via GitHub
• [PR] test [fluss-rust] via GitHub
• [I] Introduce lake lag metrics for datalake enabled table [fluss] via GitHub
  • Re: [I] Introduce lake lag metrics for datalake enabled table [fluss] via GitHub
• [PR] [flink] Union read in stream mode should support [fluss] via GitHub
  • Re: [PR] [flink] Union read in stream mode should support [fluss] via GitHub
  • Re: [PR] [flink] Union read in stream mode should support read from given timestamp [fluss] via GitHub
  • Re: [PR] [flink] Union read in stream mode should support read from given timestamp [fluss] via GitHub
  • Re: [PR] [flink] Union read in stream mode should support read from given timestamp [fluss] via GitHub
  • Re: [PR] [flink] Union read in stream mode should support read from given timestamp [fluss] via GitHub
  • Re: [PR] [flink] Union read in stream mode should support read from given timestamp [fluss] via GitHub
  • Re: [PR] [flink] Union read in stream mode should support read from given timestamp [fluss] via GitHub
• [PR] [common] Support general DELETE statement on primary key table. [fluss] via GitHub
• [PR] [license] Update files headers from Alibaba to Apache Software Foundation [fluss] via GitHub
• [PR] [docs] Fix typos and improve readability in maintanance page [fluss] via GitHub
• [I] Support general DELETE statement on primary key table [fluss] via GitHub
  • Re: [I] Support general DELETE statement on primary key table [fluss] via GitHub
  • Re: [I] Support general DELETE statement on primary key table [fluss] via GitHub
  • Re: [I] Support general DELETE statement on primary key table [fluss] via GitHub
• Re: [I] Accelerate the speed of deleting tables and partitions [fluss] via GitHub
• [PR] [hotfix] Ignore some license check [fluss-rust] via GitHub
  • Re: [PR] [hotfix] Ignore some license check [fluss-rust] via GitHub
• [I] Add infra code to support IT [fluss-rust] via GitHub
  • Re: [I] Add code to support IT [fluss-rust] via GitHub
  • Re: [I] Add code to support IT [fluss-rust] via GitHub
  • Re: [I] Add code to support IT [fluss-rust] via GitHub
  • Re: [I] Add code to support IT [fluss-rust] via GitHub
• [I] Enhance ReplicaManager#getReplicaOrException to return more accurate error messages [fluss] via GitHub
  • Re: [I] Enhance ReplicaManager#getReplicaOrException to return more accurate error messages [fluss] via GitHub

• Earlier messages