[jira] [Created] (NIFI-2851) Improve performance of SplitText

2016-09-30 Thread Mark Payne (JIRA)
Mark Payne created NIFI-2851:


 Summary: Improve performance of SplitText
 Key: NIFI-2851
 URL: https://issues.apache.org/jira/browse/NIFI-2851
 Project: Apache NiFi
  Issue Type: Improvement
  Components: Core Framework
Reporter: Mark Payne
Assignee: Mark Payne
 Fix For: 1.1.0


SplitText is fairly CPU-intensive and quite slow. A simple flow that splits a 
1.4 million line text file into 5k line chunks and then splits those 5k line 
chunks into 1 line chunks is only capable of pushing through about 10k lines 
per second. This equates to about 10 MB/sec. JVisualVM shows that the majority 
of the time is spent in the locateSplitPoint() method. Isolating this code and 
inspecting how it works, and using some micro-benchmarking, it appears that if 
we refactor the calls to InputStream.read() to instead read into a byte array, 
we can improve performance.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Created] (NIFI-2850) Provide ability for a FlowFile to be migrated from one Process Session to another

2016-09-30 Thread Mark Payne (JIRA)
Mark Payne created NIFI-2850:


 Summary: Provide ability for a FlowFile to be migrated from one 
Process Session to another
 Key: NIFI-2850
 URL: https://issues.apache.org/jira/browse/NIFI-2850
 Project: Apache NiFi
  Issue Type: Improvement
  Components: Core Framework
Reporter: Mark Payne
Assignee: Mark Payne
 Fix For: 1.1.0


Currently, the MergeContent processor creates a separate ProcessSession for 
each FlowFile that it pulls. This is done so that we can ensure that we can 
commit all Process Sessions when a bin is full. Unfortunately, this means that 
MergeContent is required to call ProcessSession.get() many times, which adds a 
lot of contention on the FlowFile Queue. If we allow FlowFiles to be migrated 
from 1 session to another, we can have a session per bin, and then use 
ProcessSession.get(100) to greatly reduce lock contention. This will likely 
have benefits in other processors as well.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (NIFI-2341) Create a processor to parse logs formated using CEF

2016-09-30 Thread ASF GitHub Bot (JIRA)

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

ASF GitHub Bot commented on NIFI-2341:
--

Github user mattyb149 commented on the issue:

https://github.com/apache/nifi/pull/785
  
Sounds good thanks, will take a look soon


> Create a processor to parse logs formated using CEF
> ---
>
> Key: NIFI-2341
> URL: https://issues.apache.org/jira/browse/NIFI-2341
> Project: Apache NiFi
>  Issue Type: Improvement
>Reporter: Andre
>Assignee: Andre
> Fix For: 1.1.0
>
>
> As NiFi continue to increase its abilities to complement SIEM, Splunk and ELK 
> deployments, a number of users will be looking to parse CEF formatted 
> logs[1][2].
> CEF is a format specified by Arcsight (now part of HPE) and is described in 
> detail in here:
> https://www.protect724.hpe.com/docs/DOC-1072
> [1] 
> http://apache-nifi.1125220.n5.nabble.com/Suggestion-of-processors-td9795.html
> [2] 
> https://community.hortonworks.com/questions/43185/which-processor-is-used-to-parse-cef-format-logs.html



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (NIFI-2341) Create a processor to parse logs formated using CEF

2016-09-30 Thread ASF GitHub Bot (JIRA)

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

ASF GitHub Bot commented on NIFI-2341:
--

Github user trixpan commented on the issue:

https://github.com/apache/nifi/pull/785
  
@mattyb149 all feedback addressed.

this should be ready for review


> Create a processor to parse logs formated using CEF
> ---
>
> Key: NIFI-2341
> URL: https://issues.apache.org/jira/browse/NIFI-2341
> Project: Apache NiFi
>  Issue Type: Improvement
>Reporter: Andre
>Assignee: Andre
> Fix For: 1.1.0
>
>
> As NiFi continue to increase its abilities to complement SIEM, Splunk and ELK 
> deployments, a number of users will be looking to parse CEF formatted 
> logs[1][2].
> CEF is a format specified by Arcsight (now part of HPE) and is described in 
> detail in here:
> https://www.protect724.hpe.com/docs/DOC-1072
> [1] 
> http://apache-nifi.1125220.n5.nabble.com/Suggestion-of-processors-td9795.html
> [2] 
> https://community.hortonworks.com/questions/43185/which-processor-is-used-to-parse-cef-format-logs.html



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] nifi issue #785: NIFI-2341 - Introduce ParseCEF processor

2016-09-30 Thread mattyb149
Github user mattyb149 commented on the issue:

https://github.com/apache/nifi/pull/785
  
Sounds good thanks, will take a look soon


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] nifi issue #785: NIFI-2341 - Introduce ParseCEF processor

2016-09-30 Thread trixpan
Github user trixpan commented on the issue:

https://github.com/apache/nifi/pull/785
  
@mattyb149 all feedback addressed.

this should be ready for review


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Commented] (NIFI-2709) Email processors with Exchange don't output to RFC2822 format

2016-09-30 Thread ASF GitHub Bot (JIRA)

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

ASF GitHub Bot commented on NIFI-2709:
--

Github user trixpan commented on the issue:

https://github.com/apache/nifi/pull/1083
  
@bbende code should pass contrib-check and be ready for review. 


> Email processors with Exchange don't output to RFC2822 format
> -
>
> Key: NIFI-2709
> URL: https://issues.apache.org/jira/browse/NIFI-2709
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Extensions
>Affects Versions: 1.0.0
> Environment: Ubuntu 16.04 LTS with openjdk-8-jre-headless
>Reporter: Emil Frank
>Assignee: Andre
>Priority: Minor
> Attachments: 1083.patch, screenshot-1.png
>
>
> When using the new ConsumeIMAP and ConsumePOP3 processors with a Microsoft 
> Exchange 2013 IMAP server the flowfiles which are produced are simple HTML 
> messages with no RFC2822 headers. I have also tried setting Exchange to force 
> emails to be text only, sadly only the body with some Content-Type: fields 
> are outputed.
> This mean that ExtractEmailHeaders and ExtractEmailAttachments cannot be used 
> directly with these processors.
> In Python, I can force Exchange to output the headers by specify RFC822 in 
> the connection settings:
> - https://docs.python.org/3/library/imaplib.html#imap4-example
> Is a similar option available for the spring mail framework?



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] nifi issue #1083: NIFI-2709 - Refactor ConsumeIMAP and ConsumePOP3 to genera...

2016-09-30 Thread trixpan
Github user trixpan commented on the issue:

https://github.com/apache/nifi/pull/1083
  
@bbende code should pass contrib-check and be ready for review. 


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Commented] (NIFI-2848) Queues aren't fairly drained when leading to a single component

2016-09-30 Thread Joseph Gresock (JIRA)

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

Joseph Gresock commented on NIFI-2848:
--

You're right, it appears to be the same issue.

> Queues aren't fairly drained when leading to a single component
> ---
>
> Key: NIFI-2848
> URL: https://issues.apache.org/jira/browse/NIFI-2848
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Core Framework
>Affects Versions: 1.0.0, 0.7.0
>Reporter: Joseph Gresock
> Attachments: Backpressure_prioritization_test.xml, dominate_1.png, 
> dominate_2.png, queue_drain.png
>
>
> Consider the scenario where multiple queues lead to a single component and 
> all of them are full due to back pressure.  With the attached template, it is 
> easily observable that once a single queue starts to drain due to relieved 
> back pressure, it will continue to drain as long as it has incoming flow 
> files.  This means that if there's a constant flow of incoming flow files to 
> this queue, the other queues will never be drained (at least, that's my 
> theory based on several hours of observation).
> To reproduce this: 
> # Load the template into NiFi 1.0.0
> # Play all three GenerateFlowFile processors, but not the UpdateAttribute 
> processor (this simulates backpressure).  Wait until each queue has 1,000 
> flow files (max backpressure)
> # Stop the GenerateFlowFile processors, and play the UpdateAttribute 
> processor (this relieves the backpressure)
> # Observe which queue has started to drain, and start its GenerateFlowFile 
> processor
> # Observe that the other two queues remain full indefinitely, while the 
> draining queue continues to replenish and be drained indefinitely



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (NIFI-2774) ConsumeJMS processor losses messages on NiFi restart

2016-09-30 Thread ASF GitHub Bot (JIRA)

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

ASF GitHub Bot commented on NIFI-2774:
--

Github user mosermw commented on a diff in the pull request:

https://github.com/apache/nifi/pull/1036#discussion_r81410549
  
--- Diff: 
nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/ConsumeJMS.java
 ---
