@@ -2225,7 +2225,7 @@ def __init__(
2225
2225
features : Optional [List [Union ["feature.Feature" , Dict [str , Any ]]]] = None ,
2226
2226
location : Optional [str ] = None ,
2227
2227
online_enabled : bool = False ,
2228
- time_travel_format : Optional [str ] = None ,
2228
+ time_travel_format : Optional [str ] = "HUDI" ,
2229
2229
statistics_config : Optional [Union ["StatisticsConfig" , Dict [str , Any ]]] = None ,
2230
2230
online_topic_name : Optional [str ] = None ,
2231
2231
topic_name : Optional [str ] = None ,
@@ -2330,20 +2330,13 @@ def __init__(
2330
2330
2331
2331
self .primary_key = primary_key
2332
2332
self .partition_key = partition_key
2333
- if (
2334
- time_travel_format is not None
2335
- and time_travel_format .upper () == "HUDI" or time_travel_format is None
2336
- and self ._features
2337
- ):
2338
- self ._hudi_precombine_key = (
2339
- util .autofix_feature_name (hudi_precombine_key )
2340
- if hudi_precombine_key is not None
2341
- and self ._time_travel_format is not None
2342
- and self ._time_travel_format == "HUDI" or time_travel_format is None
2343
- else None
2344
- )
2345
- else :
2346
- self ._hudi_precombine_key : Optional [str ] = None
2333
+ self ._hudi_precombine_key = (
2334
+ util .autofix_feature_name (hudi_precombine_key )
2335
+ if hudi_precombine_key is not None
2336
+ and self ._time_travel_format is not None
2337
+ and self ._time_travel_format == "HUDI"
2338
+ else None
2339
+ )
2347
2340
self .statistics_config = statistics_config
2348
2341
self ._offline_backfill_every_hr = offline_backfill_every_hr
2349
2342
0 commit comments