Re: Updating Scala package names while preserving state

2023-02-13 Thread Thomas Eckestad
namespace). So it could have been done that way I guess. I did not find any other option for migrating the state due to a namespace/package name change. Performing text replace with sed does not work. On 7 Feb 2023, at 12:03, Thomas Eckestad mailto:thomas.eckes...@niradynamics.se>> wrot

Updating Scala package names while preserving state

2023-02-07 Thread Thomas Eckestad
on FLink 1.13.6. Thanks, Thomas Thomas Eckestad Systems Engineer Development RSI NIRA Dynamics AB Wallenbergs gata 4 58330 Link?ping, Sweden Mobile: +46 701 447 279 thomas.eckes...@niradynamics.se www.niradynamics.se

Re: Stop vs Cancel with savepoint

2021-03-08 Thread Thomas Eckestad
update the REST API documentation and have a section outlining the problems with cancel-with-savepoint. Would you like to open a ticket yourself? On 3/3/2021 11:16 AM, Thomas Eckestad wrote: Hi! Cancel with savepoint is marked as deprecated in the cli-documentation. It is not marked as depr

Stop vs Cancel with savepoint

2021-03-03 Thread Thomas Eckestad
that explains why it is deprecated and why usage of it is discouraged, or? Thanks, Thomas Thomas Eckestad Systems Engineer Road Perception NIRA Dynamics AB Wallenbergs gata 4 58330 Link?ping, Sweden Mobile: +46 738 453 937 thomas.eckes...@niradynamics.se www.niradynamics.se

Re: Strange behaviour when using RMQSource in Flink 1.11.2

2020-11-19 Thread Thomas Eckestad
Hi Andrey, Thank you for your response. I created https://issues.apache.org/jira/browse/FLINK-20244. Best Regards, Thomas From: Andrey Zagrebin Sent: Thursday, November 19, 2020 8:41 To: Thomas Eckestad Cc: user@flink.apache.org Subject: Re: Strange behaviour

Strange behaviour when using RMQSource in Flink 1.11.2

2020-11-18 Thread Thomas Eckestad
seems buggy. Does my reasoning make sense to you? Best Regards, Thomas Eckestad

Two Kubernetes clusters and one Flink cluster?

2019-02-28 Thread Thomas Eckestad
Hi, I'm working with two separate Kubernetes clusters located in different regions (hosted in proprietary data centers), the distance between the regions introduces a pretty high (~50ms) latency between the clusters, so communication should not go cross-site unless necessary. I would like to

Re: Running single Flink job in a job cluster, problem starting JobManager

2019-02-12 Thread Thomas Eckestad
between Flink bootstrap-code and the Flink job? /Thomas From: Chesnay Schepler Sent: Sunday, February 10, 2019 10:30:54 AM To: Thomas Eckestad; user@flink.apache.org Subject: Re: Running single Flink job in a job cluster, problem starting JobManager I'm afraid we

Re: Running single Flink job in a job cluster, problem starting JobManager

2019-02-08 Thread Thomas Eckestad
Hi again, when removing Spring Boot from the application it works. I would really like to mix Spring Boot and Flink. It does work with Spring Boot when submitting jobs to a session cluster, as stated before. /Thomas From: Thomas Eckestad Sent: Friday, February

Running single Flink job in a job cluster, problem starting JobManager

2019-02-08 Thread Thomas Eckestad
ala_2.11.tgz (I have also tried 1.6.3 and 1.7.0, no difference in behavior). * docker --version -> Docker version 1.13.1 * uname -a -> Linux SEOSTL0069.SEC.INTRA 4.20.4-200.fc29.x86_64 #1 SMP Wed Jan 23 16:11:28 UTC 2019 x86_64 x86_64 x86_64 GNU/Linux Thank you, Thomas Eckestad