@@ -54,8 +61,31 @@
 @SeeAlso(value = { PublishJMS.class, JMSConnectionFactoryProvider.class })
 public class ConsumeJMS extends AbstractJMSProcessor {
 
+static final AllowableValue AUTO_ACK = new 
AllowableValue(String.valueOf(Session.AUTO_ACKNOWLEDGE),
+"AUTO_ACKNOWLEDGE",
+"Automatically acknowledges a client's receipt of a message, 
regardless if NiFi session has been commited. "
++ "Can result in data loss in the event where NiFi 
abruptly stopped before session was commited.");
+
+static final AllowableValue CLIENT_ACK = new 
AllowableValue(String.valueOf(Session.CLIENT_ACKNOWLEDGE),
+"CLIENT_ACKNOWLEDGE",
+"(DEFAULT) Manually acknowledges a client's receipt of a 
message after NiFi Session was commited, thus ensuring no data loss");
+
+static final AllowableValue DUPS_OK = new 
AllowableValue(String.valueOf(Session.DUPS_OK_ACKNOWLEDGE),
+"DUPS_OK_ACKNOWLEDGE",
+"This acknowledgment mode instructs the session to lazily 
acknowledge the delivery of messages. May result uin both data "
--- End diff --

Spelling "uin"


> ConsumeJMS processor losses messages on NiFi restart
> 
>
> Key: NIFI-2774
> URL: https://issues.apache.org/jira/browse/NIFI-2774
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Core Framework
>Affects Versions: 1.0.0, 0.7.0
>Reporter: Christopher McDermott
>Assignee: Oleg Zhurakousky
>Priority: Critical
> Fix For: 1.1.0, 0.8.0
>
> Attachments: 2774.patch
>
>
> ConsumeJMS processor uses auto-acknowledge mode.  Unlike the deprecated 
> GetJMSQueue processor it does not provide a way to specify a different ACK 
> mode (i.e. client-acknowledge.)  Using auto-acknowledge, acknowledges message 
> receipt from JMS *before* the messages are actually added to the flow.  This 
> leads to data-loss on NiFi stop (or crash.)
> I believe the fix for this is to allow the user to specify the ACK mode in 
> the processor configuration like is allowed by the GetJMSQueue processor.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (NIFI-2774) ConsumeJMS processor losses messages on NiFi restart

2016-09-30 Thread ASF GitHub Bot (JIRA)

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

ASF GitHub Bot commented on NIFI-2774:
--

Github user mosermw commented on a diff in the pull request:

https://github.com/apache/nifi/pull/1036#discussion_r81411506
  
--- Diff: 
nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/ConsumeJMS.java
 ---
@@ -116,18 +154,26 @@ protected JMSConsumer 
finishBuildingTargetResource(JmsTemplate jmsTemplate) {
 }
 
 /**
+ *
+ */
+@Override
+protected List getSupportedPropertyDescriptors() {
+List pd = new 
ArrayList<>(super.getSupportedPropertyDescriptors());
+pd.add(ACKNOWLEDGEMENT_MODE);
+return pd;
--- End diff --

Not an incredibly big deal, but getSupportedPropertyDescriptors() is called 
very often (most often in validation during a UI Refresh) which causes lots of 
ArrayLists to be created.  I prefer the way DistributeLoad handles this, by 
creating one ArrayList and reusing it, while also using an AtomicBoolean to 
know when it should be recreated.


> ConsumeJMS processor losses messages on NiFi restart
> 
>
> Key: NIFI-2774
> URL: https://issues.apache.org/jira/browse/NIFI-2774
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Core Framework
>Affects Versions: 1.0.0, 0.7.0
>Reporter: Christopher McDermott
>Assignee: Oleg Zhurakousky
>Priority: Critical
> Fix For: 1.1.0, 0.8.0
>
> Attachments: 2774.patch
>
>
> ConsumeJMS processor uses auto-acknowledge mode.  Unlike the deprecated 
> GetJMSQueue processor it does not provide a way to specify a different ACK 
> mode (i.e. client-acknowledge.)  Using auto-acknowledge, acknowledges message 
> receipt from JMS *before* the messages are actually added to the flow.  This 
> leads to data-loss on NiFi stop (or crash.)
> I believe the fix for this is to allow the user to specify the ACK mode in 
> the processor configuration like is allowed by the GetJMSQueue processor.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] nifi pull request #1036: NIFI-2774 added configurable QoS options

2016-09-30 Thread mosermw
Github user mosermw commented on a diff in the pull request:

https://github.com/apache/nifi/pull/1036#discussion_r81410549
  
--- Diff: 
nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/ConsumeJMS.java
 ---
@@ -54,8 +61,31 @@
 @SeeAlso(value = { PublishJMS.class, JMSConnectionFactoryProvider.class })
 public class ConsumeJMS extends AbstractJMSProcessor {
 
+static final AllowableValue AUTO_ACK = new 
AllowableValue(String.valueOf(Session.AUTO_ACKNOWLEDGE),
+"AUTO_ACKNOWLEDGE",
+"Automatically acknowledges a client's receipt of a message, 
regardless if NiFi session has been commited. "
++ "Can result in data loss in the event where NiFi 
abruptly stopped before session was commited.");
+
+static final AllowableValue CLIENT_ACK = new 
AllowableValue(String.valueOf(Session.CLIENT_ACKNOWLEDGE),
+"CLIENT_ACKNOWLEDGE",
+"(DEFAULT) Manually acknowledges a client's receipt of a 
message after NiFi Session was commited, thus ensuring no data loss");
+
+static final AllowableValue DUPS_OK = new 
AllowableValue(String.valueOf(Session.DUPS_OK_ACKNOWLEDGE),
+"DUPS_OK_ACKNOWLEDGE",
+"This acknowledgment mode instructs the session to lazily 
acknowledge the delivery of messages. May result uin both data "
--- End diff --

Spelling "uin"


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] nifi pull request #1036: NIFI-2774 added configurable QoS options

2016-09-30 Thread mosermw
Github user mosermw commented on a diff in the pull request:

https://github.com/apache/nifi/pull/1036#discussion_r81411506
  
--- Diff: 
nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/ConsumeJMS.java
 ---
@@ -116,18 +154,26 @@ protected JMSConsumer 
finishBuildingTargetResource(JmsTemplate jmsTemplate) {
 }
 
 /**
+ *
+ */
+@Override
+protected List getSupportedPropertyDescriptors() {
+List pd = new 
ArrayList<>(super.getSupportedPropertyDescriptors());
+pd.add(ACKNOWLEDGEMENT_MODE);
+return pd;
--- End diff --

Not an incredibly big deal, but getSupportedPropertyDescriptors() is called 
very often (most often in validation during a UI Refresh) which causes lots of 
ArrayLists to be created.  I prefer the way DistributeLoad handles this, by 
creating one ArrayList and reusing it, while also using an AtomicBoolean to 
know when it should be recreated.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Commented] (NIFI-2603) Bringing Some UI Color Back

2016-09-30 Thread Peter Wicks (JIRA)

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

Peter Wicks commented on NIFI-2603:
---

Sounds good.  We've been running a modified 1.0 with my UI Color branch merged 
into it. I've found that in many cases I agree with some of the guidance, like 
getting rid of color on mouseovers, they feel more distracting then anything 
now.

> Bringing Some UI Color Back
> ---
>
> Key: NIFI-2603
> URL: https://issues.apache.org/jira/browse/NIFI-2603
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Core UI
>Reporter: Peter Wicks
>Priority: Minor
>
> In the new 1.0 UI all of the colors associated with status (except the orange 
> triangle) are gone; replaced with a dark gray color.
> I propose bringing back color.  The screenshots are in the format of before 
> on the top and after on the bottom, except were labeled in the picture itself:
>  - Top Status Menu: https://goo.gl/photos/se1JnvhRwU7N4Fap7
>  - Process Group: https://goo.gl/photos/dqjG4KvC6xqxQfgT7
>  - Processes (Running/Stopped/Invalid): 
> https://goo.gl/photos/dSS8vgE2RkrXtc77A
>  - Operate Play/Stop buttons (only on mouse hover): 
> https://goo.gl/photos/Am5SUEEn7G9RjmMe6
>  - Processor/Processor Group Context Menu: 
> https://goo.gl/photos/Jq3qFg4ezaN91qms5
> This is not a "100% done, I've covered everything" before/after list.  I know 
> I need to do the NiFi summary page also at the minimum.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] nifi-minifi pull request #40: MINIFI-46 - Supporting multiple relationships ...

2016-09-30 Thread brosander
GitHub user brosander opened a pull request:

https://github.com/apache/nifi-minifi/pull/40

MINIFI-46 - Supporting multiple relationships for MiNiFi connections



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/brosander/nifi-minifi MINIFI-46

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/nifi-minifi/pull/40.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #40


commit 7e423ea3eff428a706dbddfe96ed6c4ad3ba9217
Author: Bryan Rosander 
Date:   2016-09-30T13:32:40Z

MINIFI-46 - Supporting multiple relationships for MiNiFi connections




---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Commented] (NIFI-766) UI should indicate when backpressure is configured for a Connection

2016-09-30 Thread ASF GitHub Bot (JIRA)

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

ASF GitHub Bot commented on NIFI-766:
-

Github user mcgilman commented on the issue:

https://github.com/apache/nifi/pull/1080
  
@pvillard31,

Following some of the discussion on the mailing list recently and the 
original commentary on the JIRA [1], I'd like to propose shifting from an icon 
based approach when back pressure is engaged to a progress bar style approach 
where the user can quickly get a sense of how 'full' the queue is currently.


![backpressure](https://cloud.githubusercontent.com/assets/123395/19003638/c0abcfc6-871f-11e6-9338-c6b2500c4ee3.png)

The mockup shows various configuration scenarios. 

- Expiration (clock icon)
- Object and Data size backpressure (left and right bars respectively)
- Empty bar - backpressure not configured
- Partial bar - backpressure configured, partial represent precentage full
- Full solid bar - backpressure engaged

If you're up for some additional cycles on this PR I'd be happy to work 
through the changes with you. If not, I'm happy to take what you started and 
continue toward the mockup above.

Thanks!

[1] https://issues.apache.org/jira/browse/NIFI-766



> UI should indicate when backpressure is configured for a Connection
> ---
>
> Key: NIFI-766
> URL: https://issues.apache.org/jira/browse/NIFI-766
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Core Framework, Core UI
>Reporter: Mark Payne
>Assignee: Pierre Villard
> Fix For: 1.1.0
>
> Attachments: backpressure.png, backpressure_and_expiration.png, 
> normal.png
>
>
> It is sometimes unclear why a Processor is not running, if it is due to 
> backpressure. Recommend we add an icon to the Connection label to indicate 
> that backpressure is configured. If backpressure is "applied" (i.e., the 
> backpressure threshold has been reached), that icon should be highlighted 
> somehow.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] nifi issue #1080: NIFI-766 Added icon on connection when backpressure is ena...

2016-09-30 Thread mcgilman
Github user mcgilman commented on the issue:

https://github.com/apache/nifi/pull/1080
  
@pvillard31,

Following some of the discussion on the mailing list recently and the 
original commentary on the JIRA [1], I'd like to propose shifting from an icon 
based approach when back pressure is engaged to a progress bar style approach 
where the user can quickly get a sense of how 'full' the queue is currently.


![backpressure](https://cloud.githubusercontent.com/assets/123395/19003638/c0abcfc6-871f-11e6-9338-c6b2500c4ee3.png)

The mockup shows various configuration scenarios. 

- Expiration (clock icon)
- Object and Data size backpressure (left and right bars respectively)
- Empty bar - backpressure not configured
- Partial bar - backpressure configured, partial represent precentage full
- Full solid bar - backpressure engaged

If you're up for some additional cycles on this PR I'd be happy to work 
through the changes with you. If not, I'm happy to take what you started and 
continue toward the mockup above.

Thanks!

[1] https://issues.apache.org/jira/browse/NIFI-766



---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Commented] (NIFI-2603) Bringing Some UI Color Back

2016-09-30 Thread Rob Moran (JIRA)

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

Rob Moran commented on NIFI-2603:
-

Sorry just getting back on this. I am working on some ideas and will attach 
here when complete.

> Bringing Some UI Color Back
> ---
>
> Key: NIFI-2603
> URL: https://issues.apache.org/jira/browse/NIFI-2603
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Core UI
>Reporter: Peter Wicks
>Priority: Minor
>
> In the new 1.0 UI all of the colors associated with status (except the orange 
> triangle) are gone; replaced with a dark gray color.
> I propose bringing back color.  The screenshots are in the format of before 
> on the top and after on the bottom, except were labeled in the picture itself:
>  - Top Status Menu: https://goo.gl/photos/se1JnvhRwU7N4Fap7
>  - Process Group: https://goo.gl/photos/dqjG4KvC6xqxQfgT7
>  - Processes (Running/Stopped/Invalid): 
> https://goo.gl/photos/dSS8vgE2RkrXtc77A
>  - Operate Play/Stop buttons (only on mouse hover): 
> https://goo.gl/photos/Am5SUEEn7G9RjmMe6
>  - Processor/Processor Group Context Menu: 
> https://goo.gl/photos/Jq3qFg4ezaN91qms5
> This is not a "100% done, I've covered everything" before/after list.  I know 
> I need to do the NiFi summary page also at the minimum.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (NIFI-2848) Queues aren't fairly drained when leading to a single component

2016-09-30 Thread Pierre Villard (JIRA)

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

Pierre Villard commented on NIFI-2848:
--

After looking into it, I believe this could be related to NIFI-2751.

Indeed in processors such as UpdateAttribute or LogAttribute we are getting 
batch of flow files. Will look further into it.

> Queues aren't fairly drained when leading to a single component
> ---
>
> Key: NIFI-2848
> URL: https://issues.apache.org/jira/browse/NIFI-2848
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Core Framework
>Affects Versions: 1.0.0, 0.7.0
>Reporter: Joseph Gresock
> Attachments: Backpressure_prioritization_test.xml, dominate_1.png, 
> dominate_2.png, queue_drain.png
>
>
> Consider the scenario where multiple queues lead to a single component and 
> all of them are full due to back pressure.  With the attached template, it is 
> easily observable that once a single queue starts to drain due to relieved 
> back pressure, it will continue to drain as long as it has incoming flow 
> files.  This means that if there's a constant flow of incoming flow files to 
> this queue, the other queues will never be drained (at least, that's my 
> theory based on several hours of observation).
> To reproduce this: 
> # Load the template into NiFi 1.0.0
> # Play all three GenerateFlowFile processors, but not the UpdateAttribute 
> processor (this simulates backpressure).  Wait until each queue has 1,000 
> flow files (max backpressure)
> # Stop the GenerateFlowFile processors, and play the UpdateAttribute 
> processor (this relieves the backpressure)
> # Observe which queue has started to drain, and start its GenerateFlowFile 
> processor
> # Observe that the other two queues remain full indefinitely, while the 
> draining queue continues to replenish and be drained indefinitely



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (NIFI-2756) nifi-processor-bundle-archetype lacks displayName property

2016-09-30 Thread ASF GitHub Bot (JIRA)

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

ASF GitHub Bot commented on NIFI-2756:
--

Github user asfgit closed the pull request at:

https://github.com/apache/nifi/pull/1004


> nifi-processor-bundle-archetype lacks displayName property
> --
>
> Key: NIFI-2756
> URL: https://issues.apache.org/jira/browse/NIFI-2756
> Project: Apache NiFi
>  Issue Type: Bug
>Reporter: Andre
>Assignee: Andre
> Fix For: 1.1.0
>
>
> When using {{nifi-processor-bundle-archetype}} to create a new bundle, the 
> resulting code lacks displayName leading to a number of PR and contributions 
> to arrive to peer review without displayName configured



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (NIFI-2756) nifi-processor-bundle-archetype lacks displayName property

2016-09-30 Thread Bryan Bende (JIRA)

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

Bryan Bende updated NIFI-2756:
--
Fix Version/s: 1.1.0

> nifi-processor-bundle-archetype lacks displayName property
> --
>
> Key: NIFI-2756
> URL: https://issues.apache.org/jira/browse/NIFI-2756
> Project: Apache NiFi
>  Issue Type: Bug
>Reporter: Andre
>Assignee: Andre
> Fix For: 1.1.0
>
>
> When using {{nifi-processor-bundle-archetype}} to create a new bundle, the 
> resulting code lacks displayName leading to a number of PR and contributions 
> to arrive to peer review without displayName configured



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Resolved] (NIFI-2756) nifi-processor-bundle-archetype lacks displayName property

2016-09-30 Thread Bryan Bende (JIRA)

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

Bryan Bende resolved NIFI-2756.
---
Resolution: Fixed

> nifi-processor-bundle-archetype lacks displayName property
> --
>
> Key: NIFI-2756
> URL: https://issues.apache.org/jira/browse/NIFI-2756
> Project: Apache NiFi
>  Issue Type: Bug
>Reporter: Andre
>Assignee: Andre
> Fix For: 1.1.0
>
>
> When using {{nifi-processor-bundle-archetype}} to create a new bundle, the 
> resulting code lacks displayName leading to a number of PR and contributions 
> to arrive to peer review without displayName configured



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] nifi pull request #1004: NIFI-2756 - Add displayName to maven archetypes

2016-09-30 Thread asfgit
Github user asfgit closed the pull request at:

https://github.com/apache/nifi/pull/1004


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Commented] (NIFI-2756) nifi-processor-bundle-archetype lacks displayName property

2016-09-30 Thread ASF subversion and git services (JIRA)

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

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

Commit 2054888fb1cbb442a70e3677139dc7a26348671d in nifi's branch 
refs/heads/master from Andre F de Miranda
[ https://git-wip-us.apache.org/repos/asf?p=nifi.git;h=2054888 ]

NIFI-2756 - Add displayName to maven archetypes and remove unused import
- Code generated generated by the NiFi archetypes should pass contrib-check by 
default

This closes #1004.

Signed-off-by: Bryan Bende 


> nifi-processor-bundle-archetype lacks displayName property
> --
>
> Key: NIFI-2756
> URL: https://issues.apache.org/jira/browse/NIFI-2756
> Project: Apache NiFi
>  Issue Type: Bug
>Reporter: Andre
>Assignee: Andre
>
> When using {{nifi-processor-bundle-archetype}} to create a new bundle, the 
> resulting code lacks displayName leading to a number of PR and contributions 
> to arrive to peer review without displayName configured



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (NIFI-2756) nifi-processor-bundle-archetype lacks displayName property

2016-09-30 Thread ASF GitHub Bot (JIRA)

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

ASF GitHub Bot commented on NIFI-2756:
--

Github user trixpan commented on the issue:

https://github.com/apache/nifi/pull/1004
  
@bbende hopefully the second commit should address your feedback. 

May I ask you to test and if ok, merge into master?

Kind regards


> nifi-processor-bundle-archetype lacks displayName property
> --
>
> Key: NIFI-2756
> URL: https://issues.apache.org/jira/browse/NIFI-2756
> Project: Apache NiFi
>  Issue Type: Bug
>Reporter: Andre
>Assignee: Andre
>
> When using {{nifi-processor-bundle-archetype}} to create a new bundle, the 
> resulting code lacks displayName leading to a number of PR and contributions 
> to arrive to peer review without displayName configured



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] nifi issue #1004: NIFI-2756 - Add displayName to maven archetypes

2016-09-30 Thread trixpan
Github user trixpan commented on the issue:

https://github.com/apache/nifi/pull/1004
  
@bbende hopefully the second commit should address your feedback. 

May I ask you to test and if ok, merge into master?

Kind regards


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] nifi issue #1024: Adding EL support to TailFile processor

2016-09-30 Thread trixpan
Github user trixpan commented on the issue:

https://github.com/apache/nifi/pull/1024
  
@apsaltis is the PR still required?


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Commented] (NIFI-2685) Builds fails due to "java.awt.AWTError: Can't connect to X11 window server "

