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
--
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
@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
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
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
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
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
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
