Limess commented on issue #6367:
URL: https://github.com/apache/hudi/issues/6367#issuecomment-1211816894
This now seems to have turned into errors when running Deltastreamer:
```
22/08/11 10:16:25 INFO HoodieTableMetaClient: Loading HoodieTableMetaClient
from
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata
22/08/11 10:16:25 INFO HoodieTableConfig: Loading table properties from
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/.hoodie/hoodie.properties
22/08/11 10:16:25 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/.hoodie/hoodie.properties'
for reading
22/08/11 10:16:25 INFO HoodieTableMetaClient: Finished Loading Table of type
MERGE_ON_READ(version=1, baseFileFormat=HFILE) from
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata
22/08/11 10:16:25 INFO HoodieActiveTimeline: Loaded instants upto :
Option{val=[==>20220811051710480__deltacommit__INFLIGHT]}
22/08/11 10:16:25 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.1_0-0-0'
for reading
22/08/11 10:16:25 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.1_0-0-0',
fileLen=-1}
22/08/11 10:16:25 INFO AbstractHoodieLogRecordReader: Reading a delete block
from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.1_0-0-0
22/08/11 10:16:25 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.1_6-82-177086'
for reading
22/08/11 10:16:25 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.1_6-82-177086',
fileLen=-1}
22/08/11 10:16:26 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.1_6-82-177086',
fileLen=-1}
22/08/11 10:16:26 INFO AbstractHoodieLogRecordReader: Reading a data block
from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.1_6-82-177086
at instant 20220809191455283
22/08/11 10:16:26 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.1_6-82-177086',
fileLen=-1}
22/08/11 10:16:26 INFO AbstractHoodieLogRecordReader: Reading a data block
from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.1_6-82-177086
at instant 20220809191455283
22/08/11 10:16:26 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.1_6-82-177086',
fileLen=-1}
22/08/11 10:16:26 INFO AbstractHoodieLogRecordReader: Reading a data block
from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.1_6-82-177086
at instant 20220809191455283
22/08/11 10:16:26 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.1_6-82-177086',
fileLen=-1}
22/08/11 10:16:26 INFO AbstractHoodieLogRecordReader: Reading a data block
from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.1_6-82-177086
at instant 20220809191455283
22/08/11 10:16:26 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.1_6-82-177086',
fileLen=-1}
22/08/11 10:16:26 INFO AbstractHoodieLogRecordReader: Reading a data block
from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.1_6-82-177086
at instant 20220809191455283
22/08/11 10:16:26 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.2_6-95-187512'
for reading
22/08/11 10:16:26 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.2_6-95-187512',
fileLen=-1}
22/08/11 10:16:26 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.2_6-95-187512',
fileLen=-1}
22/08/11 10:16:26 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.3_6-45-7441'
for reading
22/08/11 10:16:26 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.3_6-45-7441',
fileLen=-1}
22/08/11 10:16:26 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.3_6-45-7441',
fileLen=-1}
22/08/11 10:16:27 INFO AbstractHoodieLogRecordReader: Reading a data block
from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.3_6-45-7441
at instant 20220809211217471
22/08/11 10:16:27 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.4_6-69-9102'
for reading
22/08/11 10:16:27 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.4_6-69-9102',
fileLen=-1}
22/08/11 10:16:27 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.4_6-69-9102',
fileLen=-1}
22/08/11 10:16:27 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.5_6-78-10414'
for reading
22/08/11 10:16:27 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.5_6-78-10414',
fileLen=-1}
22/08/11 10:16:27 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.5_6-78-10414',
fileLen=-1}
22/08/11 10:16:27 INFO AbstractHoodieLogRecordReader: Reading a data block
from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.5_6-78-10414
at instant 20220809214331325
22/08/11 10:16:27 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.6_6-45-8672'
for reading
22/08/11 10:16:27 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.6_6-45-8672',
fileLen=-1}
22/08/11 10:16:27 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.6_6-45-8672',
fileLen=-1}
22/08/11 10:16:27 INFO AbstractHoodieLogRecordReader: Reading a data block
from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.6_6-45-8672
at instant 20220809220937461
22/08/11 10:16:27 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.7_6-71-10286'
for reading
22/08/11 10:16:27 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.7_6-71-10286',
fileLen=-1}
22/08/11 10:16:27 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.7_6-71-10286',
fileLen=-1}
22/08/11 10:16:28 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.8_6-80-11549'
for reading
22/08/11 10:16:28 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.8_6-80-11549',
fileLen=-1}
22/08/11 10:16:28 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.8_6-80-11549',
fileLen=-1}
22/08/11 10:16:28 INFO AbstractHoodieLogRecordReader: Reading a data block
from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.8_6-80-11549
at instant 20220809224742978
22/08/11 10:16:28 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.9_6-45-7685'
for reading
22/08/11 10:16:28 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.9_6-45-7685',
fileLen=-1}
22/08/11 10:16:28 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.9_6-45-7685',
fileLen=-1}
22/08/11 10:16:28 INFO AbstractHoodieLogRecordReader: Reading a data block
from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.9_6-45-7685
at instant 20220810001435544
22/08/11 10:16:28 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.10_6-71-9348'
for reading
22/08/11 10:16:28 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.10_6-71-9348',
fileLen=-1}
22/08/11 10:16:28 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.10_6-71-9348',
fileLen=-1}
22/08/11 10:16:28 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.11_6-80-10660'
for reading
22/08/11 10:16:28 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.11_6-80-10660',
fileLen=-1}
22/08/11 10:16:28 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.11_6-80-10660',
fileLen=-1}
22/08/11 10:16:28 INFO AbstractHoodieLogRecordReader: Reading a data block
from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.11_6-80-10660
at instant 20220810004659044
22/08/11 10:16:28 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.12_6-45-7075'
for reading
22/08/11 10:16:28 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.12_6-45-7075',
fileLen=-1}
22/08/11 10:16:28 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.12_6-45-7075',
fileLen=-1}
22/08/11 10:16:29 INFO AbstractHoodieLogRecordReader: Reading a data block
from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.12_6-45-7075
at instant 20220810041141162
22/08/11 10:16:29 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.13_6-71-8738'
for reading
22/08/11 10:16:29 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.13_6-71-8738',
fileLen=-1}
22/08/11 10:16:29 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.13_6-71-8738',
fileLen=-1}
22/08/11 10:16:29 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.14_6-80-10050'
for reading
22/08/11 10:16:29 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.14_6-80-10050',
fileLen=-1}
22/08/11 10:16:29 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.14_6-80-10050',
fileLen=-1}
22/08/11 10:16:29 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.15_6-45-7343'
for reading
22/08/11 10:16:29 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.15_6-45-7343',
fileLen=-1}
22/08/11 10:16:29 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.15_6-45-7343',
fileLen=-1}
22/08/11 10:16:29 INFO AbstractHoodieLogRecordReader: Reading a data block
from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.15_6-45-7343
at instant 20220810094328704
22/08/11 10:16:29 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.16_1-0-1'
for reading
22/08/11 10:16:29 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.16_1-0-1',
fileLen=-1}
22/08/11 10:16:29 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.16_1-0-1',
fileLen=-1}
22/08/11 10:16:29 INFO AbstractHoodieLogRecordReader: Reading a command
block from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.16_1-0-1
22/08/11 10:16:29 WARN AbstractHoodieLogRecordReader: TargetInstantTime
20220810043930567 invalid or extra rollback command block in
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.16_1-0-1
22/08/11 10:16:29 INFO AbstractHoodieLogRecordReader: Number of applied
rollback blocks 0
22/08/11 10:16:29 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.17_6-78-9134'
for reading
22/08/11 10:16:29 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.17_6-78-9134',
fileLen=-1}
22/08/11 10:16:29 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.17_6-78-9134',
fileLen=-1}
22/08/11 10:16:29 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.18_6-87-10446'
for reading
22/08/11 10:16:29 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.18_6-87-10446',
fileLen=-1}
22/08/11 10:16:29 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.18_6-87-10446',
fileLen=-1}
22/08/11 10:16:30 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.19_6-96-11758'
for reading
22/08/11 10:16:30 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.19_6-96-11758',
fileLen=-1}
22/08/11 10:16:30 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.19_6-96-11758',
fileLen=-1}
22/08/11 10:16:30 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.20_6-45-7355'
for reading
22/08/11 10:16:30 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.20_6-45-7355',
fileLen=-1}
22/08/11 10:16:30 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.20_6-45-7355',
fileLen=-1}
22/08/11 10:16:30 INFO AbstractHoodieLogRecordReader: Reading a data block
from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.20_6-45-7355
at instant 20220810104914503
22/08/11 10:16:30 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.21_1-0-1'
for reading
22/08/11 10:16:30 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.21_1-0-1',
fileLen=-1}
22/08/11 10:16:30 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.21_1-0-1',
fileLen=-1}
22/08/11 10:16:30 INFO AbstractHoodieLogRecordReader: Reading a command
block from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.21_1-0-1
22/08/11 10:16:30 WARN AbstractHoodieLogRecordReader: TargetInstantTime
20220810101401795 invalid or extra rollback command block in
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.21_1-0-1
22/08/11 10:16:30 INFO AbstractHoodieLogRecordReader: Number of applied
rollback blocks 0
22/08/11 10:16:30 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.22_1-0-1'
for reading
22/08/11 10:16:30 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.22_1-0-1',
fileLen=-1}
22/08/11 10:16:30 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.22_1-0-1',
fileLen=-1}
22/08/11 10:16:30 INFO AbstractHoodieLogRecordReader: Reading a command
block from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.22_1-0-1
22/08/11 10:16:30 WARN AbstractHoodieLogRecordReader: TargetInstantTime
20220810043930567 invalid or extra rollback command block in
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.22_1-0-1
22/08/11 10:16:30 INFO AbstractHoodieLogRecordReader: Number of applied
rollback blocks 0
22/08/11 10:16:30 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.23_6-85-9274'
for reading
22/08/11 10:16:30 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.23_6-85-9274',
fileLen=-1}
22/08/11 10:16:30 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.23_6-85-9274',
fileLen=-1}
22/08/11 10:16:31 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.24_6-94-10586'
for reading
22/08/11 10:16:31 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.24_6-94-10586',
fileLen=-1}
22/08/11 10:16:31 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.24_6-94-10586',
fileLen=-1}
22/08/11 10:16:31 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.25_6-103-11898'
for reading
22/08/11 10:16:31 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.25_6-103-11898',
fileLen=-1}
22/08/11 10:16:31 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.25_6-103-11898',
fileLen=-1}
22/08/11 10:16:31 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.26_6-112-13210'
for reading
22/08/11 10:16:31 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.26_6-112-13210',
fileLen=-1}
22/08/11 10:16:31 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.26_6-112-13210',
fileLen=-1}
22/08/11 10:16:31 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.27_6-45-7544'
for reading
22/08/11 10:16:31 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.27_6-45-7544',
fileLen=-1}
22/08/11 10:16:31 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.27_6-45-7544',
fileLen=-1}
22/08/11 10:16:31 INFO AbstractHoodieLogRecordReader: Reading a data block
from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.27_6-45-7544
at instant 20220810121317806
22/08/11 10:16:31 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.28_1-0-1'
for reading
22/08/11 10:16:31 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.28_1-0-1',
fileLen=-1}
22/08/11 10:16:31 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.28_1-0-1',
fileLen=-1}
22/08/11 10:16:32 INFO AbstractHoodieLogRecordReader: Reading a command
block from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.28_1-0-1
22/08/11 10:16:32 WARN AbstractHoodieLogRecordReader: TargetInstantTime
20220810112003465 invalid or extra rollback command block in
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.28_1-0-1
22/08/11 10:16:32 INFO AbstractHoodieLogRecordReader: Number of applied
rollback blocks 0
22/08/11 10:16:32 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.29_1-0-1'
for reading
22/08/11 10:16:32 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.29_1-0-1',
fileLen=-1}
22/08/11 10:16:32 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.29_1-0-1',
fileLen=-1}
22/08/11 10:16:32 INFO AbstractHoodieLogRecordReader: Reading a command
block from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.29_1-0-1
22/08/11 10:16:32 WARN AbstractHoodieLogRecordReader: TargetInstantTime
20220810101401795 invalid or extra rollback command block in
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.29_1-0-1
22/08/11 10:16:32 INFO AbstractHoodieLogRecordReader: Number of applied
rollback blocks 0
22/08/11 10:16:32 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.30_1-0-1'
for reading
22/08/11 10:16:32 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.30_1-0-1',
fileLen=-1}
22/08/11 10:16:32 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.30_1-0-1',
fileLen=-1}
22/08/11 10:16:32 INFO AbstractHoodieLogRecordReader: Reading a command
block from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.30_1-0-1
22/08/11 10:16:32 WARN AbstractHoodieLogRecordReader: TargetInstantTime
20220810043930567 invalid or extra rollback command block in
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.30_1-0-1
22/08/11 10:16:32 INFO AbstractHoodieLogRecordReader: Number of applied
rollback blocks 0
22/08/11 10:16:32 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.31_6-92-9591'
for reading
22/08/11 10:16:32 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.31_6-92-9591',
fileLen=-1}
22/08/11 10:16:32 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.31_6-92-9591',
fileLen=-1}
22/08/11 10:16:32 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.32_6-101-10903'
for reading
22/08/11 10:16:32 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.32_6-101-10903',
fileLen=-1}
22/08/11 10:16:32 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.32_6-101-10903',
fileLen=-1}
22/08/11 10:16:32 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.33_6-110-12215'
for reading
22/08/11 10:16:32 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.33_6-110-12215',
fileLen=-1}
22/08/11 10:16:32 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.33_6-110-12215',
fileLen=-1}
22/08/11 10:16:32 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.34_6-119-13527'
for reading
22/08/11 10:16:32 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.34_6-119-13527',
fileLen=-1}
22/08/11 10:16:33 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.34_6-119-13527',
fileLen=-1}
22/08/11 10:16:33 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.35_6-128-14839'
for reading
22/08/11 10:16:33 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.35_6-128-14839',
fileLen=-1}
22/08/11 10:16:33 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.35_6-128-14839',
fileLen=-1}
22/08/11 10:16:33 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.36_6-45-8123'
for reading
22/08/11 10:16:33 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.36_6-45-8123',
fileLen=-1}
22/08/11 10:16:33 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.36_6-45-8123',
fileLen=-1}
22/08/11 10:16:33 INFO AbstractHoodieLogRecordReader: Reading a data block
from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.36_6-45-8123
at instant 20220810162446348
22/08/11 10:16:33 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.37_1-0-1'
for reading
22/08/11 10:16:33 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.37_1-0-1',
fileLen=-1}
22/08/11 10:16:33 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.37_1-0-1',
fileLen=-1}
22/08/11 10:16:33 INFO AbstractHoodieLogRecordReader: Reading a command
block from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.37_1-0-1
22/08/11 10:16:33 WARN AbstractHoodieLogRecordReader: TargetInstantTime
20220810124451210 invalid or extra rollback command block in
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.37_1-0-1
22/08/11 10:16:33 INFO AbstractHoodieLogRecordReader: Number of applied
rollback blocks 0
22/08/11 10:16:33 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.38_1-0-1'
for reading
22/08/11 10:16:33 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.38_1-0-1',
fileLen=-1}
22/08/11 10:16:33 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.38_1-0-1',
fileLen=-1}
22/08/11 10:16:33 INFO AbstractHoodieLogRecordReader: Reading a command
block from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.38_1-0-1
22/08/11 10:16:33 WARN AbstractHoodieLogRecordReader: TargetInstantTime
20220810112003465 invalid or extra rollback command block in
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.38_1-0-1
22/08/11 10:16:33 INFO AbstractHoodieLogRecordReader: Number of applied
rollback blocks 0
22/08/11 10:16:33 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.39_1-0-1'
for reading
22/08/11 10:16:33 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.39_1-0-1',
fileLen=-1}
22/08/11 10:16:33 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.39_1-0-1',
fileLen=-1}
22/08/11 10:16:33 INFO AbstractHoodieLogRecordReader: Reading a command
block from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.39_1-0-1
22/08/11 10:16:33 WARN AbstractHoodieLogRecordReader: TargetInstantTime
20220810101401795 invalid or extra rollback command block in
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.39_1-0-1
22/08/11 10:16:33 INFO AbstractHoodieLogRecordReader: Number of applied
rollback blocks 0
22/08/11 10:16:33 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.40_1-0-1'
for reading
22/08/11 10:16:33 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.40_1-0-1',
fileLen=-1}
22/08/11 10:16:33 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.40_1-0-1',
fileLen=-1}
22/08/11 10:16:33 INFO AbstractHoodieLogRecordReader: Reading a command
block from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.40_1-0-1
22/08/11 10:16:33 WARN AbstractHoodieLogRecordReader: TargetInstantTime
20220810043930567 invalid or extra rollback command block in
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.40_1-0-1
22/08/11 10:16:33 INFO AbstractHoodieLogRecordReader: Number of applied
rollback blocks 0
22/08/11 10:16:34 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.41_6-99-10298'
for reading
22/08/11 10:16:34 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.41_6-99-10298',
fileLen=-1}
22/08/11 10:16:34 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.41_6-99-10298',
fileLen=-1}
22/08/11 10:16:34 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.42_6-108-11610'
for reading
22/08/11 10:16:34 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.42_6-108-11610',
fileLen=-1}
22/08/11 10:16:34 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.42_6-108-11610',
fileLen=-1}
22/08/11 10:16:34 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.43_6-117-12921'
for reading
22/08/11 10:16:34 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.43_6-117-12921',
fileLen=-1}
22/08/11 10:16:34 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.43_6-117-12921',
fileLen=-1}
22/08/11 10:16:34 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.44_6-126-14234'
for reading
22/08/11 10:16:34 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.44_6-126-14234',
fileLen=-1}
22/08/11 10:16:34 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.44_6-126-14234',
fileLen=-1}
22/08/11 10:16:35 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.45_6-135-15546'
for reading
22/08/11 10:16:35 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.45_6-135-15546',
fileLen=-1}
22/08/11 10:16:35 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.45_6-135-15546',
fileLen=-1}
22/08/11 10:16:35 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.46_6-144-16858'
for reading
22/08/11 10:16:35 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.46_6-144-16858',
fileLen=-1}
22/08/11 10:16:35 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.46_6-144-16858',
fileLen=-1}
22/08/11 10:16:35 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.47_6-45-7900'
for reading
22/08/11 10:16:35 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.47_6-45-7900',
fileLen=-1}
22/08/11 10:16:35 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.47_6-45-7900',
fileLen=-1}
22/08/11 10:16:35 INFO AbstractHoodieLogRecordReader: Reading a data block
from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.47_6-45-7900
at instant 20220810201123717
22/08/11 10:16:35 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.48_1-0-1'
for reading
22/08/11 10:16:35 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.48_1-0-1',
fileLen=-1}
22/08/11 10:16:35 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.48_1-0-1',
fileLen=-1}
22/08/11 10:16:35 INFO AbstractHoodieLogRecordReader: Reading a command
block from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.48_1-0-1
22/08/11 10:16:35 WARN AbstractHoodieLogRecordReader: TargetInstantTime
20220810170031127 invalid or extra rollback command block in
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.48_1-0-1
22/08/11 10:16:35 INFO AbstractHoodieLogRecordReader: Number of applied
rollback blocks 0
22/08/11 10:16:35 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.49_1-0-1'
for reading
22/08/11 10:16:35 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.49_1-0-1',
fileLen=-1}
22/08/11 10:16:35 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.49_1-0-1',
fileLen=-1}
22/08/11 10:16:35 INFO AbstractHoodieLogRecordReader: Reading a command
block from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.49_1-0-1
22/08/11 10:16:35 WARN AbstractHoodieLogRecordReader: TargetInstantTime
20220810124451210 invalid or extra rollback command block in
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.49_1-0-1
22/08/11 10:16:35 INFO AbstractHoodieLogRecordReader: Number of applied
rollback blocks 0
22/08/11 10:16:35 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.50_1-0-1'
for reading
22/08/11 10:16:35 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.50_1-0-1',
fileLen=-1}
22/08/11 10:16:45 INFO GlobalS3Executor: ReadTimeout File:
articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.50_1-0-1;
Range: null
Use default timeout configuration to retry for read timeout {}
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.SdkClientException: Unable
to execute HTTP request: Timeout waiting for connection from pool
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleRetryableException(AmazonHttpClient.java:1216)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1162)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.doExecute(AmazonHttpClient.java:811)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeWithTimer(AmazonHttpClient.java:779)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.execute(AmazonHttpClient.java:753)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.access$500(AmazonHttpClient.java:713)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutionBuilderImpl.execute(AmazonHttpClient.java:695)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:559)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:539)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:5453)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:5400)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.services.s3.AmazonS3Client.getObject(AmazonS3Client.java:1524)
at
com.amazon.ws.emr.hadoop.fs.s3.lite.call.GetObjectCall.perform(GetObjectCall.java:35)
at
com.amazon.ws.emr.hadoop.fs.s3.lite.call.GetObjectCall.perform(GetObjectCall.java:13)
at
com.amazon.ws.emr.hadoop.fs.s3.lite.executor.GlobalS3Executor.execute(GlobalS3Executor.java:136)
at
com.amazon.ws.emr.hadoop.fs.s3.lite.AmazonS3LiteClient.invoke(AmazonS3LiteClient.java:191)
at
com.amazon.ws.emr.hadoop.fs.s3.lite.AmazonS3LiteClient.getObject(AmazonS3LiteClient.java:102)
at
com.amazon.ws.emr.hadoop.fs.s3.GetObjectInputStreamWithInfoFactory.create(GetObjectInputStreamWithInfoFactory.java:63)
at
com.amazon.ws.emr.hadoop.fs.s3.S3FSInputStream.open(S3FSInputStream.java:200)
at
com.amazon.ws.emr.hadoop.fs.s3.S3FSInputStream.retrieveInputStreamWithInfo(S3FSInputStream.java:391)
at
com.amazon.ws.emr.hadoop.fs.s3.S3FSInputStream.reopenStream(S3FSInputStream.java:378)
at
com.amazon.ws.emr.hadoop.fs.s3.S3FSInputStream.seekStream(S3FSInputStream.java:451)
at
com.amazon.ws.emr.hadoop.fs.s3.S3FSInputStream.read(S3FSInputStream.java:255)
at java.io.BufferedInputStream.fill(BufferedInputStream.java:246)
at java.io.BufferedInputStream.read1(BufferedInputStream.java:286)
at java.io.BufferedInputStream.read(BufferedInputStream.java:345)
at java.io.DataInputStream.read(DataInputStream.java:149)
at java.io.DataInputStream.readFully(DataInputStream.java:195)
at
org.apache.hudi.common.table.log.HoodieLogFileReader.hasNextMagic(HoodieLogFileReader.java:379)
at
org.apache.hudi.common.table.log.HoodieLogFileReader.readMagic(HoodieLogFileReader.java:365)
at
org.apache.hudi.common.table.log.HoodieLogFileReader.hasNext(HoodieLogFileReader.java:350)
at
org.apache.hudi.common.table.log.HoodieLogFormatReader.hasNext(HoodieLogFormatReader.java:99)
at
org.apache.hudi.common.table.log.HoodieLogFormatReader.hasNext(HoodieLogFormatReader.java:116)
at
org.apache.hudi.common.table.log.AbstractHoodieLogRecordReader.scanInternal(AbstractHoodieLogRecordReader.java:223)
at
org.apache.hudi.common.table.log.AbstractHoodieLogRecordReader.scan(AbstractHoodieLogRecordReader.java:192)
at
org.apache.hudi.common.table.log.HoodieMergedLogRecordScanner.performScan(HoodieMergedLogRecordScanner.java:110)
at
org.apache.hudi.common.table.log.HoodieMergedLogRecordScanner.<init>(HoodieMergedLogRecordScanner.java:103)
at
org.apache.hudi.metadata.HoodieMetadataMergedLogRecordReader.<init>(HoodieMetadataMergedLogRecordReader.java:63)
at
org.apache.hudi.metadata.HoodieMetadataMergedLogRecordReader.<init>(HoodieMetadataMergedLogRecordReader.java:51)
at
org.apache.hudi.metadata.HoodieMetadataMergedLogRecordReader$Builder.build(HoodieMetadataMergedLogRecordReader.java:230)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.getLogRecordScanner(HoodieBackedTableMetadata.java:499)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.getLogRecordScanner(HoodieBackedTableMetadata.java:461)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.openReaders(HoodieBackedTableMetadata.java:407)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.lambda$getOrCreateReaders$10(HoodieBackedTableMetadata.java:393)
at
java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.getOrCreateReaders(HoodieBackedTableMetadata.java:393)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.lambda$getRecordsByKeys$0(HoodieBackedTableMetadata.java:202)
at java.util.HashMap.forEach(HashMap.java:1290)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.getRecordsByKeys(HoodieBackedTableMetadata.java:200)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.getRecordByKey(HoodieBackedTableMetadata.java:140)
at
org.apache.hudi.metadata.BaseTableMetadata.fetchAllFilesInPartition(BaseTableMetadata.java:312)
at
org.apache.hudi.metadata.BaseTableMetadata.getAllFilesInPartition(BaseTableMetadata.java:135)
at
org.apache.hudi.metadata.HoodieMetadataFileSystemView.listPartition(HoodieMetadataFileSystemView.java:66)
at
org.apache.hudi.common.table.view.AbstractTableFileSystemView.lambda$ensurePartitionLoadedCorrectly$9(AbstractTableFileSystemView.java:304)
at
java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660)
at
org.apache.hudi.common.table.view.AbstractTableFileSystemView.ensurePartitionLoadedCorrectly(AbstractTableFileSystemView.java:295)
at
org.apache.hudi.common.table.view.AbstractTableFileSystemView.getLatestBaseFilesBeforeOrOn(AbstractTableFileSystemView.java:502)
at
org.apache.hudi.timeline.service.handlers.BaseFileHandler.getLatestDataFilesBeforeOrOn(BaseFileHandler.java:60)
at
org.apache.hudi.timeline.service.RequestHandler.lambda$registerDataFilesAPI$6(RequestHandler.java:272)
at
org.apache.hudi.timeline.service.RequestHandler$ViewHandler.handle(RequestHandler.java:501)
at
io.javalin.core.security.SecurityUtil.noopAccessManager(SecurityUtil.kt:23)
at
io.javalin.http.JavalinServlet$addHandler$protectedHandler$1.handle(JavalinServlet.kt:128)
at
io.javalin.http.JavalinServlet$service$2$1.invoke(JavalinServlet.kt:45)
at
io.javalin.http.JavalinServlet$service$2$1.invoke(JavalinServlet.kt:24)
at
io.javalin.http.JavalinServlet$service$1.invoke(JavalinServlet.kt:136)
at io.javalin.http.JavalinServlet$service$2.invoke(JavalinServlet.kt:40)
at io.javalin.http.JavalinServlet.service(JavalinServlet.kt:81)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:790)
at io.javalin.websocket.JavalinWsServlet.service(JavalinWsServlet.kt:51)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:790)
at
org.apache.hudi.org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:799)
at
org.apache.hudi.org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:550)
at
org.apache.hudi.org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
at
org.apache.hudi.org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1624)
at
org.apache.hudi.org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
at
io.javalin.core.JavalinServer$start$wsAndHttpHandler$1.doHandle(JavalinServer.kt:49)
at
org.apache.hudi.org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188)
at
org.apache.hudi.org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:501)
at
org.apache.hudi.org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1594)
at
org.apache.hudi.org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186)
at
org.apache.hudi.org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1349)
at
org.apache.hudi.org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
at
org.apache.hudi.org.eclipse.jetty.server.handler.StatisticsHandler.handle(StatisticsHandler.java:179)
at
org.apache.hudi.org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)
at
org.apache.hudi.org.eclipse.jetty.server.Server.handle(Server.java:516)
at
org.apache.hudi.org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:388)
at
org.apache.hudi.org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:633)
at
org.apache.hudi.org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:380)
at
org.apache.hudi.org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:277)
at
org.apache.hudi.org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311)
at
org.apache.hudi.org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:105)
at
org.apache.hudi.org.eclipse.jetty.io.ChannelEndPoint$1.run(ChannelEndPoint.java:104)
at
org.apache.hudi.org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:883)
at
org.apache.hudi.org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1034)
at java.lang.Thread.run(Thread.java:750)
Caused by:
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.conn.ConnectionPoolTimeoutException:
Timeout waiting for connection from pool
at
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.impl.conn.PoolingHttpClientConnectionManager.leaseConnection(PoolingHttpClientConnectionManager.java:314)
at
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.impl.conn.PoolingHttpClientConnectionManager$1.get(PoolingHttpClientConnectionManager.java:280)
at sun.reflect.GeneratedMethodAccessor16.invoke(Unknown Source)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.conn.ClientConnectionRequestFactory$Handler.invoke(ClientConnectionRequestFactory.java:70)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.conn.$Proxy47.get(Unknown
Source)
at
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:190)
at
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:186)
at
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185)
at
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:83)
at
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:56)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.apache.client.impl.SdkHttpClient.execute(SdkHttpClient.java:72)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeOneRequest(AmazonHttpClient.java:1343)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1154)
... 93 more
22/08/11 10:16:46 INFO AbstractHoodieLogRecordReader: Scanning log file
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.50_1-0-1',
fileLen=-1}
22/08/11 10:16:56 INFO GlobalS3Executor: ReadTimeout File:
articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.50_1-0-1;
Range: [14, 104]
Use default timeout configuration to retry for read timeout {}
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.SdkClientException: Unable
to execute HTTP request: Timeout waiting for connection from pool
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleRetryableException(AmazonHttpClient.java:1216)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1162)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.doExecute(AmazonHttpClient.java:811)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeWithTimer(AmazonHttpClient.java:779)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.execute(AmazonHttpClient.java:753)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.access$500(AmazonHttpClient.java:713)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutionBuilderImpl.execute(AmazonHttpClient.java:695)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:559)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:539)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:5453)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:5400)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.services.s3.AmazonS3Client.getObject(AmazonS3Client.java:1524)
at
com.amazon.ws.emr.hadoop.fs.s3.lite.call.GetObjectCall.perform(GetObjectCall.java:35)
at
com.amazon.ws.emr.hadoop.fs.s3.lite.call.GetObjectCall.perform(GetObjectCall.java:13)
at
com.amazon.ws.emr.hadoop.fs.s3.lite.executor.GlobalS3Executor.execute(GlobalS3Executor.java:136)
at
com.amazon.ws.emr.hadoop.fs.s3.lite.AmazonS3LiteClient.invoke(AmazonS3LiteClient.java:191)
at
com.amazon.ws.emr.hadoop.fs.s3.lite.AmazonS3LiteClient.getObject(AmazonS3LiteClient.java:102)
at
com.amazon.ws.emr.hadoop.fs.s3.GetObjectInputStreamWithInfoFactory.create(GetObjectInputStreamWithInfoFactory.java:63)
at
com.amazon.ws.emr.hadoop.fs.s3.S3FSInputStream.open(S3FSInputStream.java:200)
at
com.amazon.ws.emr.hadoop.fs.s3.S3FSInputStream.retrieveInputStreamWithInfo(S3FSInputStream.java:391)
at
com.amazon.ws.emr.hadoop.fs.s3.S3FSInputStream.reopenStream(S3FSInputStream.java:378)
at
com.amazon.ws.emr.hadoop.fs.s3.S3FSInputStream.seekStream(S3FSInputStream.java:451)
at
com.amazon.ws.emr.hadoop.fs.s3.S3FSInputStream.read(S3FSInputStream.java:255)
at java.io.BufferedInputStream.fill(BufferedInputStream.java:246)
at java.io.BufferedInputStream.read(BufferedInputStream.java:265)
at java.io.FilterInputStream.read(FilterInputStream.java:83)
at java.io.DataInputStream.readInt(DataInputStream.java:387)
at
org.apache.hudi.common.table.log.HoodieLogFileReader.readVersion(HoodieLogFileReader.java:360)
at
org.apache.hudi.common.table.log.HoodieLogFileReader.readBlock(HoodieLogFileReader.java:170)
at
org.apache.hudi.common.table.log.HoodieLogFileReader.next(HoodieLogFileReader.java:387)
at
org.apache.hudi.common.table.log.HoodieLogFormatReader.next(HoodieLogFormatReader.java:123)
at
org.apache.hudi.common.table.log.AbstractHoodieLogRecordReader.scanInternal(AbstractHoodieLogRecordReader.java:229)
at
org.apache.hudi.common.table.log.AbstractHoodieLogRecordReader.scan(AbstractHoodieLogRecordReader.java:192)
at
org.apache.hudi.common.table.log.HoodieMergedLogRecordScanner.performScan(HoodieMergedLogRecordScanner.java:110)
at
org.apache.hudi.common.table.log.HoodieMergedLogRecordScanner.<init>(HoodieMergedLogRecordScanner.java:103)
at
org.apache.hudi.metadata.HoodieMetadataMergedLogRecordReader.<init>(HoodieMetadataMergedLogRecordReader.java:63)
at
org.apache.hudi.metadata.HoodieMetadataMergedLogRecordReader.<init>(HoodieMetadataMergedLogRecordReader.java:51)
at
org.apache.hudi.metadata.HoodieMetadataMergedLogRecordReader$Builder.build(HoodieMetadataMergedLogRecordReader.java:230)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.getLogRecordScanner(HoodieBackedTableMetadata.java:499)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.getLogRecordScanner(HoodieBackedTableMetadata.java:461)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.openReaders(HoodieBackedTableMetadata.java:407)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.lambda$getOrCreateReaders$10(HoodieBackedTableMetadata.java:393)
at
java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.getOrCreateReaders(HoodieBackedTableMetadata.java:393)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.lambda$getRecordsByKeys$0(HoodieBackedTableMetadata.java:202)
at java.util.HashMap.forEach(HashMap.java:1290)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.getRecordsByKeys(HoodieBackedTableMetadata.java:200)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.getRecordByKey(HoodieBackedTableMetadata.java:140)
at
org.apache.hudi.metadata.BaseTableMetadata.fetchAllFilesInPartition(BaseTableMetadata.java:312)
at
org.apache.hudi.metadata.BaseTableMetadata.getAllFilesInPartition(BaseTableMetadata.java:135)
at
org.apache.hudi.metadata.HoodieMetadataFileSystemView.listPartition(HoodieMetadataFileSystemView.java:66)
at
org.apache.hudi.common.table.view.AbstractTableFileSystemView.lambda$ensurePartitionLoadedCorrectly$9(AbstractTableFileSystemView.java:304)
at
java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660)
at
org.apache.hudi.common.table.view.AbstractTableFileSystemView.ensurePartitionLoadedCorrectly(AbstractTableFileSystemView.java:295)
at
org.apache.hudi.common.table.view.AbstractTableFileSystemView.getLatestBaseFilesBeforeOrOn(AbstractTableFileSystemView.java:502)
at
org.apache.hudi.timeline.service.handlers.BaseFileHandler.getLatestDataFilesBeforeOrOn(BaseFileHandler.java:60)
at
org.apache.hudi.timeline.service.RequestHandler.lambda$registerDataFilesAPI$6(RequestHandler.java:272)
at
org.apache.hudi.timeline.service.RequestHandler$ViewHandler.handle(RequestHandler.java:501)
at
io.javalin.core.security.SecurityUtil.noopAccessManager(SecurityUtil.kt:23)
at
io.javalin.http.JavalinServlet$addHandler$protectedHandler$1.handle(JavalinServlet.kt:128)
at
io.javalin.http.JavalinServlet$service$2$1.invoke(JavalinServlet.kt:45)
at
io.javalin.http.JavalinServlet$service$2$1.invoke(JavalinServlet.kt:24)
at
io.javalin.http.JavalinServlet$service$1.invoke(JavalinServlet.kt:136)
at io.javalin.http.JavalinServlet$service$2.invoke(JavalinServlet.kt:40)
at io.javalin.http.JavalinServlet.service(JavalinServlet.kt:81)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:790)
at io.javalin.websocket.JavalinWsServlet.service(JavalinWsServlet.kt:51)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:790)
at
org.apache.hudi.org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:799)
at
org.apache.hudi.org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:550)
at
org.apache.hudi.org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
at
org.apache.hudi.org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1624)
at
org.apache.hudi.org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
at
io.javalin.core.JavalinServer$start$wsAndHttpHandler$1.doHandle(JavalinServer.kt:49)
at
org.apache.hudi.org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188)
at
org.apache.hudi.org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:501)
at
org.apache.hudi.org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1594)
at
org.apache.hudi.org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186)
at
org.apache.hudi.org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1349)
at
org.apache.hudi.org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
at
org.apache.hudi.org.eclipse.jetty.server.handler.StatisticsHandler.handle(StatisticsHandler.java:179)
at
org.apache.hudi.org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)
at
org.apache.hudi.org.eclipse.jetty.server.Server.handle(Server.java:516)
at
org.apache.hudi.org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:388)
at
org.apache.hudi.org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:633)
at
org.apache.hudi.org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:380)
at
org.apache.hudi.org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:277)
at
org.apache.hudi.org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311)
at
org.apache.hudi.org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:105)
at
org.apache.hudi.org.eclipse.jetty.io.ChannelEndPoint$1.run(ChannelEndPoint.java:104)
at
org.apache.hudi.org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:883)
at
org.apache.hudi.org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1034)
at java.lang.Thread.run(Thread.java:750)
Caused by:
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.conn.ConnectionPoolTimeoutException:
Timeout waiting for connection from pool
at
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.impl.conn.PoolingHttpClientConnectionManager.leaseConnection(PoolingHttpClientConnectionManager.java:314)
at
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.impl.conn.PoolingHttpClientConnectionManager$1.get(PoolingHttpClientConnectionManager.java:280)
at sun.reflect.GeneratedMethodAccessor16.invoke(Unknown Source)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.conn.ClientConnectionRequestFactory$Handler.invoke(ClientConnectionRequestFactory.java:70)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.conn.$Proxy47.get(Unknown
Source)
at
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:190)
at
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:186)
at
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185)
at
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:83)
at
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:56)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.apache.client.impl.SdkHttpClient.execute(SdkHttpClient.java:72)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeOneRequest(AmazonHttpClient.java:1343)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1154)
... 91 more
22/08/11 10:16:56 INFO AbstractHoodieLogRecordReader: Reading a command
block from file
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.50_1-0-1
22/08/11 10:16:56 WARN AbstractHoodieLogRecordReader: TargetInstantTime
20220810112003465 invalid or extra rollback command block in
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.50_1-0-1
22/08/11 10:16:56 INFO AbstractHoodieLogRecordReader: Number of applied
rollback blocks 0
22/08/11 10:16:56 INFO S3NativeFileSystem: Opening
's3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.51_1-0-1'
for reading
22/08/11 10:16:56 INFO HoodieLogFormatReader: Moving to the next reader for
logfile
HoodieLogFile{pathStr='s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.51_1-0-1',
fileLen=-1}
22/08/11 10:16:59 INFO MultipartUploadOutputStream: close closed:false
s3://prod-signal-articles-store/articles_hudi_copy_on_write/.hoodie/.heartbeat/20220811101559309
22/08/11 10:17:06 INFO GlobalS3Executor: ReadTimeout File:
articles_hudi_copy_on_write/.hoodie/metadata/files/.files-0000_20220809191455283.log.51_1-0-1;
Range: null
Use default timeout configuration to retry for read timeout {}
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.SdkClientException: Unable
to execute HTTP request: Timeout waiting for connection from pool
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleRetryableException(AmazonHttpClient.java:1216)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1162)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.doExecute(AmazonHttpClient.java:811)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeWithTimer(AmazonHttpClient.java:779)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.execute(AmazonHttpClient.java:753)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.access$500(AmazonHttpClient.java:713)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutionBuilderImpl.execute(AmazonHttpClient.java:695)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:559)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:539)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:5453)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:5400)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.services.s3.AmazonS3Client.getObject(AmazonS3Client.java:1524)
at
com.amazon.ws.emr.hadoop.fs.s3.lite.call.GetObjectCall.perform(GetObjectCall.java:35)
at
com.amazon.ws.emr.hadoop.fs.s3.lite.call.GetObjectCall.perform(GetObjectCall.java:13)
at
com.amazon.ws.emr.hadoop.fs.s3.lite.executor.GlobalS3Executor.execute(GlobalS3Executor.java:136)
at
com.amazon.ws.emr.hadoop.fs.s3.lite.AmazonS3LiteClient.invoke(AmazonS3LiteClient.java:191)
at
com.amazon.ws.emr.hadoop.fs.s3.lite.AmazonS3LiteClient.getObject(AmazonS3LiteClient.java:102)
at
com.amazon.ws.emr.hadoop.fs.s3.GetObjectInputStreamWithInfoFactory.create(GetObjectInputStreamWithInfoFactory.java:63)
at
com.amazon.ws.emr.hadoop.fs.s3.S3FSInputStream.open(S3FSInputStream.java:200)
at
com.amazon.ws.emr.hadoop.fs.s3.S3FSInputStream.retrieveInputStreamWithInfo(S3FSInputStream.java:391)
at
com.amazon.ws.emr.hadoop.fs.s3.S3FSInputStream.reopenStream(S3FSInputStream.java:378)
at
com.amazon.ws.emr.hadoop.fs.s3.S3FSInputStream.seekStream(S3FSInputStream.java:451)
at
com.amazon.ws.emr.hadoop.fs.s3.S3FSInputStream.read(S3FSInputStream.java:255)
at java.io.BufferedInputStream.fill(BufferedInputStream.java:246)
at java.io.BufferedInputStream.read1(BufferedInputStream.java:286)
at java.io.BufferedInputStream.read(BufferedInputStream.java:345)
at java.io.DataInputStream.read(DataInputStream.java:149)
at java.io.DataInputStream.readFully(DataInputStream.java:195)
at
org.apache.hudi.common.table.log.HoodieLogFileReader.hasNextMagic(HoodieLogFileReader.java:379)
at
org.apache.hudi.common.table.log.HoodieLogFileReader.readMagic(HoodieLogFileReader.java:365)
at
org.apache.hudi.common.table.log.HoodieLogFileReader.hasNext(HoodieLogFileReader.java:350)
at
org.apache.hudi.common.table.log.HoodieLogFormatReader.hasNext(HoodieLogFormatReader.java:99)
at
org.apache.hudi.common.table.log.HoodieLogFormatReader.hasNext(HoodieLogFormatReader.java:116)
at
org.apache.hudi.common.table.log.AbstractHoodieLogRecordReader.scanInternal(AbstractHoodieLogRecordReader.java:223)
at
org.apache.hudi.common.table.log.AbstractHoodieLogRecordReader.scan(AbstractHoodieLogRecordReader.java:192)
at
org.apache.hudi.common.table.log.HoodieMergedLogRecordScanner.performScan(HoodieMergedLogRecordScanner.java:110)
at
org.apache.hudi.common.table.log.HoodieMergedLogRecordScanner.<init>(HoodieMergedLogRecordScanner.java:103)
at
org.apache.hudi.metadata.HoodieMetadataMergedLogRecordReader.<init>(HoodieMetadataMergedLogRecordReader.java:63)
at
org.apache.hudi.metadata.HoodieMetadataMergedLogRecordReader.<init>(HoodieMetadataMergedLogRecordReader.java:51)
at
org.apache.hudi.metadata.HoodieMetadataMergedLogRecordReader$Builder.build(HoodieMetadataMergedLogRecordReader.java:230)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.getLogRecordScanner(HoodieBackedTableMetadata.java:499)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.getLogRecordScanner(HoodieBackedTableMetadata.java:461)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.openReaders(HoodieBackedTableMetadata.java:407)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.lambda$getOrCreateReaders$10(HoodieBackedTableMetadata.java:393)
at
java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.getOrCreateReaders(HoodieBackedTableMetadata.java:393)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.lambda$getRecordsByKeys$0(HoodieBackedTableMetadata.java:202)
at java.util.HashMap.forEach(HashMap.java:1290)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.getRecordsByKeys(HoodieBackedTableMetadata.java:200)
at
org.apache.hudi.metadata.HoodieBackedTableMetadata.getRecordByKey(HoodieBackedTableMetadata.java:140)
at
org.apache.hudi.metadata.BaseTableMetadata.fetchAllFilesInPartition(BaseTableMetadata.java:312)
at
org.apache.hudi.metadata.BaseTableMetadata.getAllFilesInPartition(BaseTableMetadata.java:135)
at
org.apache.hudi.metadata.HoodieMetadataFileSystemView.listPartition(HoodieMetadataFileSystemView.java:66)
at
org.apache.hudi.common.table.view.AbstractTableFileSystemView.lambda$ensurePartitionLoadedCorrectly$9(AbstractTableFileSystemView.java:304)
at
java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660)
at
org.apache.hudi.common.table.view.AbstractTableFileSystemView.ensurePartitionLoadedCorrectly(AbstractTableFileSystemView.java:295)
at
org.apache.hudi.common.table.view.AbstractTableFileSystemView.getLatestBaseFilesBeforeOrOn(AbstractTableFileSystemView.java:502)
at
org.apache.hudi.timeline.service.handlers.BaseFileHandler.getLatestDataFilesBeforeOrOn(BaseFileHandler.java:60)
at
org.apache.hudi.timeline.service.RequestHandler.lambda$registerDataFilesAPI$6(RequestHandler.java:272)
at
org.apache.hudi.timeline.service.RequestHandler$ViewHandler.handle(RequestHandler.java:501)
at
io.javalin.core.security.SecurityUtil.noopAccessManager(SecurityUtil.kt:23)
at
io.javalin.http.JavalinServlet$addHandler$protectedHandler$1.handle(JavalinServlet.kt:128)
at
io.javalin.http.JavalinServlet$service$2$1.invoke(JavalinServlet.kt:45)
at
io.javalin.http.JavalinServlet$service$2$1.invoke(JavalinServlet.kt:24)
at
io.javalin.http.JavalinServlet$service$1.invoke(JavalinServlet.kt:136)
at io.javalin.http.JavalinServlet$service$2.invoke(JavalinServlet.kt:40)
at io.javalin.http.JavalinServlet.service(JavalinServlet.kt:81)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:790)
at io.javalin.websocket.JavalinWsServlet.service(JavalinWsServlet.kt:51)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:790)
at
org.apache.hudi.org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:799)
at
org.apache.hudi.org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:550)
at
org.apache.hudi.org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
at
org.apache.hudi.org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1624)
at
org.apache.hudi.org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
at
io.javalin.core.JavalinServer$start$wsAndHttpHandler$1.doHandle(JavalinServer.kt:49)
at
org.apache.hudi.org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188)
at
org.apache.hudi.org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:501)
at
org.apache.hudi.org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1594)
at
org.apache.hudi.org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186)
at
org.apache.hudi.org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1349)
at
org.apache.hudi.org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
at
org.apache.hudi.org.eclipse.jetty.server.handler.StatisticsHandler.handle(StatisticsHandler.java:179)
at
org.apache.hudi.org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)
at
org.apache.hudi.org.eclipse.jetty.server.Server.handle(Server.java:516)
at
org.apache.hudi.org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:388)
at
org.apache.hudi.org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:633)
at
org.apache.hudi.org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:380)
at
org.apache.hudi.org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:277)
at
org.apache.hudi.org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311)
at
org.apache.hudi.org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:105)
at
org.apache.hudi.org.eclipse.jetty.io.ChannelEndPoint$1.run(ChannelEndPoint.java:104)
at
org.apache.hudi.org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:883)
at
org.apache.hudi.org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1034)
at java.lang.Thread.run(Thread.java:750)
Caused by:
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.conn.ConnectionPoolTimeoutException:
Timeout waiting for connection from pool
at
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.impl.conn.PoolingHttpClientConnectionManager.leaseConnection(PoolingHttpClientConnectionManager.java:314)
at
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.impl.conn.PoolingHttpClientConnectionManager$1.get(PoolingHttpClientConnectionManager.java:280)
at sun.reflect.GeneratedMethodAccessor16.invoke(Unknown Source)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.conn.ClientConnectionRequestFactory$Handler.invoke(ClientConnectionRequestFactory.java:70)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.conn.$Proxy47.get(Unknown
Source)
at
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:190)
at
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:186)
at
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185)
at
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:83)
at
com.amazon.ws.emr.hadoop.fs.shaded.org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:56)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.apache.client.impl.SdkHttpClient.execute(SdkHttpClient.java:72)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeOneRequest(AmazonHttpClient.java:1343)
at
com.amazon.ws.emr.hadoop.fs.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1154)
... 93 more
```
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
