Hi guys,
Forking in sbt solved the issue (Test / fork := true).
On Sun, Dec 3, 2023 at 7:48 AM Barak Ben-Nathan
wrote:
> By the way, I also upgraded to flink-connector-kafka ver. 3.0.2-1.18, to
> no avail.
>
> On Sun, Dec 3, 2023 at 7:45 AM Barak Ben-Nathan
> wrote:
&
By the way, I also upgraded to flink-connector-kafka ver. 3.0.2-1.18, to no
avail.
On Sun, Dec 3, 2023 at 7:45 AM Barak Ben-Nathan
wrote:
> Thank's Jim,
>
> Unfortunately, this did not resolve the issue.
>
> I tried downgrading to 17.2 -- and everything works fine.
> In vers
pache.org/flink/flink-docs-release-1.18/release-notes/flink-1.14/#connector-base-exposes-dependency-to-flink-core
>
> Cheers,
>
> Jim
>
> On Fri, Dec 1, 2023 at 3:30 PM Barak Ben-Nathan
> wrote:
>
>>
>> hi,
>>
>> I am trying to upgrade my app
hi,
I am trying to upgrade my app to Flink 1.18.
I have tests that run my stream from/to Embedded (in-memory) Kafka.
I.e. They create a flink cluster thus:
val flinkCluster = new MiniClusterWithClientResource(new
MiniClusterResourceConfiguration.Builder()
.setNumberSlotsPerTaskManager(2)
Hi all,
I am using Flink 1.12.1
I’m building a system that creates/cancels Flink Jobs and monitors them.
We thought to use org.apache.flink.core.execution.JobListener as a ‘push’
mechanism for job-status-change events.
We based this idea on the documentation that stated that JobListener ‘…is
I want to manage the execution of Flink Jobs programmatically through Flink
Monitoring API.
I.e. I want to run/delete jobs ONLY with the
POST /jars/:jarid/run
POST /jobs/:jobid/stop
API commands.
Now, it seems that the Session Mode may fits my needs: “Session Mode: one
JobManager instance
Hi all,
I am building an application that launches Flink Jobs and monitors them.
I want to use the JobListener interface to output job evemts to a Kafka Topic.
The problem:
In the application we have RuleId, i.e. business logic identifier for the job,
and there’s JobId which is the