2016-09-30 Thread Andre (JIRA)

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

Andre commented on NIFI-2685:
-

[~tkurc]

may I merge?

Cheers

> Builds fails due to "java.awt.AWTError: Can't connect to X11 window server "
> 
>
> Key: NIFI-2685
> URL: https://issues.apache.org/jira/browse/NIFI-2685
> Project: Apache NiFi
>  Issue Type: Bug
>Reporter: Andre
>Assignee: Andre
>Priority: Trivial
>
> When building NiFi on a machine with ssh X11 forwarding enabled, maven may 
> fail to build due to the following error:
> {code}
> testResize(org.apache.nifi.processors.image.TestResizeImage)  Time elapsed: 
> 2.22 sec  <<< FAILURE!
> java.lang.AssertionError: java.awt.AWTError: Can't connect to X11 window 
> server using 'localhost:12.0' as the value of the DISPLAY variable.
> at 
> org.apache.nifi.util.StandardProcessorTestRunner.run(StandardProcessorTestRunner.java:192)
> at 
> org.apache.nifi.util.StandardProcessorTestRunner.run(StandardProcessorTestRunner.java:151)
> at 
> org.apache.nifi.util.StandardProcessorTestRunner.run(StandardProcessorTestRunner.java:146)
> at 
> org.apache.nifi.util.StandardProcessorTestRunner.run(StandardProcessorTestRunner.java:141)
> at 
> org.apache.nifi.util.StandardProcessorTestRunner.run(StandardProcessorTestRunner.java:136)
> at 
> org.apache.nifi.processors.image.TestResizeImage.testResize(TestResizeImage.java:44)
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] nifi issue #1083: NIFI-2709 - Refactor ConsumeIMAP and ConsumePOP3 to genera...

2016-09-30 Thread trixpan
Github user trixpan commented on the issue:

https://github.com/apache/nifi/pull/1083
  
User reveals patch works as expected:

https://community.hortonworks.com/comments/59274/view.html






---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Commented] (NIFI-2709) Email processors with Exchange don't output to RFC2822 format

2016-09-30 Thread ASF GitHub Bot (JIRA)

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

ASF GitHub Bot commented on NIFI-2709:
--

Github user trixpan commented on the issue:

https://github.com/apache/nifi/pull/1083
  
User reveals patch works as expected:

https://community.hortonworks.com/comments/59274/view.html






> Email processors with Exchange don't output to RFC2822 format
> -
>
> Key: NIFI-2709
> URL: https://issues.apache.org/jira/browse/NIFI-2709
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Extensions
>Affects Versions: 1.0.0
> Environment: Ubuntu 16.04 LTS with openjdk-8-jre-headless
>Reporter: Emil Frank
>Assignee: Andre
>Priority: Minor
> Attachments: 1083.patch, screenshot-1.png
>
>
> When using the new ConsumeIMAP and ConsumePOP3 processors with a Microsoft 
> Exchange 2013 IMAP server the flowfiles which are produced are simple HTML 
> messages with no RFC2822 headers. I have also tried setting Exchange to force 
> emails to be text only, sadly only the body with some Content-Type: fields 
> are outputed.
> This mean that ExtractEmailHeaders and ExtractEmailAttachments cannot be used 
> directly with these processors.
> In Python, I can force Exchange to output the headers by specify RFC822 in 
> the connection settings:
> - https://docs.python.org/3/library/imaplib.html#imap4-example
> Is a similar option available for the spring mail framework?



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (NIFI-2825) Remote Process Group should use num of queued flow files in remote nodes to distribute load

2016-09-30 Thread Koji Kawamura (JIRA)

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

Koji Kawamura updated NIFI-2825:

Labels: Cluster  (was: )

> Remote Process Group should use num of queued flow files in remote nodes to 
> distribute load
> ---
>
> Key: NIFI-2825
> URL: https://issues.apache.org/jira/browse/NIFI-2825
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Core Framework
>Affects Versions: 1.0.0
> Environment: Clustered
>Reporter: Koji Kawamura
>Assignee: Koji Kawamura
>  Labels: Cluster
> Fix For: 1.1.0
>
>
> A RPG (Site-to-Site client) should take into account of the number of queued 
> flow files in each remote cluster nodes, to calculate the load distribution 
> balance among target nodes. So that it can send more data to nodes those have 
> less queued files, or receive more data from nodes those have more queued 
> files.
> However, after the clustering mechanism has changed since 1.0, this load 
> distribution logic is not handled appropriately. Site-to-Site remote 
> component always returns flow file count as 0. So RPG distribute load evenly, 
> even if a remote cluster has unbalanced load among nodes.
> We need to fix the remote node API to expose queued flow file count correctly.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (NIFI-2825) Remote Process Group should use num of queued flow files in remote nodes to distribute load

2016-09-30 Thread Koji Kawamura (JIRA)

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

Koji Kawamura updated NIFI-2825:

Status: Patch Available  (was: Open)

> Remote Process Group should use num of queued flow files in remote nodes to 
> distribute load
> ---
>
> Key: NIFI-2825
> URL: https://issues.apache.org/jira/browse/NIFI-2825
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Core Framework
>Affects Versions: 1.0.0
> Environment: Clustered
>Reporter: Koji Kawamura
>Assignee: Koji Kawamura
> Fix For: 1.1.0
>
>
> A RPG (Site-to-Site client) should take into account of the number of queued 
> flow files in each remote cluster nodes, to calculate the load distribution 
> balance among target nodes. So that it can send more data to nodes those have 
> less queued files, or receive more data from nodes those have more queued 
> files.
> However, after the clustering mechanism has changed since 1.0, this load 
> distribution logic is not handled appropriately. Site-to-Site remote 
> component always returns flow file count as 0. So RPG distribute load evenly, 
> even if a remote cluster has unbalanced load among nodes.
> We need to fix the remote node API to expose queued flow file count correctly.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (NIFI-2825) Remote Process Group should use num of queued flow files in remote nodes to distribute load

2016-09-30 Thread ASF GitHub Bot (JIRA)

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

ASF GitHub Bot commented on NIFI-2825:
--

GitHub user ijokarumawak opened a pull request:

https://github.com/apache/nifi/pull/1084

NIFI-2825: Fix S2S getPeers flow file count

- Added ClusterWorkload message to retrieve workload information from a
  cluster coordinator
- Use cluster workload to return queued flow file count to site-to-site
  client so that it can calculate distribution of data transfer

