Hello!
i created this example:
https://github.com/j1cs/coder-error-beam
and the issue you told me:
https://github.com/apache/beam/issues/26003
Juan Cuzmar.
--- Original Message ---
On Monday, March 27th, 2023 at 10:58 AM, Alexey Romanenko
wrote:
> Hmm, it worked fine for me on a
Hmm, it worked fine for me on a primitive pipeline and default AvroCode for
simple InboundData implementation.
Could you create a GitHub issue for that
(https://github.com/apache/beam/issues)? It would be very helpful to provide
the steps there how to reproduce this issue.
Thanks,
Alexey
>
unfortunately didn't work.
I added the @DefaultCoder as you told me and i removed the .withCoder from my
JdbcIO pipe and showed the same error:
java.lang.IllegalStateException: Unable to infer a coder for JdbcIO.readAll()
transform. Provide a coder via withCoder, or ensure that one can be
Well, perhaps it’s a bug (I’ll try to check it on my side later).
Can you try to annotate InboundData class with “@DefaultCoder(AvroCoder.class)”
for example and see if it will work?
> On 23 Mar 2023, at 15:13, Juan Cuzmar wrote:
>
> Alexey yes! here it is:
>
>
>import lombok.*;
>
Alexey yes! here it is:
import lombok.*;
import lombok.extern.jackson.Jacksonized;
import java.io.Serializable;
import java.util.List;
import java.util.Map;
@Jacksonized
@Builder
@Getter
@Value
@EqualsAndHashCode
@ToString
public class
Could you share a class declaration of your InboundData class? Is it just a
POJO?
—
Alexey
> On 23 Mar 2023, at 08:16, Juan Cuzmar wrote:
>
> Hello all,
>
> I hope this message finds you well. I am currently working with Apache Beam's
> JdbcIO and need some guidance regarding setting a
Hello all,
I hope this message finds you well. I am currently working with Apache Beam's
JdbcIO and need some guidance regarding setting a coder for the input data
without resorting to the deprecated withCoder method. I've been trying to
resolve this issue and would appreciate any insights or
