Re: Missing Flink Operator version

[Gyula Fóra]

What you linked is not the list of stable releases but the list of all past
releases.
Only the last 2 minor versions are supported, which are currently 1.3.1 and
1.2.0.

I highly recommend using the latest 1.3.1 release.

Cheers,
Gyula

On Wed, Jan 11, 2023 at 7:31 AM Meghajit Mazumdar <
meghajit.mazum...@gojek.com> wrote:

> Hello team,
>
> It appears that Flink Operator 1.1.0 is removed from the repo index
> https://downloads.apache.org/flink/
>
> However, it is still mentioned as a stable release in the list of
> downloads here
> 
> as well as in the quickstart documentation
> 
>
> Is it on purpose ? If yes, is 1.1.0 deprecated ? If not, how to use it
> then ?
> --
> *Regards,*
> *Meghajit*
>

Missing Flink Operator version

[Meghajit Mazumdar]

Hello team,

It appears that Flink Operator 1.1.0 is removed from the repo index
https://downloads.apache.org/flink/

However, it is still mentioned as a stable release in the list of downloads
here

as well as in the quickstart documentation


Is it on purpose ? If yes, is 1.1.0 deprecated ? If not, how to use it then
?
-- 
*Regards,*
*Meghajit*

[SUMMARY] Flink 1.17 Release Sync 1/10/2023

[Qingsheng Ren]

 Hi devs and users,

I'd like to share some highlights from the release sync on 1/10/2023.

- CI stabilities: owners of blocker issues should have been pinged offline.
- Priorities of the test instabilities: test instabilities are prioritized
as Critical and become blocker as soon as we notice that they are newly
introduced.
- Feature freeze has been extended until *Jan 31, 2023*
- Release sync switches to weekly from now as we are approaching the
feature freeze date. Welcome to join us!
- @Developers please share in the Slack dev channel if your FLIP needs more
people to look into it. It’ll be nice to close all FLIPs within this week
considering the timeline.

There are 3 weeks before the feature freeze on Jan 31, 2023. The next
release meeting will be on Jan 17, 2023. Feel free to join us if you are
interested!

Google Meet: https://meet.google.com/wcx-fjbt-hhz
Dial-in: https://tel.meet/wcx-fjbt-hhz?pin=1940846765126

Wish you all a happy new year :-)

Best Regards,
Qingsheng, Leonard, Matthias and Martijn

Flink Interval Joins

[Vladislav Keda]

Hi,

I was trying to write alternative of query (for example)

SELECT
FROM t1 AS t1
LEFT JOIN t2 as t2
ON t1.fk = t2.key
AND t1.proctime
  BETWEEN
t2.proctime - INTERVAL ...
  AND
t2.proctime + INTERVAL ...

on DataStreams API but I found that interval join (in DataStreams API) does
not support left/full joins.

So I'm trying to understand the difference between interval join in
DataStreams API and SQL API to write my custom CoProcess realization. If I
create timers for messages waiting for a pair in the case of a left join,
will this not entail problems with waiting for all registered timers to
fire during checkpoints?

P.S. Maybe you can send the internals of SQL interval join implementation
in Java/Scala.

---

Best Regards,
Vladislav Keda

[ANNOUNCE] Apache Flink Kubernetes Operator 1.3.1 released

[Gyula Fóra]

The Apache Flink community is very happy to announce the release of Apache
Flink Kubernetes Operator 1.3.1.

The Flink Kubernetes Operator allows users to manage their Apache Flink
applications and their lifecycle through native k8s tooling like kubectl.

Please check out the release blog post for an overview of the release:
https://flink.apache.org/news/2023/01/10/release-kubernetes-operator-1.3.1.html

The release is available for download at:
https://flink.apache.org/downloads.html

Maven artifacts for Flink Kubernetes Operator can be found at:
https://search.maven.org/artifact/org.apache.flink/flink-kubernetes-operator

Official Docker image for Flink Kubernetes Operator applications can be
found at:
https://hub.docker.com/r/apache/flink-kubernetes-operator

The full release notes are available in Jira:
https://issues.apache.org/jira/projects/FLINK/versions/12352697

We would like to thank all contributors of the Apache Flink community who
made this release possible!

Regards,
Gyula Fora

[ANNOUNCE] Apache Flink Kubernetes Operator 1.3.1 released

[Gyula Fóra]

The Apache Flink community is very happy to announce the release of Apache
Flink Kubernetes Operator 1.3.1.

The Flink Kubernetes Operator allows users to manage their Apache Flink
applications and their lifecycle through native k8s tooling like kubectl.

Please check out the release blog post for an overview of the release:
https://flink.apache.org/news/2023/01/10/release-kubernetes-operator-1.3.1.html

The release is available for download at:
https://flink.apache.org/downloads.html

Maven artifacts for Flink Kubernetes Operator can be found at:
https://search.maven.org/artifact/org.apache.flink/flink-kubernetes-operator

Official Docker image for Flink Kubernetes Operator applications can be
found at:
https://hub.docker.com/r/apache/flink-kubernetes-operator

The full release notes are available in Jira:
https://issues.apache.org/jira/projects/FLINK/versions/12352697

We would like to thank all contributors of the Apache Flink community who
made this release possible!

Regards,
Gyula Fora

Re: Upgrading pyflink to 1.16.0

[Gunnar Morling]

Hey Ramana,

I can't help you with that particular script, but perhaps this commit
is helpful to you which I did for upgrading the PyFlink Playground
project to 1.16:


https://github.com/apache/flink-playgrounds/commit/4aa9a341bbf49e51809bc9cfcf0e946b2accd8ac

In particular see the changes to the PyFlink job itself, where that
legacy stringly-typed API couldn't be used any longer.

Best,

--Gunnar

Am Di., 10. Jan. 2023 um 07:46 Uhr schrieb Ramana :
>
> All - I am trying to upgrade my pyflink installation from 1.15.2 to 1.16.0. 
> Could someone tell me if that's possible via the 
> 'setup-pyflink-virtual-env.sh 1.16.0' command? I don't want to overwrite any 
> of my configuration files, so what's the clean way of upgrading to 1.16.0?
>
> Thanks for your help
> - Ramana.