Added related unit tests, as well as test with running NiFi secure/unsecure 
cluster, and standalone.

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/ijokarumawak/nifi nifi-2825

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/nifi/pull/1084.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1084


commit 2fde9b9d478f3a421bc883ea0d23a21bfa79d5b2
Author: Koji Kawamura 
Date:   2016-09-28T02:07:22Z

NIFI-2825: Fix S2S getPeers flow file count

- Added ClusterWorkload message to retrieve workload information from a
  cluster coordinator
- Use cluster workload to return queued flow file count to site-to-site
  client so that it can calculate distribution of data transfer




> Remote Process Group should use num of queued flow files in remote nodes to 
> distribute load
> ---
>
> Key: NIFI-2825
> URL: https://issues.apache.org/jira/browse/NIFI-2825
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Core Framework
>Affects Versions: 1.0.0
> Environment: Clustered
>Reporter: Koji Kawamura
>Assignee: Koji Kawamura
> Fix For: 1.1.0
>
>
> A RPG (Site-to-Site client) should take into account of the number of queued 
> flow files in each remote cluster nodes, to calculate the load distribution 
> balance among target nodes. So that it can send more data to nodes those have 
> less queued files, or receive more data from nodes those have more queued 
> files.
> However, after the clustering mechanism has changed since 1.0, this load 
> distribution logic is not handled appropriately. Site-to-Site remote 
> component always returns flow file count as 0. So RPG distribute load evenly, 
> even if a remote cluster has unbalanced load among nodes.
> We need to fix the remote node API to expose queued flow file count correctly.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] nifi pull request #1084: NIFI-2825: Fix S2S getPeers flow file count

2016-09-30 Thread ijokarumawak
GitHub user ijokarumawak opened a pull request:

https://github.com/apache/nifi/pull/1084

NIFI-2825: Fix S2S getPeers flow file count

- Added ClusterWorkload message to retrieve workload information from a
  cluster coordinator
- Use cluster workload to return queued flow file count to site-to-site
  client so that it can calculate distribution of data transfer

Added related unit tests, as well as test with running NiFi secure/unsecure 
cluster, and standalone.

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/ijokarumawak/nifi nifi-2825

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/nifi/pull/1084.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1084


commit 2fde9b9d478f3a421bc883ea0d23a21bfa79d5b2
Author: Koji Kawamura 
Date:   2016-09-28T02:07:22Z

NIFI-2825: Fix S2S getPeers flow file count

- Added ClusterWorkload message to retrieve workload information from a
  cluster coordinator
- Use cluster workload to return queued flow file count to site-to-site
  client so that it can calculate distribution of data transfer




---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Commented] (NIFI-2848) Queues aren't fairly drained when leading to a single component

2016-09-30 Thread Toivo Adams (JIRA)

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

Toivo Adams commented on NIFI-2848:
---

I removed Funnel and tested again.

One queue tends to dominate. This time third GenerateFlowFile queue.
After stopping third GenerateFlowFile, second started dominate.
Once queue gets opportunity it uses forever and don’t give others change to 
send anything.

See dominate_1.png and dominate_2.png


> Queues aren't fairly drained when leading to a single component
> ---
>
> Key: NIFI-2848
> URL: https://issues.apache.org/jira/browse/NIFI-2848
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Core Framework
>Affects Versions: 1.0.0, 0.7.0
>Reporter: Joseph Gresock
> Attachments: Backpressure_prioritization_test.xml, dominate_1.png, 
> dominate_2.png, queue_drain.png
>
>
> Consider the scenario where multiple queues lead to a single component and 
> all of them are full due to back pressure.  With the attached template, it is 
> easily observable that once a single queue starts to drain due to relieved 
> back pressure, it will continue to drain as long as it has incoming flow 
> files.  This means that if there's a constant flow of incoming flow files to 
> this queue, the other queues will never be drained (at least, that's my 
> theory based on several hours of observation).
> To reproduce this: 
> # Load the template into NiFi 1.0.0
> # Play all three GenerateFlowFile processors, but not the UpdateAttribute 
> processor (this simulates backpressure).  Wait until each queue has 1,000 
> flow files (max backpressure)
> # Stop the GenerateFlowFile processors, and play the UpdateAttribute 
> processor (this relieves the backpressure)
> # Observe which queue has started to drain, and start its GenerateFlowFile 
> processor
> # Observe that the other two queues remain full indefinitely, while the 
> draining queue continues to replenish and be drained indefinitely



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (NIFI-2848) Queues aren't fairly drained when leading to a single component

2016-09-30 Thread Toivo Adams (JIRA)

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

Toivo Adams updated NIFI-2848:
--
Attachment: dominate_2.png
dominate_1.png

> Queues aren't fairly drained when leading to a single component
> ---
>
> Key: NIFI-2848
> URL: https://issues.apache.org/jira/browse/NIFI-2848
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Core Framework
>Affects Versions: 1.0.0, 0.7.0
>Reporter: Joseph Gresock
> Attachments: Backpressure_prioritization_test.xml, dominate_1.png, 
> dominate_2.png, queue_drain.png
>
>
> Consider the scenario where multiple queues lead to a single component and 
> all of them are full due to back pressure.  With the attached template, it is 
> easily observable that once a single queue starts to drain due to relieved 
> back pressure, it will continue to drain as long as it has incoming flow 
> files.  This means that if there's a constant flow of incoming flow files to 
> this queue, the other queues will never be drained (at least, that's my 
> theory based on several hours of observation).
> To reproduce this: 
> # Load the template into NiFi 1.0.0
> # Play all three GenerateFlowFile processors, but not the UpdateAttribute 
> processor (this simulates backpressure).  Wait until each queue has 1,000 
> flow files (max backpressure)
> # Stop the GenerateFlowFile processors, and play the UpdateAttribute 
> processor (this relieves the backpressure)
> # Observe which queue has started to drain, and start its GenerateFlowFile 
> processor
> # Observe that the other two queues remain full indefinitely, while the 
> draining queue continues to replenish and be drained indefinitely



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] nifi issue #1054: Dummy commit focused in closing stalled PR requests

2016-09-30 Thread trixpan
Github user trixpan commented on the issue:

https://github.com/apache/nifi/pull/1054
  
@apiri done


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Commented] (NIFI-2477) Document tls-toolkit

2016-09-30 Thread ASF GitHub Bot (JIRA)

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

ASF GitHub Bot commented on NIFI-2477:
--

Github user asfgit closed the pull request at:

https://github.com/apache/nifi/pull/849


> Document tls-toolkit
> 
>
> Key: NIFI-2477
> URL: https://issues.apache.org/jira/browse/NIFI-2477
> Project: Apache NiFi
>  Issue Type: Task
>Reporter: Bryan Rosander
>Assignee: Andrew Lim
> Fix For: 1.0.0
>
>
> tls-toolkit created as part of NIFI-2193 needs to be documented in order to 
> be a useful utility to ease the burden of configuring tls for one or more 
> NiFi instances.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] nifi pull request #1054: Dummy commit focused in closing stalled PR requests

2016-09-30 Thread asfgit
Github user asfgit closed the pull request at:

https://github.com/apache/nifi/pull/1054


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] nifi pull request #769: how to kafka data to hive

2016-09-30 Thread asfgit
Github user asfgit closed the pull request at:

https://github.com/apache/nifi/pull/769


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] nifi pull request #849: NIFI-2477 Document TLS generation tool in Admin and ...

2016-09-30 Thread asfgit
Github user asfgit closed the pull request at:

https://github.com/apache/nifi/pull/849


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] nifi pull request #335: Adjust batch.size property description and validatio...

2016-09-30 Thread asfgit
Github user asfgit closed the pull request at:

https://github.com/apache/nifi/pull/335


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] nifi pull request #595: pull new code

2016-09-30 Thread asfgit
Github user asfgit closed the pull request at:

https://github.com/apache/nifi/pull/595


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Commented] (NIFI-1794) For rules that have very long names, the name extends beyond the size of the delete confirmation window

2016-09-30 Thread Andrew Lim (JIRA)

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

Andrew Lim commented on NIFI-1794:
--

This does not occur in 1.1.0.  However, instead of wrapping in the window, the 
user has to scroll to see the whole name of the rule.

> For rules that have very long names, the name extends beyond the size of the 
> delete confirmation window
> ---
>
> Key: NIFI-1794
> URL: https://issues.apache.org/jira/browse/NIFI-1794
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Core UI
>Affects Versions: 0.6.0
>Reporter: Andrew Lim
>Priority: Minor
> Attachments: NIFI-1794_deleteLongRule.png
>
>
> 1.  Create a rule with a very long name.
> 2.  Select "x" next to the rule to delete it.
> 3.  In the Delete Confirmation pop-up window, the name of the rule extends 
> beyond the window (and likely beyond the rules window itself).
> Screenshot attached.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (NIFI-2849) UI - Policy Management Enhancements

2016-09-30 Thread Matt Gilman (JIRA)

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

Matt Gilman updated NIFI-2849:
--
Description: 
1 - Show component name whenever possible (specifically in the message 
regarding the inherited policy).
2 - Do not allow editing of inherited policies. Require explicit navigation to 
the component in question. Support linking to the component in the inherited 
policy message to make this easier.
3 - When overriding a policy, allow the user to optionally copy the inherited 
policy rules.

  was:
1 - Show component name whenever possible (specifically in the message 
regarding the inherited policy).
2 - Do not allow editing of inherited policies. Require explicit navigation to 
the component in question. Supporting linking to the component in the inherited 
policy message to make this easier.
3 - When overriding a policy, allow the user to optionally copy the inherited 
policy rules.


> UI - Policy Management Enhancements
> ---
>
> Key: NIFI-2849
> URL: https://issues.apache.org/jira/browse/NIFI-2849
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Core UI
>Reporter: Matt Gilman
>Assignee: Matt Gilman
> Fix For: 1.1.0
>
>
> 1 - Show component name whenever possible (specifically in the message 
> regarding the inherited policy).
> 2 - Do not allow editing of inherited policies. Require explicit navigation 
> to the component in question. Support linking to the component in the 
> inherited policy message to make this easier.
> 3 - When overriding a policy, allow the user to optionally copy the inherited 
> policy rules.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Created] (NIFI-2849) UI - Policy Management Enhancements

2016-09-30 Thread Matt Gilman (JIRA)
Matt Gilman created NIFI-2849:
-

 Summary: UI - Policy Management Enhancements
 Key: NIFI-2849
 URL: https://issues.apache.org/jira/browse/NIFI-2849
 Project: Apache NiFi
  Issue Type: Improvement
  Components: Core UI
Reporter: Matt Gilman
Assignee: Matt Gilman
 Fix For: 1.1.0


1 - Show component name whenever possible (specifically in the message 
regarding the inherited policy).
2 - Do not allow editing of inherited policies. Require explicit navigation to 
the component in question. Supporting linking to the component in the inherited 
policy message to make this easier.
3 - When overriding a policy, allow the user to optionally copy the inherited 
policy rules.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] nifi issue #1074: NIFI-2832 State management should be part of the documenta...

2016-09-30 Thread mcgilman
Github user mcgilman commented on the issue:

https://github.com/apache/nifi/pull/1074
  
Thanks @pvillard31! This has been merged to master.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Commented] (NIFI-2832) State management should be part of the documentation/usage

2016-09-30 Thread ASF GitHub Bot (JIRA)

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

ASF GitHub Bot commented on NIFI-2832:
--

Github user asfgit closed the pull request at:

https://github.com/apache/nifi/pull/1074


