[
https://issues.apache.org/jira/browse/HUDI-5850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated HUDI-5850:
---------------------------------
Labels: pull-request-available (was: )
> Timestamp(6) long overflow
> --------------------------
>
> Key: HUDI-5850
> URL: https://issues.apache.org/jira/browse/HUDI-5850
> Project: Apache Hudi
> Issue Type: Bug
> Components: flink
> Reporter: sandy du
> Priority: Major
> Labels: pull-request-available
> Fix For: 0.14.0
>
>
> When timestamp(6) field greater than "2262-04-11 23:47:16" , then throw
> following exception.
> {code:java}
> java.lang.ArithmeticException: long overflow
> at java.lang.Math.multiplyExact(Math.java:892) ~[?:1.8.0_151]
> at java.time.Instant.nanosUntil(Instant.java:1164) ~[?:1.8.0_151]
> at java.time.Instant.until(Instant.java:1149) ~[?:1.8.0_151]
> at java.time.temporal.ChronoUnit.between(ChronoUnit.java:272)
> ~[?:1.8.0_151]
> at
> org.apache.hudi.util.RowDataToAvroConverters$8.convert(RowDataToAvroConverters.java:179)
> ~[classes/:?]
> at
> org.apache.hudi.util.RowDataToAvroConverters$10.convert(RowDataToAvroConverters.java:239)
> ~[classes/:?]
> at
> org.apache.hudi.util.RowDataToAvroConverters$11.convert(RowDataToAvroConverters.java:270)
> ~[classes/:?]
> at
> org.apache.hudi.util.RowDataToAvroConverters$10.convert(RowDataToAvroConverters.java:239)
> ~[classes/:?]
> at
> org.apache.hudi.sink.transform.RowDataToHoodieFunction.toHoodieRecord(RowDataToHoodieFunction.java:109)
> ~[classes/:?]
> at
> org.apache.hudi.sink.transform.RowDataToHoodieFunction.map(RowDataToHoodieFunction.java:97)
> ~[classes/:?]
> at
> org.apache.hudi.sink.transform.RowDataToHoodieFunction.map(RowDataToHoodieFunction.java:46)
> ~[classes/:?]
> at
> org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:38)
> ~[flink-streaming-java_2.11-1.14.5.jar:1.14.5]
> at
> org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:82)
> ~[flink-streaming-java_2.11-1.14.5.jar:1.14.5]
> at
> org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:57)
> ~[flink-streaming-java_2.11-1.14.5.jar:1.14.5]
> at
> org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:29)
> ~[flink-streaming-java_2.11-1.14.5.jar:1.14.5]
> at
> org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56)
> ~[flink-streaming-java_2.11-1.14.5.jar:1.14.5]
> at
> org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29)
> ~[flink-streaming-java_2.11-1.14.5.jar:1.14.5]
> at
> org.apache.flink.streaming.api.operators.StreamFilter.processElement(StreamFilter.java:39)
> ~[flink-streaming-java_2.11-1.14.5.jar:1.14.5]
> at
> org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:82)
> ~[flink-streaming-java_2.11-1.14.5.jar:1.14.5]
> at
> org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:57)
> ~[flink-streaming-java_2.11-1.14.5.jar:1.14.5]
> at
> org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:29)
> ~[flink-streaming-java_2.11-1.14.5.jar:1.14.5]
> at
> org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56)
> ~[flink-streaming-java_2.11-1.14.5.jar:1.14.5]
> at
> org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29)
> ~[flink-streaming-java_2.11-1.14.5.jar:1.14.5]
> at
> org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualWatermarkContext.processAndCollect(StreamSourceContexts.java:418)
> ~[flink-streaming-java_2.11-1.14.5.jar:1.14.5]
> at
> org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkContext.collect(StreamSourceContexts.java:513)
> ~[flink-streaming-java_2.11-1.14.5.jar:1.14.5]
> at
> org.apache.flink.streaming.api.operators.StreamSourceContexts$SwitchingOnClose.collect(StreamSourceContexts.java:103)
> ~[flink-streaming-java_2.11-1.14.5.jar:1.14.5]
> at
> org.apache.flink.streaming.api.functions.source.InputFormatSourceFunction.run(InputFormatSourceFunction.java:92)
> ~[flink-streaming-java_2.11-1.14.5.jar:1.14.5]
> at
> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110)
> ~[flink-streaming-java_2.11-1.14.5.jar:1.14.5]
> at
> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67)
> ~[flink-streaming-java_2.11-1.14.5.jar:1.14.5] {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
