This is an automated email from the ASF dual-hosted git repository.
martinzink pushed a commit to branch MINIFICPP-2584-squashed
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
The following commit(s) were added to refs/heads/MINIFICPP-2584-squashed by
this push:
new bd86f4caa asd
bd86f4caa is described below
commit bd86f4caafb273a9fed357fa59887e2531c2bd84
Author: Martin Zink <[email protected]>
AuthorDate: Sat Jul 12 21:33:24 2025 +0200
asd
---
.../test/integration/features/core_functionality.feature | 2 +-
docker/test/integration/features/couchbase.feature | 4 ++--
docker/test/integration/features/grafana_loki.feature | 14 +++++++-------
docker/test/integration/features/http.feature | 14 +++++++-------
docker/test/integration/features/llamacpp.feature | 2 +-
docker/test/integration/features/s3.feature | 12 ++++++------
docker/test/integration/features/sql.feature | 10 +++++-----
7 files changed, 29 insertions(+), 29 deletions(-)
diff --git a/docker/test/integration/features/core_functionality.feature
b/docker/test/integration/features/core_functionality.feature
index 21b071f64..ee5290ec8 100644
--- a/docker/test/integration/features/core_functionality.feature
+++ b/docker/test/integration/features/core_functionality.feature
@@ -59,7 +59,7 @@ Feature: Core flow functionalities
Given a transient MiNiFi flow with the name "transient-minifi" is set up
And a LogOnDestructionProcessor processor with the name "logOnDestruction"
in the "transient-minifi" flow
When the MiNiFi instance starts up
- Then the Minifi logs contain the following message:
"LogOnDestructionProcessor is being destructed" in less than 100 seconds
+ Then the Minifi logs contain the following message:
"LogOnDestructionProcessor is being destructed" in less than 40 seconds
@CORE
Scenario: Agent does not crash when using provenance repositories
diff --git a/docker/test/integration/features/couchbase.feature
b/docker/test/integration/features/couchbase.feature
index 90cb0df0d..a1eda4e26 100644
--- a/docker/test/integration/features/couchbase.feature
+++ b/docker/test/integration/features/couchbase.feature
@@ -204,7 +204,7 @@ Feature: Executing Couchbase operations from MiNiFi-C++
When a Couchbase server is started
And all instances start up
- Then a flowfile with the JSON content '{"field1": "value1", "field2":
"value2"}' is placed in the monitored directory in less than 6000 seconds
+ Then a flowfile with the JSON content '{"field1": "value1", "field2":
"value2"}' is placed in the monitored directory in less than 60 seconds
And the Minifi logs contain the following message: "key:couchbase.bucket
value:test_bucket" in less than 10 seconds
And the Minifi logs contain the following message: "key:couchbase.doc.id
value:test_doc_id" in less than 1 seconds
And the Minifi logs match the following regex: "key:couchbase.doc.cas
value:[1-9][0-9]*" in less than 1 seconds
@@ -233,7 +233,7 @@ Feature: Executing Couchbase operations from MiNiFi-C++
When a Couchbase server is started
And all instances start up
- Then a flowfile with the JSON content '{"field1": "value1", "field2":
"value2"}' is placed in the monitored directory in less than 6000 seconds
+ Then a flowfile with the JSON content '{"field1": "value1", "field2":
"value2"}' is placed in the monitored directory in less than 60 seconds
And the Minifi logs contain the following message: "key:couchbase.bucket
value:test_bucket" in less than 10 seconds
And the Minifi logs contain the following message: "key:couchbase.doc.id
value:test_doc_id" in less than 1 seconds
And the Minifi logs match the following regex: "key:couchbase.doc.cas
value:[1-9][0-9]*" in less than 1 seconds
diff --git a/docker/test/integration/features/grafana_loki.feature
b/docker/test/integration/features/grafana_loki.feature
index 3ef91c448..478d4c043 100644
--- a/docker/test/integration/features/grafana_loki.feature
+++ b/docker/test/integration/features/grafana_loki.feature
@@ -27,7 +27,7 @@ Feature: MiNiFi can publish logs to Grafana Loki server
And the "Stream Labels" property of the PushGrafanaLokiREST processor is
set to "job=minifi,id=docker-test"
And the "success" relationship of the TailFile processor is connected to
the PushGrafanaLokiREST
When all instances start up
- Then "log line 1;log line 2;log line 3" lines are published to the Grafana
Loki server in less than 120 seconds
+ Then "log line 1;log line 2;log line 3" lines are published to the Grafana
Loki server in less than 60 seconds
Scenario: Logs are published to Loki server to a specific tenant through
REST API
Given a Grafana Loki server is set up with multi-tenancy enabled
@@ -38,7 +38,7 @@ Feature: MiNiFi can publish logs to Grafana Loki server
And the "Tenant ID" property of the PushGrafanaLokiREST processor is set
to "mytenant"
And the "success" relationship of the TailFile processor is connected to
the PushGrafanaLokiREST
When all instances start up
- Then "log line 1;log line 2;log line 3" lines are published to the
"mytenant" tenant on the Grafana Loki server in less than 120 seconds
+ Then "log line 1;log line 2;log line 3" lines are published to the
"mytenant" tenant on the Grafana Loki server in less than 60 seconds
Scenario: Logs are published to Loki server through REST API using SSL
Given a Grafana Loki server with SSL is set up
@@ -49,7 +49,7 @@ Feature: MiNiFi can publish logs to Grafana Loki server
And the "success" relationship of the TailFile processor is connected to
the PushGrafanaLokiREST
And a SSL context service is set up for Grafana Loki processor
"PushGrafanaLokiREST"
When all instances start up
- Then "log line 1;log line 2;log line 3" lines are published using SSL to
the Grafana Loki server in less than 120 seconds
+ Then "log line 1;log line 2;log line 3" lines are published using SSL to
the Grafana Loki server in less than 60 seconds
Scenario: Logs are published to Loki server with basic authentication
through REST API using a reverse proxy
Given a Grafana Loki server is set up
@@ -62,7 +62,7 @@ Feature: MiNiFi can publish logs to Grafana Loki server
And the "Password" property of the PushGrafanaLokiREST processor is set to
"password"
And the "success" relationship of the TailFile processor is connected to
the PushGrafanaLokiREST
When all instances start up
- Then "log line 1;log line 2;log line 3" lines are published to the Grafana
Loki server in less than 120 seconds
+ Then "log line 1;log line 2;log line 3" lines are published to the Grafana
Loki server in less than 60 seconds
Scenario: Logs are published to Loki server through gRPC
Given a Grafana Loki server is set up
@@ -72,7 +72,7 @@ Feature: MiNiFi can publish logs to Grafana Loki server
And the "Stream Labels" property of the PushGrafanaLokiGrpc processor is
set to "job=minifi,id=docker-test"
And the "success" relationship of the TailFile processor is connected to
the PushGrafanaLokiGrpc
When all instances start up
- Then "log line 1;log line 2;log line 3" lines are published to the Grafana
Loki server in less than 120 seconds
+ Then "log line 1;log line 2;log line 3" lines are published to the Grafana
Loki server in less than 60 seconds
Scenario: Logs are published to Loki server to a specific tenant through gRPC
Given a Grafana Loki server is set up with multi-tenancy enabled
@@ -83,7 +83,7 @@ Feature: MiNiFi can publish logs to Grafana Loki server
And the "Tenant ID" property of the PushGrafanaLokiGrpc processor is set
to "mytenant"
And the "success" relationship of the TailFile processor is connected to
the PushGrafanaLokiGrpc
When all instances start up
- Then "log line 1;log line 2;log line 3" lines are published to the
"mytenant" tenant on the Grafana Loki server in less than 120 seconds
+ Then "log line 1;log line 2;log line 3" lines are published to the
"mytenant" tenant on the Grafana Loki server in less than 60 seconds
Scenario: Logs are published to Loki server through gRPC using SSL
Given a Grafana Loki server with SSL is set up
@@ -94,4 +94,4 @@ Feature: MiNiFi can publish logs to Grafana Loki server
And the "success" relationship of the TailFile processor is connected to
the PushGrafanaLokiGrpc
And a SSL context service is set up for Grafana Loki processor
"PushGrafanaLokiGrpc"
When all instances start up
- Then "log line 1;log line 2;log line 3" lines are published using SSL to
the Grafana Loki server in less than 120 seconds
+ Then "log line 1;log line 2;log line 3" lines are published using SSL to
the Grafana Loki server in less than 60 seconds
diff --git a/docker/test/integration/features/http.feature
b/docker/test/integration/features/http.feature
index 92789ab79..0cd01fbbb 100644
--- a/docker/test/integration/features/http.feature
+++ b/docker/test/integration/features/http.feature
@@ -35,7 +35,7 @@ Feature: Sending data using InvokeHTTP to a receiver using
ListenHTTP
And the "success" relationship of the ListenHTTP processor is connected to
the PutFile
When both instances start up
- Then at least one flowfile with the content "test" is placed in the
monitored directory in less than 120 seconds
+ Then at least one flowfile with the content "test" is placed in the
monitored directory in less than 60 seconds
Scenario: A MiNiFi instance sends data through a HTTP proxy and another one
listens
Given a GetFile processor with the "Input Directory" property set to
"/tmp/input"
@@ -58,7 +58,7 @@ Feature: Sending data using InvokeHTTP to a receiver using
ListenHTTP
And the "success" relationship of the ListenHTTP processor is connected to
the PutFile
When all instances start up
- Then at least one flowfile with the content "test" is placed in the
monitored directory in less than 120 seconds
+ Then at least one flowfile with the content "test" is placed in the
monitored directory in less than 60 seconds
And no errors were generated on the http-proxy regarding
"http://minifi-listen-${feature_id}:8080/contentListener";
Scenario: A MiNiFi instance and transfers hashed data to another MiNiFi
instance
@@ -76,7 +76,7 @@ Feature: Sending data using InvokeHTTP to a receiver using
ListenHTTP
And the "success" relationship of the ListenHTTP processor is connected to
the PutFile
When both instances start up
- Then at least one flowfile with the content "test" is placed in the
monitored directory in less than 120 seconds
+ Then at least one flowfile with the content "test" is placed in the
monitored directory in less than 60 seconds
Scenario: A MiNiFi instance transfers data to another MiNiFi instance
without message body
Given a GetFile processor with the "Input Directory" property set to
"/tmp/input"
@@ -92,7 +92,7 @@ Feature: Sending data using InvokeHTTP to a receiver using
ListenHTTP
And the "success" relationship of the ListenHTTP processor is connected to
the PutFile
When both instances start up
- Then at least one empty flowfile is placed in the monitored directory in
less than 120 seconds
+ Then at least one empty flowfile is placed in the monitored directory in
less than 60 seconds
Scenario: A MiNiFi instance transfers data to a NiFi instance with message
body
Given a GetFile processor with the "Input Directory" property set to
"/tmp/input"
@@ -108,7 +108,7 @@ Feature: Sending data using InvokeHTTP to a receiver using
ListenHTTP
And the "success" relationship of the ListenHTTP processor is connected to
the PutFile
When both instances start up
- Then at least one flowfile with the content "test" is placed in the
monitored directory in less than 120 seconds
+ Then at least one flowfile with the content "test" is placed in the
monitored directory in less than 60 seconds
Scenario: A MiNiFi instance transfers data to another MiNiFi instance with
message body and limited speed
Given a GenerateFlowFile processor with the "File Size" property set to
"10 MB"
@@ -125,7 +125,7 @@ Feature: Sending data using InvokeHTTP to a receiver using
ListenHTTP
And the "success" relationship of the ListenHTTP processor is connected to
the PutFile
When both instances start up
- Then at least one flowfile with minimum size of "1 MB" is placed in the
monitored directory in less than 120 seconds
+ Then at least one flowfile with minimum size of "1 MB" is placed in the
monitored directory in less than 60 seconds
And the Minifi logs contain the following message: "[warning]
InvokeHTTP::onTrigger has been running for" in less than 10 seconds
Scenario: A MiNiFi instance retrieves data from another MiNiFi instance with
message body and limited speed
@@ -148,5 +148,5 @@ Feature: Sending data using InvokeHTTP to a receiver using
ListenHTTP
And the "success" relationship of the UpdateAttribute processor is
connected to the ListenHTTP
When both instances start up
- Then at least one flowfile with minimum size of "10 MB" is placed in the
monitored directory in less than 120 seconds
+ Then at least one flowfile with minimum size of "10 MB" is placed in the
monitored directory in less than 60 seconds
And the Minifi logs contain the following message: "[warning]
InvokeHTTP::onTrigger has been running for" in less than 10 seconds
diff --git a/docker/test/integration/features/llamacpp.feature
b/docker/test/integration/features/llamacpp.feature
index de8072d39..65f5a08db 100644
--- a/docker/test/integration/features/llamacpp.feature
+++ b/docker/test/integration/features/llamacpp.feature
@@ -29,4 +29,4 @@ Feature: Run language model inference using LlamaCpp processor
And the "success" relationship of the RunLlamaCppInference processor is
connected to the LogAttribute
When all instances start up
- Then the Minifi logs contain the following message: "banana" in less than
120 seconds
+ Then the Minifi logs contain the following message: "banana" in less than
60 seconds
diff --git a/docker/test/integration/features/s3.feature
b/docker/test/integration/features/s3.feature
index 6a85e0dea..1aa41e959 100644
--- a/docker/test/integration/features/s3.feature
+++ b/docker/test/integration/features/s3.feature
@@ -75,7 +75,7 @@ Feature: Sending data from MiNiFi-C++ to an AWS server
And the http proxy server is set up
When all instances start up
- Then a flowfile with the content "test" is placed in the monitored
directory in less than 150 seconds
+ Then a flowfile with the content "test" is placed in the monitored
directory in less than 60 seconds
And the object on the s3 server is "LH_O#L|FD<FASD{FO#@$#$%^
\"#\"$L%:\"@#$L\":test_data#$#%#$%?{\"F{"
And the object content type on the s3 server is "application/octet-stream"
and the object metadata matches use metadata
And no errors were generated on the http-proxy regarding
"http://s3-server-${feature_id}:9090/test_bucket/test_object_key";
@@ -96,7 +96,7 @@ Feature: Sending data from MiNiFi-C++ to an AWS server
When both instances start up
- Then a flowfile with the content "test" is placed in the monitored
directory in less than 120 seconds
+ Then a flowfile with the content "test" is placed in the monitored
directory in less than 60 seconds
And the object bucket on the s3 server is empty
Scenario: Deletion of a non-existent s3 object succeeds
@@ -111,7 +111,7 @@ Feature: Sending data from MiNiFi-C++ to an AWS server
When both instances start up
- Then a flowfile with the content "test" is placed in the monitored
directory in less than 120 seconds
+ Then a flowfile with the content "test" is placed in the monitored
directory in less than 60 seconds
And the object bucket on the s3 server is empty
Scenario: Deletion of a s3 object through a proxy-server succeeds
@@ -137,7 +137,7 @@ Feature: Sending data from MiNiFi-C++ to an AWS server
When all instances start up
- Then a flowfile with the content "test" is placed in the monitored
directory in less than 150 seconds
+ Then a flowfile with the content "test" is placed in the monitored
directory in less than 60 seconds
And the object bucket on the s3 server is empty
And no errors were generated on the http-proxy regarding
"http://s3-server-${feature_id}:9090/test_bucket/test_object_key";
@@ -159,7 +159,7 @@ Feature: Sending data from MiNiFi-C++ to an AWS server
When all instances start up
- Then a flowfile with the content "test" is placed in the monitored
directory in less than 120 seconds
+ Then a flowfile with the content "test" is placed in the monitored
directory in less than 60 seconds
Scenario: A MiNiFi instance can download s3 bucket objects via a http-proxy
Given a GetFile processor with the "Input Directory" property set to
"/tmp/input"
@@ -186,7 +186,7 @@ Feature: Sending data from MiNiFi-C++ to an AWS server
When all instances start up
- Then a flowfile with the content "test" is placed in the monitored
directory in less than 150 seconds
+ Then a flowfile with the content "test" is placed in the monitored
directory in less than 60 seconds
And no errors were generated on the http-proxy regarding
"http://s3-server-${feature_id}:9090/test_bucket/test_object_key";
Scenario: A MiNiFi instance can list an S3 bucket directly
diff --git a/docker/test/integration/features/sql.feature
b/docker/test/integration/features/sql.feature
index e3edfdf06..722897bf4 100644
--- a/docker/test/integration/features/sql.feature
+++ b/docker/test/integration/features/sql.feature
@@ -31,7 +31,7 @@ Feature: Executing SQL operations from MiNiFi-C++
And an ODBCService is setup up for PutSQL with the name "ODBCService"
And a PostgreSQL server is set up
When all instances start up
- Then the query "SELECT * FROM test_table WHERE int_col = 42" returns 1
rows in less than 120 seconds on the PostgreSQL server
+ Then the query "SELECT * FROM test_table WHERE int_col = 42" returns 1
rows in less than 60 seconds on the PostgreSQL server
Scenario: A MiNiFi instance can query to test table with ExecuteSQL processor
Given a MiNiFi CPP server with yaml config
@@ -47,7 +47,7 @@ Feature: Executing SQL operations from MiNiFi-C++
And an ODBCService is setup up for ExecuteSQL with the name "ODBCService"
And a PostgreSQL server is set up
When all instances start up
- Then at least one flowfile with the content
'[{"int_col":2,"text_col":"banana"},{"int_col":1,"text_col":"apple"}]' is
placed in the monitored directory in less than 120 seconds
+ Then at least one flowfile with the content
'[{"int_col":2,"text_col":"banana"},{"int_col":1,"text_col":"apple"}]' is
placed in the monitored directory in less than 60 seconds
Scenario: A MiNiFi instance can query to test table containing mixed case
column names with ExecuteSQL processor
Given a GenerateFlowFile processor with the "File Size" property set to
"0B"
@@ -63,7 +63,7 @@ Feature: Executing SQL operations from MiNiFi-C++
And an ODBCService is setup up for ExecuteSQL with the name "ODBCService"
And a PostgreSQL server is set up
When all instances start up
- Then at least one flowfile with the content
'[{"int_col":6,"tExT_Col":"BaNaNa"},{"int_col":5,"tExT_Col":"ApPlE"}]' is
placed in the monitored directory in less than 120 seconds
+ Then at least one flowfile with the content
'[{"int_col":6,"tExT_Col":"BaNaNa"},{"int_col":5,"tExT_Col":"ApPlE"}]' is
placed in the monitored directory in less than 60 seconds
Scenario: A MiNiFi instance can query to test table with QueryDatabaseTable
processor
Given a QueryDatabaseTable processor with the "Table Name" property set to
"test_table"
@@ -75,7 +75,7 @@ Feature: Executing SQL operations from MiNiFi-C++
And an ODBCService is setup up for QueryDatabaseTable with the name
"ODBCService"
And a PostgreSQL server is set up
When all instances start up
- Then at least one flowfile with the content '[{"text_col":"apple"}]' is
placed in the monitored directory in less than 120 seconds
+ Then at least one flowfile with the content '[{"text_col":"apple"}]' is
placed in the monitored directory in less than 60 seconds
Scenario: A MiNiFi instance can query to test table containing mixed case
column names with QueryDatabaseTable processor
Given a QueryDatabaseTable processor with the "Table Name" property set to
"test_table2"
@@ -87,4 +87,4 @@ Feature: Executing SQL operations from MiNiFi-C++
And an ODBCService is setup up for QueryDatabaseTable with the name
"ODBCService"
And a PostgreSQL server is set up
When all instances start up
- Then at least one flowfile with the content '[{"tExT_Col":"ApPlE"}]' is
placed in the monitored directory in less than 120 seconds
+ Then at least one flowfile with the content '[{"tExT_Col":"ApPlE"}]' is
placed in the monitored directory in less than 60 seconds
