Apache Beam IllegalMutationException - PullRequest
       50

Apache Beam IllegalMutationException

0 голосов
/ 05 марта 2019

Я запускаю этот пример кода из Google, тестирующего входные данные Spanner в Dataflow.Когда я пытаюсь получить доступ к столбцу по имени, я получаю IllegalMutationException.Я не пытаюсь изменить ввод (это я знаю по крайней мере).Если я удаляю println, он работает просто отлично.Это также работает, если я скажу row.getString("fieldName").Есть идеи, почему это происходит?

  public static class EstimateStructSizeFn extends DoFn<Struct, Long> {

@ProcessElement
public void processElement(ProcessContext c) throws Exception {
  Struct row = c.element();
  System.out.println(row.getString("action"));
...