Re: Python based User defined function on Flink 1.19.1

2025-05-14 Thread George
gt;> On Wed, May 14, 2025 at 11:18 AM Nikola Milutinovic < >> n.milutino...@levi9.com> wrote: >> >> Hi George. >> >> >> >> We saw the same problem, running Apache Flink 1.19 and 1.20 images. The >> cause is that Flink image provides a JRE and yo

Re: Python based User defined function on Flink 1.19.1

2025-05-14 Thread George
*Date: *Wednesday, May 14, 2025 at 1:09 PM > *To: *Nikola Milutinovic , user@flink.apache.org > > *Subject: *Re: Python based User defined function on Flink 1.19.1 > > Hi there > > > > Got it build :) > > > > I installed python3-pip in addition to the java - headless

Re: Python based User defined function on Flink 1.19.1

2025-05-14 Thread Nikola Milutinovic
m: George mailto:george...@gmail.com>> Date: Wednesday, May 14, 2025 at 10:23 AM To: user@flink.apache.org<mailto:user@flink.apache.org> mailto:user@flink.apache.org>> Subject: Python based User defined function on Flink 1.19.1 Hi all My Flink Jobmanager and Taskmanager is bas

Re: Python based User defined function on Flink 1.19.1

2025-05-14 Thread George
17-jdk-headless \ >> >> ENV JAVA_HOME=/usr/lib/jvm/java-17-openjdk-arm64 >> >> >> >> After PIP install our requirement.txt, we do cleanup. >> >> >> >> # Cleanup JDK >> >> RUN apt-get remove -y openjdk-17-jdk-headless >> >

Re: Python based User defined function on Flink 1.19.1

2025-05-14 Thread George
> > > # Cleanup JDK > > RUN apt-get remove -y openjdk-17-jdk-headless > > ENV JAVA_HOME=/opt/java/openjdk > > > > Hope it helps. > > > > Nix. > > > > *From: *George > *Date: *Wednesday, May 14, 2025 at 10:23 AM > *To: *user@fl

Re: Python based User defined function on Flink 1.19.1

2025-05-14 Thread Nikola Milutinovic
PIP install our requirement.txt, we do cleanup. # Cleanup JDK RUN apt-get remove -y openjdk-17-jdk-headless ENV JAVA_HOME=/opt/java/openjdk Hope it helps. Nix. From: George Date: Wednesday, May 14, 2025 at 10:23 AM To: user@flink.apache.org Subject: Python based User defined function on Fli

Python based User defined function on Flink 1.19.1

2025-05-14 Thread George
Hi all My Flink Jobmanager and Taskmanager is based on the community 1.19.1 on the Java 17 image. I've extended this by installing Python 3.11 and python3.11-venv. created my venv environment, activated it, when trying to pip install apache-flink. I first got an error saying /opt/java/openjdk/in