1
0
Commit Graph

1985 Commits

Author SHA1 Message Date
Manoj Govindassamy
84ca981cd0 [HUDI-2553] Metadata table compaction trigger max delta commits (#3794)
-  Setting the max delta commits default value from 24 to 10 to trigger the compaction in metadata table.
2021-10-21 13:09:37 -04:00
vinoyang
b480294e79 [HUDI-2507] Generate more dependency list file for other bundles (#3773) 2021-10-21 14:10:01 +08:00
Danny Chan
aa3c4ecda5 [HUDI-2583] Refactor TestWriteCopyOnWrite test cases (#3832) 2021-10-21 12:36:41 +08:00
Raymond Xu
f5d7362ee8 [HUDI-2077] Fix flakiness in TestHoodieDeltaStreamer (#3829) 2021-10-20 23:57:12 -04:00
Manoj Govindassamy
b68c5a68f9 [HUDI-2472] Fix few Cleaner tests with metadata table enabled (#3825) 2021-10-20 18:57:00 -04:00
Danny Chan
e355ab52db [HUDI-2578] Support merging small files for flink insert operation (#3822) 2021-10-20 21:10:07 +08:00
rmahindra123
3686c25fae [HUDI-2469] [Kafka Connect] Replace json based payload with protobuf for Transaction protocol. (#3694)
* Substitue Control Event with protobuf

* Fix tests

* Fix unit tests

* Add javadocs

* Add javadocs

* Address reviewer comments

Co-authored-by: Rajesh Mahindra <rmahindra@Rajeshs-MacBook-Pro.local>
2021-10-19 14:29:48 -07:00
董可伦
46f0496a08 [MINOR] Fix typo,'intance' corrected to 'instance' (#3788) 2021-10-19 23:16:48 +08:00
Yann Byron
1e2be85a0f [HUDI-2482] support 'drop partition' sql (#3754) 2021-10-19 22:09:53 +08:00
jaxonzhang
60d4cb505a [MINOR] Fix typo, 'upsert' corrected to 'insert' in java write example (#3809) 2021-10-19 20:04:18 +08:00
Danny Chan
3a78be9203 [HUDI-2572] Strength flink compaction rollback strategy (#3819)
* make the events of commit task distinct by file id
* fix the existence check for inflight state file
* make the compaction task fail-safe
2021-10-19 10:47:38 +08:00
Manoj Govindassamy
335e80ea1b [HUDI-2561] BitCaskDiskMap - avoiding hostname resolution when logging messages (#3811)
- InetAddress.getLocalHost() can take up as much as 30+seconds if the network
   configurations are not done right. This might be due to local hostname
   missing IPv6 address mapping in /etc/hosts or network configs slowing down
   any IPv6 name resolutions. If this API is used for logging verbose messages
   and that too in the hot code path, it can lead to order of magnitude
   slowness in the overall task completion.
2021-10-18 10:07:53 -07:00
Danny Chan
588a34aa95 [HUDI-2571] Remove include-flink-sql-connector-hive profile from flink bundle (#3818) 2021-10-18 17:34:49 +08:00
yiduwangkai
dfdfbbedae HUDI-2569 shaded hive (#3816)
Co-authored-by: wangkai9 <wangkai9@tuhu.cn>
2021-10-18 17:12:13 +08:00
Danny Chan
3025f4d796 [HUDI-2568] Simplify the view storage config properties (#3815) 2021-10-18 14:42:33 +08:00
yiduwangkai
5276850415 [HUDI-2557] Shade javax.servlet for flink bundle jar (#3807)
Co-authored-by: wangkai9 <wangkai9@tuhu.cn>
2021-10-18 11:26:21 +08:00
Danny Chan
2eda3de7f9 [HUDI-2562] Embedded timeline server on JobManager (#3812) 2021-10-18 10:45:39 +08:00
Jimmy.Zhou
9aa7cfb802 [MINOR] fix typo,'seprarated' corrected to 'separated' (#3789) 2021-10-15 13:26:16 -07:00
Danny Chan
2c370cbae0 [HUDI-2556] Tweak some default config options for flink (#3800)
* rename write.insert.drop.duplicates to write.precombine and set it as true for COW table
* set index.global.enabled default as true
* set compaction.target_io default as 500GB
2021-10-14 19:42:56 +08:00
Danny Chan
f897e6d73e [HUDI-2551] Support DefaultHoodieRecordPayload for flink (#3792) 2021-10-14 13:46:53 +08:00
Danny Chan
abf3e3fe71 [HUDI-2548] Flink streaming reader misses the rolling over file handles (#3787) 2021-10-14 10:36:18 +08:00
Sivabalan Narayanan
cff384d23f [HUDI-2552] Fixing some test failures to unblock broken CI master (#3793) 2021-10-13 18:44:43 -04:00
zhangyue19921010
e6711b171a [HUDI-2435][BUG]Fix clustering handle errors (#3666)
* done

* remove unused imports

* code reviewed

* code reviewed

Co-authored-by: yuezhang <yuezhang@freewheel.tv>
2021-10-12 15:24:48 -07:00
Sivabalan Narayanan
8a487eafa7 [HUDI-2494] Fixing glob pattern to skip all hoodie meta paths (#3768) 2021-10-12 14:06:40 -04:00
Manoj Govindassamy
252c4ed380 [HUDI-2532] Metadata table compaction trigger max delta commits (#3784)
-  Setting the max delta commits default value from 24 to 10 to trigger the
     compaction in metadata table.
2021-10-12 09:49:42 -04:00
董可伦
48a3906ccc [MINOR] Fix typo,'paritition' corrected to 'partition' (#3764) 2021-10-11 14:07:34 -04:00
Roc Marshal
f14d4e65e7 [HUDI-2540] Fixed wrong validation for metadataTableEnabled in HoodieTable (#3781) 2021-10-11 13:58:33 -04:00
Danny Chan
5b8bc664a8 [HUDI-2542] AppendWriteFunction throws NPE when checkpointing without written data (#3777) 2021-10-11 16:22:22 +08:00
Ilias Antoniou
ceace1c653 [HUDI-2496] Insert duplicate records when precombined is deactivated for "insert" operation (#3740) 2021-10-10 21:33:16 -04:00
Danny Chan
ad63938890 [HUDI-2537] Fix metadata table for flink (#3774) 2021-10-10 09:30:39 +08:00
Danny Chan
2a392d8e8e [HUDI-2534] Remove the sort operation when bulk_insert in batch mode (#3772) 2021-10-09 18:02:10 +08:00
Sivabalan Narayanan
a818020f72 [HUDI-2530] Adding async compaction support to integ test suite framework (#3750) 2021-10-08 11:30:48 -04:00
董可伦
10e3a9a3fb [MINOR] Fix typo,'properites' corrected to 'properties' (#3738) 2021-10-06 20:37:01 -04:00
Y Ethan Guo
2e152177fb [HUDI-2513] Refactor table upgrade and downgrade actions in hudi-client module (#3743) 2021-10-06 20:20:41 -04:00
Yann Byron
e91e611afb [HUDI-2456] support 'show partitions' sql (#3693) 2021-10-06 15:46:49 +08:00
Sivabalan Narayanan
5f32162a2f [HUDI-2285][HUDI-2476] Metadata table synchronous design. Rebased and Squashed from pull/3426 (#3590)
* [HUDI-2285] Adding Synchronous updates to metadata before completion of commits in data timelime.

- This patch adds synchronous updates to metadata table. In other words, every write is first committed to metadata table followed by data table. While reading metadata table, we ignore any delta commits that are present only in metadata table and not in data table timeline.
- Compaction of metadata table is fenced by the condition that we trigger compaction only when there are no inflight requests in datatable. This ensures that all base files in metadata table is always in sync with data table(w/o any holes) and only there could be some extra invalid commits among delta log files in metadata table.
- Due to this, archival of data table also fences itself up until compacted instant in metadata table.
All writes to metadata table happens within the datatable lock. So, metadata table works in one writer mode only. This might be tough to loosen since all writers write to same FILES partition and so, will result in a conflict anyways.
- As part of this, have added acquiring locks in data table for those operations which were not before while committing (rollback, clean, compaction, cluster). To note, we were not doing any conflict resolution. All we are doing here is to commit by taking a lock. So that all writes to metadata table is always a single writer. 
- Also added building block to add buckets for partitions, which will be leveraged by other indexes like record level index, etc. For now, FILES partition has only one bucket. In general, any number of buckets per partition is allowed and each partition has a fixed fileId prefix with incremental suffix for each bucket within each partition.
Have fixed [HUDI-2476]. This fix is about retrying a failed compaction if it succeeded in metadata for first time, but failed w/ data table.
- Enabling metadata table by default.
- Adding more tests for metadata table

Co-authored-by: Prashant Wason <pwason@uber.com>
2021-10-06 00:17:52 -04:00
Y Ethan Guo
46808dcb1f [HUDI-2497] Refactor clean and restore actions in hudi-client module (#3734) 2021-09-30 18:20:25 -04:00
Vinay Patil
73e8ba7620 [HUDI-2499] Making jdbc-url, user and pass as non-required field for other sync modes (#3732) 2021-09-30 11:41:15 -04:00
vinoyang
47ed917999 [HUDI-2440] Add dependency change diff script for dependency governace (#3674) 2021-09-30 16:56:11 +08:00
tangyoupeng
def08d703d [MINOR] Support JuiceFileSystem (#3729) 2021-09-30 12:50:46 +08:00
董可伦
2f07e1267f [MINOR] Fix typo Hooodie corrected to Hoodie & reuqired corrected to required (#3730) 2021-09-30 09:55:32 +08:00
zhangyue19921010
dd1bd62684 [HUDI-2277] HoodieDeltaStreamer reading ORC files directly using ORCDFSSource (#3413)
* add ORCDFSSource to support reading orc file into hudi format && add UTs

* remove ununsed import

* simplify tes

* code review

* code review

* code review

* code review

* code review

* code review

Co-authored-by: yuezhang <yuezhang@freewheel.tv>
2021-09-29 08:54:12 -07:00
vinoth chandar
2aa660f99d [MINOR] Add a RFC template and folder (#3726) 2021-09-28 10:33:27 -06:00
Sivabalan Narayanan
f0585facd6 [HUDI-2474] Refreshing timeline for every operation in Hudi when metadata is enabled (#3698) 2021-09-28 05:16:52 -04:00
qianchutao
9067657a5f [HUDI-2487] Fix JsonKafkaSource cannot filter empty messages from kafka (#3715) 2021-09-28 13:47:15 +08:00
董可伦
36be287121 [MINOR] Fix typo,'Kakfa' corrected to 'Kafka' & 'parquest' corrected to 'parquet' (#3717) 2021-09-26 21:53:39 +08:00
qianchutao
7e887b54d7 [MINOR] fix typo,'SPAKR' corrected to 'SPARK' (#3721) 2021-09-26 21:52:35 +08:00
Carl-Zhou-CN
aa546554ff [HUDI-2451] On windows client with hdfs server for wrong file separator (#3687)
Co-authored-by: yao.zhou <yao.zhou@linkflowtech.com>
2021-09-26 21:51:27 +08:00
Sagar Sumit
bc4966ea73 [HUDI-2484] Fix hive sync mode setting in Deltastreamer (#3712) 2021-09-24 13:05:42 -04:00
Danny Chan
31a301f0aa [HUDI-2485] Consume as mini-batch for flink stream reader (#3710) 2021-09-24 23:44:01 +08:00