"java.io.IOException: INTERNAL"异常导致管道失败



我有一个批处理数据流作业,该作业在日志中具有多个java.lang.RuntimeException: unexpected实例。

深入挖掘,我发现有一些明显的例外:

  • java.io.IOException: INTERNAL: Detected non-monotonic keys.
  • java.io.IOException: INTERNAL: Corruption: block checksum
  • java.io.IOException: INTERNAL: Corruption: bad entry in block
  • java.io.IOException: DATA_LOSS: record checksum mismatch

我相信这可能只是一个一次性的错误,但我不知道报告此类问题的首选位置,所以我在这里发布以提高可见性。

作业 ID 为2017-01-26_13_26_59-15900546489513181319

这可能是计算机

处理随机数据的错误的结果,并指示该特定作业运行的不可恢复的故障。 如果问题在多次运行后仍然存在,请参阅 Google 数据流,DATA_LOSS例外,了解潜在的线程问题。