What's Changed
Features
- Supports reading JSON columns. #334
- Supports reading ARRAY, STRUCT, and MAP columns. #347
- Supports LZ4 compression when sinking data with the JSON format. #354
- Supports Flink 1.19. #379
Improvements
- Supports configuring socket timeout. #319
- The Stream Load transaction interface supports asynchronous
prepare
andcommit
operations. #328 - Supports mapping a subset of columns in a StarRocks table to a Flink source table. #352
- Supports setting a specific warehouse when using the Stream Load transaction interface. #361
Bug Fixes
StarRocksSourceBeReader
inStarRocksDynamicLookupFunction
is not closed after data reading completes. #351- An exception was thrown when loading an empty JSON string into a JSON column. #380