Hi Cham,
Complete stack trace can be accessed at
https://gist.github.com/amit5148/fcf3eea068020283b2c1ef04b57d493b
Regards,
Amit
On 2021/03/04 17:15:06, Chamikara Jayalath <chamik...@google.com> wrote:
> I haven't been able to reproduce this. Do you have a stack trace ?
>
> Thanks,
> Cham
>
> On Thu, Mar 4, 2021 at 8:54 AM Amit Saraswat <amit5...@gmail.com> wrote:
>
> > Hi Cham,
> >
> > I am also getting the same error while using apache-beam==2.28.0
> >
> > Regards,
> > Amit
> >
> > On 2021/02/24 17:02:06, Chamikara Jayalath <chamik...@google.com> wrote:
> > > Which version of Beam are you using ? Also are you using
> > > notebooks/InteractiveRunner by any chance ?
> > >
> > > Thanks,
> > > Cham
> > >
> > > On Wed, Feb 24, 2021 at 8:18 AM Carilli Giuseppe <
> > > giuseppe.cari...@expleoitalia.com> wrote:
> > >
> > > > Hello,
> > > >
> > > >
> > > >
> > > > I’m receiving the error *java.lang.IllegalArgumentException: Unknown
> > > > Coder URN beam:coder:pickled_python:v1* when running
> > > > apache_beam.io.kafka.WriteToKafka.
> > > >
> > > >
> > > >
> > > > This is the transformation that gives me the error (The implementation
> > > > should be correct):
> > > >
> > > >
> > > >
> > > > from apache_beam.io.kafka import WriteToKafka
> > > >
> > > >
> > > >
> > > > …
> > > >
> > > >
> > > >
> > > > (my_pcollection
> > > >
> > > > | 'Write to Kafka topic' >> WriteToKafka(
> > > > producer_config={"bootstrap.servers": "localhost:9092"},
> > > > topic="my_topic",
> > > >
> > key_serializer="org.apache.kafka.common.serialization.ByteArraySerializer",
> > > >
> > value_serializer="org.apache.kafka.common.serialization.ByteArraySerializer",
> > > > ))
> > > >
> > > >
> > > >
> > > > Can you please give me support on this?
> > > >
> > > >
> > > >
> > > > Thank you.
> > > >
> > >
> >
>
