(camel-quarkus) branch main updated: Use target as the temporary directory location for the Flink mini cluster

[jamesnetherton]

This is an automated email from the ASF dual-hosted git repository.

jamesnetherton pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git


The following commit(s) were added to refs/heads/main by this push:
     new 10bf4e94b5 Use target as the temporary directory location for the 
Flink mini cluster
10bf4e94b5 is described below

commit 10bf4e94b557575a7ecf28bcd50a34db04d102ac
Author: James Netherton <jamesnether...@gmail.com>
AuthorDate: Fri Sep 6 09:32:10 2024 +0100

    Use target as the temporary directory location for the Flink mini cluster
---
 .../org/apache/camel/quarkus/component/flink/it/FlinkResource.java  | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/integration-tests-jvm/flink/src/main/java/org/apache/camel/quarkus/component/flink/it/FlinkResource.java
 
b/integration-tests-jvm/flink/src/main/java/org/apache/camel/quarkus/component/flink/it/FlinkResource.java
index 01fe5346ec..6885b4d60c 100644
--- 
a/integration-tests-jvm/flink/src/main/java/org/apache/camel/quarkus/component/flink/it/FlinkResource.java
+++ 
b/integration-tests-jvm/flink/src/main/java/org/apache/camel/quarkus/component/flink/it/FlinkResource.java
@@ -37,6 +37,7 @@ import org.apache.camel.component.flink.Flinks;
 import org.apache.camel.component.flink.VoidDataStreamCallback;
 import org.apache.flink.api.java.DataSet;
 import org.apache.flink.api.java.ExecutionEnvironment;
+import org.apache.flink.configuration.Configuration;
 import org.apache.flink.streaming.api.datastream.DataStream;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
 import org.jboss.logging.Logger;
@@ -66,6 +67,7 @@ public class FlinkResource {
 
         if (Files.exists(Paths.get(filePath))) {
             ExecutionEnvironment env = Flinks.createExecutionEnvironment();
+            env.getConfiguration().setString("io.tmp.dirs", "target");
             DataSet<String> myDataSet = env.readTextFile(filePath);
             context.getRegistry().bind("myDataSet", myDataSet);
             context.getRegistry().bind("countTotal", addDataSetCallback());
@@ -84,7 +86,9 @@ public class FlinkResource {
     public Response loadStream(@PathParam("filePath") String filePath, String 
data) throws IOException {
         java.nio.file.Path path = Paths.get(filePath);
         if (path != null) {
-            StreamExecutionEnvironment env = 
StreamExecutionEnvironment.getExecutionEnvironment();
+            Configuration configuration = new Configuration();
+            configuration.setString("io.tmp.dirs", "target");
+            StreamExecutionEnvironment env = 
StreamExecutionEnvironment.getExecutionEnvironment(configuration);
             DataStream<String> datastream = env.fromElements(data);
             context.getRegistry().bind("myDataStream", datastream);
             template.sendBodyAndHeader(flinkDataStreamUri, null,