- 🔭 I’m currently working on Apache Flink
- 🌱 I’m currently learning analytics and storage of big data
- 📫 How to reach me: imjark@gmail.com
- ⚡ Fun fact: I'm an ACG fan
Apache Flink PMC member & Committer.
Work at Alibaba.
- Hangzhou China
- http://wuchong.me
- @jarkwu
- in/jarkwu
Pinned Loading
-
-
alibaba/fluss
alibaba/fluss PublicFluss is a streaming storage built for real-time analytics.
267 contributions in the last year
Day of Week | March Mar | April Apr | May May | June Jun | July Jul | August Aug | September Sep | October Oct | November Nov | December Dec | January Jan | February Feb | |||||||||||||||||||||||||||||||||||||||||
Sunday Sun | |||||||||||||||||||||||||||||||||||||||||||||||||||||
Monday Mon | |||||||||||||||||||||||||||||||||||||||||||||||||||||
Tuesday Tue | |||||||||||||||||||||||||||||||||||||||||||||||||||||
Wednesday Wed | |||||||||||||||||||||||||||||||||||||||||||||||||||||
Thursday Thu | |||||||||||||||||||||||||||||||||||||||||||||||||||||
Friday Fri | |||||||||||||||||||||||||||||||||||||||||||||||||||||
Saturday Sat |
Less
No contributions.
Low contributions.
Medium-low contributions.
Medium-high contributions.
High contributions.
More
Activity overview
Loading
Contribution activity
February 2025
Created 9 commits in 1 repository
Created a pull request in alibaba/fluss that received 8 comments
[client] Refactor Table API
Purpose Linked issue: close #340
I also renamed the Admin.getTable(..)
into Admin.getTableInfo(..)
, to avoid confusion with Connection.getTable(..)
.…
+3,273
−2,496
lines changed
•
8
comments
Opened 5 other pull requests in 1 repository
alibaba/fluss
4
merged
1
open
-
[client] Fix NullPointerException when deleting on a primary key table which enabled data lake
This contribution was made on Feb 25
-
[client] Supports GenericRow as input parameter for AppendWriter, UpsertWriter and Lookuper
This contribution was made on Feb 10
-
[test] Enable FlussTableITCase#testAppendWithSmallBuffer
This contribution was made on Feb 9
-
[client] Use TableInfo instead of TableDescriptor for created table
This contribution was made on Feb 8
-
[flink] Fix connector option "sink.ignore_delete" to "sink.ignore-delete"
This contribution was made on Feb 6
Reviewed 41 pull requests in 2 repositories
alibaba/fluss
25 pull requests
-
[common] improve default configuration of auto partitioning
This contribution was made on Feb 28
-
[rpc] Support NettyClient enable TCP_NODELAY and SO_KEEPALIVE
This contribution was made on Feb 27
-
[server] Cdc log visible only when the data already flush to rocksDb from preWriteBuffer
This contribution was made on Feb 27
-
[datalake/paimon] Introduce paimon encoding
This contribution was made on Feb 27
-
[test] Harmonization of LazyMemorySegmentPoolTest and WriterMemoryBufferTest
This contribution was made on Feb 27
-
[server/coordinator] CoordinatorEventProcessor shouldn't process PartitionCreated event for existing partition
This contribution was made on Feb 27
-
[flink] Upgrade sink connector to new API version
This contribution was made on Feb 27
-
[server] Support addPartition and dropPartition
This contribution was made on Feb 27
-
[github] Add pull request changes section to pull request template
This contribution was made on Feb 27
-
[Improve] [Common] Optimize com.alibaba.fluss.cluster.Cluster #Cluste…
This contribution was made on Feb 26
-
[common] Declare serialVersionUID explicitly for serializable class
This contribution was made on Feb 26
-
[client] Use ip address instead of hostname in MetadataUpdater
This contribution was made on Feb 26
-
[netty] Modify to debug level in NettyServerHandler#exceptionCaught method to avoid to many logs if NLB is mounted
This contribution was made on Feb 26
-
[hotfix] MetadataUpdater#tryToInitializeCluster should use COORDINATO…
This contribution was made on Feb 26
-
[log] Fix Lz4ArrowCompressionCodec gets stuck during compression and is unable to flush data error
This contribution was made on Feb 25
-
[log] Fix the 'Destination buffer is too small' error while decompress data in ZstdArrowCompressionCodec
This contribution was made on Feb 25
-
[common] Bump zstd-jni version from 1.4.9-1 to 1.5.7-1
This contribution was made on Feb 25
-
[common] Replace static importing from Preconditions
This contribution was made on Feb 25
-
[rpc] Support netty metrics
This contribution was made on Feb 25
-
[connector] Fix partition state update and filter non-existent partitions on restore
This contribution was made on Feb 24
-
[build] Add Maven Wrapper
This contribution was made on Feb 24
-
[lake] all tables in lake storage configured cluster should use lake's bucke assigner
This contribution was made on Feb 22
-
[common] Change Classname DefaultLogRecord to IndexedLogRecord
This contribution was made on Feb 21
-
[paimon] Bump Paimon version from 0.8.2 to 1.0.1
This contribution was made on Feb 14
-
[rpc] Support Netty Logging at the network layer
This contribution was made on Feb 13
- Some pull request reviews not shown.
apache/flink-web
1 pull request
-
Add Hive 3.0.0 connector
This contribution was made on Feb 5
Created an issue in alibaba/fluss that received 5 comments
Test RecordAccumulatorTest.testDrainCompressedBatches is unstable
Search before asking I searched in the issues and found nothing similar. Fluss version main Please describe the bug 🐞 https://github.com/alibaba…
1 of 2 tasks
Opened 23 other issues in 1 repository
alibaba/fluss
15
open
8
closed
-
Support for Arrow Flight SQL Protocol and ADBC
This contribution was made on Feb 27
-
Support Kerberos Authentication
This contribution was made on Feb 26
-
Add "Connector Options" page in "Engine Flink"
This contribution was made on Feb 26
-
Add document for LIST/ADD/DROP PARTITION
This contribution was made on Feb 26
-
Add document about Prefix Lookup
This contribution was made on Feb 26
-
Add document for Arrow compression
This contribution was made on Feb 26
-
Add document about first-row merge engine
This contribution was made on Feb 26
-
Add documentations for Release 0.6
This contribution was made on Feb 26
-
Bump RocksDB version from 6.20.3-ververica-2.0 to official 9.9.3
This contribution was made on Feb 25
-
Support Kafka Protocol Compatibility
This contribution was made on Feb 25
-
Refactor metadata cache and async updating mechanism in client side
This contribution was made on Feb 25
-
Enable ZSTD compression for Arrow log format by default
This contribution was made on Feb 25
-
Unstable test FlinkCatalogTest#testCreateTableWithBucket
This contribution was made on Feb 24
-
Require static importing from Preconditions
This contribution was made on Feb 22
-
Improve default configuration of auto partitioning
This contribution was made on Feb 22
-
Rename KvManager and LogManager into KvStore and LogStore
This contribution was made on Feb 12
-
Rename DefaultLogRecord into IndexedLogRecord
This contribution was made on Feb 12
-
Supports GenericRow as input parameter for AppendWriter, UpsertWriter and Lookuper
This contribution was made on Feb 10
-
Use TableInfo instead of TableDescriptor for created table
This contribution was made on Feb 8
-
Support $changelog auxiliary table for flink connector
This contribution was made on Feb 8
-
[Feature] Change default value name from "initial" to "full" for scan.startup.mode option
This contribution was made on Feb 6
-
[Feature] Flink connector factory shouldn't validate "table." and "client." options
This contribution was made on Feb 6
-
[Improve] Refactor Table API
This contribution was made on Feb 5
Answered 2 discussions in 1 repository
alibaba/fluss
alibaba/fluss
-
[Bug] does fluss support kerberos authentication now?
This contribution was made on Feb 26
-
which version the fluss will support kafka protocol?
This contribution was made on Feb 26