[jira] [Commented] (NIFI-5955) Provide a Docker HEALTHCHECK

2020-12-16 Thread Ruben Laguna (Jira)


[ 
https://issues.apache.org/jira/browse/NIFI-5955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250872#comment-17250872
 ] 

Ruben Laguna commented on NIFI-5955:


The problem with this kind of healthcheck (/nifi) is that the UI may be up (GET 
/nifi 200 OK) but the UI may still be unusable (for example the UI is a node 
that is disconnected from the cluster). In  [NIFI-8100] I've requested a 
healthcheck endpoint that signals that the node is actually ready and healthy 
so that it can be used by external  load balancers, but I guess I would be also 
good to use that new endpoint for the docker healthcheck. 

> Provide a Docker HEALTHCHECK
> 
>
> Key: NIFI-5955
> URL: https://issues.apache.org/jira/browse/NIFI-5955
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Docker
>Reporter: Anthony Mastrean
>Priority: Minor
>  Time Spent: 4h 20m
>  Remaining Estimate: 0h
>
> It takes Nifi a noticeable amount of time to become available at 
> [http://localhost:8080/nifi.] We can help indicate readiness to both human 
> and machine users (see 
> [depends_on|https://docs.docker.com/compose/compose-file/compose-file-v2/#depends_on]
>  in Compose) by establishing a HEALTHCHECK in the Dockerfile.
> The 
> [documentation|https://docs.docker.com/engine/reference/builder/#healthcheck] 
> suggests
> {code:java}
> HEALTHCHECK CMD curl -f http://localhost:8080/nifi || exit 1{code}
>  
> But, there are [better cURL 
> flags|https://explainshell.com/explain?cmd=curl+-fsSL+example.org] for 
> scripts.
> {code:java}
> HEALTHCHECK CMD curl -fsSL http://localhost:8080/nifi || exit 1
> {code}
>  
> And I sometimes see problems using {{localhost}} (possibly a Docker 
> networking issue?). I've seen this pattern suggested elsewhere. 
> {code:java}
> HEALTHCHECK CMD curl -fsSL http://$(hostname -i || echo localhost):8080/nifi 
> || exit 1
> {code}
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (NIFI-8100) Provide a /health endpoint that do not require authentication for use in LoadBalancer (nifi UI)

2020-12-16 Thread Ruben Laguna (Jira)


 [ 
https://issues.apache.org/jira/browse/NIFI-8100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ruben Laguna updated NIFI-8100:
---
Description: 
Usually load balancers with AWS Application Load Balancer use periodic health 
checks to determine which node it should forward requests to. 

Today we have the /status api endpoint but that is not suitable because it 
really requires authentication on a secure nifi installation and there is no 
way to provide authorization headers in the health checks performed by load 
balancers. 

So I would like to have a /heath or /health-check endpoint that can be "open" 
that answers 200 OK *when the node is connected to the cluster and a 4xx-5xx 
error if the node is disconnected* ("Only a node connected to a cluster can 
process the request", "This node is currently not connect to the cluster. Any 
modifications to the data flow made here will not replicate across the 
cluster"). 

This will simplify secure nifi deployment with load balancing, right now if a 
node gets disconnected users will be still be routed to it even if that node is 
really not usable. 

Here I'm referring to *Load balancer for the NiFi web UI*, and  just checking 
for / or /nifi is not good enough because t he UI may be up (GET / 200OK) but 
not usable (the node is disconnected from the cluster). 

  was:
Usually load balancers with AWS Application Load Balancer use periodic health 
checks to determine which node it should forward requests to. 

Today we have the /status api endpoint but that is not suitable because it 
really requires authentication on a secure nifi installation and there is no 
way to provide authorization headers in the health checks performed by load 
balancers. 

So I would like to have a /heath or /health-check endpoint that can be "open" 
that answers 200 OK *when the node is connected to the cluster and a 4xx-5xx 
error if the node is disconnected* ("Only a node connected to a cluster can 
process the request", "This node is currently not connect to the cluster. Any 
modifications to the data flow made here will not replicate across the 
cluster"). 

This will simplify secure nifi deployment with load balancing, right now if a 
node gets disconnected users will be still be routed to it even if that node is 
really not usable. 


> Provide a /health endpoint that do not require authentication for use in 
> LoadBalancer (nifi UI)
> ---
>
> Key: NIFI-8100
> URL: https://issues.apache.org/jira/browse/NIFI-8100
> Project: Apache NiFi
>  Issue Type: Bug
>Reporter: Ruben Laguna
>Priority: Major
>
> Usually load balancers with AWS Application Load Balancer use periodic health 
> checks to determine which node it should forward requests to. 
> Today we have the /status api endpoint but that is not suitable because it 
> really requires authentication on a secure nifi installation and there is no 
> way to provide authorization headers in the health checks performed by load 
> balancers. 
> So I would like to have a /heath or /health-check endpoint that can be "open" 
> that answers 200 OK *when the node is connected to the cluster and a 4xx-5xx 
> error if the node is disconnected* ("Only a node connected to a cluster can 
> process the request", "This node is currently not connect to the cluster. Any 
> modifications to the data flow made here will not replicate across the 
> cluster"). 
> This will simplify secure nifi deployment with load balancing, right now if a 
> node gets disconnected users will be still be routed to it even if that node 
> is really not usable. 
> Here I'm referring to *Load balancer for the NiFi web UI*, and  just checking 
> for / or /nifi is not good enough because t he UI may be up (GET / 200OK) but 
> not usable (the node is disconnected from the cluster). 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (NIFI-8100) Provide a /health endpoint that do not require authentication for use in LoadBalancer (nifi UI)

2020-12-16 Thread Ruben Laguna (Jira)


 [ 
https://issues.apache.org/jira/browse/NIFI-8100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ruben Laguna updated NIFI-8100:
---
Summary: Provide a /health endpoint that do not require authentication for 
use in LoadBalancer (nifi UI)  (was: Provide a /health endpoint that do not 
require authentication for use in LoadBalancer)

> Provide a /health endpoint that do not require authentication for use in 
> LoadBalancer (nifi UI)
> ---
>
> Key: NIFI-8100
> URL: https://issues.apache.org/jira/browse/NIFI-8100
> Project: Apache NiFi
>  Issue Type: Bug
>Reporter: Ruben Laguna
>Priority: Major
>
> Usually load balancers with AWS Application Load Balancer use periodic health 
> checks to determine which node it should forward requests to. 
> Today we have the /status api endpoint but that is not suitable because it 
> really requires authentication on a secure nifi installation and there is no 
> way to provide authorization headers in the health checks performed by load 
> balancers. 
> So I would like to have a /heath or /health-check endpoint that can be "open" 
> that answers 200 OK *when the node is connected to the cluster and a 4xx-5xx 
> error if the node is disconnected* ("Only a node connected to a cluster can 
> process the request", "This node is currently not connect to the cluster. Any 
> modifications to the data flow made here will not replicate across the 
> cluster"). 
> This will simplify secure nifi deployment with load balancing, right now if a 
> node gets disconnected users will be still be routed to it even if that node 
> is really not usable. 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (NIFI-8100) Provide a /health endpoint that do not require authentication for use in LoadBalancer

2020-12-16 Thread Ruben Laguna (Jira)


 [ 
https://issues.apache.org/jira/browse/NIFI-8100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ruben Laguna updated NIFI-8100:
---
Description: 
Usually load balancers with AWS Application Load Balancer use periodic health 
checks to determine which node it should forward requests to. 

Today we have the /status api endpoint but that is not suitable because it 
really requires authentication on a secure nifi installation and there is no 
way to provide authorization headers in the health checks performed by load 
balancers. 

So I would like to have a /heath or /health-check endpoint that can be "open" 
that answers 200 OK* when the node is connected to the cluster and a 4xx-5xx 
error if the node is disconnected *("Only a node connected to a cluster can 
process the request", "This node is currently not connect to the cluster. Any 
modifications to the data flow made here will not replicate across the 
cluster"). 

This will simplify secure nifi deployment with load balancing, right now if a 
node gets disconnected users will be still be routed to it even if that node is 
really not usable. 

  was:
Usually load balancers with AWS Application Load Balancer use periodic health 
checks to determine which node it should forward requests to. 

Today we have the /status api endpoint but that is not suitable because it 
really requires authentication on a secure nifi installation and there is no 
way to provide authorization headers in the health checks performed by load 
balancers. 

So I would like to have a /heath or /health-check endpoint that can be "open" 
that answers 200 OK when the node is connected to the cluster and a 4xx-5xx 
error if the node is disconnected ("Only a node connected to a cluster can 
process the request", "This node is currently not connect to the cluster. Any 
modifications to the data flow made here will not replicate across the 
cluster"). 

This will simplify secure nifi deployment with load balancing, right now if a 
node gets disconnected users will be still be routed to it even if that node is 
really not usable. 


> Provide a /health endpoint that do not require authentication for use in 
> LoadBalancer
> -
>
> Key: NIFI-8100
> URL: https://issues.apache.org/jira/browse/NIFI-8100
> Project: Apache NiFi
>  Issue Type: Bug
>Reporter: Ruben Laguna
>Priority: Major
>
> Usually load balancers with AWS Application Load Balancer use periodic health 
> checks to determine which node it should forward requests to. 
> Today we have the /status api endpoint but that is not suitable because it 
> really requires authentication on a secure nifi installation and there is no 
> way to provide authorization headers in the health checks performed by load 
> balancers. 
> So I would like to have a /heath or /health-check endpoint that can be "open" 
> that answers 200 OK* when the node is connected to the cluster and a 4xx-5xx 
> error if the node is disconnected *("Only a node connected to a cluster can 
> process the request", "This node is currently not connect to the cluster. Any 
> modifications to the data flow made here will not replicate across the 
> cluster"). 
> This will simplify secure nifi deployment with load balancing, right now if a 
> node gets disconnected users will be still be routed to it even if that node 
> is really not usable. 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (NIFI-8100) Provide a /health endpoint that do not require authentication for use in LoadBalancer

2020-12-16 Thread Ruben Laguna (Jira)


 [ 
https://issues.apache.org/jira/browse/NIFI-8100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ruben Laguna updated NIFI-8100:
---
Description: 
Usually load balancers with AWS Application Load Balancer use periodic health 
checks to determine which node it should forward requests to. 

Today we have the /status api endpoint but that is not suitable because it 
really requires authentication on a secure nifi installation and there is no 
way to provide authorization headers in the health checks performed by load 
balancers. 

So I would like to have a /heath or /health-check endpoint that can be "open" 
that answers 200 OK *when the node is connected to the cluster and a 4xx-5xx 
error if the node is disconnected* ("Only a node connected to a cluster can 
process the request", "This node is currently not connect to the cluster. Any 
modifications to the data flow made here will not replicate across the 
cluster"). 

This will simplify secure nifi deployment with load balancing, right now if a 
node gets disconnected users will be still be routed to it even if that node is 
really not usable. 

  was:
Usually load balancers with AWS Application Load Balancer use periodic health 
checks to determine which node it should forward requests to. 

Today we have the /status api endpoint but that is not suitable because it 
really requires authentication on a secure nifi installation and there is no 
way to provide authorization headers in the health checks performed by load 
balancers. 

So I would like to have a /heath or /health-check endpoint that can be "open" 
that answers 200 OK* when the node is connected to the cluster and a 4xx-5xx 
error if the node is disconnected *("Only a node connected to a cluster can 
process the request", "This node is currently not connect to the cluster. Any 
modifications to the data flow made here will not replicate across the 
cluster"). 

This will simplify secure nifi deployment with load balancing, right now if a 
node gets disconnected users will be still be routed to it even if that node is 
really not usable. 


> Provide a /health endpoint that do not require authentication for use in 
> LoadBalancer
> -
>
> Key: NIFI-8100
> URL: https://issues.apache.org/jira/browse/NIFI-8100
> Project: Apache NiFi
>  Issue Type: Bug
>Reporter: Ruben Laguna
>Priority: Major
>
> Usually load balancers with AWS Application Load Balancer use periodic health 
> checks to determine which node it should forward requests to. 
> Today we have the /status api endpoint but that is not suitable because it 
> really requires authentication on a secure nifi installation and there is no 
> way to provide authorization headers in the health checks performed by load 
> balancers. 
> So I would like to have a /heath or /health-check endpoint that can be "open" 
> that answers 200 OK *when the node is connected to the cluster and a 4xx-5xx 
> error if the node is disconnected* ("Only a node connected to a cluster can 
> process the request", "This node is currently not connect to the cluster. Any 
> modifications to the data flow made here will not replicate across the 
> cluster"). 
> This will simplify secure nifi deployment with load balancing, right now if a 
> node gets disconnected users will be still be routed to it even if that node 
> is really not usable. 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (NIFI-8101) Improvement PutDatabaseRecord for refresh table schema cache

2020-12-16 Thread ZhangCheng (Jira)


 [ 
https://issues.apache.org/jira/browse/NIFI-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

ZhangCheng updated NIFI-8101:
-
Description: 
* Sometimes,  the target table has changed and the `PutDatabaseRecord` cached 
outdated  table schema informatiion.  Maybe we need a new property to tell the 
`PutDatabaseRecord` to refresh the table schema cache under certain conditions. 

 
 

  was:Sometimes,  the target table has changed and 


> Improvement  PutDatabaseRecord for refresh table schema cache
> -
>
> Key: NIFI-8101
> URL: https://issues.apache.org/jira/browse/NIFI-8101
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Extensions
>Reporter: ZhangCheng
>Assignee: ZhangCheng
>Priority: Major
>
> * Sometimes,  the target table has changed and the `PutDatabaseRecord` cached 
> outdated  table schema informatiion.  Maybe we need a new property to tell 
> the `PutDatabaseRecord` to refresh the table schema cache under certain 
> conditions. 
>  
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (NIFI-8101) Improvement PutDatabaseRecord for refresh table schema cache

2020-12-16 Thread ZhangCheng (Jira)


 [ 
https://issues.apache.org/jira/browse/NIFI-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

ZhangCheng updated NIFI-8101:
-
Description: Sometimes,  the target table has changed and 

> Improvement  PutDatabaseRecord for refresh table schema cache
> -
>
> Key: NIFI-8101
> URL: https://issues.apache.org/jira/browse/NIFI-8101
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Extensions
>Reporter: ZhangCheng
>Assignee: ZhangCheng
>Priority: Major
>
> Sometimes,  the target table has changed and 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Created] (NIFI-8101) Improvement PutDatabaseRecord for refresh table schema cache

2020-12-16 Thread ZhangCheng (Jira)
ZhangCheng created NIFI-8101:


 Summary: Improvement  PutDatabaseRecord for refresh table schema 
cache
 Key: NIFI-8101
 URL: https://issues.apache.org/jira/browse/NIFI-8101
 Project: Apache NiFi
  Issue Type: Improvement
  Components: Extensions
Reporter: ZhangCheng
Assignee: ZhangCheng






--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[GitHub] [nifi] markobean commented on pull request #4225: NIFI-7387: ComponentLog accepts Object varargs instead of array

2020-12-16 Thread GitBox


markobean commented on pull request #4225:
URL: https://github.com/apache/nifi/pull/4225#issuecomment-747155013


   Looking for a committer for this one. @markap14, any remaining issues? If 
not, please merge. Appreciate it! 
   Thanks!



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi] exceptionfactory opened a new pull request #4734: NIFI-8023 Added toLocalDate() and updated toDate() in DataTypeUtils

2020-12-16 Thread GitBox


exceptionfactory opened a new pull request #4734:
URL: https://github.com/apache/nifi/pull/4734


    Description of PR
   
   NIFI-8023 Added `DataTypeUtils.toLocalDate()` method for use in 
`AvroTypeUtil` to determine epoch days when logical date types enabled.
   
   Updated `DataTypeUtils.toDate()` with new `parseDate()` method that 
evaluates the format pattern of `java.text.SimpleDateFormat` to determine 
whether a Time Zone field `Z` is present in the pattern.  This conditional 
adjustment is necessary because absence of the Time Zone Field in a 
`java.text.SimpleDateFormat` pattern definition produces different results 
depending on the system time zone configuration.
   
   This approach resolves a latent issue when using the 
`DataTypeUtils.toDate()` method to parse a string that does not contain any 
time zone information.  Changes to `DataTypeUtils.toDate()` and updates to unit 
tests in referencing classes indicate the expected behavior.
   
   In order to streamline the review of the contribution we ask you
   to ensure the following steps have been taken:
   
   ### For all changes:
   - [X] Is there a JIRA ticket associated with this PR? Is it referenced 
in the commit message?
   
   - [X] Does your PR title start with **NIFI-** where  is the JIRA 
number you are trying to resolve? Pay particular attention to the hyphen "-" 
character.
   
   - [X] Has your PR been rebased against the latest commit within the target 
branch (typically `main`)?
   
   - [X] Is your initial contribution a single, squashed commit? _Additional 
commits in response to PR reviewer feedback should be made on this branch and 
pushed to allow change tracking. Do not `squash` or use `--force` when pushing 
to allow for clean monitoring of changes._
   
   ### For code changes:
   - [X] Have you ensured that the full suite of tests is executed via `mvn 
-Pcontrib-check clean install` at the root `nifi` folder?
   - [X] Have you written or updated unit tests to verify your changes?
   - [ ] Have you verified that the full build is successful on JDK 8?
   - [X] Have you verified that the full build is successful on JDK 11?
   - [ ] If adding new dependencies to the code, are these dependencies 
licensed in a way that is compatible for inclusion under [ASF 
2.0](http://www.apache.org/legal/resolved.html#category-a)? 
   - [ ] If applicable, have you updated the `LICENSE` file, including the main 
`LICENSE` file under `nifi-assembly`?
   - [ ] If applicable, have you updated the `NOTICE` file, including the main 
`NOTICE` file found under `nifi-assembly`?
   - [ ] If adding new Properties, have you added `.displayName` in addition to 
.name (programmatic access) for each of the new properties?
   
   ### For documentation related changes:
   - [ ] Have you ensured that format looks appropriate for the output in which 
it is rendered?
   
   ### Note:
   Please ensure that once the PR is submitted, you check GitHub Actions CI for 
build issues and submit an update to your PR as soon as possible.
   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi] jfrazee commented on pull request #4216: NIFI-7356 Enable TLS for embedded Zookeeper when NiFi has TLS enabled

2020-12-16 Thread GitBox


jfrazee commented on pull request #4216:
URL: https://github.com/apache/nifi/pull/4216#issuecomment-747127701


   @thenatog That sounds good to me. I feel like this could end up looking 
different with the annotation you created to inject NiFiProperties, or maybe 
something similar would make sense here. It's been a while since I looked at 
this though.



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[jira] [Commented] (NIFI-7386) AzureStorageCredentialsControllerService should also connect to storage emulator

2020-12-16 Thread ASF subversion and git services (Jira)


[ 
https://issues.apache.org/jira/browse/NIFI-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250707#comment-17250707
 ] 

ASF subversion and git services commented on NIFI-7386:
---

Commit 942030579a055b568eef9de2849e804ad034f174 in nifi's branch 
refs/heads/main from sjyang18
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=9420305 ]

NIFI-7386 Added Azure Azurite emulator credentials service

This closes #4286

Signed-off-by: Joey Frazee 


> AzureStorageCredentialsControllerService should also connect to storage 
> emulator
> 
>
> Key: NIFI-7386
> URL: https://issues.apache.org/jira/browse/NIFI-7386
> Project: Apache NiFi
>  Issue Type: New Feature
>Reporter: Eric Secules
>Assignee: Seokwon Yang
>Priority: Major
>  Time Spent: 2h
>  Remaining Estimate: 0h
>
> The controller service "AzureStorageCredentialsControllerService" should be 
> able to take an optional parameter to connect to another azure storage 
> provider, like the [Azurite 
> emulator|https://hub.docker.com/_/microsoft-azure-storage-azurite]. This will 
> likely mean taking additional parameters for a base URL and possibly 
> switching between http and https depending on Azurite's capabilities.
> I am currently setting up an isolated test environment for my application and 
> the only piece that I cannot effectively isolate is our azure storage 
> connection because NiFi doesn't support connecting to anything but the 
> official azure storage service.
> *Acceptance Criteria:*
>  * AzureStorageCredentialsControllerService can connect to an alternative 
> azure storage provider
>  * Individual azure storage processors can connect to an alternative azure 
> storage provider
>  * New parameters will be optional and default to existing behaviour.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[GitHub] [nifi] jfrazee closed pull request #4286: NIFI-7386: Azurite emulator support

2020-12-16 Thread GitBox


jfrazee closed pull request #4286:
URL: https://github.com/apache/nifi/pull/4286


   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[jira] [Updated] (NIFI-8067) Fix 1-way SSL in GRPC processors

2020-12-16 Thread Peter Turcsanyi (Jira)


 [ 
https://issues.apache.org/jira/browse/NIFI-8067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Peter Turcsanyi updated NIFI-8067:
--
Status: Patch Available  (was: Open)

> Fix 1-way SSL in GRPC processors
> 
>
> Key: NIFI-8067
> URL: https://issues.apache.org/jira/browse/NIFI-8067
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Extensions
>Affects Versions: 1.12.1
>Reporter: Peter Turcsanyi
>Assignee: Peter Turcsanyi
>Priority: Major
>  Time Spent: 10m
>  Remaining Estimate: 0h
>
> 1-way SSL is broken due to a change in NIFI-7407: 
> SslContextFactory.createSslContext() checks that the truststore must be given 
> when the keystore is given, but the presence of the truststore would turn on 
> 2-way SSL. For this reason 1-way SSL cannot be configured currently.
> The previous behavior can be restored by refactoring to remove the call to 
> createSslContext() and removing the unnecessary references to 
> SSLContext.getProvider().



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[GitHub] [nifi] turcsanyip opened a new pull request #4733: NIFI-8067: Fix 1-way SSL in GRPC processors

2020-12-16 Thread GitBox


turcsanyip opened a new pull request #4733:
URL: https://github.com/apache/nifi/pull/4733


   https://issues.apache.org/jira/browse/NIFI-8067
   
   In order to streamline the review of the contribution we ask you
   to ensure the following steps have been taken:
   
   ### For all changes:
   - [ ] Is there a JIRA ticket associated with this PR? Is it referenced 
in the commit message?
   
   - [ ] Does your PR title start with **NIFI-** where  is the JIRA 
number you are trying to resolve? Pay particular attention to the hyphen "-" 
character.
   
   - [ ] Has your PR been rebased against the latest commit within the target 
branch (typically `main`)?
   
   - [ ] Is your initial contribution a single, squashed commit? _Additional 
commits in response to PR reviewer feedback should be made on this branch and 
pushed to allow change tracking. Do not `squash` or use `--force` when pushing 
to allow for clean monitoring of changes._
   
   ### For code changes:
   - [ ] Have you ensured that the full suite of tests is executed via `mvn 
-Pcontrib-check clean install` at the root `nifi` folder?
   - [ ] Have you written or updated unit tests to verify your changes?
   - [ ] Have you verified that the full build is successful on JDK 8?
   - [ ] Have you verified that the full build is successful on JDK 11?
   - [ ] If adding new dependencies to the code, are these dependencies 
licensed in a way that is compatible for inclusion under [ASF 
2.0](http://www.apache.org/legal/resolved.html#category-a)? 
   - [ ] If applicable, have you updated the `LICENSE` file, including the main 
`LICENSE` file under `nifi-assembly`?
   - [ ] If applicable, have you updated the `NOTICE` file, including the main 
`NOTICE` file found under `nifi-assembly`?
   - [ ] If adding new Properties, have you added `.displayName` in addition to 
.name (programmatic access) for each of the new properties?
   
   ### For documentation related changes:
   - [ ] Have you ensured that format looks appropriate for the output in which 
it is rendered?
   
   ### Note:
   Please ensure that once the PR is submitted, you check GitHub Actions CI for 
build issues and submit an update to your PR as soon as possible.
   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] lordgamez commented on pull request #962: MINIFICPP-1441 Specify Lua version in Mac CI builds

2020-12-16 Thread GitBox


lordgamez commented on pull request #962:
URL: https://github.com/apache/nifi-minifi-cpp/pull/962#issuecomment-747075684


   Unfortunately there is no appropriate sol2 version for us that supports Lua 
5.4, only the latest release which would require c++17 support, so we still 
need to downgrade to Lua 5.3



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] lordgamez closed pull request #963: MINIFICPP-1442 Uplift sol2 from version 2.20.0 to 2.20.6

2020-12-16 Thread GitBox


lordgamez closed pull request #963:
URL: https://github.com/apache/nifi-minifi-cpp/pull/963


   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] lordgamez edited a comment on pull request #963: MINIFICPP-1442 Uplift sol2 from version 2.20.0 to 2.20.6

2020-12-16 Thread GitBox


lordgamez edited a comment on pull request #963:
URL: https://github.com/apache/nifi-minifi-cpp/pull/963#issuecomment-747074012


   Summary of the issue from what I gathered:
   
   - There are incompatible changes between the Lua 5.3 and 5.4 API that causes 
the build failure, see 8.3 of the [Lua 5.4 
reference](https://www.lua.org/manual/5.4/manual.html)
   - Even though sol2 library bumped the valid Lua version to 5.4 in sol2 
2.20.3 it was just [experimental ](https://github.com/ThePhD/sol2/issues/649)it 
does not guarantee compatibility.
   - Lua 5.4 compatibility was introduced in sol2 v3.2.0, but sol2 v3.0+ 
versions make use of the c++17 and c++20 language feature and thus requires GCC 
7.x.x and Clang 3.9.x compilers. Because of this we cannot upgrade to that 
version.
   
   We need to revisit the upgrade after we reach the required compiler version. 
Until then I do not see any advantage of the version upgrade.



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] lordgamez commented on pull request #963: MINIFICPP-1442 Uplift sol2 from version 2.20.0 to 2.20.6

2020-12-16 Thread GitBox


lordgamez commented on pull request #963:
URL: https://github.com/apache/nifi-minifi-cpp/pull/963#issuecomment-747074012


   Summary of the issue from what I gathered:
   
   - There are incompatible changes between the Lua 5.3 and 5.4 API that causes 
the build failure see 8.3 of the [Lua 5.4 
reference](https://www.lua.org/manual/5.4/manual.html)
   - Even though sol2 library bumped the valid Lua version to 5.4 in sol2 
2.20.3 it was just [experimental ](https://github.com/ThePhD/sol2/issues/649)it 
does not guarantee compatibility.
   - Lua 5.4 compatibility was introduced in sol2 v3.2.0, but sol2 v3.0+ 
versions make use of the c++17 and c++20 language feature and thus requires GCC 
7.x.x and Clang 3.9.x compilers. Because of this we cannot upgrade to that 
version.
   
   We need to revisit the upgrade after we reach the required compiler version. 
Until then I do not see any advantage of the version upgrade.



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] fgerlits opened a new pull request #964: MINIFICPP-1443 Fix 'possible loss of data' warnings

2020-12-16 Thread GitBox


fgerlits opened a new pull request #964:
URL: https://github.com/apache/nifi-minifi-cpp/pull/964


   ... and a few others which were related or nearby in the code.
   
   https://issues.apache.org/jira/browse/MINIFICPP-1443
   
   ---
   
   Thank you for submitting a contribution to Apache NiFi - MiNiFi C++.
   
   In order to streamline the review of the contribution we ask you
   to ensure the following steps have been taken:
   
   ### For all changes:
   - [x] Is there a JIRA ticket associated with this PR? Is it referenced
in the commit message?
   
   - [x] Does your PR title start with MINIFICPP- where  is the JIRA 
number you are trying to resolve? Pay particular attention to the hyphen "-" 
character.
   
   - [x] Has your PR been rebased against the latest commit within the target 
branch (typically main)?
   
   - [x] Is your initial contribution a single, squashed commit?
   
   ### For code changes:
   - [ ] If adding new dependencies to the code, are these dependencies 
licensed in a way that is compatible for inclusion under [ASF 
2.0](http://www.apache.org/legal/resolved.html#category-a)?
   - [ ] If applicable, have you updated the LICENSE file?
   - [ ] If applicable, have you updated the NOTICE file?
   
   ### For documentation related changes:
   - [ ] Have you ensured that format looks appropriate for the output in which 
it is rendered?
   
   ### Note:
   Please ensure that once the PR is submitted, you check GitHub Actions CI 
results for build issues and submit an update to your PR as soon as possible.
   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] dam4rus commented on a change in pull request #961: MINIFICPP-1440 PublishKafka processor's "security protocol" should ha…

2020-12-16 Thread GitBox


dam4rus commented on a change in pull request #961:
URL: https://github.com/apache/nifi-minifi-cpp/pull/961#discussion_r544609863



##
File path: extensions/librdkafka/PublishKafka.cpp
##
@@ -126,7 +126,11 @@ const core::Property PublishKafka::CompressCodec(
 const core::Property PublishKafka::MaxFlowSegSize(
 core::PropertyBuilder::createProperty("Max Flow Segment 
Size")->withDescription("Maximum flow content payload segment size for the 
kafka record. 0 B means unlimited.")
 ->isRequired(false)->withDefaultValue("0 
B")->build());
-const core::Property PublishKafka::SecurityProtocol("Security Protocol", 
"Protocol used to communicate with brokers", "");
+const core::Property PublishKafka::SecurityProtocol(
+core::PropertyBuilder::createProperty("Security Protocol")
+->withDescription("Protocol used to communicate with brokers")
+->withAllowableValues({SECURITY_PROTOCOL_PLAINTEXT, 
SECURITY_PROTOCOL_SSL, SECURITY_PROTOCOL_SASL_PLAINTEXT, 
SECURITY_PROTOCOL_SASL_SSL})

Review comment:
   > When looking at `PublishKafka.cpp:686`, it seems like only 
`SECURITY_PROTOCOL_SSL` is actually supported, and the default empty value is 
interpreted as plaintext.
   
   Should I leave the unused defines in? If it doesn't breaks backward 
compatibility removing them would make the code a bit clearer.
   
   > I suggest restricting the set of "allowable values" to plaintext and ssl, 
and handling plaintext near PublishKafka.cpp:687. I think doing nothing is a 
valid handling of plaintext.
   
   What's the suggested coding style in this case? Having an empty `else if 
(value == SECURITY_PROTOCOL_PLAINTEXT)` branch or just using `else if (value != 
SECURITY_PROTOCOL_PLAINTEXT)` to handle unexpected values?
   
   > I would also add a default value for PLAINTEXT as we are trying to make 
the behaviour consistent with NiFi:
   
https://nifi.apache.org/docs/nifi-docs/components/nifi-docs/components/org.apache.nifi/nifi-kafka-2-0-nar/1.9.0/org.apache.nifi.processors.kafka.pubsub.PublishKafka_2_0/
   
   Nifi also describes it as a required value. Should I add that too?





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[jira] [Created] (MINIFICPP-1443) Get rid of most "possible loss of data" warnings

2020-12-16 Thread Ferenc Gerlits (Jira)
Ferenc Gerlits created MINIFICPP-1443:
-

 Summary: Get rid of most "possible loss of data" warnings
 Key: MINIFICPP-1443
 URL: https://issues.apache.org/jira/browse/MINIFICPP-1443
 Project: Apache NiFi MiNiFi C++
  Issue Type: Improvement
Reporter: Ferenc Gerlits
Assignee: Ferenc Gerlits


We often convert/assign from larger to smaller types, eg. from size_t to int.  
This can lead to difficult-to-track-down bugs.

Visual Studio gives helpful warnings about this, eg. "warning C4267: '=': 
conversion from 'size_t' to 'int', possible loss of data".  Try to eliminate 
all, or almost all, of these.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Commented] (NIFI-8027) Allow semicolons in SQL Pre-Query and SQL Post-Query statements

2020-12-16 Thread ASF subversion and git services (Jira)


[ 
https://issues.apache.org/jira/browse/NIFI-8027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250592#comment-17250592
 ] 

ASF subversion and git services commented on NIFI-8027:
---

Commit 989287adafefd38273c85ec5e7391d131197a90b in nifi's branch 
refs/heads/main from Tamas Palfy
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=989287a ]

NIFI-8027 In AbstractExecuteSQL make 'SQL Pre-Query' and 'SQL Post-Query' 
properties support escaping semicolons to allow them be part of statements.

Signed-off-by: Matthew Burgess 

This closes #4732


> Allow semicolons in SQL Pre-Query and SQL Post-Query statements
> ---
>
> Key: NIFI-8027
> URL: https://issues.apache.org/jira/browse/NIFI-8027
> Project: Apache NiFi
>  Issue Type: Improvement
>Reporter: Tamas Palfy
>Assignee: Tamas Palfy
>Priority: Major
>  Time Spent: 20m
>  Remaining Estimate: 0h
>
> Certain session-wide settings require complex statements that contain 
> semicolons.
> AbstractExecuteSQL.SQL_PRE_QUERY and AbstractExecuteSQL.SQL_POST_QUERY  
> however uses semicolons as the delimiter for multiple statements.
> We could add the option to escape semicolons which then won't be considered a 
> closing of a statement.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Resolved] (NIFI-8027) Allow semicolons in SQL Pre-Query and SQL Post-Query statements

2020-12-16 Thread Matt Burgess (Jira)


 [ 
https://issues.apache.org/jira/browse/NIFI-8027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Matt Burgess resolved NIFI-8027.

Fix Version/s: 1.13.0
   Resolution: Fixed

> Allow semicolons in SQL Pre-Query and SQL Post-Query statements
> ---
>
> Key: NIFI-8027
> URL: https://issues.apache.org/jira/browse/NIFI-8027
> Project: Apache NiFi
>  Issue Type: Improvement
>Reporter: Tamas Palfy
>Assignee: Tamas Palfy
>Priority: Major
> Fix For: 1.13.0
>
>  Time Spent: 20m
>  Remaining Estimate: 0h
>
> Certain session-wide settings require complex statements that contain 
> semicolons.
> AbstractExecuteSQL.SQL_PRE_QUERY and AbstractExecuteSQL.SQL_POST_QUERY  
> however uses semicolons as the delimiter for multiple statements.
> We could add the option to escape semicolons which then won't be considered a 
> closing of a statement.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[GitHub] [nifi] mattyb149 closed pull request #4732: NIFI-8027 Support semicolons in SQL Pre- and Post-Query

2020-12-16 Thread GitBox


mattyb149 closed pull request #4732:
URL: https://github.com/apache/nifi/pull/4732


   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi] mattyb149 commented on pull request #4732: NIFI-8027 Support semicolons in SQL Pre- and Post-Query

2020-12-16 Thread GitBox


mattyb149 commented on pull request #4732:
URL: https://github.com/apache/nifi/pull/4732#issuecomment-746921673


   +1 LGTM, tested with multiple SET commands on PostgreSQL using Pre- and 
Post-Query properties. Thanks for the improvement! Merging to main



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] lordgamez commented on pull request #963: MINIFICPP-1442 Uplift sol2 from version 2.20.0 to 2.20.6

2020-12-16 Thread GitBox


lordgamez commented on pull request #963:
URL: https://github.com/apache/nifi-minifi-cpp/pull/963#issuecomment-746910434


   Even though the compatibility error disappeared, the build still fails with 
the following:
   ```
   2020-12-16T19:36:38.2089590Z 
/Users/runner/work/nifi-minifi-cpp/nifi-minifi-cpp/thirdparty/sol2-2.20.6/sol.hpp:5150:8:
 error: use of undeclared identifier 'LUA_ERRGCMM'
   2020-12-16T19:36:38.2157510Z gc = LUA_ERRGCMM,
   2020-12-16T19:36:38.2210480Z  ^
   2020-12-16T19:36:38.2292910Z 
/Users/runner/work/nifi-minifi-cpp/nifi-minifi-cpp/thirdparty/sol2-2.20.6/sol.hpp:5160:8:
 error: use of undeclared identifier 'LUA_ERRGCMM'
   2020-12-16T19:36:38.2359110Z gc = LUA_ERRGCMM,
   2020-12-16T19:36:38.2411820Z  ^
   2020-12-16T19:36:38.2496400Z 
/Users/runner/work/nifi-minifi-cpp/nifi-minifi-cpp/thirdparty/sol2-2.20.6/sol.hpp:5169:8:
 error: use of undeclared identifier 'LUA_ERRGCMM'
   2020-12-16T19:36:38.2560740Z gc = LUA_ERRGCMM,
   2020-12-16T19:36:38.2617600Z  ^
   2020-12-16T19:36:38.2706010Z 
/Users/runner/work/nifi-minifi-cpp/nifi-minifi-cpp/thirdparty/sol2-2.20.6/sol.hpp:5216:8:
 error: duplicate case value: 'gc' and 'file' both equal '6'
   2020-12-16T19:36:38.2808040Z case call_status::file:
   2020-12-16T19:36:38.2863160Z  ^
   2020-12-16T19:36:38.2922070Z 
/Users/runner/work/nifi-minifi-cpp/nifi-minifi-cpp/thirdparty/sol2-2.20.6/sol.hpp:5212:8:
 note: previous case defined here
   2020-12-16T19:36:38.3010260Z case call_status::gc:
   2020-12-16T19:36:38.3065550Z  ^
   2020-12-16T19:36:38.3125290Z 
/Users/runner/work/nifi-minifi-cpp/nifi-minifi-cpp/thirdparty/sol2-2.20.6/sol.hpp:5235:8:
 error: duplicate case value: 'gc' and 'file' both equal '6'
   2020-12-16T19:36:38.3212600Z case call_status::file:
   2020-12-16T19:36:38.3267340Z  ^
   2020-12-16T19:36:38.3328580Z 
/Users/runner/work/nifi-minifi-cpp/nifi-minifi-cpp/thirdparty/sol2-2.20.6/sol.hpp:5233:8:
 note: previous case defined here
   2020-12-16T19:36:38.3414850Z case call_status::gc:
   ```



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi] tpalfy commented on a change in pull request #4721: NIFI-8081 Added new Listing Strategy to ListFTP and ListSFTP

2020-12-16 Thread GitBox


tpalfy commented on a change in pull request #4721:
URL: https://github.com/apache/nifi/pull/4721#discussion_r544574271



##
File path: 
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ListFileTransfer.java
##
@@ -138,4 +144,32 @@ protected boolean isListingResetNecessary(final 
PropertyDescriptor property) {
 protected abstract FileTransfer getFileTransfer(final ProcessContext 
context);
 
 protected abstract String getProtocolName();
+
+protected void validateAdjustedTimeWindow(ValidationContext 
validationContext, Collection results) {
+if (
+
BY_ADJUSTED_TIME_WINDOW.getValue().equals(validationContext.getProperty(FILE_TRANSFER_LISTING_STRATEGY).getValue())
+&&
+!validationContext.getProperty(TIME_ADJUSTMENT).isSet()
+) {
+results.add(new ValidationResult.Builder()
+.explanation("'" + TIME_ADJUSTMENT.getDisplayName() + "' 
has to be set when '"
++ FILE_TRANSFER_LISTING_STRATEGY.getDisplayName() + "' 
is set to '" + BY_ADJUSTED_TIME_WINDOW.getValue() + "'")

Review comment:
   Okay





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi] tpalfy commented on a change in pull request #4721: NIFI-8081 Added new Listing Strategy to ListFTP and ListSFTP

2020-12-16 Thread GitBox


tpalfy commented on a change in pull request #4721:
URL: https://github.com/apache/nifi/pull/4721#discussion_r544573935



##
File path: 
nifi-nar-bundles/nifi-extension-utils/nifi-processor-utils/src/main/java/org/apache/nifi/processor/util/list/validator/TimeAdjustmentValidator.java
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.nifi.processor.util.list.validator;
+
+import org.apache.nifi.components.ValidationContext;
+import org.apache.nifi.components.ValidationResult;
+import org.apache.nifi.components.Validator;
+
+import java.util.Optional;
+import java.util.TimeZone;
+import java.util.regex.Pattern;
+
+import static 
org.apache.nifi.processor.util.list.AbstractListProcessor.TIME_ADJUSTMENT;
+
+public class TimeAdjustmentValidator implements Validator {
+private static final Pattern SIGNED_INTEGER_OR_SIGNED_HHmm_OR_HHmmss = 
Pattern.compile("-?(\\d{2}:\\d{2}(:\\d{2})?)|-?\\d+");
+
+@Override
+public ValidationResult validate(String subject, String input, 
ValidationContext context) {
+String evaluatedValue = 
Optional.ofNullable(context.getProperty(TIME_ADJUSTMENT).evaluateAttributeExpressions().getValue())
+.orElse("");
+
+boolean matches = evaluatedValue.equalsIgnoreCase("gmt")
+|| !TimeZone.getTimeZone(evaluatedValue).getID().equals("GMT") // 
TimeZone.getTimeZone returns GMT for an unrecognized value
+|| 
SIGNED_INTEGER_OR_SIGNED_HHmm_OR_HHmmss.matcher(evaluatedValue).matches();
+
+return new ValidationResult.Builder()
+.input(evaluatedValue)
+.subject(subject)

Review comment:
   Okay

##
File path: 
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ListFileTransfer.java
##
@@ -138,4 +144,32 @@ protected boolean isListingResetNecessary(final 
PropertyDescriptor property) {
 protected abstract FileTransfer getFileTransfer(final ProcessContext 
context);
 
 protected abstract String getProtocolName();
+
+protected void validateAdjustedTimeWindow(ValidationContext 
validationContext, Collection results) {
+if (
+
BY_ADJUSTED_TIME_WINDOW.getValue().equals(validationContext.getProperty(FILE_TRANSFER_LISTING_STRATEGY).getValue())
+&&
+!validationContext.getProperty(TIME_ADJUSTMENT).isSet()
+) {
+results.add(new ValidationResult.Builder()
+.explanation("'" + TIME_ADJUSTMENT.getDisplayName() + "' 
has to be set when '"
++ FILE_TRANSFER_LISTING_STRATEGY.getDisplayName() + "' 
is set to '" + BY_ADJUSTED_TIME_WINDOW.getValue() + "'")
+.valid(false)
+.subject(TIME_ADJUSTMENT.getDisplayName())
+.build());
+}
+
+if (
+
!BY_ADJUSTED_TIME_WINDOW.getValue().equals(validationContext.getProperty(FILE_TRANSFER_LISTING_STRATEGY).getValue())
+&&
+validationContext.getProperty(TIME_ADJUSTMENT).isSet()

Review comment:
   Removing





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi] tpalfy commented on a change in pull request #4721: NIFI-8081 Added new Listing Strategy to ListFTP and ListSFTP

2020-12-16 Thread GitBox


tpalfy commented on a change in pull request #4721:
URL: https://github.com/apache/nifi/pull/4721#discussion_r544562070



##
File path: 
nifi-nar-bundles/nifi-extension-utils/nifi-processor-utils/src/main/java/org/apache/nifi/processor/util/list/validator/TimeAdjustmentValidator.java
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.nifi.processor.util.list.validator;
+
+import org.apache.nifi.components.ValidationContext;
+import org.apache.nifi.components.ValidationResult;
+import org.apache.nifi.components.Validator;
+
+import java.util.Optional;
+import java.util.TimeZone;
+import java.util.regex.Pattern;
+
+import static 
org.apache.nifi.processor.util.list.AbstractListProcessor.TIME_ADJUSTMENT;
+
+public class TimeAdjustmentValidator implements Validator {
+private static final Pattern SIGNED_INTEGER_OR_SIGNED_HHmm_OR_HHmmss = 
Pattern.compile("-?(\\d{2}:\\d{2}(:\\d{2})?)|-?\\d+");
+
+@Override
+public ValidationResult validate(String subject, String input, 
ValidationContext context) {
+String evaluatedValue = 
Optional.ofNullable(context.getProperty(TIME_ADJUSTMENT).evaluateAttributeExpressions().getValue())
+.orElse("");
+
+boolean matches = evaluatedValue.equalsIgnoreCase("gmt")
+|| !TimeZone.getTimeZone(evaluatedValue).getID().equals("GMT") // 
TimeZone.getTimeZone returns GMT for an unrecognized value
+|| 
SIGNED_INTEGER_OR_SIGNED_HHmm_OR_HHmmss.matcher(evaluatedValue).matches();
+
+return new ValidationResult.Builder()
+.input(evaluatedValue)
+.subject(subject)
+.valid(matches)
+.explanation(matches ? null : "Value is not a recognized as either 
a valid time zone or a numerical time value.")

Review comment:
   Fixing





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[jira] [Updated] (MINIFICPP-1442) Uplift sol2 to newer version to support LUA version 5.4

2020-12-16 Thread Gabor Gyimesi (Jira)


 [ 
https://issues.apache.org/jira/browse/MINIFICPP-1442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Gabor Gyimesi updated MINIFICPP-1442:
-
Description: We should uplift sol2 to support newer LUA versions.  (was: 
Current sol2 library version is 2 years old. We should uplift sol2 to support 
newer LUA versions.)

> Uplift sol2 to newer version to support LUA version 5.4
> ---
>
> Key: MINIFICPP-1442
> URL: https://issues.apache.org/jira/browse/MINIFICPP-1442
> Project: Apache NiFi MiNiFi C++
>  Issue Type: Improvement
>Reporter: Gabor Gyimesi
>Priority: Minor
>  Time Spent: 10m
>  Remaining Estimate: 0h
>
> We should uplift sol2 to support newer LUA versions.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (MINIFICPP-1442) Uplift sol2 to newer version to support LUA version 5.4

2020-12-16 Thread Gabor Gyimesi (Jira)


 [ 
https://issues.apache.org/jira/browse/MINIFICPP-1442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Gabor Gyimesi updated MINIFICPP-1442:
-
Summary: Uplift sol2 to newer version to support LUA version 5.4  (was: 
Uplift sol2 to latest release version)

> Uplift sol2 to newer version to support LUA version 5.4
> ---
>
> Key: MINIFICPP-1442
> URL: https://issues.apache.org/jira/browse/MINIFICPP-1442
> Project: Apache NiFi MiNiFi C++
>  Issue Type: Improvement
>Reporter: Gabor Gyimesi
>Priority: Minor
>  Time Spent: 10m
>  Remaining Estimate: 0h
>
> Current sol2 library version is 2 years old. We should uplift sol2 to support 
> newer LUA versions.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Commented] (NIFI-7922) Add support for GET request in ListenHTTP for health check

2020-12-16 Thread Ruben Laguna (Jira)


[ 
https://issues.apache.org/jira/browse/NIFI-7922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250551#comment-17250551
 ] 

Ruben Laguna commented on NIFI-7922:


https://issues.apache.org/jira/plugins/servlet/mobile#issue/NIFI-8100

> Add support for GET request in ListenHTTP for health check
> --
>
> Key: NIFI-7922
> URL: https://issues.apache.org/jira/browse/NIFI-7922
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Extensions
>Reporter: Peter Gyori
>Assignee: Peter Gyori
>Priority: Major
> Fix For: 1.13.0
>
>  Time Spent: 3h
>  Remaining Estimate: 0h
>
> Add support for GET request in ListenHTTP processor, so that when put behind 
> a load balancer, the LB can make a health check to verify that the service is 
> available.
> The health check service should be available on 
> /healthcheck.
> It should be available via the listening port specified in the processor's 
> property, but it should optionally be configured to be available on a 
> different port.
> Accessing the health check service via a dedicated port should use 1-way SSL 
> at most, even if the main service uses 2-way SSL, since some load balancers 
> do not support client certificate handling:
>  - If the processor is set not to use SSL, SSL should not be used on the 
> health check port, either.
>  - If the processor is set to use one-way SSL, one-way SSL should be used on 
> the health check port.
>  - If the processor is set to use two-way SSL, one-way SSL should be used on 
> the health check port.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Commented] (NIFI-7922) Add support for GET request in ListenHTTP for health check

2020-12-16 Thread Ruben Laguna (Jira)


[ 
https://issues.apache.org/jira/browse/NIFI-7922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250549#comment-17250549
 ] 

Ruben Laguna commented on NIFI-7922:


Can this be used to determine if the Nifi UI is “healthy” ? I mean, if a node 
get disconnected the listenhttp processor in that node will stop? Does this 
removes the need for NIFi-8100?

> Add support for GET request in ListenHTTP for health check
> --
>
> Key: NIFI-7922
> URL: https://issues.apache.org/jira/browse/NIFI-7922
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Extensions
>Reporter: Peter Gyori
>Assignee: Peter Gyori
>Priority: Major
> Fix For: 1.13.0
>
>  Time Spent: 3h
>  Remaining Estimate: 0h
>
> Add support for GET request in ListenHTTP processor, so that when put behind 
> a load balancer, the LB can make a health check to verify that the service is 
> available.
> The health check service should be available on 
> /healthcheck.
> It should be available via the listening port specified in the processor's 
> property, but it should optionally be configured to be available on a 
> different port.
> Accessing the health check service via a dedicated port should use 1-way SSL 
> at most, even if the main service uses 2-way SSL, since some load balancers 
> do not support client certificate handling:
>  - If the processor is set not to use SSL, SSL should not be used on the 
> health check port, either.
>  - If the processor is set to use one-way SSL, one-way SSL should be used on 
> the health check port.
>  - If the processor is set to use two-way SSL, one-way SSL should be used on 
> the health check port.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Commented] (NIFI-3882) Unable to run NiFi behind AWS Load Balancer

2020-12-16 Thread Ruben Laguna (Jira)


[ 
https://issues.apache.org/jira/browse/NIFI-3882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250545#comment-17250545
 ] 

Ruben Laguna commented on NIFI-3882:


Maybe it would be better to comment that in NIFI-8100. But for the purpose of 
setting an LB for the Nifi UI we need a single endpoint that summarizes if the 
load balancer should route traffic to it. 
I guess the other information that you mention is already accesible vía the 
nifi api (with authentication) but not useful for the case of load balancing to 
the UI



> Unable to run NiFi behind AWS Load Balancer
> ---
>
> Key: NIFI-3882
> URL: https://issues.apache.org/jira/browse/NIFI-3882
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Core UI
>Reporter: Richard St. John
>Priority: Major
>
> Running Apache NiFi behind an AWS Elastic Load Balancer fails.
> Upon closer inspection, AWS Elastic Load Balancers only support the following 
> headers:
>X-Forwarded-For
>X-Forwarded-Proto
>X-Forwarded-Port
> In our case, we would like our ELB to be HTTPS enabled, but our NiFi cluster 
> is running in a trusted environment on port 8080.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[GitHub] [nifi] mattyb149 commented on a change in pull request #4668: NIFI-7991 Flow Configuration History displays "annotation data not fo…

2020-12-16 Thread GitBox


mattyb149 commented on a change in pull request #4668:
URL: https://github.com/apache/nifi/pull/4668#discussion_r544549281



##
File path: 
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/audit/ProcessorAuditor.java
##
@@ -400,4 +444,39 @@ private PropertyDescriptor 
locatePropertyDescriptor(Set prop
 return specDescriptor;
 }
 
+/**
+ * Gets Item Paths and set path and node in Map map
+ * @param nl NodeList to generate path
+ * @param path String path to ParentNode
+ * @param map  Map of path to node, and node reference
+ */
+private void getItemPaths(NodeList nl, String path, Map map){
+if(nl!=null) {
+
+
+for (int i = 0; i < nl.getLength(); i++) {
+Node n;
+if (( n = nl.item(i)) != null) {
+if(n.getNodeType() == Node.ELEMENT_NODE || n.getNodeType() 
== Node.TEXT_NODE) {
+if(n.hasChildNodes()){
+   if(n.getNodeType() == Node.ELEMENT_NODE) {
+getItemPaths(n.getChildNodes(), path + ":" + 
n.getNodeName(), map);
+   }
+}
+if(!n.hasChildNodes()) {
+map.put(path + ":" + 
n.getNodeName().trim()+":"+n.getNodeValue(), n);
+}
+
+if (n.hasAttributes()) {
+NamedNodeMap na = n.getAttributes();
+for (int j = 0; j < na.getLength(); j++) {
+map.put(path + ":" + n.getNodeName() + ":" + 
na.item(j).getNodeName().trim()+":"+na.item(j).getNodeValue(), n);

Review comment:
   I'm seeing something like this displayed:
   
`:#document:criteria:rules:conditions:expression:#text:${filename:equals("hello!")}`
   Is that intended? I would think it would be more helpful (if possible) to 
have something like the Rule Name then the condition or action or whatever 
changed.





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi] turcsanyip commented on a change in pull request #4721: NIFI-8081 Added new Listing Strategy to ListFTP and ListSFTP

2020-12-16 Thread GitBox


turcsanyip commented on a change in pull request #4721:
URL: https://github.com/apache/nifi/pull/4721#discussion_r544543960



##
File path: 
nifi-nar-bundles/nifi-extension-utils/nifi-processor-utils/src/main/java/org/apache/nifi/processor/util/list/validator/TimeAdjustmentValidator.java
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.nifi.processor.util.list.validator;
+
+import org.apache.nifi.components.ValidationContext;
+import org.apache.nifi.components.ValidationResult;
+import org.apache.nifi.components.Validator;
+
+import java.util.Optional;
+import java.util.TimeZone;
+import java.util.regex.Pattern;
+
+import static 
org.apache.nifi.processor.util.list.AbstractListProcessor.TIME_ADJUSTMENT;
+
+public class TimeAdjustmentValidator implements Validator {
+private static final Pattern SIGNED_INTEGER_OR_SIGNED_HHmm_OR_HHmmss = 
Pattern.compile("-?(\\d{2}:\\d{2}(:\\d{2})?)|-?\\d+");
+
+@Override
+public ValidationResult validate(String subject, String input, 
ValidationContext context) {
+String evaluatedValue = 
Optional.ofNullable(context.getProperty(TIME_ADJUSTMENT).evaluateAttributeExpressions().getValue())
+.orElse("");
+
+boolean matches = evaluatedValue.equalsIgnoreCase("gmt")
+|| !TimeZone.getTimeZone(evaluatedValue).getID().equals("GMT") // 
TimeZone.getTimeZone returns GMT for an unrecognized value
+|| 
SIGNED_INTEGER_OR_SIGNED_HHmm_OR_HHmmss.matcher(evaluatedValue).matches();
+
+return new ValidationResult.Builder()
+.input(evaluatedValue)
+.subject(subject)
+.valid(matches)
+.explanation(matches ? null : "Value is not a recognized as either 
a valid time zone or a numerical time value.")

Review comment:
   The explanation will be concatenated into the middle of the error 
message so it should be started with lower case.





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi] turcsanyip commented on a change in pull request #4721: NIFI-8081 Added new Listing Strategy to ListFTP and ListSFTP

2020-12-16 Thread GitBox


turcsanyip commented on a change in pull request #4721:
URL: https://github.com/apache/nifi/pull/4721#discussion_r544542796



##
File path: 
nifi-nar-bundles/nifi-extension-utils/nifi-processor-utils/src/main/java/org/apache/nifi/processor/util/list/validator/TimeAdjustmentValidator.java
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.nifi.processor.util.list.validator;
+
+import org.apache.nifi.components.ValidationContext;
+import org.apache.nifi.components.ValidationResult;
+import org.apache.nifi.components.Validator;
+
+import java.util.Optional;
+import java.util.TimeZone;
+import java.util.regex.Pattern;
+
+import static 
org.apache.nifi.processor.util.list.AbstractListProcessor.TIME_ADJUSTMENT;
+
+public class TimeAdjustmentValidator implements Validator {
+private static final Pattern SIGNED_INTEGER_OR_SIGNED_HHmm_OR_HHmmss = 
Pattern.compile("-?(\\d{2}:\\d{2}(:\\d{2})?)|-?\\d+");
+
+@Override
+public ValidationResult validate(String subject, String input, 
ValidationContext context) {
+String evaluatedValue = 
Optional.ofNullable(context.getProperty(TIME_ADJUSTMENT).evaluateAttributeExpressions().getValue())
+.orElse("");
+
+boolean matches = evaluatedValue.equalsIgnoreCase("gmt")
+|| !TimeZone.getTimeZone(evaluatedValue).getID().equals("GMT") // 
TimeZone.getTimeZone returns GMT for an unrecognized value
+|| 
SIGNED_INTEGER_OR_SIGNED_HHmm_OR_HHmmss.matcher(evaluatedValue).matches();
+
+return new ValidationResult.Builder()
+.input(evaluatedValue)
+.subject(subject)

Review comment:
   As the validator is already tied to the 
`AbstractListProcessor.TIME_ADJUSTMENT` property, the display name of the 
property could be used here instead of the `subject` which is the (technical) 
name.





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi] turcsanyip commented on a change in pull request #4721: NIFI-8081 Added new Listing Strategy to ListFTP and ListSFTP

2020-12-16 Thread GitBox


turcsanyip commented on a change in pull request #4721:
URL: https://github.com/apache/nifi/pull/4721#discussion_r544537496



##
File path: 
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ListFileTransfer.java
##
@@ -138,4 +144,32 @@ protected boolean isListingResetNecessary(final 
PropertyDescriptor property) {
 protected abstract FileTransfer getFileTransfer(final ProcessContext 
context);
 
 protected abstract String getProtocolName();
+
+protected void validateAdjustedTimeWindow(ValidationContext 
validationContext, Collection results) {
+if (
+
BY_ADJUSTED_TIME_WINDOW.getValue().equals(validationContext.getProperty(FILE_TRANSFER_LISTING_STRATEGY).getValue())
+&&
+!validationContext.getProperty(TIME_ADJUSTMENT).isSet()
+) {
+results.add(new ValidationResult.Builder()
+.explanation("'" + TIME_ADJUSTMENT.getDisplayName() + "' 
has to be set when '"
++ FILE_TRANSFER_LISTING_STRATEGY.getDisplayName() + "' 
is set to '" + BY_ADJUSTED_TIME_WINDOW.getValue() + "'")
+.valid(false)
+.subject(TIME_ADJUSTMENT.getDisplayName())
+.build());
+}
+
+if (
+
!BY_ADJUSTED_TIME_WINDOW.getValue().equals(validationContext.getProperty(FILE_TRANSFER_LISTING_STRATEGY).getValue())
+&&
+validationContext.getProperty(TIME_ADJUSTMENT).isSet()

Review comment:
   As Time Adjustment property is hidden when the Listing Strategy is other 
than Adjusted Time Window, this validation might not be necessary.





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi] turcsanyip commented on a change in pull request #4721: NIFI-8081 Added new Listing Strategy to ListFTP and ListSFTP

2020-12-16 Thread GitBox


turcsanyip commented on a change in pull request #4721:
URL: https://github.com/apache/nifi/pull/4721#discussion_r544536013



##
File path: 
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ListFileTransfer.java
##
@@ -138,4 +144,32 @@ protected boolean isListingResetNecessary(final 
PropertyDescriptor property) {
 protected abstract FileTransfer getFileTransfer(final ProcessContext 
context);
 
 protected abstract String getProtocolName();
+
+protected void validateAdjustedTimeWindow(ValidationContext 
validationContext, Collection results) {
+if (
+
BY_ADJUSTED_TIME_WINDOW.getValue().equals(validationContext.getProperty(FILE_TRANSFER_LISTING_STRATEGY).getValue())
+&&
+!validationContext.getProperty(TIME_ADJUSTMENT).isSet()
+) {
+results.add(new ValidationResult.Builder()
+.explanation("'" + TIME_ADJUSTMENT.getDisplayName() + "' 
has to be set when '"
++ FILE_TRANSFER_LISTING_STRATEGY.getDisplayName() + "' 
is set to '" + BY_ADJUSTED_TIME_WINDOW.getValue() + "'")

Review comment:
   `BY_ADJUSTED_TIME_WINDOW.getDisplayName()` should be used instead of 
`getValue()`
   Also in line 169.





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi] tpalfy opened a new pull request #4732: NIFI-8027 Support semicolons in SQL Pre- and Post-Query

2020-12-16 Thread GitBox


tpalfy opened a new pull request #4732:
URL: https://github.com/apache/nifi/pull/4732


   In AbstractExecuteSQL semicolons can be escaped in SQL Pre- and Post-Query
   
   ### For all changes:
   - [ ] Is there a JIRA ticket associated with this PR? Is it referenced 
in the commit message?
   
   - [ ] Does your PR title start with **NIFI-** where  is the JIRA 
number you are trying to resolve? Pay particular attention to the hyphen "-" 
character.
   
   - [ ] Has your PR been rebased against the latest commit within the target 
branch (typically `main`)?
   
   - [ ] Is your initial contribution a single, squashed commit? _Additional 
commits in response to PR reviewer feedback should be made on this branch and 
pushed to allow change tracking. Do not `squash` or use `--force` when pushing 
to allow for clean monitoring of changes._
   
   ### For code changes:
   - [ ] Have you ensured that the full suite of tests is executed via `mvn 
-Pcontrib-check clean install` at the root `nifi` folder?
   - [ ] Have you written or updated unit tests to verify your changes?
   - [ ] Have you verified that the full build is successful on JDK 8?
   - [ ] Have you verified that the full build is successful on JDK 11?
   - [ ] If adding new dependencies to the code, are these dependencies 
licensed in a way that is compatible for inclusion under [ASF 
2.0](http://www.apache.org/legal/resolved.html#category-a)? 
   - [ ] If applicable, have you updated the `LICENSE` file, including the main 
`LICENSE` file under `nifi-assembly`?
   - [ ] If applicable, have you updated the `NOTICE` file, including the main 
`NOTICE` file found under `nifi-assembly`?
   - [ ] If adding new Properties, have you added `.displayName` in addition to 
.name (programmatic access) for each of the new properties?
   
   ### For documentation related changes:
   - [ ] Have you ensured that format looks appropriate for the output in which 
it is rendered?
   
   ### Note:
   Please ensure that once the PR is submitted, you check GitHub Actions CI for 
build issues and submit an update to your PR as soon as possible.
   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] lordgamez commented on pull request #962: MINIFICPP-1441 Specify Lua version in Mac CI builds

2020-12-16 Thread GitBox


lordgamez commented on pull request #962:
URL: https://github.com/apache/nifi-minifi-cpp/pull/962#issuecomment-746767755


   Yes, exactly. But before closing this PR I would like to see if the tests 
pass with the upgraded sol2 version and see if anyone has any objections 
against the upgrade.



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] szaszm commented on pull request #962: MINIFICPP-1441 Specify Lua version in Mac CI builds

2020-12-16 Thread GitBox


szaszm commented on pull request #962:
URL: https://github.com/apache/nifi-minifi-cpp/pull/962#issuecomment-746760913


   So the original idea was to downgrade Lua, but it didn't work, so you went 
for the upgrade, which is a better solution anyway, do I understand it right? 
If so, this PR can be closed without merge.



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] lordgamez commented on pull request #962: MINIFICPP-1441 Specify Lua version in Mac CI builds

2020-12-16 Thread GitBox


lordgamez commented on pull request #962:
URL: https://github.com/apache/nifi-minifi-cpp/pull/962#issuecomment-746756551


   > I thought this PR fixes the incompatibility issue by installing 5.3 
instead of 5.4
   
   That was the original idea as sol2 2.20.0 is hardcoded to be incompatible 
with LUA 5.3+ as there was no newer version back when this was released. But as 
it seems that the Github MacOS VMs come with LUA 5.4 pre installed, it may be 
counter-productive to force LUA version 5.3 in our environment instead of 
supporting version 5.4. Let me know if you disagree, we can discuss which would 
be the better way to move forward with.



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] szaszm commented on pull request #962: MINIFICPP-1441 Specify Lua version in Mac CI builds

2020-12-16 Thread GitBox


szaszm commented on pull request #962:
URL: https://github.com/apache/nifi-minifi-cpp/pull/962#issuecomment-746747703


   I thought this PR fixes the incompatibility issue by installing 5.3 instead 
of 5.4



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[jira] [Updated] (NIFI-6242) PutFileTransfer generating incorrect provenance events

2020-12-16 Thread Tim Smith (Jira)


 [ 
https://issues.apache.org/jira/browse/NIFI-6242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Tim Smith updated NIFI-6242:

Status: Patch Available  (was: Open)

> PutFileTransfer generating incorrect provenance events
> --
>
> Key: NIFI-6242
> URL: https://issues.apache.org/jira/browse/NIFI-6242
> Project: Apache NiFi
>  Issue Type: Bug
>Affects Versions: 1.9.2
>Reporter: Brandon Rhys DeVries
>Assignee: Tim Smith
>Priority: Minor
>  Time Spent: 1h 40m
>  Remaining Estimate: 0h
>
> PutFileTransfer transfers a (configurable size) batch of FlowFiles.  However, 
> the provenance SEND event generated [1] uses the hostname evaluated from the 
> first FlowFile of the batch.  If the hostname is a hardcoded string, there's 
> no issue... but if the hostname uses Expression Language, the generated 
> provenance events will be incorrect (and very confusing).
> [1] 
> [https://github.com/apache/nifi/blob/f60585a9b6df6b3b28be1eb80a0a60deac6c0493/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutFileTransfer.java#L146-L147]
> [2] 
> [https://github.com/apache/nifi/blob/f60585a9b6df6b3b28be1eb80a0a60deac6c0493/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutFileTransfer.java#L97]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[GitHub] [nifi-minifi-cpp] lordgamez commented on pull request #962: MINIFICPP-1441 Specify Lua version in Mac CI builds

2020-12-16 Thread GitBox


lordgamez commented on pull request #962:
URL: https://github.com/apache/nifi-minifi-cpp/pull/962#issuecomment-746733014


   The issue comes from the compatibility of sol2 library that we use version 
2.20.0 of. This release is 2 years old, so it might be more appropriate to 
uplift this library to its latest release version instead to solve this issue. 
The suggested change can be found in PR #963 



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] lordgamez opened a new pull request #963: MINIFICPP-1442 Uplift sol2 from version 2.20.0 to 3.2.2

2020-12-16 Thread GitBox


lordgamez opened a new pull request #963:
URL: https://github.com/apache/nifi-minifi-cpp/pull/963


   Version 3.2.2 released single hpp library was downloaded from 
https://github.com/ThePhD/sol2/releases
   
   Thank you for submitting a contribution to Apache NiFi - MiNiFi C++.
   
   In order to streamline the review of the contribution we ask you
   to ensure the following steps have been taken:
   
   ### For all changes:
   - [ ] Is there a JIRA ticket associated with this PR? Is it referenced
in the commit message?
   
   - [ ] Does your PR title start with MINIFICPP- where  is the JIRA 
number you are trying to resolve? Pay particular attention to the hyphen "-" 
character.
   
   - [ ] Has your PR been rebased against the latest commit within the target 
branch (typically main)?
   
   - [ ] Is your initial contribution a single, squashed commit?
   
   ### For code changes:
   - [ ] If adding new dependencies to the code, are these dependencies 
licensed in a way that is compatible for inclusion under [ASF 
2.0](http://www.apache.org/legal/resolved.html#category-a)?
   - [ ] If applicable, have you updated the LICENSE file?
   - [ ] If applicable, have you updated the NOTICE file?
   
   ### For documentation related changes:
   - [ ] Have you ensured that format looks appropriate for the output in which 
it is rendered?
   
   ### Note:
   Please ensure that once the PR is submitted, you check GitHub Actions CI 
results for build issues and submit an update to your PR as soon as possible.
   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[jira] [Created] (MINIFICPP-1442) Uplift sol2 to latest release version

2020-12-16 Thread Gabor Gyimesi (Jira)
Gabor Gyimesi created MINIFICPP-1442:


 Summary: Uplift sol2 to latest release version
 Key: MINIFICPP-1442
 URL: https://issues.apache.org/jira/browse/MINIFICPP-1442
 Project: Apache NiFi MiNiFi C++
  Issue Type: Improvement
Reporter: Gabor Gyimesi


Current sol2 library version is 2 years old. We should uplift sol2 to support 
newer LUA versions.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[GitHub] [nifi] NissimShiman edited a comment on pull request #4620: NIFI-6242 PutFileTransfer generation incorrect provenance event

2020-12-16 Thread GitBox


NissimShiman edited a comment on pull request #4620:
URL: https://github.com/apache/nifi/pull/4620#issuecomment-746644194


   Code has been reviewed. It is well structured and unit tested.  
   
   I compiled and tested on both java 8 and java 11 and issue is fixed.  
   
   Issue was that transitUri in SEND ProvenanceEvent can be incorrect when 
PutFTP/PutSFTP's hostname property is set to an expression.  
   
   It used to evaluate the first flowfile that went through for the hostname's 
expression and then use that value for all future flowfiles' transitUri for 
their SEND events.  
   
   Now the transitUri always reflects the correct hostname value for the 
associated flowfile.
   
   Nice job @tlsmith109!
   
   LGTM +1



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi] NissimShiman edited a comment on pull request #4620: NIFI-6242 PutFileTransfer generation incorrect provenance event

2020-12-16 Thread GitBox


NissimShiman edited a comment on pull request #4620:
URL: https://github.com/apache/nifi/pull/4620#issuecomment-746644194


   Code has been reviewed. It is well structured and unit tested.  
   
   I compiled and tested on both java 8 and java 11 and issue is fixed.  
   
   Issue was that transitUri in SEND ProvenanceEvent can be incorrect when 
PutFTP/PutSFTP's hostname property is set to an expression.  
   
   It used to evaluate the first flowfile that went through for the hostname's 
expression and then use that value for all future flowfiles' transitUri for 
their SEND events.  
   
   Now the transitUri always reflects the correct hostname value for the 
associated flowfile.
   
   Nice job @tlsmith109!



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi] NissimShiman commented on pull request #4620: NIFI-6242 PutFileTransfer generation incorrect provenance event

2020-12-16 Thread GitBox


NissimShiman commented on pull request #4620:
URL: https://github.com/apache/nifi/pull/4620#issuecomment-746644194


   Code is well structured and unit tested.  
   
   I compiled and tested on both java 8 and java 11 and issue is fixed.  
   
   Issue was that transitUri in SEND ProvenanceEvent can be incorrect when 
PutFTP/PutSFTP's hostname property is set to an expression.  
   
   It used to evaluate the first flowfile that went through for the hostname's 
expression and then use that value for all future flowfiles' transitUri for 
their SEND events.  
   
   Now the transitUri always reflects the correct hostname value for the 
associated flowfile.
   
   Nice job @tlsmith109!



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] lordgamez commented on a change in pull request #962: MINIFICPP-1441 Specify Lua version in Mac CI builds

2020-12-16 Thread GitBox


lordgamez commented on a change in pull request #962:
URL: https://github.com/apache/nifi-minifi-cpp/pull/962#discussion_r50153



##
File path: .github/workflows/ci.yml
##
@@ -9,7 +9,7 @@ jobs:
   - id: checkout
 uses: actions/checkout@v2
   - id: install_dependencies
-run: brew install ossp-uuid boost flex openssl python lua xz libssh2
+run: brew install lua@5.3 && brew install ossp-uuid boost flex openssl 
python xz libssh2

Review comment:
   It seems like it depends on what VM we get on Github, some of them have 
Lua pre-installed, some don't. But when it is pre-installed, it cannot unlink 
it as it comes from OSX not from homebrew.





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] lordgamez commented on a change in pull request #962: MINIFICPP-1441 Specify Lua version in Mac CI builds

2020-12-16 Thread GitBox


lordgamez commented on a change in pull request #962:
URL: https://github.com/apache/nifi-minifi-cpp/pull/962#discussion_r50153



##
File path: .github/workflows/ci.yml
##
@@ -9,7 +9,7 @@ jobs:
   - id: checkout
 uses: actions/checkout@v2
   - id: install_dependencies
-run: brew install ossp-uuid boost flex openssl python lua xz libssh2
+run: brew install lua@5.3 && brew install ossp-uuid boost flex openssl 
python xz libssh2

Review comment:
   It seems like it depends on what VM we get on Github, some of them have 
Lua pre-installed, some don't. But when it is pre-installed, it cannot unlink 
it.





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] lordgamez commented on a change in pull request #962: MINIFICPP-1441 Specify Lua version in Mac CI builds

2020-12-16 Thread GitBox


lordgamez commented on a change in pull request #962:
URL: https://github.com/apache/nifi-minifi-cpp/pull/962#discussion_r50153



##
File path: .github/workflows/ci.yml
##
@@ -9,7 +9,7 @@ jobs:
   - id: checkout
 uses: actions/checkout@v2
   - id: install_dependencies
-run: brew install ossp-uuid boost flex openssl python lua xz libssh2
+run: brew install lua@5.3 && brew install ossp-uuid boost flex openssl 
python xz libssh2

Review comment:
   It seems like it depends on what VM we get on Github, some of them have 
Lua pre-installed, some don't.





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] lordgamez commented on a change in pull request #962: MINIFICPP-1441 Specify Lua version in Mac CI builds

2020-12-16 Thread GitBox


lordgamez commented on a change in pull request #962:
URL: https://github.com/apache/nifi-minifi-cpp/pull/962#discussion_r50153



##
File path: .github/workflows/ci.yml
##
@@ -9,7 +9,7 @@ jobs:
   - id: checkout
 uses: actions/checkout@v2
   - id: install_dependencies
-run: brew install ossp-uuid boost flex openssl python lua xz libssh2
+run: brew install lua@5.3 && brew install ossp-uuid boost flex openssl 
python xz libssh2

Review comment:
   It seems like it depends on what VM we get on Github, some of them has 
Lua pre-installed, some don't.





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] lordgamez commented on a change in pull request #962: MINIFICPP-1441 Specify Lua version in Mac CI builds

2020-12-16 Thread GitBox


lordgamez commented on a change in pull request #962:
URL: https://github.com/apache/nifi-minifi-cpp/pull/962#discussion_r544436458



##
File path: .github/workflows/ci.yml
##
@@ -9,7 +9,7 @@ jobs:
   - id: checkout
 uses: actions/checkout@v2
   - id: install_dependencies
-run: brew install ossp-uuid boost flex openssl python lua xz libssh2
+run: brew install lua@5.3 && brew install ossp-uuid boost flex openssl 
python xz libssh2

Review comment:
   I'm not sure what the difference is, but in 2 separate runs the same 
command had 2 different outcomes:
   ```
   Run brew install ossp-uuid boost flex openssl python lua@5.3 xz libssh2 && 
brew unlink lua && brew link lua@5.3 --force --overwrite
 brew install ossp-uuid boost flex openssl python lua@5.3 xz libssh2 && 
brew unlink lua && brew link lua@5.3 --force --overwrite
 shell: /bin/bash -e {0}
   Warning: openssl@1.1 1.1.1h is already installed and up-to-date
   To reinstall 1.1.1h, run `brew reinstall openssl@1.1`
   Warning: python@3.9 3.9.0_2 is already installed and up-to-date
   To reinstall 3.9.0_2, run `brew reinstall python@3.9`
   Warning: xz 5.2.5 is already installed and up-to-date
   To reinstall 5.2.5, run `brew reinstall xz`
   Warning: libssh2 1.9.0_1 is already installed and up-to-date
   To reinstall 1.9.0_1, run `brew reinstall libssh2`
   ==> Downloading 
https://homebrew.bintray.com/bottles/ossp-uuid-1.6.2_2.catalina.bottle.tar.gz
   ==> Pouring ossp-uuid-1.6.2_2.catalina.bottle.tar.gz
     /usr/local/Cellar/ossp-uuid/1.6.2_2: 18 files, 209.5KB
   ==> Downloading 
https://homebrew.bintray.com/bottles/boost-1.74.0.catalina.bottle.tar.gz
   ==> Downloading from 
https://d29vzk4ow07wi7.cloudfront.net/0c3609787aac666de8db539259e2f604bda631bcc4fde5f5427ea83f4692dec1?response-content-disposition=attachment%3Bfilename%3D%22boost-1.74.0.catalina.bottle.tar.gz%22=eyJTdGF0ZW1lbnQiOiBbeyJSZXNvdXJjZSI6Imh0dHAqOi8vZDI5dnprNG93MDd3aTcuY2xvdWRmcm9udC5uZXQvMGMzNjA5Nzg3YWFjNjY2ZGU4ZGI1MzkyNTllMmY2MDRiZGE2MzFiY2M0ZmRlNWY1NDI3ZWE4M2Y0NjkyZGVjMT9yZXNwb25zZS1jb250ZW50LWRpc3Bvc2l0aW9uPWF0dGFjaG1lbnQlM0JmaWxlbmFtZSUzRCUyMmJvb3N0LTEuNzQuMC5jYXRhbGluYS5ib3R0bGUudGFyLmd6JTIyIiwiQ29uZGl0aW9uIjp7IkRhdGVMZXNzVGhhbiI6eyJBV1M6RXBvY2hUaW1lIjoxNjA4MTM2MDg5fSwiSXBBZGRyZXNzIjp7IkFXUzpTb3VyY2VJcCI6IjAuMC4wLjAvMCJ9fX1dfQ__=AO2Et4NcT71qnzbOdzjO2mBhgHX0F~V7NsrZjA0PKHL6Lsr5aVuRPrliKObSKf51AJ8exbhTcIuuNjtyL~AgUCx7ffhOx9~sgECVTrJp9d6fnfTTLgOc0OejJnxmjhkyK0~gwNGUIyPZ5lmvQj4Q1Q2JDmoPNVZNKfKhGwOaA7KM3efSxKK1z2hQCoiFKIpfn660BhpWHUaQ5MLd3U1dPg3k6sFUkZ3IOSU7pcUOzOhLXpNu6iVmHmImFWAnujyQZNE-QfEwH8ePpeDJgMdVBc5Qai9CZiKLmJ9B5atOGK6sH1besmT~BvSAcvQs2L
 obSYE13dsdvA6nsM-dA4l0vw__=APKAIFKFWOMXM2UMTSFA
   ==> Pouring boost-1.74.0.catalina.bottle.tar.gz
     /usr/local/Cellar/boost/1.74.0: 14,695 files, 524.4MB
   ==> Downloading 
https://homebrew.bintray.com/bottles/flex-2.6.4_1.catalina.bottle.tar.gz
   ==> Downloading from 
https://d29vzk4ow07wi7.cloudfront.net/902e2701bb4d8130fe3177211dda84b6ebc6a520467874a52bcd7ff043b949cc?response-content-disposition=attachment%3Bfilename%3D%22flex-2.6.4_1.catalina.bottle.tar.gz%22=eyJTdGF0ZW1lbnQiOiBbeyJSZXNvdXJjZSI6Imh0dHAqOi8vZDI5dnprNG93MDd3aTcuY2xvdWRmcm9udC5uZXQvOTAyZTI3MDFiYjRkODEzMGZlMzE3NzIxMWRkYTg0YjZlYmM2YTUyMDQ2Nzg3NGE1MmJjZDdmZjA0M2I5NDljYz9yZXNwb25zZS1jb250ZW50LWRpc3Bvc2l0aW9uPWF0dGFjaG1lbnQlM0JmaWxlbmFtZSUzRCUyMmZsZXgtMi42LjRfMS5jYXRhbGluYS5ib3R0bGUudGFyLmd6JTIyIiwiQ29uZGl0aW9uIjp7IkRhdGVMZXNzVGhhbiI6eyJBV1M6RXBvY2hUaW1lIjoxNjA4MTM2MTIzfSwiSXBBZGRyZXNzIjp7IkFXUzpTb3VyY2VJcCI6IjAuMC4wLjAvMCJ9fX1dfQ__=Ij8SlZH8abiKyV359dg6m6yb12JfLcNuAx8lOTPZc2V6JqJ9WEctnDbPMYtjjXt4EVREBruQIdYONmKrW6p2MEhdXw0H~qLc0ZJ6NwyyzGOpE5JKj2Qv0dL7ILuc4Q4tx6Hn7zTTqeVvrEfNVen72AU9dHygtJUAx1OhDHgVLI0mCuYHAFSFh7Z3rTNxo55ZGOWoK0b5ABAl0uRdSogj2auMgIPGTvX~CNqx0JC6LDvMX-0FZgzSiStI2Nxl-u0XVw7u5Lyf2-3aoX4CJyhO2Vx-ee~jZS2KsANb4eWnSgIHmvtTWLQTLdXAG1MJMl
 I8Qv4lSiSnC4HRPcFg3A37Aw__=APKAIFKFWOMXM2UMTSFA
   ==> Pouring flex-2.6.4_1.catalina.bottle.tar.gz
   ==> Caveats
   flex is keg-only, which means it was not symlinked into /usr/local,
   because macOS already provides this software and installing another version 
in
   parallel can cause all kinds of trouble.
   
   If you need to have flex first in your PATH run:
 echo 'export PATH="/usr/local/opt/flex/bin:$PATH"' >> 
/Users/runner/.bash_profile
   
   For compilers to find flex you may need to set:
 export LDFLAGS="-L/usr/local/opt/flex/lib"
 export CPPFLAGS="-I/usr/local/opt/flex/include"
   
   ==> Summary
     /usr/local/Cellar/flex/2.6.4_1: 45 files, 1.4MB
   ==> Downloading 
https://homebrew.bintray.com/bottles/lua-5.3.5_1.catalina.bottle.tar.gz
   ==> Pouring lua-5.3.5_1.catalina.bottle.tar.gz
   ==> Caveats
   You may also want luarocks:
 brew install luarocks
   ==> Summary
     /usr/local/Cellar/lua/5.3.5_1: 28 files, 286.6KB
   ==> Caveats
   ==> flex
   flex is keg-only, which means it was not symlinked into /usr/local,
   because 

[GitHub] [nifi-minifi-cpp] szaszm commented on pull request #962: MINIFICPP-1441 Specify Lua version in Mac CI builds

2020-12-16 Thread GitBox


szaszm commented on pull request #962:
URL: https://github.com/apache/nifi-minifi-cpp/pull/962#issuecomment-746574641


   Still failing :disappointed: 
https://github.com/apache/nifi-minifi-cpp/pull/962/checks?check_run_id=1564459700#step:5:10792



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] hunyadi-dev commented on a change in pull request #962: MINIFICPP-1441 Specify Lua version in Mac CI builds

2020-12-16 Thread GitBox


hunyadi-dev commented on a change in pull request #962:
URL: https://github.com/apache/nifi-minifi-cpp/pull/962#discussion_r544425110



##
File path: .github/workflows/ci.yml
##
@@ -9,7 +9,7 @@ jobs:
   - id: checkout
 uses: actions/checkout@v2
   - id: install_dependencies
-run: brew install ossp-uuid boost flex openssl python lua xz libssh2
+run: brew install lua@5.3 && brew install ossp-uuid boost flex openssl 
python xz libssh2

Review comment:
   I think that means you did not run `brew install lua@5.3` before. If 
that was run it should by default automatically link it unless a previous 
version is already present to be found.





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] hunyadi-dev commented on a change in pull request #962: MINIFICPP-1441 Specify Lua version in Mac CI builds

2020-12-16 Thread GitBox


hunyadi-dev commented on a change in pull request #962:
URL: https://github.com/apache/nifi-minifi-cpp/pull/962#discussion_r544411596



##
File path: .github/workflows/ci.yml
##
@@ -9,7 +9,7 @@ jobs:
   - id: checkout
 uses: actions/checkout@v2
   - id: install_dependencies
-run: brew install ossp-uuid boost flex openssl python lua xz libssh2
+run: brew install lua@5.3 && brew install ossp-uuid boost flex openssl 
python xz libssh2

Review comment:
   How about this? 
   ```yaml
   run: brew install ossp-uuid boost flex openssl python lua@5.3 xz libssh2 && 
brew switch lua 5.3
   ```
   
   **Update:**
   Brew switch is deprecated in homebrew 2.6.0:
   
![image](https://user-images.githubusercontent.com/64011968/102373022-1267df00-3fc0-11eb-8875-9df63684e0de.png)
   
   I think we need to unlink the old version and link the new version before 
using it. I don't have a mac to check it now, but googling shows this might be 
the correct syntax:
   ```bash
   brew unlink lua
   brew link lua@5.3 --force --overwrite
   ```





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] lordgamez commented on a change in pull request #962: MINIFICPP-1441 Specify Lua version in Mac CI builds

2020-12-16 Thread GitBox


lordgamez commented on a change in pull request #962:
URL: https://github.com/apache/nifi-minifi-cpp/pull/962#discussion_r544419612



##
File path: .github/workflows/ci.yml
##
@@ -9,7 +9,7 @@ jobs:
   - id: checkout
 uses: actions/checkout@v2
   - id: install_dependencies
-run: brew install ossp-uuid boost flex openssl python lua xz libssh2
+run: brew install lua@5.3 && brew install ossp-uuid boost flex openssl 
python xz libssh2

Review comment:
   It fails with:
   ```
   Error: lua not found in the Cellar.
   Error: Process completed with exit code 1.
   ```





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] hunyadi-dev commented on a change in pull request #962: MINIFICPP-1441 Specify Lua version in Mac CI builds

2020-12-16 Thread GitBox


hunyadi-dev commented on a change in pull request #962:
URL: https://github.com/apache/nifi-minifi-cpp/pull/962#discussion_r544411596



##
File path: .github/workflows/ci.yml
##
@@ -9,7 +9,7 @@ jobs:
   - id: checkout
 uses: actions/checkout@v2
   - id: install_dependencies
-run: brew install ossp-uuid boost flex openssl python lua xz libssh2
+run: brew install lua@5.3 && brew install ossp-uuid boost flex openssl 
python xz libssh2

Review comment:
   How about 
   ```yaml
   run: brew install ossp-uuid boost flex openssl python lua@5.3 xz libssh2 && 
brew switch lua 5.3
   ```





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi] thenatog commented on pull request #4731: NIFI-8098 - Bump jetty.version from 9.4.34.v20201102 to 9.4.35.v20201120

2020-12-16 Thread GitBox


thenatog commented on pull request #4731:
URL: https://github.com/apache/nifi/pull/4731#issuecomment-746515095


   Tested upgraded Jetty in a secure cluster. Checked the other web contexts 
work as expected. Tested out using ListenHTTP, PostHTTP processors, and used 
Site-To-Site to transmit data to an input port on the same cluster. 



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi] thenatog opened a new pull request #4731: NIFI-8098 - Bump jetty.version from 9.4.34.v20201102 to 9.4.35.v20201120

2020-12-16 Thread GitBox


thenatog opened a new pull request #4731:
URL: https://github.com/apache/nifi/pull/4731


   dependabot[bot]  Updates `jetty-server` from 
9.4.34.v20201102 to 9.4.35.v20201120
   - [Release notes](https://github.com/eclipse/jetty.project/releases)
   - 
[Commits](https://github.com/eclipse/jetty.project/compare/jetty-9.4.34.v20201102...jetty-9.4.35.v20201120)
   
   Thank you for submitting a contribution to Apache NiFi.
   
   Please provide a short description of the PR here:
   
    Description of PR
   
   _Enables X functionality; fixes bug NIFI-._
   
   In order to streamline the review of the contribution we ask you
   to ensure the following steps have been taken:
   
   ### For all changes:
   - [x] Is there a JIRA ticket associated with this PR? Is it referenced 
in the commit message?
   
   - [x] Does your PR title start with **NIFI-** where  is the JIRA 
number you are trying to resolve? Pay particular attention to the hyphen "-" 
character.
   
   - [ ] Has your PR been rebased against the latest commit within the target 
branch (typically `main`)?
   
   - [x] Is your initial contribution a single, squashed commit? _Additional 
commits in response to PR reviewer feedback should be made on this branch and 
pushed to allow change tracking. Do not `squash` or use `--force` when pushing 
to allow for clean monitoring of changes._
   
   ### For code changes:
   - [x] Have you ensured that the full suite of tests is executed via `mvn 
-Pcontrib-check clean install` at the root `nifi` folder?
   - [ ] Have you written or updated unit tests to verify your changes?
   - [x] Have you verified that the full build is successful on JDK 8?
   - [x] Have you verified that the full build is successful on JDK 11?
   - [ ] If adding new dependencies to the code, are these dependencies 
licensed in a way that is compatible for inclusion under [ASF 
2.0](http://www.apache.org/legal/resolved.html#category-a)? 
   - [ ] If applicable, have you updated the `LICENSE` file, including the main 
`LICENSE` file under `nifi-assembly`?
   - [ ] If applicable, have you updated the `NOTICE` file, including the main 
`NOTICE` file found under `nifi-assembly`?
   - [ ] If adding new Properties, have you added `.displayName` in addition to 
.name (programmatic access) for each of the new properties?
   
   ### For documentation related changes:
   - [ ] Have you ensured that format looks appropriate for the output in which 
it is rendered?
   
   ### Note:
   Please ensure that once the PR is submitted, you check GitHub Actions CI for 
build issues and submit an update to your PR as soon as possible.
   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] lordgamez commented on a change in pull request #962: MINIFICPP-1441 Specify Lua version in Mac CI builds

2020-12-16 Thread GitBox


lordgamez commented on a change in pull request #962:
URL: https://github.com/apache/nifi-minifi-cpp/pull/962#discussion_r544404215



##
File path: .github/workflows/ci.yml
##
@@ -9,7 +9,7 @@ jobs:
   - id: checkout
 uses: actions/checkout@v2
   - id: install_dependencies
-run: brew install ossp-uuid boost flex openssl python lua xz libssh2
+run: brew install lua@5.3 && brew install ossp-uuid boost flex openssl 
python xz libssh2

Review comment:
   I managed to make it work when lua@5.3 was installed before the other 
packages in a single brew command, but then it failed in the next github 
actions run. I thought the order of install is arbitrary if I use a single brew 
install command so I separated them, but seems it seems not to be the case, as 
it is still failing. CMake still finds lua5.4 somehow which needs to be removed.





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] lordgamez commented on a change in pull request #962: MINIFICPP-1441 Specify Lua version in Mac CI builds

2020-12-16 Thread GitBox


lordgamez commented on a change in pull request #962:
URL: https://github.com/apache/nifi-minifi-cpp/pull/962#discussion_r544404215



##
File path: .github/workflows/ci.yml
##
@@ -9,7 +9,7 @@ jobs:
   - id: checkout
 uses: actions/checkout@v2
   - id: install_dependencies
-run: brew install ossp-uuid boost flex openssl python lua xz libssh2
+run: brew install lua@5.3 && brew install ossp-uuid boost flex openssl 
python xz libssh2

Review comment:
   I managed to make it work when lua@5.3 was installed before the other 
packages in a single brew command, but then it failed in the next github 
actions command. I thought the order of install is arbitrary if I use a single 
brew install command so I separated them, but seems it seems not to be the 
case, as it is still failing. CMake still finds lua5.4 somehow which needs to 
be removed.





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] szaszm commented on pull request #624: CEM-462 CEM-417 Fixed.

2020-12-16 Thread GitBox


szaszm commented on pull request #624:
URL: https://github.com/apache/nifi-minifi-cpp/pull/624#issuecomment-746496480


   Closing this because of inactivity. It seems to be fixed already, but the 
issue it not 100% clear from the PR.



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] szaszm closed pull request #624: CEM-462 CEM-417 Fixed.

2020-12-16 Thread GitBox


szaszm closed pull request #624:
URL: https://github.com/apache/nifi-minifi-cpp/pull/624


   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] szaszm commented on pull request #618: POC: MINIFICPP-985 - Implement listvalidators

2020-12-16 Thread GitBox


szaszm commented on pull request #618:
URL: https://github.com/apache/nifi-minifi-cpp/pull/618#issuecomment-746490514


   Closing this because of inactivity.



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] szaszm closed pull request #618: POC: MINIFICPP-985 - Implement listvalidators

2020-12-16 Thread GitBox


szaszm closed pull request #618:
URL: https://github.com/apache/nifi-minifi-cpp/pull/618


   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] szaszm closed pull request #617: Minificpp 897

2020-12-16 Thread GitBox


szaszm closed pull request #617:
URL: https://github.com/apache/nifi-minifi-cpp/pull/617


   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] szaszm commented on pull request #617: Minificpp 897

2020-12-16 Thread GitBox


szaszm commented on pull request #617:
URL: https://github.com/apache/nifi-minifi-cpp/pull/617#issuecomment-746487461


   Closing this because of inactivity



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] szaszm commented on pull request #603: MINIFICPP-929 mmap

2020-12-16 Thread GitBox


szaszm commented on pull request #603:
URL: https://github.com/apache/nifi-minifi-cpp/pull/603#issuecomment-746483791


   Closing this because of inactivity. I think the community doesn't have the 
capacity to review such huge PRs in general.



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] szaszm closed pull request #603: MINIFICPP-929 mmap

2020-12-16 Thread GitBox


szaszm closed pull request #603:
URL: https://github.com/apache/nifi-minifi-cpp/pull/603


   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] szaszm commented on pull request #598: MINIFICPP-934: Enable all features again

2020-12-16 Thread GitBox


szaszm commented on pull request #598:
URL: https://github.com/apache/nifi-minifi-cpp/pull/598#issuecomment-746481596


   This has been superseded by github actions CI, where there is a 
configuration with all stable features enabled.



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] szaszm closed pull request #598: MINIFICPP-934: Enable all features again

2020-12-16 Thread GitBox


szaszm closed pull request #598:
URL: https://github.com/apache/nifi-minifi-cpp/pull/598


   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] szaszm commented on pull request #563: WiP: MINIFICPP-839 - Fix memleaks

2020-12-16 Thread GitBox


szaszm commented on pull request #563:
URL: https://github.com/apache/nifi-minifi-cpp/pull/563#issuecomment-746479797


   Closing this because of inactivity. Some of the leaks have been fixed on 
main, and I'll make sure to check this as reference when similar efforts are 
underway.



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] szaszm closed pull request #563: WiP: MINIFICPP-839 - Fix memleaks

2020-12-16 Thread GitBox


szaszm closed pull request #563:
URL: https://github.com/apache/nifi-minifi-cpp/pull/563


   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] szaszm closed pull request #515: MINIFICPP-646 - Re-evaluate passing attributes. Potentially deprecate…

2020-12-16 Thread GitBox


szaszm closed pull request #515:
URL: https://github.com/apache/nifi-minifi-cpp/pull/515


   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] szaszm commented on pull request #515: MINIFICPP-646 - Re-evaluate passing attributes. Potentially deprecate…

2020-12-16 Thread GitBox


szaszm commented on pull request #515:
URL: https://github.com/apache/nifi-minifi-cpp/pull/515#issuecomment-746472846


   Closing this because of inactivity



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] szaszm closed pull request #472: MINIFICPP-710 - Fix errors in Property StringToInt conversion

2020-12-16 Thread GitBox


szaszm closed pull request #472:
URL: https://github.com/apache/nifi-minifi-cpp/pull/472


   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] szaszm commented on pull request #472: MINIFICPP-710 - Fix errors in Property StringToInt conversion

2020-12-16 Thread GitBox


szaszm commented on pull request #472:
URL: https://github.com/apache/nifi-minifi-cpp/pull/472#issuecomment-746471822


   Closing this because of inactivity



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] hunyadi-dev commented on a change in pull request #961: MINIFICPP-1440 PublishKafka processor's "security protocol" should ha…

2020-12-16 Thread GitBox


hunyadi-dev commented on a change in pull request #961:
URL: https://github.com/apache/nifi-minifi-cpp/pull/961#discussion_r544387125



##
File path: extensions/librdkafka/PublishKafka.cpp
##
@@ -126,7 +126,11 @@ const core::Property PublishKafka::CompressCodec(
 const core::Property PublishKafka::MaxFlowSegSize(
 core::PropertyBuilder::createProperty("Max Flow Segment 
Size")->withDescription("Maximum flow content payload segment size for the 
kafka record. 0 B means unlimited.")
 ->isRequired(false)->withDefaultValue("0 
B")->build());
-const core::Property PublishKafka::SecurityProtocol("Security Protocol", 
"Protocol used to communicate with brokers", "");
+const core::Property PublishKafka::SecurityProtocol(
+core::PropertyBuilder::createProperty("Security Protocol")
+->withDescription("Protocol used to communicate with brokers")
+->withAllowableValues({SECURITY_PROTOCOL_PLAINTEXT, 
SECURITY_PROTOCOL_SSL, SECURITY_PROTOCOL_SASL_PLAINTEXT, 
SECURITY_PROTOCOL_SASL_SSL})

Review comment:
   I would also add a default value for `PLAINTEXT` as we are trying to 
make the behaviour consistent with NiFi:
   
https://nifi.apache.org/docs/nifi-docs/components/nifi-docs/components/org.apache.nifi/nifi-kafka-2-0-nar/1.9.0/org.apache.nifi.processors.kafka.pubsub.PublishKafka_2_0/





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] szaszm closed pull request #959: MINIFICPP-1424 Stabilize several flaky test suites

2020-12-16 Thread GitBox


szaszm closed pull request #959:
URL: https://github.com/apache/nifi-minifi-cpp/pull/959


   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] fgerlits commented on a change in pull request #962: MINIFICPP-1441 Specify Lua version in Mac CI builds

2020-12-16 Thread GitBox


fgerlits commented on a change in pull request #962:
URL: https://github.com/apache/nifi-minifi-cpp/pull/962#discussion_r544370743



##
File path: .github/workflows/ci.yml
##
@@ -9,7 +9,7 @@ jobs:
   - id: checkout
 uses: actions/checkout@v2
   - id: install_dependencies
-run: brew install ossp-uuid boost flex openssl python lua xz libssh2
+run: brew install lua@5.3 && brew install ossp-uuid boost flex openssl 
python xz libssh2

Review comment:
   why do we need two `brew` commands?  `brew install ossp-uuid boost flex 
openssl python lua@5.3 xz libssh2` doesn't work, or did you just want to make 
this easier to spot for readers?





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[jira] [Commented] (NIFI-3882) Unable to run NiFi behind AWS Load Balancer

2020-12-16 Thread Otto Fowler (Jira)


[ 
https://issues.apache.org/jira/browse/NIFI-3882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250369#comment-17250369
 ] 

Otto Fowler commented on NIFI-3882:
---

Maybe there would need to be multiple endpoints, with different logical 
meanings?
Cluster Health would be one, would there be others?  One that says some set of 
flows are running?   One that says if some set of queues are full or back 
pressure is being applied?

> Unable to run NiFi behind AWS Load Balancer
> ---
>
> Key: NIFI-3882
> URL: https://issues.apache.org/jira/browse/NIFI-3882
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Core UI
>Reporter: Richard St. John
>Priority: Major
>
> Running Apache NiFi behind an AWS Elastic Load Balancer fails.
> Upon closer inspection, AWS Elastic Load Balancers only support the following 
> headers:
>X-Forwarded-For
>X-Forwarded-Proto
>X-Forwarded-Port
> In our case, we would like our ELB to be HTTPS enabled, but our NiFi cluster 
> is running in a trusted environment on port 8080.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[GitHub] [nifi-minifi-cpp] szaszm closed pull request #920: MINIFICPP-1296 - All tests should use volatile state storage

2020-12-16 Thread GitBox


szaszm closed pull request #920:
URL: https://github.com/apache/nifi-minifi-cpp/pull/920


   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[jira] [Assigned] (MINIFICPP-1441) Specify Lua version instead of default

2020-12-16 Thread Gabor Gyimesi (Jira)


 [ 
https://issues.apache.org/jira/browse/MINIFICPP-1441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Gabor Gyimesi reassigned MINIFICPP-1441:


Assignee: Gabor Gyimesi

> Specify Lua version instead of default
> --
>
> Key: MINIFICPP-1441
> URL: https://issues.apache.org/jira/browse/MINIFICPP-1441
> Project: Apache NiFi MiNiFi C++
>  Issue Type: Bug
>Reporter: Gabor Gyimesi
>Assignee: Gabor Gyimesi
>Priority: Minor
>  Time Spent: 10m
>  Remaining Estimate: 0h
>
> Current default Lua version 5.4 on Mac environments in Github actions is 
> unsupported by third party component sol2 2.20. We need to specify version 
> 5.3 in the environment to fix the issue.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[GitHub] [nifi-minifi-cpp] lordgamez opened a new pull request #962: MINIFICPP-1441 Specify Lua version in Mac CI builds

2020-12-16 Thread GitBox


lordgamez opened a new pull request #962:
URL: https://github.com/apache/nifi-minifi-cpp/pull/962


   Current default Lua version 5.4 on Mac environments in Github actions is 
unsupported by third party component sol2 2.20. Version 5.3 needs to be 
installed before flex which would install Lua 5.4 as a dependency.
   
   

   Thank you for submitting a contribution to Apache NiFi - MiNiFi C++.
   
   In order to streamline the review of the contribution we ask you
   to ensure the following steps have been taken:
   
   ### For all changes:
   - [ ] Is there a JIRA ticket associated with this PR? Is it referenced
in the commit message?
   
   - [ ] Does your PR title start with MINIFICPP- where  is the JIRA 
number you are trying to resolve? Pay particular attention to the hyphen "-" 
character.
   
   - [ ] Has your PR been rebased against the latest commit within the target 
branch (typically main)?
   
   - [ ] Is your initial contribution a single, squashed commit?
   
   ### For code changes:
   - [ ] If adding new dependencies to the code, are these dependencies 
licensed in a way that is compatible for inclusion under [ASF 
2.0](http://www.apache.org/legal/resolved.html#category-a)?
   - [ ] If applicable, have you updated the LICENSE file?
   - [ ] If applicable, have you updated the NOTICE file?
   
   ### For documentation related changes:
   - [ ] Have you ensured that format looks appropriate for the output in which 
it is rendered?
   
   ### Note:
   Please ensure that once the PR is submitted, you check GitHub Actions CI 
results for build issues and submit an update to your PR as soon as possible.
   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[jira] [Created] (MINIFICPP-1441) Specify Lua version instead of default

2020-12-16 Thread Gabor Gyimesi (Jira)
Gabor Gyimesi created MINIFICPP-1441:


 Summary: Specify Lua version instead of default
 Key: MINIFICPP-1441
 URL: https://issues.apache.org/jira/browse/MINIFICPP-1441
 Project: Apache NiFi MiNiFi C++
  Issue Type: Bug
Reporter: Gabor Gyimesi


Current default Lua version 5.4 on Mac environments in Github actions is 
unsupported by third party component sol2 2.20. We need to specify version 5.3 
in the environment to fix the issue.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[GitHub] [nifi-minifi-cpp] szaszm closed pull request #901: MINIFICPP-1288 - Refactor YamlConfiguration::parsePropertiesNodeYaml

2020-12-16 Thread GitBox


szaszm closed pull request #901:
URL: https://github.com/apache/nifi-minifi-cpp/pull/901


   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] szaszm commented on a change in pull request #961: MINIFICPP-1440 PublishKafka processor's "security protocol" should ha…

2020-12-16 Thread GitBox


szaszm commented on a change in pull request #961:
URL: https://github.com/apache/nifi-minifi-cpp/pull/961#discussion_r544326007



##
File path: extensions/librdkafka/PublishKafka.cpp
##
@@ -126,7 +126,11 @@ const core::Property PublishKafka::CompressCodec(
 const core::Property PublishKafka::MaxFlowSegSize(
 core::PropertyBuilder::createProperty("Max Flow Segment 
Size")->withDescription("Maximum flow content payload segment size for the 
kafka record. 0 B means unlimited.")
 ->isRequired(false)->withDefaultValue("0 
B")->build());
-const core::Property PublishKafka::SecurityProtocol("Security Protocol", 
"Protocol used to communicate with brokers", "");
+const core::Property PublishKafka::SecurityProtocol(
+core::PropertyBuilder::createProperty("Security Protocol")
+->withDescription("Protocol used to communicate with brokers")
+->withAllowableValues({SECURITY_PROTOCOL_PLAINTEXT, 
SECURITY_PROTOCOL_SSL, SECURITY_PROTOCOL_SASL_PLAINTEXT, 
SECURITY_PROTOCOL_SASL_SSL})

Review comment:
   When looking at `PublishKafka.cpp:686`, it seems like only 
`SECURITY_PROTOCOL_SSL` is actually supported, and the default empty value is 
interpreted as plaintext.
   
   I suggest restricting the set of "allowable values" to plaintext and ssl, 
and handling plaintext near `PublishKafka.cpp:687`. I think doing nothing is a 
valid handling of plaintext.





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[jira] [Assigned] (NIFIREG-434) Support BCFKS Keystore Type

2020-12-16 Thread David Handermann (Jira)


 [ 
https://issues.apache.org/jira/browse/NIFIREG-434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

David Handermann reassigned NIFIREG-434:


Assignee: David Handermann

> Support BCFKS Keystore Type
> ---
>
> Key: NIFIREG-434
> URL: https://issues.apache.org/jira/browse/NIFIREG-434
> Project: NiFi Registry
>  Issue Type: Improvement
>Affects Versions: 0.8.0
>Reporter: David Handermann
>Assignee: David Handermann
>Priority: Minor
>  Labels: security
>  Time Spent: 10m
>  Remaining Estimate: 0h
>
> The [Bouncy Castle FIPS Key 
> Store|https://cryptosense.com/blog/bouncycastle-keystore-security/] (BCFKS) 
> format supports storage of certificates and private keys using AES-CCM and 
> PBKDF2 algorithms, providing greater security than the standard JKS and 
> PKCS12 implementations. Support for BCFKS can be implemented using Bouncy 
> Castle security provider libraries that are already leveraged throughout the 
> system.
> Initial support should include the ability to specify BCFKS as the key store 
> and trust store type in standard properties files.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[GitHub] [nifi-minifi-cpp] szaszm commented on a change in pull request #901: MINIFICPP-1288 - Refactor YamlConfiguration::parsePropertiesNodeYaml

2020-12-16 Thread GitBox


szaszm commented on a change in pull request #901:
URL: https://github.com/apache/nifi-minifi-cpp/pull/901#discussion_r544313026



##
File path: libminifi/src/core/yaml/YamlConfiguration.cpp
##
@@ -762,106 +762,109 @@ void YamlConfiguration::parsePortYaml(YAML::Node 
*portNode, core::ProcessGroup *
   }
 }
 
-void YamlConfiguration::parsePropertiesNodeYaml(YAML::Node *propertiesNode, 
std::shared_ptr processor, const std::string 
_name,
-const std::string 
_section) {
-  // Treat generically as a YAML node so we can perform inspection on entries 
to ensure they are populated
-  logger_->log_trace("Entered %s", component_name);
-  for (YAML::const_iterator propsIter = propertiesNode->begin(); propsIter != 
propertiesNode->end(); ++propsIter) {
-std::string propertyName = propsIter->first.as();
-YAML::Node propertyValueNode = propsIter->second;
-logger_->log_trace("Encountered %s", propertyName);
-if (!propertyValueNode.IsNull() && propertyValueNode.IsDefined()) {
-  if (propertyValueNode.IsSequence()) {
-for (auto iter : propertyValueNode) {
-  if (iter.IsDefined()) {
-YAML::Node nodeVal = iter.as();
-YAML::Node propertiesNode = nodeVal["value"];
-// must insert the sequence in differently.
-std::string rawValueString = propertiesNode.as();
-logger_->log_debug("Found %s=%s", propertyName, rawValueString);
-if (!processor->updateProperty(propertyName, rawValueString)) {
-  std::shared_ptr proc = 
std::dynamic_pointer_cast(processor);
-  if (proc != 0) {
-logger_->log_warn("Received property %s with value %s but is 
not one of the properties for %s. "
-  "Attempting to add as dynamic property.",
-  propertyName, rawValueString, 
proc->getName());
-if (!processor->setDynamicProperty(propertyName, 
rawValueString)) {
-  logger_->log_warn("Unable to set the dynamic property %s 
with value %s", propertyName.c_str(), rawValueString.c_str());
-} else {
-  logger_->log_warn("Dynamic property %s with value %s set", 
propertyName.c_str(), rawValueString.c_str());
-}
-  }
-}
-  }
-}
-  } else {
-core::Property myProp(propertyName, "", "");
-processor->getProperty(propertyName, myProp);
-PropertyValue defaultValue;
-defaultValue = myProp.getDefaultValue();
-auto defaultType = defaultValue.getTypeInfo();
-PropertyValue coercedValue = defaultValue;
-
-// coerce the types. upon failure we will either exit or use the 
default value.
-// we do this here ( in addition to the PropertyValue class ) to get 
the earliest
-// possible YAML failure.
-try {
-  if (defaultType == typeid(std::string)) {
-auto typedValue = propertyValueNode.as();
-coercedValue = typedValue;
-  } else if (defaultType == typeid(int64_t)) {
-auto typedValue = propertyValueNode.as();
-coercedValue = typedValue;
-  } else if (defaultType == typeid(uint64_t)) {
-try {
-  auto typedValue = propertyValueNode.as();
-  coercedValue = typedValue;
-} catch (...) {
-  auto typedValue = propertyValueNode.as();
-  coercedValue = typedValue;
-}
-  } else if (defaultType == typeid(int)) {
-auto typedValue = propertyValueNode.as();
-coercedValue = typedValue;
-  } else if (defaultType == typeid(bool)) {
-auto typedValue = propertyValueNode.as();
-coercedValue = typedValue;
+void YamlConfiguration::parsePropertyValueSequence(const std::string& 
propertyName, const YAML::Node& propertyValueNode, 
std::shared_ptr processor,
+const std::string _section) {
+  for (auto iter : propertyValueNode) {
+if (iter.IsDefined()) {
+  YAML::Node nodeVal = iter.as();
+  YAML::Node propertiesNode = nodeVal["value"];
+  // must insert the sequence in differently.
+  std::string rawValueString = propertiesNode.as();
+  logger_->log_debug("Found %s=%s", propertyName, rawValueString);
+  if (!processor->updateProperty(propertyName, rawValueString)) {
+std::shared_ptr proc = 
std::dynamic_pointer_cast(processor);
+if (proc != 0) {
+  logger_->log_warn("Received property %s with value %s but is not one 
of the properties for %s. Attempting to add as dynamic property.", 
propertyName, rawValueString, proc->getName());
+  if (!processor->setDynamicProperty(propertyName, rawValueString)) {
+logger_->log_warn("Unable to set the dynamic property %s with 
value %s", propertyName.c_str(), rawValueString.c_str());
   } else {
-  

[GitHub] [nifi-registry] exceptionfactory opened a new pull request #314: NIFIREG-434 Added support for BCFKS Keystore Type

2020-12-16 Thread GitBox


exceptionfactory opened a new pull request #314:
URL: https://github.com/apache/nifi-registry/pull/314


    Description of PR
   
   NIFIREG-434 Adds support for Bouncy Castle FIPS Key Store (BCFKS) in NiFi 
Registry configuration properties. BCFKS provides improved security for storage 
of certificates and private keys using AES-CCM and PKBDF2 algorithms for 
encryption of entries. The implementation leverages the existing Bouncy Castle 
Security Provider library and updates the KeystoreType enumeration along with 
related unit tests for KeystoreUtils.  Updates include removing the 
KeyStoreUtils.getTrustStore() method, which logged a deprecation warning for 
PKCS12.  PKCS12 is the default keystore type starting in Java 9, so the log 
message should be removed.
   
   The Java Keytool command can be used to convert JKS or PKCS12 keystores to 
BCFKS by referencing the Bouncy Castle Security Provider library and provider 
class using the following command:
   
   keytool -importkeystore -srckeystore keystore.jks -destkeystore 
keystore.bcfks -deststoretype BCFKS -providerpath bcprov-jdk15on-1.66.jar 
-providerclass org.bouncycastle.jce.provider.BouncyCastleProvider
   
   In order to streamline the review of the contribution we ask you
   to ensure the following steps have been taken:
   
   ### For all changes:
   - [X] Is there a JIRA ticket associated with this PR? Is it referenced 
in the commit message?
   
   - [X] Does your PR title start with **NIFIREG-** where  is the JIRA 
number you are trying to resolve? Pay particular attention to the hyphen "-" 
character.
   
   - [X] Has your PR been rebased against the latest commit within the target 
branch (typically `main`)?
   
   - [X] Is your initial contribution a single, squashed commit? _Additional 
commits in response to PR reviewer feedback should be made on this branch and 
pushed to allow change tracking. Do not `squash` or use `--force` when pushing 
to allow for clean monitoring of changes._
   
   ### For code changes:
   - [X] Have you ensured that the full suite of tests is executed via `mvn 
-Pcontrib-check clean install` at the root `nifi-registry` folder?
   - [X] Have you written or updated unit tests to verify your changes?
   - [ ] Have you verified that the full build is successful on JDK 8?
   - [X] Have you verified that the full build is successful on JDK 11?
   - [ ] If adding new dependencies to the code, are these dependencies 
licensed in a way that is compatible for inclusion under [ASF 
2.0](http://www.apache.org/legal/resolved.html#category-a)? 
   - [ ] If applicable, have you updated the `LICENSE` file, including the main 
`LICENSE` file under `nifi-registry-assembly`?
   - [ ] If applicable, have you updated the `NOTICE` file, including the main 
`NOTICE` file found under `nifi-registry-assembly`?
   
   ### For documentation related changes:
   - [X] Have you ensured that format looks appropriate for the output in which 
it is rendered?
   
   ### Note:
   Please ensure that once the PR is submitted, you check GitHub Actions CI for 
build issues and submit an update to your PR as soon as possible.
   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[GitHub] [nifi-minifi-cpp] dam4rus opened a new pull request #961: MINIFICPP-1440 PublishKafka processor's "security protocol" should ha…

2020-12-16 Thread GitBox


dam4rus opened a new pull request #961:
URL: https://github.com/apache/nifi-minifi-cpp/pull/961


   …ve allowable values
   
   Thank you for submitting a contribution to Apache NiFi - MiNiFi C++.
   
   In order to streamline the review of the contribution we ask you
   to ensure the following steps have been taken:
   
   ### For all changes:
   - [ ] Is there a JIRA ticket associated with this PR? Is it referenced
in the commit message?
   
   - [ ] Does your PR title start with MINIFICPP- where  is the JIRA 
number you are trying to resolve? Pay particular attention to the hyphen "-" 
character.
   
   - [ ] Has your PR been rebased against the latest commit within the target 
branch (typically main)?
   
   - [ ] Is your initial contribution a single, squashed commit?
   
   ### For code changes:
   - [ ] If adding new dependencies to the code, are these dependencies 
licensed in a way that is compatible for inclusion under [ASF 
2.0](http://www.apache.org/legal/resolved.html#category-a)?
   - [ ] If applicable, have you updated the LICENSE file?
   - [ ] If applicable, have you updated the NOTICE file?
   
   ### For documentation related changes:
   - [ ] Have you ensured that format looks appropriate for the output in which 
it is rendered?
   
   ### Note:
   Please ensure that once the PR is submitted, you check GitHub Actions CI 
results for build issues and submit an update to your PR as soon as possible.
   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[jira] [Commented] (NIFI-3882) Unable to run NiFi behind AWS Load Balancer

2020-12-16 Thread Ruben Laguna (Jira)


[ 
https://issues.apache.org/jira/browse/NIFI-3882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250279#comment-17250279
 ] 

Ruben Laguna commented on NIFI-3882:


I guess, that it was really terminating the HTTPS for the NiFI UI, which is 
possible already today. 
What is not possible (IMHO) is to do it reliably due to the lack of a /health 
endpoint that allows the load balancer to check if the node is ready to accept 
UI requests.

 I've reported this in https://issues.apache.org/jira/browse/NIFI-8100. The 
gist is that for AWS Load Balancer we need an endpoint that does NOT require 
authentication and that gives a 4xx-5xx http status code if the node is 
disconnected (not part of the cluster). 




 

> Unable to run NiFi behind AWS Load Balancer
> ---
>
> Key: NIFI-3882
> URL: https://issues.apache.org/jira/browse/NIFI-3882
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Core UI
>Reporter: Richard St. John
>Priority: Major
>
> Running Apache NiFi behind an AWS Elastic Load Balancer fails.
> Upon closer inspection, AWS Elastic Load Balancers only support the following 
> headers:
>X-Forwarded-For
>X-Forwarded-Proto
>X-Forwarded-Port
> In our case, we would like our ELB to be HTTPS enabled, but our NiFi cluster 
> is running in a trusted environment on port 8080.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[GitHub] [nifi-minifi-cpp] lordgamez commented on a change in pull request #959: MINIFICPP-1424 Stabilize several flaky test suites

2020-12-16 Thread GitBox


lordgamez commented on a change in pull request #959:
URL: https://github.com/apache/nifi-minifi-cpp/pull/959#discussion_r544237854



##
File path: libminifi/test/persistence-tests/PersistenceTests.cpp
##
@@ -326,11 +335,15 @@ TEST_CASE("Persisted flowFiles are updated on 
modification", "[TestP1]") {
 ff_repository->start();
 // wait for FlowFileRepository to start and notify the owners of
 // the resurrected FlowFiles
-std::this_thread::sleep_for(std::chrono::milliseconds{100});
-
+std::this_thread::sleep_for(std::chrono::milliseconds(100));

Review comment:
   It seems unfortunately wait is still needed in RepoTests and one of them 
cannot be checked by any log entries either, so one sleep is necessary (updated 
in 
[986ff8d](https://github.com/apache/nifi-minifi-cpp/pull/959/commits/986ff8db637d6551ff5e0d68f02656b6039a28af)).





This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org




[jira] [Commented] (NIFI-8099) HTTP Headers is case-insentitive and overwrite attributes values

2020-12-16 Thread Pierre Villard (Jira)


[ 
https://issues.apache.org/jira/browse/NIFI-8099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250266#comment-17250266
 ] 

Pierre Villard commented on NIFI-8099:
--

Not sure what would the correct approach be in this case. Suggestion:
 * if the processor has an incoming relationship, check if the flow file has 
two attributes with the same name (when case insensitive), generate a bulletin 
and route the flow file to failure
 * if the processor has no incoming relationship, make the processor invalid if 
configured with dynamic properties with multiple values for the same attribute 
(when case insensitive)

> HTTP Headers is case-insentitive and overwrite attributes values
> 
>
> Key: NIFI-8099
> URL: https://issues.apache.org/jira/browse/NIFI-8099
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Core Framework
>Affects Versions: 1.12.1
>Reporter: Jens M Kofoed
>Priority: Major
>
> I've created 2 flows at 2 different NIFI instances for testing HTTP transfer 
> between NIFI.
> RFC-2616 says that headers is case-insentitive, but if I create 3 attributes 
> with values as this:
> MyAttribute : "MyData", myattribute : "mydata" & MYATTRIBUTE : "MYDATA" all 3 
> fields is coming through as they are, but all 3 value are set to "mydata" 
> I'm using InvokeHTTP to trasfer data to the other instance. 
> IncludeDataHeaders = True and Attributes to send is set to .* and I'm using 
> ListenHTTP to recive data
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (NIFI-8092) Fix ITPutS3Object test failure due to Outposts storage class

2020-12-16 Thread Pierre Villard (Jira)


 [ 
https://issues.apache.org/jira/browse/NIFI-8092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Pierre Villard updated NIFI-8092:
-
Fix Version/s: 1.13.0
   Resolution: Fixed
   Status: Resolved  (was: Patch Available)

> Fix ITPutS3Object test failure due to Outposts storage class
> 
>
> Key: NIFI-8092
> URL: https://issues.apache.org/jira/browse/NIFI-8092
> Project: Apache NiFi
>  Issue Type: Test
>  Components: Extensions
>Reporter: Peter Turcsanyi
>Assignee: Peter Turcsanyi
>Priority: Minor
> Fix For: 1.13.0
>
>  Time Spent: 0.5h
>  Remaining Estimate: 0h
>
> "Outposts" storage class cannot be tested on AWS cloud infrastructure. It 
> should be skipped.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


  1   2   >