> State management should be part of the documentation/usage
> --
>
> Key: NIFI-2832
> URL: https://issues.apache.org/jira/browse/NIFI-2832
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Documentation & Website
>Reporter: Pierre Villard
>Assignee: Pierre Villard
>Priority: Minor
>  Labels: documentation
> Fix For: 1.1.0
>
>
> At the moment, ``@Stateful`` annotation if only used in the 'View State' 
> panel. This may not be intuitive for users (NIFI-2705) and this information 
> should be part of the documentation (in the 'Usage' panel and the web 
> documentation as well).



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (NIFI-2848) Queues aren't fairly drained when leading to a single component

2016-09-30 Thread Toivo Adams (JIRA)

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

Toivo Adams updated NIFI-2848:
--
Attachment: queue_drain.png

> Queues aren't fairly drained when leading to a single component
> ---
>
> Key: NIFI-2848
> URL: https://issues.apache.org/jira/browse/NIFI-2848
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Core Framework
>Affects Versions: 1.0.0, 0.7.0
>Reporter: Joseph Gresock
> Attachments: Backpressure_prioritization_test.xml, queue_drain.png
>
>
> Consider the scenario where multiple queues lead to a single component and 
> all of them are full due to back pressure.  With the attached template, it is 
> easily observable that once a single queue starts to drain due to relieved 
> back pressure, it will continue to drain as long as it has incoming flow 
> files.  This means that if there's a constant flow of incoming flow files to 
> this queue, the other queues will never be drained (at least, that's my 
> theory based on several hours of observation).
> To reproduce this: 
> # Load the template into NiFi 1.0.0
> # Play all three GenerateFlowFile processors, but not the UpdateAttribute 
> processor (this simulates backpressure).  Wait until each queue has 1,000 
> flow files (max backpressure)
> # Stop the GenerateFlowFile processors, and play the UpdateAttribute 
> processor (this relieves the backpressure)
> # Observe which queue has started to drain, and start its GenerateFlowFile 
> processor
> # Observe that the other two queues remain full indefinitely, while the 
> draining queue continues to replenish and be drained indefinitely



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (NIFI-2832) State management should be part of the documentation/usage

2016-09-30 Thread Matt Gilman (JIRA)

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

Matt Gilman updated NIFI-2832:
--
Resolution: Fixed
Status: Resolved  (was: Patch Available)

> State management should be part of the documentation/usage
> --
>
> Key: NIFI-2832
> URL: https://issues.apache.org/jira/browse/NIFI-2832
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Documentation & Website
>Reporter: Pierre Villard
>Assignee: Pierre Villard
>Priority: Minor
>  Labels: documentation
> Fix For: 1.1.0
>
>
> At the moment, ``@Stateful`` annotation if only used in the 'View State' 
> panel. This may not be intuitive for users (NIFI-2705) and this information 
> should be part of the documentation (in the 'Usage' panel and the web 
> documentation as well).



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (NIFI-2832) State management should be part of the documentation/usage

2016-09-30 Thread ASF GitHub Bot (JIRA)

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

ASF GitHub Bot commented on NIFI-2832:
--

Github user mcgilman commented on the issue:

https://github.com/apache/nifi/pull/1074
  
Thanks @pvillard31! This has been merged to master.


> State management should be part of the documentation/usage
> --
>
> Key: NIFI-2832
> URL: https://issues.apache.org/jira/browse/NIFI-2832
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Documentation & Website
>Reporter: Pierre Villard
>Assignee: Pierre Villard
>Priority: Minor
>  Labels: documentation
> Fix For: 1.1.0
>
>
> At the moment, ``@Stateful`` annotation if only used in the 'View State' 
> panel. This may not be intuitive for users (NIFI-2705) and this information 
> should be part of the documentation (in the 'Usage' panel and the web 
> documentation as well).



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (NIFI-2832) State management should be part of the documentation/usage

2016-09-30 Thread ASF subversion and git services (JIRA)

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

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

Commit d6867283b55a8b40a4467197ed611c5c8669dff8 in nifi's branch 
refs/heads/master from [~pvillard]
[ https://git-wip-us.apache.org/repos/asf?p=nifi.git;h=d686728 ]

NIFI-2832 State management should be part of the documentation/usage. This 
closes #1074


> State management should be part of the documentation/usage
> --
>
> Key: NIFI-2832
> URL: https://issues.apache.org/jira/browse/NIFI-2832
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Documentation & Website
>Reporter: Pierre Villard
>Assignee: Pierre Villard
>Priority: Minor
>  Labels: documentation
> Fix For: 1.1.0
>
>
> At the moment, ``@Stateful`` annotation if only used in the 'View State' 
> panel. This may not be intuitive for users (NIFI-2705) and this information 
> should be part of the documentation (in the 'Usage' panel and the web 
> documentation as well).



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] nifi pull request #1074: NIFI-2832 State management should be part of the do...

2016-09-30 Thread asfgit
Github user asfgit closed the pull request at:

https://github.com/apache/nifi/pull/1074


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Commented] (NIFI-2848) Queues aren't fairly drained when leading to a single component

2016-09-30 Thread Toivo Adams (JIRA)

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

Toivo Adams commented on NIFI-2848:
---

Hi Joseph Gresock 

I observed similar behaviour.
First GenerateFlowFile (from left to right) got opportunity and continued to 
push new files.
Second did not have any chance.
Third had opportunity (only short period) before I started first again.

Thanks
Toivo

> Queues aren't fairly drained when leading to a single component
> ---
>
> Key: NIFI-2848
> URL: https://issues.apache.org/jira/browse/NIFI-2848
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Core Framework
>Affects Versions: 1.0.0, 0.7.0
>Reporter: Joseph Gresock
> Attachments: Backpressure_prioritization_test.xml
>
>
> Consider the scenario where multiple queues lead to a single component and 
> all of them are full due to back pressure.  With the attached template, it is 
> easily observable that once a single queue starts to drain due to relieved 
> back pressure, it will continue to drain as long as it has incoming flow 
> files.  This means that if there's a constant flow of incoming flow files to 
> this queue, the other queues will never be drained (at least, that's my 
> theory based on several hours of observation).
> To reproduce this: 
> # Load the template into NiFi 1.0.0
> # Play all three GenerateFlowFile processors, but not the UpdateAttribute 
> processor (this simulates backpressure).  Wait until each queue has 1,000 
> flow files (max backpressure)
> # Stop the GenerateFlowFile processors, and play the UpdateAttribute 
> processor (this relieves the backpressure)
> # Observe which queue has started to drain, and start its GenerateFlowFile 
> processor
> # Observe that the other two queues remain full indefinitely, while the 
> draining queue continues to replenish and be drained indefinitely



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (NIFI-2847) In NiFi Cluster window, filtering "by status" or "by address" do not work as expected

2016-09-30 Thread Andrew Lim (JIRA)

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

Andrew Lim commented on NIFI-2847:
--

Thanks [~jameswing]!  I was testing in a secured 1.0.0 cluster, so before 
Matt's commit.  I'll re-test in 1.1.0.

> In NiFi Cluster window, filtering "by status" or "by address" do not work as 
> expected
> -
>
> Key: NIFI-2847
> URL: https://issues.apache.org/jira/browse/NIFI-2847
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Core UI
>Affects Versions: 1.0.0
>Reporter: Andrew Lim
> Attachments: NIFI-2847_NiFiClusterFilter.png
>
>
> Attaching a screenshot of what this window displays when no filters are 
> applied to the displayed results for a 3 node cluster.
> When filtering "by status":
> -If I enter "CONNECTED", all 3 results are shown.
> -But if I enter "CONNECTED,"  or "COORDINATOR", no results are shown.  I 
> expected this to filter out all nodes except the cluster coordinator.
> When filtering "by address":
> -if I enter "localhost", all 3 results are shown.
> -But if I enter "localhost:" or any of the ports (9443, for example), no 
> results are shown.  I think it is a very common use case to filter by port.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Assigned] (NIFI-2847) In NiFi Cluster window, filtering "by status" or "by address" do not work as expected

2016-09-30 Thread Andrew Lim (JIRA)

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

Andrew Lim reassigned NIFI-2847:


Assignee: Andrew Lim

> In NiFi Cluster window, filtering "by status" or "by address" do not work as 
> expected
> -
>
> Key: NIFI-2847
> URL: https://issues.apache.org/jira/browse/NIFI-2847
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Core UI
>Affects Versions: 1.0.0
>Reporter: Andrew Lim
>Assignee: Andrew Lim
> Attachments: NIFI-2847_NiFiClusterFilter.png
>
>
> Attaching a screenshot of what this window displays when no filters are 
> applied to the displayed results for a 3 node cluster.
> When filtering "by status":
> -If I enter "CONNECTED", all 3 results are shown.
> -But if I enter "CONNECTED,"  or "COORDINATOR", no results are shown.  I 
> expected this to filter out all nodes except the cluster coordinator.
> When filtering "by address":
> -if I enter "localhost", all 3 results are shown.
> -But if I enter "localhost:" or any of the ports (9443, for example), no 
> results are shown.  I think it is a very common use case to filter by port.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Resolved] (NIFI-2783) Command line site-to-site client in toolkit would be useful

2016-09-30 Thread Bryan Bende (JIRA)

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

Bryan Bende resolved NIFI-2783.
---
Resolution: Fixed

> Command line site-to-site client in toolkit would be useful
> ---
>
> Key: NIFI-2783
> URL: https://issues.apache.org/jira/browse/NIFI-2783
> Project: Apache NiFi
>  Issue Type: New Feature
>Reporter: Bryan Rosander
>Assignee: Bryan Rosander
> Fix For: 1.1.0
>
>
> A command line site-to-site client in the toolkit would be beneficial in 
> several scenarios:
> 1. Easily pipe data into, out of NiFi flows using command line utilities or 
> other (non-java) programs makes integrating other tools with NiFi trivial
> 2. Easier to debug site-to-site issues when only one NiFi instance is 
> involved in the troubleshooting process
> 3. Dev testing site-to-site is easier command line reproduction of 
> issues/validation of functionality



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (NIFI-2783) Command line site-to-site client in toolkit would be useful

2016-09-30 Thread Bryan Bende (JIRA)

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

Bryan Bende updated NIFI-2783:
--
Assignee: Bryan Rosander

> Command line site-to-site client in toolkit would be useful
> ---
>
> Key: NIFI-2783
> URL: https://issues.apache.org/jira/browse/NIFI-2783
> Project: Apache NiFi
>  Issue Type: New Feature
>Reporter: Bryan Rosander
>Assignee: Bryan Rosander
> Fix For: 1.1.0
>
>
> A command line site-to-site client in the toolkit would be beneficial in 
> several scenarios:
> 1. Easily pipe data into, out of NiFi flows using command line utilities or 
> other (non-java) programs makes integrating other tools with NiFi trivial
> 2. Easier to debug site-to-site issues when only one NiFi instance is 
> involved in the troubleshooting process
> 3. Dev testing site-to-site is easier command line reproduction of 
> issues/validation of functionality



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (NIFI-2783) Command line site-to-site client in toolkit would be useful

2016-09-30 Thread Bryan Bende (JIRA)

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

Bryan Bende updated NIFI-2783:
--
Fix Version/s: 1.1.0

> Command line site-to-site client in toolkit would be useful
> ---
>
> Key: NIFI-2783
> URL: https://issues.apache.org/jira/browse/NIFI-2783
> Project: Apache NiFi
>  Issue Type: New Feature
>Reporter: Bryan Rosander
> Fix For: 1.1.0
>
>
> A command line site-to-site client in the toolkit would be beneficial in 
> several scenarios:
> 1. Easily pipe data into, out of NiFi flows using command line utilities or 
> other (non-java) programs makes integrating other tools with NiFi trivial
> 2. Easier to debug site-to-site issues when only one NiFi instance is 
> involved in the troubleshooting process
> 3. Dev testing site-to-site is easier command line reproduction of 
> issues/validation of functionality



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (NIFI-2783) Command line site-to-site client in toolkit would be useful

