Uploaded image for project: 'Apache Hudi'
  1. Apache Hudi
  2. HUDI-5850

Timestamp(6) long overflow

    XMLWordPrintableJSON

Details

    Description

      When timestamp(6) field  greater than "2262-04-11 23:47:16" , then throw  following exception.

      
      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] 

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              sandyfog sandy du
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: