You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Vishnu I P <vi...@gmail.com> on 2025/03/25 07:57:51 UTC
Flink job jar file runs with java command not with flink cluster
Hello,
This is my first message to the Flink mailing list.
I previously had a Flink job jar that worked flawlessly on my old Debian
machine about six months ago. Recently, I migrated to a new Debian PC and
deployed the same jar file using the same version of Flink. Although the
job appears to run in the Flink dashboard without any errors, it fails to
write data to the PostgreSQL database, but the job itself is not stopping.
Notably, when I run the jar file directly using the Java command on the new
PC, it works as expected. I also updated to the latest Flink version and
rebuilt the jar with the updated dependencies, but the issue persists.
Has anyone encountered a similar problem or have suggestions on what might
be causing this discrepancy when running via the Flink cluster?
Thank you for your assistance.
Best regards,
Vishnu
Re: Flink job jar file runs with java command not with flink cluster
Posted by Vishnu I P <vi...@gmail.com>.
i used flink 1.20.0 and 1.20.1
I will try with 2.0.0 and update
From Vishnu I P
On Tue, Mar 25, 2025 at 1:30 PM Vishnu I P <vi...@gmail.com> wrote:
> the purpose of the flink job is to read data from a pulsar topic and put
> that into a postgresql db
>
> From Vishnu I P
>
>
> On Tue, Mar 25, 2025 at 1:27 PM Vishnu I P <vi...@gmail.com> wrote:
>
>> Hello,
>>
>> This is my first message to the Flink mailing list.
>>
>> I previously had a Flink job jar that worked flawlessly on my old Debian
>> machine about six months ago. Recently, I migrated to a new Debian PC and
>> deployed the same jar file using the same version of Flink. Although the
>> job appears to run in the Flink dashboard without any errors, it fails to
>> write data to the PostgreSQL database, but the job itself is not stopping.
>>
>> Notably, when I run the jar file directly using the Java command on the
>> new PC, it works as expected. I also updated to the latest Flink version
>> and rebuilt the jar with the updated dependencies, but the issue persists.
>>
>> Has anyone encountered a similar problem or have suggestions on what
>> might be causing this discrepancy when running via the Flink cluster?
>>
>> Thank you for your assistance.
>>
>> Best regards,
>> Vishnu
>>
>>
Re: Flink job jar file runs with java command not with flink cluster
Posted by Vishnu I P <vi...@gmail.com>.
the purpose of the flink job is to read data from a pulsar topic and put
that into a postgresql db
From Vishnu I P
On Tue, Mar 25, 2025 at 1:27 PM Vishnu I P <vi...@gmail.com> wrote:
> Hello,
>
> This is my first message to the Flink mailing list.
>
> I previously had a Flink job jar that worked flawlessly on my old Debian
> machine about six months ago. Recently, I migrated to a new Debian PC and
> deployed the same jar file using the same version of Flink. Although the
> job appears to run in the Flink dashboard without any errors, it fails to
> write data to the PostgreSQL database, but the job itself is not stopping.
>
> Notably, when I run the jar file directly using the Java command on the
> new PC, it works as expected. I also updated to the latest Flink version
> and rebuilt the jar with the updated dependencies, but the issue persists.
>
> Has anyone encountered a similar problem or have suggestions on what might
> be causing this discrepancy when running via the Flink cluster?
>
> Thank you for your assistance.
>
> Best regards,
> Vishnu
>
>