2016-09-30 Thread ASF subversion and git services (JIRA)

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

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

Commit 4e13fef7243935962848ae83b3e31a5283c71c66 in nifi's branch 
refs/heads/master from [~bryanrosan...@gmail.com]
[ https://git-wip-us.apache.org/repos/asf?p=nifi.git;h=4e13fef ]

NIFI-2783 - Site-to-site command line client - s2s.sh shell script warnings -> 
stderr, usage improvement with examples - Increasing heap settings for s2s cli

This closes #1056.

Signed-off-by: Bryan Bende 


> Command line site-to-site client in toolkit would be useful
> ---
>
> Key: NIFI-2783
> URL: https://issues.apache.org/jira/browse/NIFI-2783
> Project: Apache NiFi
>  Issue Type: New Feature
>Reporter: Bryan Rosander
> Fix For: 1.1.0
>
>
> A command line site-to-site client in the toolkit would be beneficial in 
> several scenarios:
> 1. Easily pipe data into, out of NiFi flows using command line utilities or 
> other (non-java) programs makes integrating other tools with NiFi trivial
> 2. Easier to debug site-to-site issues when only one NiFi instance is 
> involved in the troubleshooting process
> 3. Dev testing site-to-site is easier command line reproduction of 
> issues/validation of functionality



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (NIFI-2783) Command line site-to-site client in toolkit would be useful

2016-09-30 Thread ASF GitHub Bot (JIRA)

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

ASF GitHub Bot commented on NIFI-2783:
--

Github user asfgit closed the pull request at:

https://github.com/apache/nifi/pull/1056


> Command line site-to-site client in toolkit would be useful
> ---
>
> Key: NIFI-2783
> URL: https://issues.apache.org/jira/browse/NIFI-2783
> Project: Apache NiFi
>  Issue Type: New Feature
>Reporter: Bryan Rosander
> Fix For: 1.1.0
>
>
> A command line site-to-site client in the toolkit would be beneficial in 
> several scenarios:
> 1. Easily pipe data into, out of NiFi flows using command line utilities or 
> other (non-java) programs makes integrating other tools with NiFi trivial
> 2. Easier to debug site-to-site issues when only one NiFi instance is 
> involved in the troubleshooting process
> 3. Dev testing site-to-site is easier command line reproduction of 
> issues/validation of functionality



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] nifi pull request #1056: NIFI-2783 - Site-to-site command line client

2016-09-30 Thread asfgit
Github user asfgit closed the pull request at:

https://github.com/apache/nifi/pull/1056


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Updated] (NIFI-2709) Email processors with Exchange don't output to RFC2822 format

2016-09-30 Thread Andre (JIRA)

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

Andre updated NIFI-2709:

Attachment: 1083.patch

> Email processors with Exchange don't output to RFC2822 format
> -
>
> Key: NIFI-2709
> URL: https://issues.apache.org/jira/browse/NIFI-2709
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Extensions
>Affects Versions: 1.0.0
> Environment: Ubuntu 16.04 LTS with openjdk-8-jre-headless
>Reporter: Emil Frank
>Assignee: Andre
>Priority: Minor
> Attachments: 1083.patch, screenshot-1.png
>
>
> When using the new ConsumeIMAP and ConsumePOP3 processors with a Microsoft 
> Exchange 2013 IMAP server the flowfiles which are produced are simple HTML 
> messages with no RFC2822 headers. I have also tried setting Exchange to force 
> emails to be text only, sadly only the body with some Content-Type: fields 
> are outputed.
> This mean that ExtractEmailHeaders and ExtractEmailAttachments cannot be used 
> directly with these processors.
> In Python, I can force Exchange to output the headers by specify RFC822 in 
> the connection settings:
> - https://docs.python.org/3/library/imaplib.html#imap4-example
> Is a similar option available for the spring mail framework?



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (NIFI-2709) Email processors with Exchange don't output to RFC2822 format

2016-09-30 Thread Andre (JIRA)

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

Andre updated NIFI-2709:

Status: Patch Available  (was: Open)

> Email processors with Exchange don't output to RFC2822 format
> -
>
> Key: NIFI-2709
> URL: https://issues.apache.org/jira/browse/NIFI-2709
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Extensions
>Affects Versions: 1.0.0
> Environment: Ubuntu 16.04 LTS with openjdk-8-jre-headless
>Reporter: Emil Frank
>Assignee: Andre
>Priority: Minor
> Attachments: 1083.patch, screenshot-1.png
>
>
> When using the new ConsumeIMAP and ConsumePOP3 processors with a Microsoft 
> Exchange 2013 IMAP server the flowfiles which are produced are simple HTML 
> messages with no RFC2822 headers. I have also tried setting Exchange to force 
> emails to be text only, sadly only the body with some Content-Type: fields 
> are outputed.
> This mean that ExtractEmailHeaders and ExtractEmailAttachments cannot be used 
> directly with these processors.
> In Python, I can force Exchange to output the headers by specify RFC822 in 
> the connection settings:
> - https://docs.python.org/3/library/imaplib.html#imap4-example
> Is a similar option available for the spring mail framework?



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (NIFI-2709) Email processors with Exchange don't output to RFC2822 format

2016-09-30 Thread ASF GitHub Bot (JIRA)

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

ASF GitHub Bot commented on NIFI-2709:
--

Github user trixpan commented on the issue:

https://github.com/apache/nifi/pull/1083
  
content no long loaded into memory. except for the issue around jUnits (2 & 
3), it should be ready to review 


> Email processors with Exchange don't output to RFC2822 format
> -
>
> Key: NIFI-2709
> URL: https://issues.apache.org/jira/browse/NIFI-2709
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Extensions
>Affects Versions: 1.0.0
> Environment: Ubuntu 16.04 LTS with openjdk-8-jre-headless
>Reporter: Emil Frank
>Assignee: Andre
>Priority: Minor
> Attachments: screenshot-1.png
>
>
> When using the new ConsumeIMAP and ConsumePOP3 processors with a Microsoft 
> Exchange 2013 IMAP server the flowfiles which are produced are simple HTML 
> messages with no RFC2822 headers. I have also tried setting Exchange to force 
> emails to be text only, sadly only the body with some Content-Type: fields 
> are outputed.
> This mean that ExtractEmailHeaders and ExtractEmailAttachments cannot be used 
> directly with these processors.
> In Python, I can force Exchange to output the headers by specify RFC822 in 
> the connection settings:
> - https://docs.python.org/3/library/imaplib.html#imap4-example
> Is a similar option available for the spring mail framework?



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] nifi issue #1083: NIFI-2709 - Refactor ConsumeIMAP and ConsumePOP3 to genera...

2016-09-30 Thread trixpan
Github user trixpan commented on the issue:

https://github.com/apache/nifi/pull/1083
  
content no long loaded into memory. except for the issue around jUnits (2 & 
3), it should be ready to review 


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] nifi issue #1054: Dummy commit focused in closing stalled PR requests

2016-09-30 Thread apiri
Github user apiri commented on the issue:

https://github.com/apache/nifi/pull/1054
  
@trixpan yeah, feel free to merge.  I think there has been sufficient time 
for folks to chime in.  Thanks!


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] nifi issue #1083: NIFI-2709 - Refactor ConsumeIMAP and ConsumePOP3 to genera...

2016-09-30 Thread trixpan
Github user trixpan commented on the issue:

https://github.com/apache/nifi/pull/1083
  
@bbende this should solve the IMAP issue.

Notes:

1. This PR reads the content of the message into memory, in contrast with 
the original design that relied on InputStream to write the content into the 
FlowFile. This is due to the fact that JavaMail doesn't seem to have an 
inputstream method capable of providing an RFC2822 message. In case anyone has 
an idea on how to improve that, I am keen to incorporate into this PR.

2. The PR includes a GreenMail based junit and required dependency to ease 
debugging. Since I am not sure if we want to refactor the jUnits already in 
place (they seem to work well) with GreenMail based jUnits I aded very little 
coverage. Let me know your preference and I will either remove the new jUnit or 
to refactor @olegz original jUnit to use GreenMail based unit testing.

3. This will fail contrib-check. To be addressed once we decide what to do 
with the jUnit tests mentioned above.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Commented] (NIFI-2709) Email processors with Exchange don't output to RFC2822 format

2016-09-30 Thread ASF GitHub Bot (JIRA)

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

ASF GitHub Bot commented on NIFI-2709:
--

Github user trixpan commented on the issue:

https://github.com/apache/nifi/pull/1083
  
@bbende this should solve the IMAP issue.

Notes:

1. This PR reads the content of the message into memory, in contrast with 
the original design that relied on InputStream to write the content into the 
FlowFile. This is due to the fact that JavaMail doesn't seem to have an 
inputstream method capable of providing an RFC2822 message. In case anyone has 
an idea on how to improve that, I am keen to incorporate into this PR.

2. The PR includes a GreenMail based junit and required dependency to ease 
debugging. Since I am not sure if we want to refactor the jUnits already in 
place (they seem to work well) with GreenMail based jUnits I aded very little 
coverage. Let me know your preference and I will either remove the new jUnit or 
to refactor @olegz original jUnit to use GreenMail based unit testing.

3. This will fail contrib-check. To be addressed once we decide what to do 
with the jUnit tests mentioned above.


> Email processors with Exchange don't output to RFC2822 format
> -
>
> Key: NIFI-2709
> URL: https://issues.apache.org/jira/browse/NIFI-2709
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Extensions
>Affects Versions: 1.0.0
> Environment: Ubuntu 16.04 LTS with openjdk-8-jre-headless
>Reporter: Emil Frank
>Assignee: Andre
>Priority: Minor
> Attachments: screenshot-1.png
>
>
> When using the new ConsumeIMAP and ConsumePOP3 processors with a Microsoft 
> Exchange 2013 IMAP server the flowfiles which are produced are simple HTML 
> messages with no RFC2822 headers. I have also tried setting Exchange to force 
> emails to be text only, sadly only the body with some Content-Type: fields 
> are outputed.
> This mean that ExtractEmailHeaders and ExtractEmailAttachments cannot be used 
> directly with these processors.
> In Python, I can force Exchange to output the headers by specify RFC822 in 
> the connection settings:
> - https://docs.python.org/3/library/imaplib.html#imap4-example
> Is a similar option available for the spring mail framework?



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (NIFI-2756) nifi-processor-bundle-archetype lacks displayName property

2016-09-30 Thread ASF GitHub Bot (JIRA)

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

ASF GitHub Bot commented on NIFI-2756:
--

Github user bbende commented on the issue:

https://github.com/apache/nifi/pull/1004
  
@trixpan sure...

1) mvn clean install on this branch

2) In some other directory:

`mvn archetype:generate -DarchetypeGroupId=org.apache.nifi 
-DarchetypeArtifactId=nifi-processor-bundle-archetype 
-DarchetypeVersion=1.1.0-SNAPSHOT -DnifiVersion=1.1.0-SNAPSHOT 
-DarchetypeCatalog=local`

3) Fill in something like groupId org.apache.nifi, artifactId 
displaytest-bundle, basename displaytest

4) Try to build the generated project using mvn clean install 
-Pcontrib-check

5) Repeat with service archetype:

`mvn archetype:generate -DarchetypeGroupId=org.apache.nifi 
-DarchetypeArtifactId=nifi-service-bundle-archetype 
-DarchetypeVersion=1.1.0-SNAPSHOT -DnifiVersion=1.1.0-SNAPSHOT 
-DarchetypeCatalog=local`

For additional reference:

https://cwiki.apache.org/confluence/display/NIFI/Maven+Projects+for+Extensions


