Advertisement
Guest User

Untitled

a guest
Feb 12th, 2018
320
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 1.89 KB | None | 0 0
  1. ParDo requires its input to use KvCoder in order to use state and timers.
  2. java.lang.IllegalArgumentException: ParDo requires its input to use KvCoder in order to use state and timers.
  3.     at org.apache.beam.sdk.repackaged.com.google.common.base.Preconditions.checkArgument(Preconditions.java:383)
  4.     at org.apache.beam.sdk.transforms.ParDo.validateStateApplicableForInput(ParDo.java:463)
  5.     at org.apache.beam.sdk.transforms.ParDo.access$300(ParDo.java:423)
  6.     at org.apache.beam.sdk.transforms.ParDo$MultiOutput.expand(ParDo.java:768)
  7.     at org.apache.beam.sdk.transforms.ParDo$MultiOutput.expand(ParDo.java:703)
  8.     at org.apache.beam.sdk.Pipeline.applyInternal(Pipeline.java:525)
  9.     at org.apache.beam.sdk.Pipeline.applyTransform(Pipeline.java:460)
  10.     at org.apache.beam.sdk.values.PCollection.apply(PCollection.java:284)
  11.     at org.apache.beam.sdk.transforms.ParDo$SingleOutput.expand(ParDo.java:644)
  12.     at org.apache.beam.sdk.transforms.ParDo$SingleOutput.expand(ParDo.java:582)
  13.     at org.apache.beam.sdk.Pipeline.applyInternal(Pipeline.java:525)
  14.     at org.apache.beam.sdk.Pipeline.applyTransform(Pipeline.java:479)
  15.     at org.apache.beam.sdk.values.PCollection.apply(PCollection.java:297)
  16.     at com.spotify.scio.values.PCollectionWrapper.applyInternal(PCollectionWrapper.scala:44)
  17.     at com.spotify.scio.values.PCollectionWrapper.applyInternal$(PCollectionWrapper.scala:42)
  18.     at com.spotify.scio.values.SCollectionImpl.applyInternal(SCollection.scala:1268)
  19.     at com.spotify.scio.values.PCollectionWrapper.pApply(PCollectionWrapper.scala:54)
  20.     at com.spotify.scio.values.PCollectionWrapper.pApply$(PCollectionWrapper.scala:46)
  21.     at com.spotify.scio.values.SCollectionImpl.pApply(SCollection.scala:1268)
  22.     at com.spotify.scio.values.SCollection.applyTransform(SCollection.scala:134)
  23.     at com.spotify.scio.values.SCollection.applyTransform$(SCollection.scala:132)
  24.     at com.spotify.scio.values.SCollectionImpl.applyTransform(SCollection.scala:1268)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement