Great to hear! Thanks a lot to everyone who helped make this release
possible.
Cheers,
Till
On Sat, Jan 2, 2021 at 3:37 AM Tzu-Li (Gordon) Tai
wrote:
> The Apache Flink community released the second bugfix release of the
> Stateful Functions (StateFun) 2.2 series, version 2.2.2.
>
> *We strongl
Hello All,
First of all Happy New Year!! Thanks for the excellent community support.
I have a job which requires a 2 seconds tumbling time window per key, For
each user we wait for 2 seconds to collect enough data and proceed to
further processing. My question is should I use the regular DSL win
Hi All,
Currently we are using flink in session cluster mode and we manually deploy
the jobs i.e. through the web UI. We use AWS ECS for running the docker
container with 2 services definitions, one for JM and other for TM. How is
everyone managing the CICD process? Is there a better way to run a
Could you not use the JM web address to utilize the rest api? You can
start/stop/save point/restore + upload new jars via the rest api. While I
did not run on ECS( ran on EMR) I was able to use the rest api to do
deployments.
On Sun, Jan 3, 2021 at 19:09 Navneeth Krishnan
wrote:
> Hi All,
>
> Cu
Thanks Vikash for the response. Yes thats very much feasible but we are
planning to move to job/application cluster model where in the artifacts
are bundled inside the container. When there is a new container image then
we might have to do the following.
- Take a savepoint
- Upgrade the JM and TM c
@Gordon Thanks a lot for the release and for being the release manager.
And thanks to everyone who made this release possible!
Best,
Xingbo
Till Rohrmann 于2021年1月3日周日 下午8:31写道：
> Great to hear! Thanks a lot to everyone who helped make this release
> possible.
>
> Cheers,
> Till
>
> On Sat, Jan
Hi Navneeth
For me I think you may start with using the window function and an example
for the custom window function could be found in [1]. From the description I
think it should be a standard Tumbling window, if implementing with the
customized process function, it would end up have a sim
Hi Narasimha,
Since the Kafka-connect itself is purely implemented with Java, thus I
guess that with high probabililty it is not the issue of scala version. I think
may first have a check of the kafka cluster's status ?
Best,
Yun
--
