You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by "YinChunGuang (via GitHub)" <gi...@apache.org> on 2025/05/27 08:24:28 UTC
[I] [SUPPORT]flink read hudi table with file not found exception [hudi]
YinChunGuang opened a new issue, #13363:
URL: https://github.com/apache/hudi/issues/13363
**_Tips before filing an issue_**
- Have you gone through our [FAQs](https://hudi.apache.org/learn/faq/)?
- Join the mailing list to engage in conversations and get faster support at dev-subscribe@hudi.apache.org.
- If you have triaged this as a bug, then file an [issue](https://issues.apache.org/jira/projects/HUDI/issues) directly.
**Describe the problem you faced**
A clear and concise description of the problem.
**To Reproduce**
Steps to reproduce the behavior:
1.
2.
3.
4.
**Expected behavior**
A clear and concise description of what you expected to happen.
**Environment Description**
* Hudi version :0.15
* Flink Version : 1.18.1
* Spark version :3.3
* Hive version :2.3.9
* Hadoop version :3.1
* Storage (HDFS/S3/GCS..) : hdfs
* Running on Docker? (yes/no) : no
**Additional context**
Add any other context about the problem here.
**Stacktrace**
``` 2025-05-25 14:47:28,941 INFO org.apache.hudi.common.table.log.AbstractHoodieLogRecordReader [] - Number of remaining logblocks to merge 2
2025-05-25 14:47:28,949 INFO org.apache.hudi.common.table.log.AbstractHoodieLogRecordReader [] - Number of remaining logblocks to merge 1
2025-05-25 14:47:28,957 INFO org.apache.hudi.common.table.log.HoodieLogFileReader [] - Closing Log file reader .c35b5ad2-6d5f-442e-ac51-e8ad0bf35c0b_20250525144645456.log.1_0-1-0
2025-05-25 14:47:28,957 INFO org.apache.hudi.common.table.log.HoodieMergedLogRecordScanner [] - Number of log files scanned => 5
2025-05-25 14:47:28,957 INFO org.apache.hudi.common.table.log.HoodieMergedLogRecordScanner [] - MaxMemoryInBytes allowed for compaction => 104857600
2025-05-25 14:47:28,957 INFO org.apache.hudi.common.table.log.HoodieMergedLogRecordScanner [] - Number of entries in MemoryBasedMap in ExternalSpillableMap => 27
2025-05-25 14:47:28,957 INFO org.apache.hudi.common.table.log.HoodieMergedLogRecordScanner [] - Total size in bytes of MemoryBasedMap in ExternalSpillableMap => 12960
2025-05-25 14:47:28,957 INFO org.apache.hudi.common.table.log.HoodieMergedLogRecordScanner [] - Number of entries in DiskBasedMap in ExternalSpillableMap => 0
2025-05-25 14:47:28,957 INFO org.apache.hudi.common.table.log.HoodieMergedLogRecordScanner [] - Size of file spilled to disk => 0
2025-05-25 14:47:31,071 INFO org.apache.hudi.common.table.HoodieTableMetaClient [] - Loading HoodieTableMetaClient from hdfs://172.22.92.29:9000/user/bdetl/hudi-warehouse/hudi_oc_contract_goods_all
2025-05-25 14:47:31,072 INFO org.apache.hudi.common.table.HoodieTableConfig [] - Loading table properties from hdfs://172.22.92.29:9000/user/bdetl/hudi-warehouse/hudi_oc_contract_goods_all/.hoodie/hoodie.properties
2025-05-25 14:47:31,073 INFO org.apache.hudi.common.table.HoodieTableMetaClient [] - Finished Loading Table of type MERGE_ON_READ(version=1, baseFileFormat=PARQUET) from hdfs://172.22.92.29:9000/user/bdetl/hudi-warehouse/hudi_oc_contract_goods_all
2025-05-25 14:47:31,082 INFO org.apache.hudi.common.table.timeline.HoodieActiveTimeline [] - Loaded instants upto : Option{val=[20250525144730500__clean__COMPLETED__20250525144730547]}
2025-05-25 14:47:31,085 ERROR org.apache.hudi.common.table.log.AbstractHoodieLogRecordReader [] - Got exception when reading log file
org.apache.hudi.exception.HoodieIOException: Exception creating input stream from file: hdfs://172.22.92.29:9000/user/bdetl/hudi-warehouse/hudi_oc_contract_goods_all/.8fadd831-d16c-42ad-a55a-5139adc86e82_20250525144515642.log.1_0-1-0
at org.apache.hudi.hadoop.fs.HadoopFSUtils.getFSDataInputStream(HadoopFSUtils.java:203) ~[hudi-flink1.18-bundle-0.15.0.jar:0.15.0]
at org.apache.hudi.storage.hadoop.HoodieHadoopStorage.openSeekable(HoodieHadoopStorage.java:154) ~[hudi-flink1.18-bundle-0.15.0.jar:0.15.0]
at org.apache.hudi.common.table.log.HoodieLogFileReader.getDataInputStream(HoodieLogFileReader.java:474) ~[hudi-flink1.18-bundle-0.15.0.jar:0.15.0]
at org.apache.hudi.common.table.log.HoodieLogFileReader.<init>(HoodieLogFileReader.java:110) ~[hudi-flink1.18-bundle-0.15.0.jar:0.15.0]
at org.apache.hudi.common.table.log.HoodieLogFormatReader.<init>(HoodieLogFormatReader.java:62) ~[hudi-flink1.18-bundle-0.15.0.jar:0.15.0]
at org.apache.hudi.common.table.log.AbstractHoodieLogRecordReader.scanInternalV1(AbstractHoodieLogRecordReader.java:245) ~[hudi-flink1.18-bundle-0.15.0.jar:0.15.0]
at org.apache.hudi.common.table.log.AbstractHoodieLogRecordReader.scanInternal(AbstractHoodieLogRecordReader.java:220) ~[hudi-flink1.18-bundle-0.15.0.jar:0.15.0]
at org.apache.hudi.common.table.log.HoodieMergedLogRecordScanner.performScan(HoodieMergedLogRecordScanner.java:204) ~[hudi-flink1.18-bundle-0.15.0.jar:0.15.0]
at org.apache.hudi.common.table.log.HoodieMergedLogRecordScanner.<init>(HoodieMergedLogRecordScanner.java:120) ~[hudi-flink1.18-bundle-0.15.0.jar:0.15.0
a r.aacehud.omo.tbl.o.OIEREGCRNNRntoigdgcrdnnr>aa& {ui_ln!!*bnle)!>)jr>%)
togapce>uicomntbl>o>oigegcraneldrbuldirgdcodanrjva$# hu_fik!!_unl_>!>)a)!>}
a r>aah>hd>abefrmtrmtlslgnrMTISJAA!# HD_LNK>!_UNL_)!>>AR)!%)
ATOGAPCE>HTBE>RMTMR>GDUTMTGEGEEATRREAPURMTJV#% HD_FIK>_UDE_>%)>A)!>} A OGAPCHUITBL>FRMTMO>RGAPURA>IIERTRGADURA>AA@! HD_FIK>*_UDE)>%)JR)>%)} TOGAPCEHUITBE>OMT>ORREAPURATOEGDURTJAA!*HUIFLN!!_UNL_>%>>A)!>}
A R>AHEHDISUC>RAARTR>ROSSLTEMAEATRJAA!!HUIFIK!!_BNL_>!>>AR)!%)
ATOG>PCHFLN>SRAIN>RNIM>AKSREMKTNEO>RNOWNRAMKIOEUORJVAFLN_IS!>*!>A>*>} T R>PCH>LNKSRAMN>UNIETSK>MILO>LRUI>AA( {FNKDS_>!>>AR!>*>}
ATOGAACEFIKSREMNGRNIETAK>MIBX>LBXOESRRUILOESO>AA({LN_IS_!*>A!!>} A R>AAH>LIKSTAMN>RNIETKMIBOXLOXCSORPRCSLNOKIGBOOESO>AV*FNKDI_>>J!>*!
ATOG>PCE>LN>SRAIG>UTIETSK>MLBX>ILOCSORPOESLLXOCSOJA#$FLN_IS_>!>!A>!>!
T R>AAH>LIKSTEMIGRTITSS>ALOXILOOCSO>UNLBXOLBXOESRJVA@( {IKDIT!>!!JA>!>} A RGAACEFIK>MN>RNIM>AK>EARULBXPEMS>AA%FLNIT_>*!>A>*!} T R>PACLNKSRAING>RUK>EMS>NVKEASKJVA*&)IK_IT_>*>>A>!>}
A RGAPCEFIN>UTIETSKAAERS>RNTSETITRNS>AA(% FIN_DS_>!>>JR!!*!} A OG>PAHEIKRNIM>ASMNGRKRSOREDOEKJV(@ FLN_IS_>*>>A>!>} A OGAACEFLK>UTM>TSKNAE>K>ONS>JV&^ FIK_IT!!*!A>*>} TOR>PCE>LIKRNTM>ASMNAE>S>US>JV^@ FIN_IT!>*!JA>!>} TJAALNGRADRNEDJVA&* {>>)@!
UE B JV>IETNCETIN L OSNO XST UE?DET?DIWREOSEUDCOTATODL>*FD#!D^_$A_%%A%#AD^E@@@)@$%!$>G)!) T O>APH>DOP>DFSVE>NEE>NDEE>AUNDL>JV^ TOG>PCH>AOP>DSSVRNMEND>NDEL>AUEL>AA&^
A OGAAC>HDO>DF>ERE>AEND>SRTTNG>GTCKAIOSDRATNGJV!%
ATOG>PCE>HPHDSSRERNMEOESESSE>ECCAINNMSSTE>AA@$
A RGAAHE>DOPHDSSEVEMEOE>EDCRE>GTCAINSMDERVRJAA& ATOGAPCEHAOPHFSPROOB>ETMNDOTCLRERIASATRBtokctosetendooclvedeano>v$) tor>ahehaophds>tclprt>inmndetcoooineoetool@clokigtoineoeooootsjva
a ogapcehdopic>ooufgnevrtcokrclloobfie>av@!
a r>aah>hdo>p>otbfgnvetfcvkrcaltbfcie@jv%(
a ogaacehdopictbfcin@rvrotfcoercloougne>aa& a r>pah>ado>pccsrerclpcv!! t r>aah>hdo>pcrecl>urerjaa!)(
a ogapch>aoo>pcveclrnve>aa!)@
tjv>scrtycetrle>oiieedtvethd
tjaa>ecrt>ut>bet>dbect>@
a rg>eadourty>opfrmt>oaOPAIOA*() ataahe.hRVnlr>rve>ja^
a unflctiestrucesorwsttivtod)>*)@!} tsu>elcttiesrutrcsoplnwstnetvestutrcsoljva^{>>)@!
tsu>eletlgaigstutrcsolnesacelgtngstucocesrp>aa$% !*>*}
a av>ag>elctntuco>ewtnestctrjva$# {:*>*}
a ogaahehdo>pcmoeetonisanitetonmtpto>jv!! {likshded_hadp__be_>>!&@()_&#>)>a>>>&@(>_&#()} a o>apch>aoo>p>mteetin>nraotcetomtetinjaa** {likshdd_ado_#ubr_>>!&@(>)&#()jr>!!&>>>)!#_>} a or>pce>hdo>ds>fsin>altokatosscietjaa** fikshdd_ado__ur_>!!&@>>_&#()ja>!!&>>>)!&_>} og>pcehaophdsfciet>eteoksfcintjva*% fln_hae_ado_#uer#!!&>>>)!#()>a>!!&@>>_&#()
a ogapce>aoo>df>fcetgecteoksscen>aa${ln_saedhdop#ubr#!>>>>(_!#(>>a#!!&(>_&_()
togapcehaoo>df>sen>pefsetjva!!{lnkhae_hdo_#uer#!!>>>>)!#(>>a>>!&@>>_&_()
atog>pch>aop>dftiuedese>dstiuelse>av#* {fikshad_adp_#ue_>!!&@()_&_()ja>>!&@>>_&#>)
>> *mreue yorapce>aoo>icotcpinedesnteis sr?dtlhd_wrhus?uiccotatodsal>*ad*!d!c$ada%_%#ac^e@@)%%%$$!^$>lg!)!_
a ogaacehdopdssrernmnoedl>vlendeja* t r>pch>aop>dssevrnaeoendl>aleele>v& a rgaah>hdo>hf>eve>aend>srtstngtokaiossastngjaa%
ator>pah>adophfssrernmeoesesstmgtokatonsmssemjv!@ tor>aahehdo>hf>sre>amnd>mdervrgtokatoseecre>aa^ t r>aachef>rtoo>ineodooovrdasltrbeokctinineoeooolvrdanltr>aa$^) tog>pce>aop>dsprtco>rtointeodotcltoinendoocl@caloknhdetendtclto>aa
tor>pch>aop>p>ooucgn@vrotfcoercloougne>av
atogapce>aop>p>oougn@vrtfcvkrcalotbfIE>JV*(
A RGAACEHDOPIC>TOUCIE@RRTcvercloobfcgie>aa& tor>pch>aoo>p>csrvrcllc>aa@#
tog>pce>aop>p>reclruve>aa!)(
tor>pah>hdo>p>recl>ure>jv!!
a aaseuit>cstole>oiilgdtietod
a avxscrtyat>bet>objc>aa@
a r>pah>ado>ecrtyeopfrain>orupomain>aa!*(
tor>pce>aop>p>vrdlrrnvrjaa#@
a r>aah>hdo>p>intgtcpnsenaa%@ {fik_hddhaop#ubr#>>>>@()_&_>>j#!!&@>>_!#()} togapce>adopic>in>alet>av%){lnkhae_hdopubr_>>>&@(>_&#()ja#!!>>>>)!#(>} tor>pcehaop>p>in>alen>av$)fik_hddhaop#_br_>>>&@>>_&#()ja>>>>@(>!#_>} atogapcehaopic>tbucgnvkrinoetoufgnejv@# {likshddhaop#ubr#!!>>>>_!#()>a>>!&@>>_&_()
togapcehdopictbfcgnvkrinoetbfcgn>av! {liksaddhaop#_br_>>>>@()!&_>>jr#!>>>>>)!#()} tcmsu>royxy^gecainskow rc{} t r>pch>aoo>ds>rtcl>enmeoeooonlto>etcainintendotclasatr>v#) {fin_saedhdop#_be_>!>&@>>_&#()jr>>>>>()!#_>} a u>rfet>eatdtocsor*inoenwnuce}
t u>efeteaintodesop>nvklgtigtocssrp>av# !*>@*} lagrflc>th>nvkho>aa$(!*>*!
a rg>pce>aopi>ety>roainnle>nvetotyvctonnerjv#! {fnkshe_adop#uer#!>>>>>)!#(>>a#!!&@>>&#()
torgpah>ado>o>er>tyoctodel>noktotyoctinde>jv^^ {liksaddhdop#uer#!>>>>()!&_>)ja>!!&>>>)!#_>)
tog>pcehdoo>o>etyrvotinnlrllinoervoaindlrjaa!* fik_hdd_aop__br_>>>&@()_&_(>jr#>>!>>()!&_>} tor>pah>ado>i>erytvctonderl>inoeercainnlr>aa(^ {liksae_hdo_#be_!>&@(>_&_>)jr>>>&@()!&_>}
ogapcehdopi>rty>ryoainnlr>noervcainnlr>aa^ {ln_sae_hdo_#ue_>!!&@>>_!_()jr>>>&@(>_&_>}
a omsn>rx>x#>etckainkon re
tog>pce>aop>dsscietclokctonfcet>aa*^{ln_sae_hdo_#ue_>!!&>(>_&_()ja#!!&>>>)!#(>} a r>aah>hdophf>fsen>etaeokssin>av%fln_sae_hdo_#ue_#!!>>>()!#_>>ar#!!>>>()!&_>)
at r>pahehdop>fsset>ecaeocssin>aa*$fln_hdd_aop__be_>!!&@>>_&#()ja>>>&@()_&_>) a ogaah>hdo>hf>fitopnscin>jv)!{ik_hde_aop__b#>>>>>()!#_>>ar#!!>>>>_!#()
atog>pcehaoo>ds>tibtdlsem$dlltiuedete>av# {ln_sae_hdop#_br#>>>>@()!&_>)jr#>>>>@()!&_>}
a r>aahehdo>hf>sriutdlsem$dllstiuedese>av# {liksae_hdo_#ue_>!!>@>>_&#()ja>>!&@(>_&#()} t rgaacehdopfslemkslerrsovesenkovr>aa* {liksaddhdop#ubr#!>>>>>)(>>a#!!&>>>_!#_>} a r>aah>ado>ds>tibultmoenriutdlstmjaa#%fln_hae_ado_#ue_#!!>>>()_&_>>jr#!>>>>>)!#(>} torg>ap>aopfsdopsisgtdtapteadosl>jva@! huifin!>*bnde_>!>>jr>%>} >>@* e@@%)_@ !&!<( o g>pah>fik>onribeaintteksbkydaeced{} osdk ae knd ann p ksbrkn ircoy dt#daayr##?oaluerah?ado?pcah?ppiato^((@^$$^!?mcntie)!(*#@$$%!!!))$?m?jb)d***&)(faf!$#c)!(pemATR^(BFB*BD$*B^&^$$DCUDC^#(C$B_$F_^)&^$EF*$>@)%)%@%!&#<)@AN RGAACEFIKRUTM>TSMNGE>K } HDOONRCTGOSL{$}_ L{(}?$! $(#$&)F*A#&C%A*%A$@^(((*^E&*B^&^&$DCF@!!STHD RONIN ALD T FIUR CUS
OGAACEHD>ECPIO>DICPIOCPTO HE EAIGLO IE
A RGAAH>HD>OMO>ABELO>TACOIEODAE>AENA!TACOIECOAE>J^ {UIFLN!!_BNL_)!>>JR)!%)
ATOGAPCE>UD>CMN>ABELGTATDIGCRADRSAENLTATOIGCRAERJV@) {UD_LNK>*BNDE)>%)JR)>%>} TOG>PCE>UICMONTBLG>DIRECRNNRPROMAOIEGDODANR>AA@)HUIFIK!!_BNL_)!>>JR!>)
A RGAAH>HD>OMO>ALELG>ODGEGORANE>INTDEMCRNE>JV@) {UD_LNK>*BUDE_!%)JA)%>}
A R>AAH>HD>OMO>TBELG>DIREGCONERNTOIRGDODANRJAA&& {UDFLN!!*BNDE)!%)JR>%)
ATOGAPCE>DICMONTBELO>Orgdgodanride>uidodegdCRANE>AA& {UIFN!>*BNL_)!>>JA>%>}
T G>PCH>HD>ALEFRATRALSLGANRRMTLSJV&# {UI_LI!>*BNDE)!%)JR)>%)
TOR>PCEHUITBE>OMT>O>REAPTRA>ETERAOREAPTRMTJA#% {HD_LIN>*BUDE)>%)>>%>} T R>PCH>UD>ALEFRATMRREAUrmtiitrtoreaptrat>@! {hd_lnk>!_unl_>%>>ar)!>}
atogapacheefomt>orreaurm>pnrgadumtjaa!(huifik!!*unl_>%>>a>!>}
t r>aacehuisoreremaertrprcsisemaeao>jv&! {ui_ln!!*bnle)!>>jr)>%)
ator>aacefln>tramn>utietak>easineuor!rnrwnramktoctr>aa) fik_it_!*!>a>!>! t rgaahefln>sraig>utmetss>aloxilrnil>va( {likds_>*>>a!!>}
a rgaah>fikstemn>rnie>ak>aibxiloocso>rlilocso>aa({fn_is_>*>>a!!>} tor>pceflnksrain>unie>ak>mibx>loxcssrpoesisncinlbcssrjva##finks_>*!>a>*>} tog>pcefln>traig>utmetss>aibxloxoeso>pocslloocss>jv$% {linst!!>>ar!*!
a r>aah>liksramn>rnie>assmilbibxcesrrniboopibxoesrjaa@( fin_it_>*!>a!!>} a r>aah>liksramn>unte>ass>aSKRNILOXPRASKJVA{LNKDS_!!>>JR!!*!
A OGAACE>IN>TEAIGRUNETSS>EMS>NVKRAKJA)& {FIKDS_>!>>JR!!>!
ATOGAPCEFLN>RNIETSKAAERKRNTSEMTNTOIGK>AA%# {FIKDST!!>!JR!>*!} T R>PAH>LIKRNTM>TSMNGR>KRETRVE>JV#@ FIK_IT_>*!>A!!>} T R>AAH>FIKRUTIETSKAAE>SKDNKJV$ FIN_IT!!*!JA>*>} T R>PAH>LN>RNIE>ASAAGRSKRNKJVA^ FIN_IST>!*JA!!*}
TJAA>GEA>UE>JVA&* {>*)@!
UE BOGAPCEHDIECPO>DIOCPTO ETNCEAIG NU TEA RMFIE HFS?!@@>@@(())UE?ELHD_WRHUS?UICCNTATGOD?>FDD#_!C_@DA%A%#(D*E*)%)@!$%%$>LG>__
ATOGAACE>UIDOPF>OOSL>ESAPTEMOPUIS>AA@)HUIFLN!>*BNLE)!>)JR)>%)
T >PCE>UI>TRAEHDO>ODEOPOAE>PNEALEODEDOPOAEJAA%$) k.8-ude0.50jr>%)} A OGAPCEHDICMONTBE>O>OIGLADRGETAUEMODEEDRJAA$&HDIFLK!!_UNLE)>%)>A>!>} TOR>PAH>UD>CMMNTAL>LO>DIGLDE>NTDIGLAE>AV!) {UD_LIK>*_UDE)!%)JA>%)} APCEHDICMONTBE>O>OIERADE>IIDEGMTDE>AA@ {HD_LIK>*_UNL_)!>>JR)>%)} T R>PAH>UD>CMO>TAL>LO>TRCODCRDDRSCNTRAASRCTDEGCODDE>AV${UIFIN!!_UNL_>%>>A>!>}
>>@ OE
SDBY AVIOLEUDCPINEDESNTEIS?SRDTLHD_ARHUEHUIOCNRCTGOSAL?*AD*!_!C$ADA%_!#AC^E@@)%%%!!%>O>!)!_```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@hudi.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] [SUPPORT]flink read hudi table with file not found exception [hudi]
Posted by "danny0405 (via GitHub)" <gi...@apache.org>.
danny0405 commented on issue #13363:
URL: https://github.com/apache/hudi/issues/13363#issuecomment-2912133063
Hi, did you skip the compaction while triggerring streaming read? It looks like there is a lag for the streaming reader akka to the writer, you may increase the `clean.retain_commits` to enable longer TTL time for the logs.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@hudi.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] [SUPPORT]flink read hudi table with file not found exception [hudi]
Posted by "YinChunGuang (via GitHub)" <gi...@apache.org>.
YinChunGuang commented on issue #13363:
URL: https://github.com/apache/hudi/issues/13363#issuecomment-3322248150
@ad1happy2go I haven't encountered it since I last rebuilt the table.
Thank you!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@hudi.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] [SUPPORT]flink read hudi table with file not found exception [hudi]
Posted by "YinChunGuang (via GitHub)" <gi...@apache.org>.
YinChunGuang closed issue #13363: [SUPPORT]flink read hudi table with file not found exception
URL: https://github.com/apache/hudi/issues/13363
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@hudi.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] [SUPPORT]flink read hudi table with file not found exception [hudi]
Posted by "ad1happy2go (via GitHub)" <gi...@apache.org>.
ad1happy2go commented on issue #13363:
URL: https://github.com/apache/hudi/issues/13363#issuecomment-3219684226
Hi @YinChunGuang
Could you please let me know if any further updates are required on this issue?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@hudi.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org