Ananth
From: Guowei Ma mailto:guowei@gmail.com>>
Date: Monday, 21 February 2022 at 8:42 pm
To: Ananth Gundabattula
mailto:agundabatt...@darwinium.com>>
Cc: user@flink.apache.org<mailto:user@flink.apache.org>
mailto:user@flink.apache.org>>,
affei...@gmail.com<mailto:
gt;
>> Cheers,
>> Yufei.
>>
>> On Mon, Feb 21, 2022 at 5:47 PM Ananth Gundabattula <
>> agundabatt...@darwinium.com> wrote:
>>
>>> Thanks Guowei.
>>>
>>>
>>>
>>> A small correction in the telnet result command below. I had
tula
> *Cc: *user@flink.apache.org , affei...@gmail.com <
> affei...@gmail.com>
> *Subject: *Re: Pulsar connector 2.9.1 failing job submission in
> standalone.
>
> Thanks Ananth for your clarification.But I am not an expert on Pulsar.
>
> I would cc the author of the connect
2022 at 8:42 pm
To: Ananth Gundabattula
Cc: user@flink.apache.org , affei...@gmail.com
Subject: Re: Pulsar connector 2.9.1 failing job submission in standalone.
Thanks Ananth for your clarification.But I am not an expert on Pulsar.
I would cc the author of the connector to have a look. Would Yufei
> both 2.8.0 pulsar and 2.9.1 pulsar)
>
>
>
> Regards,
>
> Ananth
>
>
>
> *From: *Guowei Ma
> *Date: *Monday, 21 February 2022 at 4:57 pm
> *To: *Ananth Gundabattula
> *Cc: *user@flink.apache.org
> *Subject: *Re: Pulsar connector 2.9.1 failing job submissi
2022 at 4:57 pm
To: Ananth Gundabattula
Cc: user@flink.apache.org
Subject: Re: Pulsar connector 2.9.1 failing job submission in standalone.
Hi, Ansanth
I don't see any error logs on the server side, so it's hard to tell what the
specific problem is. From the current log, there are two
Hi, Ansanth
I don't see any error logs on the server side, so it's hard to tell what
the specific problem is. From the current log, there are two things to try
first:
1. From the client's log, it is a 5-minute timeout, so you can telnet
127.0.0.1:8086 to see if there is a problem with the local n
Hello All,
I have a Pyflink script that needs to read from Pulsar and process the data.
I have done the following to implement a prototype.
1. Since I need Pyflink way to connect to Pulsar , I checked out the code
from master branch as advised in a different thread. (PyFlink Pulsar connecto
