Danny Chan
22c45a7704
[HUDI-4188] Fix flaky ITTestDataSTreamWrite.testWriteCopyOnWrite ( #5749 )
2022-06-06 12:12:48 +08:00
喻兆靖
c20db99a7b
[HUDI-2207] Support independent flink hudi clustering function
2022-05-24 20:16:48 +08:00
Danny Chan
43e08193ef
[HUDI-4098] Metadata table heartbeat for instant has expired, last heartbeat 0 ( #5583 )
2022-05-16 17:40:08 +08:00
Bo Cui
7fb436d3cf
[HUDI-4078][HUDI-FLINK]BootstrapOperator contains the pending compact… ( #5545 )
...
* [HUDI-4078][HUDI-FLINK]BootstrapOperator contains the pending compaction files
2022-05-13 14:32:48 +08:00
Bo Cui
701f8c039d
[HUDI-3336][HUDI-FLINK]Support custom hadoop config for flink ( #5528 )
...
* [HUDI-3336][HUDI-FLINK]Support custom hadoop config for flink
2022-05-13 09:50:11 +08:00
xicm
6b47ef6ed2
[HUDI-4053] Flaky ITTestHoodieDataSource.testStreamWriteBatchReadOpti… ( #5526 )
...
* [HUDI-4053] Flaky ITTestHoodieDataSource.testStreamWriteBatchReadOptimized
Co-authored-by: xicm <xicm@asiainfo.com >
2022-05-09 16:35:50 +08:00
ForwardXu
4c70840275
[MINOR] Fixing close for HoodieCatalog's test ( #5531 )
...
* [MINOR] Fixing close for HoodieCatalog's test
2022-05-09 15:17:24 +08:00
Wangyh
33ff4752ba
[HUDI-3978] Fix use of partition path field as hive partition field in flink ( #5434 )
...
* Fix partition path fields as hive sync partition fields error
2022-04-29 20:58:54 -07:00
Danny Chan
e1ccf2e00b
[HUDI-3977] Flink hudi table with date type partition path throws HoodieNotSupportedException ( #5432 )
2022-04-27 13:19:55 +08:00
董可伦
b8e465fdfc
[MINOR] Fix typos in log4j-surefire.properties ( #5212 )
2022-04-15 13:33:37 -07:00
Danny Chan
0281725c6b
[MINOR] Inline the partition path logic into the builder ( #5310 )
2022-04-13 16:54:39 +05:30
Sagar Sumit
df87095ef0
[HUDI-3454] Fix partition name in all code paths for LogRecordScanner ( #5252 )
...
* Depend on FSUtils#getRelativePartitionPath(basePath, logFilePath.getParent)
to get the partition.
* If the list of log file paths in the split is empty, then fallback to usual behaviour.
2022-04-08 09:59:36 +05:30
Danny Chan
b9fbada2f2
[minor] Follow 3178, fix the flink metadata table compaction ( #5175 )
2022-03-30 20:45:29 +08:00
Danny Chan
5c1b482a1b
[HUDI-3741] Fix flink bucket index bulk insert generates too many small files ( #5164 )
2022-03-30 08:18:36 +08:00
Danny Chan
4d940bbf8a
[HUDI-3716] OOM occurred when use bulk_insert cow table with flink BUCKET index ( #5135 )
2022-03-27 09:13:58 +08:00
Danny Chan
5e86cdd1e9
[HUDI-3701] Flink bulk_insert support bucket hash index ( #5118 )
2022-03-25 09:01:42 +08:00
wxp4532
26e5d2e6fc
[HUDI-3559] Flink bucket index with COW table throws NoSuchElementException
...
Actually method FlinkWriteHelper#deduplicateRecords does not guarantee the records sequence, but there is a
implicit constraint: all the records in one bucket should have the same bucket type(instant time here),
the BucketStreamWriteFunction breaks the rule and fails to comply with this constraint.
close apache/hudi#5018
2022-03-21 17:34:54 +08:00
Danny Chan
799c78e688
[HUDI-3665] Support flink multiple versions ( #5072 )
2022-03-21 10:34:50 +08:00