> nifi-processor-bundle-archetype lacks displayName property
> --
>
> Key: NIFI-2756
> URL: https://issues.apache.org/jira/browse/NIFI-2756
> Project: Apache NiFi
>  Issue Type: Bug
>Reporter: Andre
>Assignee: Andre
>
> When using {{nifi-processor-bundle-archetype}} to create a new bundle, the 
> resulting code lacks displayName leading to a number of PR and contributions 
> to arrive to peer review without displayName configured



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] nifi issue #1004: NIFI-2756 - Add displayName to maven archetypes

2016-09-30 Thread bbende
Github user bbende commented on the issue:

https://github.com/apache/nifi/pull/1004
  
@trixpan sure...

1) mvn clean install on this branch

2) In some other directory:

`mvn archetype:generate -DarchetypeGroupId=org.apache.nifi 
-DarchetypeArtifactId=nifi-processor-bundle-archetype 
-DarchetypeVersion=1.1.0-SNAPSHOT -DnifiVersion=1.1.0-SNAPSHOT 
-DarchetypeCatalog=local`

3) Fill in something like groupId org.apache.nifi, artifactId 
displaytest-bundle, basename displaytest

4) Try to build the generated project using mvn clean install 
-Pcontrib-check

5) Repeat with service archetype:

`mvn archetype:generate -DarchetypeGroupId=org.apache.nifi 
-DarchetypeArtifactId=nifi-service-bundle-archetype 
-DarchetypeVersion=1.1.0-SNAPSHOT -DnifiVersion=1.1.0-SNAPSHOT 
-DarchetypeCatalog=local`

For additional reference:

https://cwiki.apache.org/confluence/display/NIFI/Maven+Projects+for+Extensions


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Commented] (NIFI-2709) Email processors with Exchange don't output to RFC2822 format

2016-09-30 Thread ASF GitHub Bot (JIRA)

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

ASF GitHub Bot commented on NIFI-2709:
--

GitHub user trixpan opened a pull request:

https://github.com/apache/nifi/pull/1083

NIFI-2709 - Refactor ConsumeIMAP and ConsumePOP3 to generate RFC2822

compliant flowfiles

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/trixpan/nifi NIFI-2709

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/nifi/pull/1083.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1083


commit 4fc0779960480b6d8e81372506201e2a9a9bae29
Author: Andre F de Miranda 
Date:   2016-09-30T09:00:59Z

NIFI-2709 - Refactor ConsumeIMAP and ConsumePOP3 to generate RFC2822
compliant flowfiles




> Email processors with Exchange don't output to RFC2822 format
> -
>
> Key: NIFI-2709
> URL: https://issues.apache.org/jira/browse/NIFI-2709
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Extensions
>Affects Versions: 1.0.0
> Environment: Ubuntu 16.04 LTS with openjdk-8-jre-headless
>Reporter: Emil Frank
>Assignee: Andre
>Priority: Minor
> Attachments: screenshot-1.png
>
>
> When using the new ConsumeIMAP and ConsumePOP3 processors with a Microsoft 
> Exchange 2013 IMAP server the flowfiles which are produced are simple HTML 
> messages with no RFC2822 headers. I have also tried setting Exchange to force 
> emails to be text only, sadly only the body with some Content-Type: fields 
> are outputed.
> This mean that ExtractEmailHeaders and ExtractEmailAttachments cannot be used 
> directly with these processors.
> In Python, I can force Exchange to output the headers by specify RFC822 in 
> the connection settings:
> - https://docs.python.org/3/library/imaplib.html#imap4-example
> Is a similar option available for the spring mail framework?



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] nifi pull request #1083: NIFI-2709 - Refactor ConsumeIMAP and ConsumePOP3 to...

2016-09-30 Thread trixpan
GitHub user trixpan opened a pull request:

https://github.com/apache/nifi/pull/1083

NIFI-2709 - Refactor ConsumeIMAP and ConsumePOP3 to generate RFC2822

compliant flowfiles

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/trixpan/nifi NIFI-2709

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/nifi/pull/1083.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #1083


commit 4fc0779960480b6d8e81372506201e2a9a9bae29
Author: Andre F de Miranda 
Date:   2016-09-30T09:00:59Z

NIFI-2709 - Refactor ConsumeIMAP and ConsumePOP3 to generate RFC2822
compliant flowfiles




---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Updated] (NIFI-2848) Queues aren't fairly drained when leading to a single component

2016-09-30 Thread Joseph Gresock (JIRA)

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

Joseph Gresock updated NIFI-2848:
-
Description: 
Consider the scenario where multiple queues lead to a single component and all 
of them are full due to back pressure.  With the attached template, it is 
easily observable that once a single queue starts to drain due to relieved back 
pressure, it will continue to drain as long as it has incoming flow files.  
This means that if there's a constant flow of incoming flow files to this 
queue, the other queues will never be drained (at least, that's my theory based 
on an hour of observation).

To reproduce this: 
# Load the template into NiFi 1.0.0
# Play all three GenerateFlowFile processors, but not the UpdateAttribute 
processor (this simulates backpressure).  Wait until each queue has 1,000 flow 
files (max backpressure)
# Stop the GenerateFlowFile processors, and play the UpdateAttribute processor 
(this relieves the backpressure)
# Observe which queue has started to drain, and start its GenerateFlowFile 
processor
# Observe that the other two queues remain full indefinitely, while the 
draining queue continues to replenish and be drained indefinitely

  was:
Consider the scenario where multiple queues lead to a single component and all 
of them are full due to back pressure.  With the attached template, it is 
easily observable that once a single queue starts to drain due to relieved back 
pressure, it will continue to drain as long as it has incoming flow files.  
This means that if there's a constant flow of incoming flow files to this 
queue, the other two queues will never be drained (at least, that's my theory 
based on an hour of observation).

To reproduce this: 
# Load the template into NiFi 1.0.0
# Play all three GenerateFlowFile processors, but not the UpdateAttribute 
processor (this simulates backpressure).  Wait until each queue has 1,000 flow 
files (max backpressure)
# Stop the GenerateFlowFile processors, and play the UpdateAttribute processor 
(this relieves the backpressure)
# Observe which queue has started to drain, and start its GenerateFlowFile 
processor
# Observe that the other two queues remain full indefinitely, while the 
draining queue continues to replenish and be drained indefinitely


> Queues aren't fairly drained when leading to a single component
> ---
>
> Key: NIFI-2848
> URL: https://issues.apache.org/jira/browse/NIFI-2848
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Core Framework
>Affects Versions: 1.0.0, 0.7.0
>Reporter: Joseph Gresock
> Attachments: Backpressure_prioritization_test.xml
>
>
> Consider the scenario where multiple queues lead to a single component and 
> all of them are full due to back pressure.  With the attached template, it is 
> easily observable that once a single queue starts to drain due to relieved 
> back pressure, it will continue to drain as long as it has incoming flow 
> files.  This means that if there's a constant flow of incoming flow files to 
> this queue, the other queues will never be drained (at least, that's my 
> theory based on an hour of observation).
> To reproduce this: 
> # Load the template into NiFi 1.0.0
> # Play all three GenerateFlowFile processors, but not the UpdateAttribute 
> processor (this simulates backpressure).  Wait until each queue has 1,000 
> flow files (max backpressure)
> # Stop the GenerateFlowFile processors, and play the UpdateAttribute 
> processor (this relieves the backpressure)
> # Observe which queue has started to drain, and start its GenerateFlowFile 
> processor
> # Observe that the other two queues remain full indefinitely, while the 
> draining queue continues to replenish and be drained indefinitely



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (NIFI-2848) Queues aren't fairly drained when leading to a single component

2016-09-30 Thread Joseph Gresock (JIRA)

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

Joseph Gresock updated NIFI-2848:
-
Description: 
Consider the scenario where multiple queues lead to a single component and all 
of them are full due to back pressure.  With the attached template, it is 
easily observable that once a single queue starts to drain due to relieved back 
pressure, it will continue to drain as long as it has incoming flow files.  
This means that if there's a constant flow of incoming flow files to this 
queue, the other queues will never be drained (at least, that's my theory based 
on several hours of observation).

To reproduce this: 
# Load the template into NiFi 1.0.0
# Play all three GenerateFlowFile processors, but not the UpdateAttribute 
processor (this simulates backpressure).  Wait until each queue has 1,000 flow 
files (max backpressure)
# Stop the GenerateFlowFile processors, and play the UpdateAttribute processor 
(this relieves the backpressure)
# Observe which queue has started to drain, and start its GenerateFlowFile 
processor
# Observe that the other two queues remain full indefinitely, while the 
draining queue continues to replenish and be drained indefinitely

  was:
Consider the scenario where multiple queues lead to a single component and all 
of them are full due to back pressure.  With the attached template, it is 
easily observable that once a single queue starts to drain due to relieved back 
pressure, it will continue to drain as long as it has incoming flow files.  
This means that if there's a constant flow of incoming flow files to this 
queue, the other queues will never be drained (at least, that's my theory based 
on an hour of observation).

To reproduce this: 
# Load the template into NiFi 1.0.0
# Play all three GenerateFlowFile processors, but not the UpdateAttribute 
processor (this simulates backpressure).  Wait until each queue has 1,000 flow 
files (max backpressure)
# Stop the GenerateFlowFile processors, and play the UpdateAttribute processor 
(this relieves the backpressure)
# Observe which queue has started to drain, and start its GenerateFlowFile 
processor
# Observe that the other two queues remain full indefinitely, while the 
draining queue continues to replenish and be drained indefinitely


> Queues aren't fairly drained when leading to a single component
> ---
>
> Key: NIFI-2848
> URL: https://issues.apache.org/jira/browse/NIFI-2848
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Core Framework
>Affects Versions: 1.0.0, 0.7.0
>Reporter: Joseph Gresock
> Attachments: Backpressure_prioritization_test.xml
>
>
> Consider the scenario where multiple queues lead to a single component and 
> all of them are full due to back pressure.  With the attached template, it is 
> easily observable that once a single queue starts to drain due to relieved 
> back pressure, it will continue to drain as long as it has incoming flow 
> files.  This means that if there's a constant flow of incoming flow files to 
> this queue, the other queues will never be drained (at least, that's my 
> theory based on several hours of observation).
> To reproduce this: 
> # Load the template into NiFi 1.0.0
> # Play all three GenerateFlowFile processors, but not the UpdateAttribute 
> processor (this simulates backpressure).  Wait until each queue has 1,000 
> flow files (max backpressure)
> # Stop the GenerateFlowFile processors, and play the UpdateAttribute 
> processor (this relieves the backpressure)
> # Observe which queue has started to drain, and start its GenerateFlowFile 
> processor
> # Observe that the other two queues remain full indefinitely, while the 
> draining queue continues to replenish and be drained indefinitely



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (NIFI-2709) Email processors with Exchange don't output to RFC2822 format

2016-09-30 Thread Andre (JIRA)

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

Andre commented on NIFI-2709:
-

[~bbende] seems like there is a disconnect between what ConsumeImap produces by 
default and what the extraction processors expect, hence the "validation 
errors".

The following code confirm this. Note how the FlowFile content equals to the 
body of the generated message instead of the whole email message...

