Ошибка при записи в BigTable с использованием облачного потока данных - PullRequest
Новая
       19

Ошибка при записи в BigTable с использованием облачного потока данных

1 голос
/ 13 марта 2019

Я получаю следующую ошибку при записи большого количества записей в BigTable. 

java.lang.NullPointerException
    at java.util.TreeMap.getEntry(TreeMap.java:347)
    at java.util.TreeMap.get(TreeMap.java:278)
    at com.google.cloud.bigtable.beam.AbstractCloudBigtableTableDoFn.logRetriesExhaustedWithDetailsException(AbstractCloudBigtableTableDoFn.java:58)
    at com.google.cloud.bigtable.beam.AbstractCloudBigtableTableDoFn.logExceptions(AbstractCloudBigtableTableDoFn.java:107)
    at com.google.cloud.bigtable.beam.CloudBigtableIO$BufferedMutatorDoFn$1.onException(CloudBigtableIO.java:840)
    at com.google.cloud.bigtable.hbase.BigtableBufferedMutator.handleExceptions(BigtableBufferedMutator.java:146)
    at com.google.cloud.bigtable.hbase.BigtableBufferedMutator.mutate(BigtableBufferedMutator.java:135)
    at com.google.cloud.bigtable.beam.CloudBigtableIO$CloudBigtableSingleTableBufferedWriteFn.processElement(CloudBigtableIO.java:877)

Я думаю, что это как-то связано с реализацией класса TreeMap.Это происходит только тогда, когда я увеличиваю количество записей, которые читаются из GCS.Как мне это решить?

...