[jira] [Commented] (MINIFI-522) Fixed Access denied to: http://jcenter.bintray.com which caused Failed to execute goal on project minifi-standard-nar
[
https://issues.apache.org/jira/browse/MINIFI-522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015467#comment-17015467
]
sapinkumar amin commented on MINIFI-522:
Its looking for
~/.m2/repository/com/github/palindromicity/simple-syslog-5424/0.0.8/simple-syslog-5424-0.0.8.jar
which if does not exits, tries to download from
https://jcenter.bintray.com/com/github/palindromicity/simple-syslog-5424/0.0.8/simple-syslog-5424-0.0.8.jar.
> Fixed Access denied to: http://jcenter.bintray.com which caused Failed to
> execute goal on project minifi-standard-nar
> -
>
> Key: MINIFI-522
> URL: https://issues.apache.org/jira/browse/MINIFI-522
> Project: Apache NiFi MiNiFi
> Issue Type: Bug
>Reporter: sapinkumar amin
>Priority: Blocker
> Fix For: 0.6.0
>
>
> {code:java}
> mvn clean install {code}
> throws below error
> {code:java}
> [INFO] minifi-update-attribute-nar SUCCESS [ 0.326
> s]
> [INFO] minifi-standard-nar FAILURE [ 1.198
> s]
> [INFO] minifi-ssl-context-service-nar . SKIPPED
> [INFO] minifi-docs SKIPPED
> [INFO] minifi-assembly SKIPPED
> [INFO] minifi-toolkit . SKIPPED
> [INFO] minifi-toolkit-configuration ... SKIPPED
> [INFO] minifi-toolkit-assembly SKIPPED
> [INFO] minifi-docker .. SKIPPED
> [INFO] minifi-c2 .. SKIPPED
> [INFO] minifi-c2-api .. SKIPPED
> [INFO] minifi-c2-cache SKIPPED
> [INFO] minifi-c2-cache-filesystem . SKIPPED
> [INFO] minifi-c2-cache-s3 . SKIPPED
> [INFO] minifi-c2-provider . SKIPPED
> [INFO] minifi-c2-provider-util SKIPPED
> [INFO] minifi-c2-provider-cache ... SKIPPED
> [INFO] minifi-c2-provider-delegating .. SKIPPED
> [INFO] minifi-c2-provider-nifi-rest ... SKIPPED
> [INFO] minifi-c2-service .. SKIPPED
> [INFO] minifi-c2-jetty SKIPPED
> [INFO] minifi-c2-assembly . SKIPPED
> [INFO] minifi-c2-docker ... SKIPPED
> [INFO] minifi-c2-integration-tests SKIPPED
> [INFO] minifi-integration-tests ... SKIPPED
> [INFO]
>
> [INFO] BUILD FAILURE
> [INFO]
>
> [INFO] Total time: 29.209 s
> [INFO] Finished at: 2020-01-14T14:02:00-08:00
> [INFO]
>
> [ERROR] Failed to execute goal on project minifi-standard-nar: Could not
> resolve dependencies for project
> org.apache.nifi.minifi:minifi-standard-nar:nar:0.6.0-SNAPSHOT: Failed to
> collect dependencies at org.apache.nifi:nifi-standard-processors:jar:1.8.0 ->
> org.apache.nifi:nifi-syslog-utils:jar:1.8.0 ->
> com.github.palindromicity:simple-syslog-5424:jar:0.0.8: Failed to read
> artifact descriptor for
> com.github.palindromicity:simple-syslog-5424:jar:0.0.8: Could not transfer
> artifact com.github.palindromicity:simple-syslog-5424:pom:0.0.8 from/to
> jcenter (http://jcenter.bintray.com): Access denied to:
> http://jcenter.bintray.com/com/github/palindromicity/simple-syslog-5424/0.0.8/simple-syslog-5424-0.0.8.pom
> -> [Help 1]
> {code}
>
> From Jan13th : 2020 , access to jcenter.bintray.com is only allowed over
> https protocol (previously it use to support http and https).
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Updated] (MINIFI-522) Fixed Access denied to: http://jcenter.bintray.com which caused Failed to execute goal on project minifi-standard-nar
[
https://issues.apache.org/jira/browse/MINIFI-522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sapinkumar amin updated MINIFI-522:
---
Summary: Fixed Access denied to: http://jcenter.bintray.com which caused
Failed to execute goal on project minifi-standard-nar (was: Failed to execute
goal on project minifi-standard-nar : Access denied to:
http://jcenter.bintray.com)
> Fixed Access denied to: http://jcenter.bintray.com which caused Failed to
> execute goal on project minifi-standard-nar
> -
>
> Key: MINIFI-522
> URL: https://issues.apache.org/jira/browse/MINIFI-522
> Project: Apache NiFi MiNiFi
> Issue Type: Bug
>Reporter: sapinkumar amin
>Priority: Blocker
> Fix For: 0.6.0
>
>
> {code:java}
> mvn clean install {code}
> throws below error
> {code:java}
> [INFO] minifi-update-attribute-nar SUCCESS [ 0.326
> s]
> [INFO] minifi-standard-nar FAILURE [ 1.198
> s]
> [INFO] minifi-ssl-context-service-nar . SKIPPED
> [INFO] minifi-docs SKIPPED
> [INFO] minifi-assembly SKIPPED
> [INFO] minifi-toolkit . SKIPPED
> [INFO] minifi-toolkit-configuration ... SKIPPED
> [INFO] minifi-toolkit-assembly SKIPPED
> [INFO] minifi-docker .. SKIPPED
> [INFO] minifi-c2 .. SKIPPED
> [INFO] minifi-c2-api .. SKIPPED
> [INFO] minifi-c2-cache SKIPPED
> [INFO] minifi-c2-cache-filesystem . SKIPPED
> [INFO] minifi-c2-cache-s3 . SKIPPED
> [INFO] minifi-c2-provider . SKIPPED
> [INFO] minifi-c2-provider-util SKIPPED
> [INFO] minifi-c2-provider-cache ... SKIPPED
> [INFO] minifi-c2-provider-delegating .. SKIPPED
> [INFO] minifi-c2-provider-nifi-rest ... SKIPPED
> [INFO] minifi-c2-service .. SKIPPED
> [INFO] minifi-c2-jetty SKIPPED
> [INFO] minifi-c2-assembly . SKIPPED
> [INFO] minifi-c2-docker ... SKIPPED
> [INFO] minifi-c2-integration-tests SKIPPED
> [INFO] minifi-integration-tests ... SKIPPED
> [INFO]
>
> [INFO] BUILD FAILURE
> [INFO]
>
> [INFO] Total time: 29.209 s
> [INFO] Finished at: 2020-01-14T14:02:00-08:00
> [INFO]
>
> [ERROR] Failed to execute goal on project minifi-standard-nar: Could not
> resolve dependencies for project
> org.apache.nifi.minifi:minifi-standard-nar:nar:0.6.0-SNAPSHOT: Failed to
> collect dependencies at org.apache.nifi:nifi-standard-processors:jar:1.8.0 ->
> org.apache.nifi:nifi-syslog-utils:jar:1.8.0 ->
> com.github.palindromicity:simple-syslog-5424:jar:0.0.8: Failed to read
> artifact descriptor for
> com.github.palindromicity:simple-syslog-5424:jar:0.0.8: Could not transfer
> artifact com.github.palindromicity:simple-syslog-5424:pom:0.0.8 from/to
> jcenter (http://jcenter.bintray.com): Access denied to:
> http://jcenter.bintray.com/com/github/palindromicity/simple-syslog-5424/0.0.8/simple-syslog-5424-0.0.8.pom
> -> [Help 1]
> {code}
>
> From Jan13th : 2020 , access to jcenter.bintray.com is only allowed over
> https protocol (previously it use to support http and https).
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Updated] (MINIFI-522) Failed to execute goal on project minifi-standard-nar : Access denied to: http://jcenter.bintray.com
[
https://issues.apache.org/jira/browse/MINIFI-522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sapinkumar amin updated MINIFI-522:
---
Description:
{code:java}
mvn clean install {code}
throws below error
{code:java}
[INFO] minifi-update-attribute-nar SUCCESS [ 0.326 s]
[INFO] minifi-standard-nar FAILURE [ 1.198 s]
[INFO] minifi-ssl-context-service-nar . SKIPPED
[INFO] minifi-docs SKIPPED
[INFO] minifi-assembly SKIPPED
[INFO] minifi-toolkit . SKIPPED
[INFO] minifi-toolkit-configuration ... SKIPPED
[INFO] minifi-toolkit-assembly SKIPPED
[INFO] minifi-docker .. SKIPPED
[INFO] minifi-c2 .. SKIPPED
[INFO] minifi-c2-api .. SKIPPED
[INFO] minifi-c2-cache SKIPPED
[INFO] minifi-c2-cache-filesystem . SKIPPED
[INFO] minifi-c2-cache-s3 . SKIPPED
[INFO] minifi-c2-provider . SKIPPED
[INFO] minifi-c2-provider-util SKIPPED
[INFO] minifi-c2-provider-cache ... SKIPPED
[INFO] minifi-c2-provider-delegating .. SKIPPED
[INFO] minifi-c2-provider-nifi-rest ... SKIPPED
[INFO] minifi-c2-service .. SKIPPED
[INFO] minifi-c2-jetty SKIPPED
[INFO] minifi-c2-assembly . SKIPPED
[INFO] minifi-c2-docker ... SKIPPED
[INFO] minifi-c2-integration-tests SKIPPED
[INFO] minifi-integration-tests ... SKIPPED
[INFO]
[INFO] BUILD FAILURE
[INFO]
[INFO] Total time: 29.209 s
[INFO] Finished at: 2020-01-14T14:02:00-08:00
[INFO]
[ERROR] Failed to execute goal on project minifi-standard-nar: Could not
resolve dependencies for project
org.apache.nifi.minifi:minifi-standard-nar:nar:0.6.0-SNAPSHOT: Failed to
collect dependencies at org.apache.nifi:nifi-standard-processors:jar:1.8.0 ->
org.apache.nifi:nifi-syslog-utils:jar:1.8.0 ->
com.github.palindromicity:simple-syslog-5424:jar:0.0.8: Failed to read artifact
descriptor for com.github.palindromicity:simple-syslog-5424:jar:0.0.8: Could
not transfer artifact com.github.palindromicity:simple-syslog-5424:pom:0.0.8
from/to jcenter (http://jcenter.bintray.com): Access denied to:
http://jcenter.bintray.com/com/github/palindromicity/simple-syslog-5424/0.0.8/simple-syslog-5424-0.0.8.pom
-> [Help 1]
{code}
>From Jan13th : 2020 , access to jcenter.bintray.com is only allowed over https
>protocol (previously it use to support http and https).
was:
{code:java}
mvn clean install {code}
throws below error
{code:java}
[INFO] minifi-update-attribute-nar SUCCESS [ 0.326 s]
[INFO] minifi-standard-nar FAILURE [ 1.198 s]
[INFO] minifi-ssl-context-service-nar . SKIPPED
[INFO] minifi-docs SKIPPED
[INFO] minifi-assembly SKIPPED
[INFO] minifi-toolkit . SKIPPED
[INFO] minifi-toolkit-configuration ... SKIPPED
[INFO] minifi-toolkit-assembly SKIPPED
[INFO] minifi-docker .. SKIPPED
[INFO] minifi-c2 .. SKIPPED
[INFO] minifi-c2-api .. SKIPPED
[INFO] minifi-c2-cache SKIPPED
[INFO] minifi-c2-cache-filesystem . SKIPPED
[INFO] minifi-c2-cache-s3 . SKIPPED
[INFO] minifi-c2-provider . SKIPPED
[INFO] minifi-c2-provider-util SKIPPED
[INFO] minifi-c2-provider-cache ... SKIPPED
[INFO] minifi-c2-provider-delegating .. SKIPPED
[INFO] minifi-c2-provider-nifi-rest ... SKIPPED
[INFO] minifi-c2-service .. SKIPPED
[INFO] minifi-c2-jetty SKIPPED
[INFO] minifi-c2-assembly . SKIPPED
[INFO] minifi-c2-docker ... SKIPPED
[INFO] minifi-c2-integration-tests SKIPPED
[INFO] minifi-integration-tests
[nifi] branch master updated (421bfdd -> 1033253)
This is an automated email from the ASF dual-hosted git repository. markap14 pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/nifi.git. from 421bfdd NIFI-6919: Added relationship attribute to DistributeLoad add 1033253 NIFI-7015 - ConsumeJMS now supports ObjectMessage, MapMessage and StreamMessage types as well. Added optional ERROR_QUEUE property. Result flowfiles get a 'jms.messagetype' attribute that contains the incoming message type (TextMessage, BytesMessage, ObjectMessage, MapMessage or StreamMessage). No new revisions were added by this update. Summary of changes: .../nifi/jms/processors/AbstractJMSProcessor.java | 2 + .../org/apache/nifi/jms/processors/ConsumeJMS.java | 42 - .../apache/nifi/jms/processors/JMSConsumer.java| 43 - .../processors/MessageBodyToBytesConverter.java| 121 +- .../apache/nifi/jms/processors/ConsumeJMSIT.java | 186 + .../nifi/jms/processors/ConsumeJMSManualTest.java | 149 + .../jms/processors/JMSPublisherConsumerIT.java | 178 +++- 7 files changed, 704 insertions(+), 17 deletions(-) create mode 100644 nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/test/java/org/apache/nifi/jms/processors/ConsumeJMSManualTest.java
[jira] [Created] (MINIFI-522) Failed to execute goal on project minifi-standard-nar : Access denied to: http://jcenter.bintray.com
sapinkumar amin created MINIFI-522:
--
Summary: Failed to execute goal on project minifi-standard-nar :
Access denied to: http://jcenter.bintray.com
Key: MINIFI-522
URL: https://issues.apache.org/jira/browse/MINIFI-522
Project: Apache NiFi MiNiFi
Issue Type: Bug
Reporter: sapinkumar amin
Fix For: 0.6.0
{code:java}
mvn clean install {code}
throws below error
{code:java}
[INFO] minifi-update-attribute-nar SUCCESS [ 0.326 s]
[INFO] minifi-standard-nar FAILURE [ 1.198 s]
[INFO] minifi-ssl-context-service-nar . SKIPPED
[INFO] minifi-docs SKIPPED
[INFO] minifi-assembly SKIPPED
[INFO] minifi-toolkit . SKIPPED
[INFO] minifi-toolkit-configuration ... SKIPPED
[INFO] minifi-toolkit-assembly SKIPPED
[INFO] minifi-docker .. SKIPPED
[INFO] minifi-c2 .. SKIPPED
[INFO] minifi-c2-api .. SKIPPED
[INFO] minifi-c2-cache SKIPPED
[INFO] minifi-c2-cache-filesystem . SKIPPED
[INFO] minifi-c2-cache-s3 . SKIPPED
[INFO] minifi-c2-provider . SKIPPED
[INFO] minifi-c2-provider-util SKIPPED
[INFO] minifi-c2-provider-cache ... SKIPPED
[INFO] minifi-c2-provider-delegating .. SKIPPED
[INFO] minifi-c2-provider-nifi-rest ... SKIPPED
[INFO] minifi-c2-service .. SKIPPED
[INFO] minifi-c2-jetty SKIPPED
[INFO] minifi-c2-assembly . SKIPPED
[INFO] minifi-c2-docker ... SKIPPED
[INFO] minifi-c2-integration-tests SKIPPED
[INFO] minifi-integration-tests ... SKIPPED
[INFO]
[INFO] BUILD FAILURE
[INFO]
[INFO] Total time: 29.209 s
[INFO] Finished at: 2020-01-14T14:02:00-08:00
[INFO]
[ERROR] Failed to execute goal on project minifi-standard-nar: Could not
resolve dependencies for project
org.apache.nifi.minifi:minifi-standard-nar:nar:0.6.0-SNAPSHOT: Failed to
collect dependencies at org.apache.nifi:nifi-standard-processors:jar:1.8.0 ->
org.apache.nifi:nifi-syslog-utils:jar:1.8.0 ->
com.github.palindromicity:simple-syslog-5424:jar:0.0.8: Failed to read artifact
descriptor for com.github.palindromicity:simple-syslog-5424:jar:0.0.8: Could
not transfer artifact com.github.palindromicity:simple-syslog-5424:pom:0.0.8
from/to jcenter (http://jcenter.bintray.com): Access denied to:
http://jcenter.bintray.com/com/github/palindromicity/simple-syslog-5424/0.0.8/simple-syslog-5424-0.0.8.pom
-> [Help 1]
{code}
>From Jan13th , 2020, access to jcenter.bintray.com is only allowed over https
>protocol (previously it use to support both).
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[nifi] branch master updated: NIFI-6919: Added relationship attribute to DistributeLoad
This is an automated email from the ASF dual-hosted git repository.
mattyb149 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/master by this push:
new 421bfdd NIFI-6919: Added relationship attribute to DistributeLoad
421bfdd is described below
commit 421bfdd5fff87e477a91450f8414d7a989bd083f
Author: Michael Hogue
AuthorDate: Thu Dec 12 21:06:15 2019 -0500
NIFI-6919: Added relationship attribute to DistributeLoad
NIFI-6919: Cleaned up docs
NIFI-6919: Cleanup
NIFI-6919: Cleanup
NIFI-6919: added negative unit test
NIFI-6919: Removed unnecesary feature flag
Updated attribute description
Signed-off-by: Matthew Burgess
This closes #3939
---
.../nifi/processors/standard/DistributeLoad.java | 42 --
.../processors/standard/TestDistributeLoad.java| 29 ++-
2 files changed, 51 insertions(+), 20 deletions(-)
diff --git
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DistributeLoad.java
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DistributeLoad.java
index 8c1f9bd..57c1723 100644
---
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DistributeLoad.java
+++
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DistributeLoad.java
@@ -31,14 +31,16 @@ import java.util.concurrent.atomic.AtomicReference;
import org.apache.commons.lang3.StringUtils;
import org.apache.nifi.annotation.behavior.DynamicProperty;
+import org.apache.nifi.annotation.behavior.DynamicRelationship;
import org.apache.nifi.annotation.behavior.EventDriven;
import org.apache.nifi.annotation.behavior.InputRequirement;
+import org.apache.nifi.annotation.behavior.InputRequirement.Requirement;
import org.apache.nifi.annotation.behavior.SideEffectFree;
import org.apache.nifi.annotation.behavior.SupportsBatching;
import org.apache.nifi.annotation.behavior.TriggerWhenAnyDestinationAvailable;
-import org.apache.nifi.annotation.behavior.InputRequirement.Requirement;
+import org.apache.nifi.annotation.behavior.WritesAttribute;
+import org.apache.nifi.annotation.behavior.WritesAttributes;
import org.apache.nifi.annotation.documentation.CapabilityDescription;
-import org.apache.nifi.annotation.behavior.DynamicRelationship;
import org.apache.nifi.annotation.documentation.Tags;
import org.apache.nifi.annotation.lifecycle.OnScheduled;
import org.apache.nifi.components.PropertyDescriptor;
@@ -71,6 +73,9 @@ import org.apache.nifi.processor.util.StandardValidators;
+ "'5' will be receive 10 FlowFiles in each iteration instead of 1.")
@DynamicRelationship(name = "A number 1..",
description = "FlowFiles are sent to this relationship per the "
+ "")
+@WritesAttributes(
+@WritesAttribute(attribute = "distribute.load.relationship",
description = "The name of the specific relationship the flow file has been
routed through")
+)
public class DistributeLoad extends AbstractProcessor {
public static final String STRATEGY_ROUND_ROBIN = "round robin";
@@ -93,31 +98,26 @@ public class DistributeLoad extends AbstractProcessor {
.allowableValues(STRATEGY_ROUND_ROBIN, STRATEGY_NEXT_AVAILABLE,
STRATEGY_LOAD_DISTRIBUTION_SERVICE)
.defaultValue(STRATEGY_ROUND_ROBIN)
.build();
-
public static final PropertyDescriptor HOSTNAMES = new
PropertyDescriptor.Builder()
.name("Hostnames")
.description("List of remote servers to distribute across. Each
server must be FQDN and use either ',', ';', or [space] as a delimiter")
.required(true)
-.addValidator(new Validator() {
-
-@Override
-public ValidationResult validate(String subject, String input,
ValidationContext context) {
-ValidationResult result = new
ValidationResult.Builder().subject(subject).valid(true).input(input).explanation("Good
FQDNs").build();
-if (null == input) {
+.addValidator((subject, input, context) -> {
+ValidationResult result = new
ValidationResult.Builder().subject(subject).valid(true).input(input).explanation("Good
FQDNs").build();
+if (null == input) {
+result = new
ValidationResult.Builder().subject(subject).input(input).valid(false)
+.explanation("Need to specify delimited list of
FQDNs").build();
+return result;
+}
+String[] hostNames = input.split("(?:,+|;+|\\s+)");
+for (String hostName : hostNames) {
+if (StringUtils.isNotBlank(hostName) &&
!host
[nifi] branch master updated (2601f72 -> 824cc0e)
This is an automated email from the ASF dual-hosted git repository. joewitt pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/nifi.git. from 2601f72 NIFI-6998 This closes #3972. Batch & Partitioning key + Asynchronous sending in limited batches + Property to determine attribute name carrying partitioning key + Maximum batch size property + Carrier object - Unit test fakery NIFI-6998 Attributes to User Defined properties NIFI-6998 Unit tests NIFI-6998 Review corrections + Interruption propagation (& test) + Final carrier members + Unnecessary generic modifiers removed from generic container NIFI-6998 checkstyle correc [...] new eb37e74 NIFI-6902 Update PrometheusReportingTask to supply correct fields for OutputPort new 6dbcf9d NIFI-6902: This closes #3986. Added unit test for original author's patch new 824cc0e NIFI-7014: This closes #3985. Add RecordReader/Writer access in ExecuteGroovyScript The 3 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../nifi-groovyx-processors/pom.xml| 17 ++ .../processors/groovyx/ExecuteGroovyScript.java| 65 -- .../additionalDetails.html | 12 .../groovyx/ExecuteGroovyScriptTest.java | 44 +++ .../groovy/test_record_reader_writer.groovy| 45 +++ .../prometheus/api/PrometheusMetricsUtil.java | 2 +- .../prometheus/TestPrometheusReportingTask.java| 10 7 files changed, 177 insertions(+), 18 deletions(-) create mode 100644 nifi-nar-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/test/resources/groovy/test_record_reader_writer.groovy
[nifi] 01/03: NIFI-6902 Update PrometheusReportingTask to supply correct fields for OutputPort
This is an automated email from the ASF dual-hosted git repository.
joewitt pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git
commit eb37e7475f9e8473f3cbc64dc5fba1e086bfa417
Author: Tom
AuthorDate: Fri Nov 22 23:48:37 2019 +
NIFI-6902 Update PrometheusReportingTask to supply correct fields for
OutputPort
---
.../org/apache/nifi/reporting/prometheus/api/PrometheusMetricsUtil.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/nifi-nar-bundles/nifi-prometheus-bundle/nifi-prometheus-reporting-task/src/main/java/org/apache/nifi/reporting/prometheus/api/PrometheusMetricsUtil.java
b/nifi-nar-bundles/nifi-prometheus-bundle/nifi-prometheus-reporting-task/src/main/java/org/apache/nifi/reporting/prometheus/api/PrometheusMetricsUtil.java
index 1437239..91a54a0 100644
---
a/nifi-nar-bundles/nifi-prometheus-bundle/nifi-prometheus-reporting-task/src/main/java/org/apache/nifi/reporting/prometheus/api/PrometheusMetricsUtil.java
+++
b/nifi-nar-bundles/nifi-prometheus-bundle/nifi-prometheus-reporting-task/src/main/java/org/apache/nifi/reporting/prometheus/api/PrometheusMetricsUtil.java
@@ -480,7 +480,7 @@ public class PrometheusMetricsUtil {
final String parentId = portStatus.getGroupId();
final String portComponentType = "OutputPort";
AMOUNT_FLOWFILES_SENT.labels(instanceId, portComponentType,
portComponentName, portComponentId,
parentId).set(portStatus.getFlowFilesSent());
-AMOUNT_FLOWFILES_RECEIVED.labels(instanceId,
portComponentType, portComponentName,
portComponentId).set(portStatus.getFlowFilesReceived());
+AMOUNT_FLOWFILES_RECEIVED.labels(instanceId,
portComponentType, portComponentName, portComponentId,
parentId).set(portStatus.getFlowFilesReceived());
AMOUNT_BYTES_SENT.labels(instanceId, portComponentType,
portComponentName, portComponentId, parentId).set(portStatus.getBytesSent());
AMOUNT_BYTES_READ.labels(instanceId, portComponentType,
portComponentName, portComponentId, parentId).set(portStatus.getInputBytes());
[nifi] 02/03: NIFI-6902: This closes #3986. Added unit test for original author's patch
This is an automated email from the ASF dual-hosted git repository.
joewitt pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git
commit 6dbcf9d521cbda499877dce30c41602b66496ec8
Author: Matthew Burgess
AuthorDate: Tue Jan 14 10:49:25 2020 -0500
NIFI-6902: This closes #3986. Added unit test for original author's patch
Signed-off-by: Joe Witt
---
.../nifi/reporting/prometheus/TestPrometheusReportingTask.java | 10 ++
1 file changed, 10 insertions(+)
diff --git
a/nifi-nar-bundles/nifi-prometheus-bundle/nifi-prometheus-reporting-task/src/test/java/org/apache/nifi/reporting/prometheus/TestPrometheusReportingTask.java
b/nifi-nar-bundles/nifi-prometheus-bundle/nifi-prometheus-reporting-task/src/test/java/org/apache/nifi/reporting/prometheus/TestPrometheusReportingTask.java
index aef9e0c..b39d757 100644
---
a/nifi-nar-bundles/nifi-prometheus-bundle/nifi-prometheus-reporting-task/src/test/java/org/apache/nifi/reporting/prometheus/TestPrometheusReportingTask.java
+++
b/nifi-nar-bundles/nifi-prometheus-bundle/nifi-prometheus-reporting-task/src/test/java/org/apache/nifi/reporting/prometheus/TestPrometheusReportingTask.java
@@ -27,7 +27,9 @@ import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.util.EntityUtils;
+import org.apache.nifi.controller.status.PortStatus;
import org.apache.nifi.controller.status.ProcessGroupStatus;
+import org.apache.nifi.controller.status.RunStatus;
import org.apache.nifi.reporting.InitializationException;
import org.apache.nifi.reporting.prometheus.api.PrometheusMetricsUtil;
import org.apache.nifi.state.MockStateManager;
@@ -83,6 +85,14 @@ public class TestPrometheusReportingTask {
rootGroupStatus.setOutputCount(100);
rootGroupStatus.setInputCount(1000);
+PortStatus outputPortStatus = new PortStatus();
+outputPortStatus.setId("9876");
+outputPortStatus.setName("out");
+outputPortStatus.setGroupId("1234");
+outputPortStatus.setRunStatus(RunStatus.Stopped);
+outputPortStatus.setActiveThreadCount(1);
+
+
rootGroupStatus.setOutputPortStatus(Collections.singletonList(outputPortStatus));
}
@Test
[nifi] 03/03: NIFI-7014: This closes #3985. Add RecordReader/Writer access in ExecuteGroovyScript
This is an automated email from the ASF dual-hosted git repository.
joewitt pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git
commit 824cc0ed77b93d69a33358b1e8323102f30837ff
Author: Matthew Burgess
AuthorDate: Tue Jan 14 09:56:43 2020 -0500
NIFI-7014: This closes #3985. Add RecordReader/Writer access in
ExecuteGroovyScript
Signed-off-by: Joe Witt
---
.../nifi-groovyx-processors/pom.xml| 17 ++
.../processors/groovyx/ExecuteGroovyScript.java| 65 --
.../additionalDetails.html | 12
.../groovyx/ExecuteGroovyScriptTest.java | 44 +++
.../groovy/test_record_reader_writer.groovy| 45 +++
5 files changed, 166 insertions(+), 17 deletions(-)
diff --git
a/nifi-nar-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/pom.xml
b/nifi-nar-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/pom.xml
index 94589bd..3adefbc 100644
--- a/nifi-nar-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/pom.xml
+++ b/nifi-nar-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/pom.xml
@@ -37,6 +37,11 @@
1.11.0-SNAPSHOT
+org.apache.nifi
+nifi-record-serialization-service-api
+1.11.0-SNAPSHOT
+
+
org.codehaus.groovy
groovy-json
${nifi.groovy.version}
@@ -66,6 +71,18 @@
test
+org.apache.nifi
+nifi-record
+1.11.0-SNAPSHOT
+test
+
+
+org.apache.nifi
+nifi-mock-record-utils
+1.11.0-SNAPSHOT
+test
+
+
org.apache.derby
derby
10.12.1.1
diff --git
a/nifi-nar-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/ExecuteGroovyScript.java
b/nifi-nar-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/ExecuteGroovyScript.java
index f67df2b..5516aeb 100644
---
a/nifi-nar-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/ExecuteGroovyScript.java
+++
b/nifi-nar-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/ExecuteGroovyScript.java
@@ -46,6 +46,8 @@ import
org.apache.nifi.processors.groovyx.flow.GroovyProcessSessionWrap;
import org.apache.nifi.processors.groovyx.sql.OSql;
import org.apache.nifi.processors.groovyx.util.Files;
import org.apache.nifi.processors.groovyx.util.Validators;
+import org.apache.nifi.serialization.RecordReaderFactory;
+import org.apache.nifi.serialization.RecordSetWriterFactory;
import org.codehaus.groovy.control.CompilerConfiguration;
import org.codehaus.groovy.runtime.ResourceGroovyMethods;
import org.codehaus.groovy.runtime.StackTraceUtils;
@@ -80,8 +82,9 @@ import java.util.Set;
@DynamicProperty(name = "A script engine property to update",
value = "The value to set it to",
expressionLanguageScope = ExpressionLanguageScope.FLOWFILE_ATTRIBUTES,
-description = "Updates a script engine property specified by the
Dynamic Property's key with the value "
-+ "specified by the Dynamic Property's value. Use `CTL.` to
access any controller services.")
+description = "Updates a script engine property specified by the
Dynamic Property's key with the value specified by the Dynamic Property's
value. "
++ "Use `CTL.` to access any controller services, `SQL.` to
access any DBCPServices, `RecordReader.` to access RecordReaderFactory
instances, or "
++ "`RecordWriter.` to access any RecordSetWriterFactory
instances.")
public class ExecuteGroovyScript extends AbstractProcessor {
public static final String GROOVY_CLASSPATH = "${groovy.classes.path}";
@@ -335,9 +338,8 @@ public class ExecuteGroovyScript extends AbstractProcessor {
/**
* init SQL variables from DBCP services
*/
-@SuppressWarnings("unchecked")
-private void onInitSQL(HashMap SQL) throws SQLException {
-for (Map.Entry e : (Set) SQL.entrySet()) {
+private void onInitSQL(Map SQL) throws SQLException {
+for (Map.Entry e : SQL.entrySet()) {
DBCPService s = (DBCPService) e.getValue();
OSql sql = new OSql(s.getConnection(Collections.emptyMap()));
//try to set autocommit to false
@@ -355,9 +357,8 @@ public class ExecuteGroovyScript extends AbstractProcessor {
/**
* before commit SQL services
*/
-@SuppressWarnings("unchecked")
-private void onCommitSQL(HashMap SQL) throws SQLException {
-for (Map.Entry e : (Set) SQL.entrySet()) {
+private void onCommitSQL(Map SQL) throws SQLException {
+for (Map.Entry e : SQL.entrySet()) {
OSql sql = (OSql) e.getVal
[nifi-minifi-cpp] branch master updated (6e2f859 -> 14dcab2)
This is an automated email from the ASF dual-hosted git repository.
aboda pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git.
from 6e2f859 MINIFICPP-1022 - Refactored third party build system
add 14dcab2 MINIFICPP-1117 - minifi::Exception is now nothrow copyable
No new revisions were added by this update.
Summary of changes:
.../tests/integration/SecureSocketGetTCPTest.cpp | 4 +-
.../tests/unit/ProcessorTests.cpp | 2 +-
libminifi/include/Exception.h | 38 ++--
libminifi/include/utils/StringUtils.h | 103 -
.../test/unit/{Tests.cpp => ExceptionTests.cpp}| 7 +-
libminifi/test/unit/StringUtilsTests.cpp | 26 ++
6 files changed, 143 insertions(+), 37 deletions(-)
copy libminifi/test/unit/{Tests.cpp => ExceptionTests.cpp} (76%)