{code}
/*
 * 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.processors.email;

import com.icegreen.greenmail.user.GreenMailUser;
import com.icegreen.greenmail.util.GreenMail;
import com.icegreen.greenmail.util.ServerSetupTest;
import org.apache.nifi.util.MockFlowFile;
import org.apache.nifi.util.TestRunner;
import org.apache.nifi.util.TestRunners;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;

import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.Session;
import javax.mail.internet.AddressException;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;
import java.util.List;
import java.util.Properties;


public class TestConsumeIMAP {

private GreenMail mockImapServer;
private GreenMailUser user;

// Setup mock imap server
@Before
public void setUp() {
mockImapServer = new GreenMail(ServerSetupTest.IMAP);
mockImapServer.start();
user = mockImapServer.setUser("t...@nifi.org", "nifiUser", 
"nifiPassword");
}

@After
public void cleanUp() {
mockImapServer.stop();
}

public void addMessage(String testName) throws MessagingException {
Properties prop = new Properties();
Session session = Session.getDefaultInstance(prop);
MimeMessage message = new MimeMessage(session);
message.setFrom(new InternetAddress("al...@nifi.org"));
message.addRecipient(Message.RecipientType.TO, new 
InternetAddress("t...@nifi.org"));
message.setSubject("Test email" + testName);
message.setText("test test test chocolate");
user.deliver(message);
}

// Start the testing units
@Test
public void testConsumeImap() throws Exception {

final TestRunner runner = TestRunners.newTestRunner(new ConsumeIMAP());
runner.setProperty(ConsumeIMAP.HOST, 
ServerSetupTest.IMAP.getBindAddress());
runner.setProperty(ConsumeIMAP.PORT, 
String.valueOf(ServerSetupTest.IMAP.getPort()));
runner.setProperty(ConsumeIMAP.USER, "nifiUser");
runner.setProperty(ConsumeIMAP.PASSWORD, "nifiPassword");
runner.setProperty(ConsumeIMAP.FOLDER, "INBOX");
runner.setProperty(ConsumeIMAP.USE_SSL, "false");

addMessage("testConsumeImap");

runner.run();

runner.assertTransferCount(ConsumeIMAP.REL_SUCCESS, 1);
final List messages = 
runner.getFlowFilesForRelationship(ConsumeIMAP.REL_SUCCESS);
MockFlowFile x = messages.get(0);
x.assertContentEquals("test test test chocolate");
}
}
{code}



> Email processors with Exchange don't output to RFC2822 format
> -
>
> Key: NIFI-2709
> URL: https://issues.apache.org/jira/browse/NIFI-2709
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Extensions
>Affects Versions: 1.0.0
> Environment: Ubuntu 16.04 LTS with openjdk-8-jre-headless
>Reporter: Emil Frank
>Assignee: Andre
>Priority: Minor
> Attachments: screenshot-1.png
>
>
> When using the new ConsumeIMAP and ConsumePOP3 processors with a Microsoft 
> Exchange 2013 IMAP server the flowfiles which are produced are simple HTML 
> messages with no RFC2822 headers. I have also tried setting Exchange to force 
> emails to be text only, sadly only the body with some Content-Type: fields 
> are outputed.
> This mean that ExtractEmailHeaders and ExtractEmailAttachments cannot be used 
> directly with these processors.
> In Python, I can force Exchange to output the headers by specify R

[jira] [Assigned] (NIFI-2709) Email processors with Exchange don't output to RFC2822 format

2016-09-30 Thread Andre (JIRA)

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

Andre reassigned NIFI-2709:
---

Assignee: Andre

> Email processors with Exchange don't output to RFC2822 format
> -
>
> Key: NIFI-2709
> URL: https://issues.apache.org/jira/browse/NIFI-2709
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Extensions
>Affects Versions: 1.0.0
> Environment: Ubuntu 16.04 LTS with openjdk-8-jre-headless
>Reporter: Emil Frank
>Assignee: Andre
>Priority: Minor
> Attachments: screenshot-1.png
>
>
> When using the new ConsumeIMAP and ConsumePOP3 processors with a Microsoft 
> Exchange 2013 IMAP server the flowfiles which are produced are simple HTML 
> messages with no RFC2822 headers. I have also tried setting Exchange to force 
> emails to be text only, sadly only the body with some Content-Type: fields 
> are outputed.
> This mean that ExtractEmailHeaders and ExtractEmailAttachments cannot be used 
> directly with these processors.
> In Python, I can force Exchange to output the headers by specify RFC822 in 
> the connection settings:
> - https://docs.python.org/3/library/imaplib.html#imap4-example
> Is a similar option available for the spring mail framework?



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (NIFI-2848) Queues aren't fairly drained when leading to a single component

2016-09-30 Thread Joseph Gresock (JIRA)

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

Joseph Gresock updated NIFI-2848:
-
Attachment: Backpressure_prioritization_test.xml

> Queues aren't fairly drained when leading to a single component
> ---
>
> Key: NIFI-2848
> URL: https://issues.apache.org/jira/browse/NIFI-2848
> Project: Apache NiFi
>  Issue Type: Improvement
>  Components: Core Framework
>Affects Versions: 1.0.0, 0.7.0
>Reporter: Joseph Gresock
> Attachments: Backpressure_prioritization_test.xml
>
>
> Consider the scenario where multiple queues lead to a single component and 
> all of them are full due to back pressure.  With the attached template, it is 
> easily observable that once a single queue starts to drain due to relieved 
> back pressure, it will continue to drain as long as it has incoming flow 
> files.  This means that if there's a constant flow of incoming flow files to 
> this queue, the other two queues will never be drained (at least, that's my 
> theory based on an hour of observation).
> To reproduce this: 
> # Load the template into NiFi 1.0.0
> # Play all three GenerateFlowFile processors, but not the UpdateAttribute 
> processor (this simulates backpressure).  Wait until each queue has 1,000 
> flow files (max backpressure)
> # Stop the GenerateFlowFile processors, and play the UpdateAttribute 
> processor (this relieves the backpressure)
> # Observe which queue has started to drain, and start its GenerateFlowFile 
> processor
> # Observe that the other two queues remain full indefinitely, while the 
> draining queue continues to replenish and be drained indefinitely



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Created] (NIFI-2848) Queues aren't fairly drained when leading to a single component

2016-09-30 Thread Joseph Gresock (JIRA)
Joseph Gresock created NIFI-2848:


 Summary: Queues aren't fairly drained when leading to a single 
component
 Key: NIFI-2848
 URL: https://issues.apache.org/jira/browse/NIFI-2848
 Project: Apache NiFi
  Issue Type: Improvement
  Components: Core Framework
Affects Versions: 0.7.0, 1.0.0
Reporter: Joseph Gresock


Consider the scenario where multiple queues lead to a single component and all 
of them are full due to back pressure.  With the attached template, it is 
easily observable that once a single queue starts to drain due to relieved back 
pressure, it will continue to drain as long as it has incoming flow files.  
This means that if there's a constant flow of incoming flow files to this 
queue, the other two queues will never be drained (at least, that's my theory 
based on an hour of observation).

To reproduce this: 
# Load the template into NiFi 1.0.0
# Play all three GenerateFlowFile processors, but not the UpdateAttribute 
processor (this simulates backpressure).  Wait until each queue has 1,000 flow 
files (max backpressure)
# Stop the GenerateFlowFile processors, and play the UpdateAttribute processor 
(this relieves the backpressure)
# Observe which queue has started to drain, and start its GenerateFlowFile 
processor
# Observe that the other two queues remain full indefinitely, while the 
draining queue continues to replenish and be drained indefinitely



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (NIFI-2756) nifi-processor-bundle-archetype lacks displayName property

2016-09-30 Thread ASF GitHub Bot (JIRA)

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

ASF GitHub Bot commented on NIFI-2756:
--

Github user trixpan commented on the issue:

https://github.com/apache/nifi/pull/1004
  
@bbende mind sharing the steps you took? Keen to try to reproduce and fix.



> nifi-processor-bundle-archetype lacks displayName property
> --
>
> Key: NIFI-2756
> URL: https://issues.apache.org/jira/browse/NIFI-2756
> Project: Apache NiFi
>  Issue Type: Bug
>Reporter: Andre
>Assignee: Andre
>
> When using {{nifi-processor-bundle-archetype}} to create a new bundle, the 
> resulting code lacks displayName leading to a number of PR and contributions 
> to arrive to peer review without displayName configured



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] nifi issue #1004: NIFI-2756 - Add displayName to maven archetypes

2016-09-30 Thread trixpan
Github user trixpan commented on the issue:

https://github.com/apache/nifi/pull/1004
  
@bbende mind sharing the steps you took? Keen to try to reproduce and fix.



---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Commented] (NIFI-2380) ExtractEmailAttachments processor should support TNEF files (aka winmail.dat)

2016-09-30 Thread ASF GitHub Bot (JIRA)

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

ASF GitHub Bot commented on NIFI-2380:
--

Github user trixpan commented on the issue:

https://github.com/apache/nifi/pull/817
  
@olegz I guess you have been busy but I was wondering if you are still 
planning to review this? 

Cheers


> ExtractEmailAttachments processor should support TNEF files (aka winmail.dat)
> -
>
> Key: NIFI-2380
> URL: https://issues.apache.org/jira/browse/NIFI-2380
> Project: Apache NiFi
>  Issue Type: Improvement
>Affects Versions: 1.0.0
>Reporter: Andre
>Assignee: Andre
> Fix For: 1.1.0
>
>
> during the review of NIFI-1899 Dan Marshall highlighted some use cases for 
> email processing that have not been addressed as part of the initial 
> development cycle.
> One of these use cases was the decoding of Microsoft Transport Neutral 
> Encoding Files (TNEF). 
> This type of attachments is popularly know as winmail.dat and uses a non RFC 
> compliant structure to transfer attachments across different Microsoft 
> Outlook clients.
> Given the prevalence of outlook and the issues with winmail.dat files, it 
> would be nice to be able to decode TNEF as we currently do with MIME 
> attachments.
> Permalink to Dan's comments 
> http://mail-archives.apache.org/mod_mbox/nifi-dev/201607.mbox/%3C1468716836729-12827.post%40n7.nabble.com%3E



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] nifi issue #817: NIFI-2380 - Introduce ExtractTNEFAttachments

2016-09-30 Thread trixpan
Github user trixpan commented on the issue:

https://github.com/apache/nifi/pull/817
  
@olegz I guess you have been busy but I was wondering if you are still 
planning to review this? 

Cheers


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] nifi issue #1054: Dummy commit focused in closing stalled PR requests

2016-09-30 Thread trixpan
Github user trixpan commented on the issue:

https://github.com/apache/nifi/pull/1054
  
@apiri should we go ahead and commit the PR?


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Commented] (NIFI-2847) In NiFi Cluster window, filtering "by status" or "by address" do not work as expected

2016-09-30 Thread James Wing (JIRA)

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

James Wing commented on NIFI-2847:
--

How recent of a build did you test this in?  I believe this was true in the 
1.0.0 release, but [~mcgilman] addressed both of these issues in commit 
[508b218|https://git-wip-us.apache.org/repos/asf?p=nifi.git;h=508b218] as part 
of an update to the cluster UI for NIFI-2795.  I just want to double check if 
the version you are working with is before or after that recent change.

> In NiFi Cluster window, filtering "by status" or "by address" do not work as 
> expected
> -
>
> Key: NIFI-2847
> URL: https://issues.apache.org/jira/browse/NIFI-2847
> Project: Apache NiFi
>  Issue Type: Bug
>  Components: Core UI
>Affects Versions: 1.0.0
>Reporter: Andrew Lim
> Attachments: NIFI-2847_NiFiClusterFilter.png
>
>
> Attaching a screenshot of what this window displays when no filters are 
> applied to the displayed results for a 3 node cluster.
> When filtering "by status":
> -If I enter "CONNECTED", all 3 results are shown.
> -But if I enter "CONNECTED,"  or "COORDINATOR", no results are shown.  I 
> expected this to filter out all nodes except the cluster coordinator.
> When filtering "by address":
> -if I enter "localhost", all 3 results are shown.
> -But if I enter "localhost:" or any of the ports (9443, for example), no 
> results are shown.  I think it is a very common use case to filter by port.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)