svn commit: r12809 - in /dev/nifi/nifi-0.6.0: nifi-0.6.0-bin.tar.gz.asc nifi-0.6.0-bin.tar.gz.sha256 nifi-0.6.0-bin.zip.asc nifi-0.6.0-bin.zip.sha256 nifi-0.6.0-source-release.zip.asc nifi-0.6.0-sourc
Author: aldrin Date: Tue Mar 22 03:00:29 2016 New Revision: 12809 Log: NIFI-1634-RC1 Updating signatures outside of the Maven build and adding a sha256 for the source archive. Added: dev/nifi/nifi-0.6.0/nifi-0.6.0-source-release.zip.sha256 Modified: dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.asc dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.sha256 dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.zip.asc dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.zip.sha256 dev/nifi/nifi-0.6.0/nifi-0.6.0-source-release.zip.asc Modified: dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.asc == --- dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.asc (original) +++ dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.asc Tue Mar 22 03:00:29 2016 @@ -1,16 +1,16 @@ -BEGIN PGP SIGNATURE- -iQIcBAABCgAGBQJW8FACAAoJEFMa66pM/l0A1aIP/i83eSKewJE3UJoGMagyQIAX -kQ7ZuYkNzI1d9lkAh4Zca4VrXc9VkaJN03V4i0OYq013IM+W5WNeMK3yon5xhxSp -gohCthSItu03lI68KvKc+Ed5nShCh7jml0pGEojtPd2JFgbGrlz7FFJJoGO6OYXf -YwvppXsQGX+cjxM3gSYcHZjlFJ2KRwNMNdF54yyOLUgNoqHcDFXIox6VIjJPMTNn -JsPfuIlr0AJkIa5rFLy1QmjgEKYyAwi2GnDTEKaYOQiii40QiZ/P+ZNW6FNCObqf -zWXdj6Py8idiXVlqtsJhapR9KiZsRt66IRlCXA+uDwiurnklPrto87Z17scRh7hi -ivpUwkrcWrapLfgD2NF1yxR/RBbs2nNImY1MDKcbX37YjRiEMN48vuqb+gvfHNkA -Wv/GgafkGeh7GZ8GdDJhFQvE3FVa8N5qNWmOUCivF+nFR+oVzususwbuUQad1PQq -6Sfy1KsFPrDsz+ljYzp8ctZoIIiqt//eV++DKSAZG1rtzZFyhWNOwFc3HceMs+95 -sFpGrv0YwflaA4dlj10lX/EYQpKKrrzYuJ3gfSPjlRg7b3veG1cMZ0OQfDr3EUls -YzN0+29grqqjIu/p6JoLtr1t1IJkj4jyyoLA0NsLgw9psXU7LPszFDt/FfbZ8UUC -V3WJZWsOmDLmzhm4KDoF -=AD14 +iQIcBAABCgAGBQJW8LK5AAoJEFMa66pM/l0AZVMP/RMkEgzmsxy8IhJrDiN4K1hA +5qSZmosvb9erye4Vh/SodOmAIrcfRp2yzTHdLh11Z+vIh5t8aL5PIt+CNEI4pxkv +tUuCxX7EajMuG1jsBkIthXM4nCWbmhctvipElz23tROzN4EmaA34Shr+6f1CVsgf +aCmyDdACzvGwzekmfETvAx+2kFKw/Eo3fLqzjVHkmSsX3O9lIK30K97Gw8+BMqJH +m5ye3yeJFCT2W6qgXycXNXVSxobGKXEFHmhGEyMIbaKEHmSzD7oAY0gL1JHPlumM +zxptW4+bsfArLIyyJokTQiOo90dM2k8joFGgr2qAzDlAO1lC2MuS/LniRqaKszHG +4fW/20QmDs4t3GnL2/6sULow/4Lp14tHxYQpg4L6RdmXFdPqd8hQNm0G10TEGkYa +Rq1XKhfrf5yGt4BSH8aiL0p8zuZH3gGVLu2xDF/G8BC31/DYd8a6mWY9QPws03YO +mCsRaEZBlElHphMoZzUOFRi6V/+o3QtQDV1ZiP5Wp3UsF0mQeuUXZ3kD7TNz6LeB +ZbzRLbkbgdrmpN1zstuIeS8UP2DqKBK7W1lkjmjRWShAGZJdKlha2kMz8F9onxZH +kvjqC1xkAu033naGdb6DSZoXMGhjhP/4fkqc+cfaHV3BBSjGCdOcNYPNMoOFNJfr +KkGVSMxUFuTZuEio5WxK +=uKHC -END PGP SIGNATURE- Modified: dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.sha256 == --- dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.sha256 (original) +++ dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.sha256 Tue Mar 22 03:00:29 2016 @@ -1 +1 @@ -3c3ed05b9631e36aacb24a568c3318efa884e183 \ No newline at end of file +3c3ed05b9631e36aacb24a568c3318efa884e183670b96edea50a5ec3c8e1dfb \ No newline at end of file Modified: dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.zip.asc == --- dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.zip.asc (original) +++ dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.zip.asc Tue Mar 22 03:00:29 2016 @@ -1,16 +1,16 @@ -BEGIN PGP SIGNATURE- -iQIcBAABCgAGBQJW8E/1AAoJEFMa66pM/l0AMx4P/3EGTKBl7PDRcwCu+YJAisJN -OlSoxuGDkW8g/IVzAiLGDyU5CJhoQCxjK174s7bliLleHbbIQL0XvBjmCKrVukW1 -B04QDPPkyvuQ2jA5BLe+pCK6QCgNmbXTNmUgKa3axu/Z3G/8c7ryIBy14pkFVX73 -5mOUEiZ2vXW8qwEewDkDppiOvSgc3nDrN068b+XXpigkVCJ2OHNk9sWK4XK9+McA -a3qHEb7tE09qMqNfMcBej60bcQRhhIvAD+jQktbJHs+3qJAJiGgQmwCJ2nVVKYlD -xEMsZVjOfXVEdqLdGqrQ3rDhfY4SYrdWG1EbUsWA1BBH/BCu65YKSQO+4695rz77 -2enzM82SR8/ShAzq9vNxTn7mJs6xapYh3loy9XXbTNBCCkecgNOBzVAyWyTDAfi8 -q30YwZDMcDqQ+p6Pux7rsjwhrnNZDs89FbaJrxHDKJDv4GqE3YZe/Tzg7FGrX/zr -scqRywCzRszfRpkMa2ehVzzBfVaFlICf1mo8VjF9Kgvv9+Z9b595vH6A2efbOS9t -RTfnEqPK6fgpgvgu2RSuyfd1pq3+wr34KCZ0F33Fjs2S1oCMlqUx7rcfpTF5d9E1 -Kk6OCHcEGVXXB5UJgtpBQjjEZFW9iMyp91GcrWyn7lIwLBHuhGRYSZ0XRjKNDjP2 -lsmz4rKnz8ujQTXKO1XI -=gmTn +iQIcBAABCgAGBQJW8LKxAAoJEFMa66pM/l0AVbcP/1aUg2MGvG001FuuPBW8mMFF +XU30C8ctEB/0loe8Sg2U0A8Ht3oE+RQVAUBLcW83/zX0buGE6zsJgiZBD2WFbjCn +2oqcT9yZWXD1It0rOcjRS9jCk5b9agK9LDPXwF//8xiAhhdgkIMpoo5aVmcIP0OA +nzm0pSToHN2uFqoj/NLKJVS3/zU2Kt3dOLZoxnHqr3Q4n07crg0f31IX0EWzDqpf +t3ubzS/aUph5UxTYOfN4QshQIODx5aCakROcrBFqc02Qu+NUDtcxCGd0Npp5YOM/ +/78t6lMFxsk9IMUsSETTFWoRoyDvDmo/eYk5Yei30v/TY2+/h/lkXYSTWEqiwdjb +Qeo++6yfL5vXtO8C80NYipIvtLfue9Rp8JghkUH0zgUMuyo3Q91l7kL42YdvyEyF +DowfA5ocvHnKRBrMc0H0gm+Jb6yvwLwJrryg9GVgNzgG6XrtwVEFr1B0cgZ/UWVQ +c7gmE0HkTwfj4ssE7GZs23VcWeCJLAg4/9rsGLKR8N6YToYfU+oEFmi/4JK07HpL +47IKE7tQj+LsGmj34g663hKgYlKZPlINcwzu7TAe38RMw31y67m3A+IJ3U9658Os +nzEx5onEQVPVtMn0/L7w0daMHzoDWMJTZOaij8RFFqLMaqM049ezvbLg4XiG8Ybd +TixjAeFTaQ3+Rt6hxPuy +=JiGw -END PGP SIGNATURE- Modified: dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.zip.sha256 == --- dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.zip.sha256 (original) +++ dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.zip.sha256 Tue Mar 22 03:00:29 2016 @@ -1 +1 @@ -248b10b17c42bfb465042ef4af2
[jira] [Commented] (NIFI-1620) Allow empty Content-Type in InvokeHTTP processor
[
https://issues.apache.org/jira/browse/NIFI-1620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205638#comment-15205638
]
ASF GitHub Bot commented on NIFI-1620:
--
Github user taftster commented on a diff in the pull request:
https://github.com/apache/nifi/pull/272#discussion_r56928547
--- Diff:
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/InvokeHTTP.java
---
@@ -215,14 +215,24 @@
.build();
public static final PropertyDescriptor PROP_CONTENT_TYPE = new
PropertyDescriptor.Builder()
-.name("Content-Type")
-.description("The Content-Type to specify for when content is
being transmitted through a PUT or POST. "
-+ "In the case of an empty value after evaluating an
expression language expression, Content-Type defaults to " +
DEFAULT_CONTENT_TYPE)
-.required(true)
-.expressionLanguageSupported(true)
-.defaultValue("${" + CoreAttributes.MIME_TYPE.key() + "}")
-.addValidator(StandardValidators.NON_EMPTY_VALIDATOR)
-.build();
+.name("Content-Type")
+.description("The Content-Type to specify for when content is
being transmitted through a PUT or POST. "
++ "In the case of an empty value after evaluating an
expression language expression, Content-Type defaults to " +
DEFAULT_CONTENT_TYPE + "."
++ "If and only if body is not sent, Content-Type must
be set to empty")
+.required(false)
+.expressionLanguageSupported(true)
+.defaultValue("${" + CoreAttributes.MIME_TYPE.key() + "}")
+
.addValidator(StandardValidators.createAttributeExpressionLanguageValidator(AttributeExpression.ResultType.STRING))
+.build();
+
+public static final PropertyDescriptor PROP_SEND_BODY = new
PropertyDescriptor.Builder()
+.name("Send body")
+.description("True if the body content should be sent, false
otherwise")
+.defaultValue("true")
--- End diff --
We should refer to this as the HTTP spec refers to it. It's called the
"message-body" in the spec, so I think we should use that here as well. i.e.
```
.name("send-message-body")
.displayName("Send Message Body")
.description("If true, sends the HTTP message body on POST/PUT requests
(default). If false, suppresses the message body and content-type header for
these requests.")
```
> Allow empty Content-Type in InvokeHTTP processor
>
>
> Key: NIFI-1620
> URL: https://issues.apache.org/jira/browse/NIFI-1620
> Project: Apache NiFi
> Issue Type: Bug
> Components: Extensions
>Affects Versions: 0.5.1
>Reporter: Pierre Villard
>Assignee: Pierre Villard
>
> External API could expect a POST request without a Content-Type property or
> at least with this property empty:
> *Error example:*
> {quote}
> You provided a non-empty HTTP "Content-Type" header ("application/json").
> This API function requires that the header be missing or empty.
> {quote}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Commented] (NIFI-1620) Allow empty Content-Type in InvokeHTTP processor
[
https://issues.apache.org/jira/browse/NIFI-1620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205637#comment-15205637
]
ASF GitHub Bot commented on NIFI-1620:
--
Github user taftster commented on a diff in the pull request:
https://github.com/apache/nifi/pull/272#discussion_r56928543
--- Diff:
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/InvokeHTTP.java
---
@@ -215,14 +215,24 @@
.build();
public static final PropertyDescriptor PROP_CONTENT_TYPE = new
PropertyDescriptor.Builder()
-.name("Content-Type")
-.description("The Content-Type to specify for when content is
being transmitted through a PUT or POST. "
-+ "In the case of an empty value after evaluating an
expression language expression, Content-Type defaults to " +
DEFAULT_CONTENT_TYPE)
-.required(true)
-.expressionLanguageSupported(true)
-.defaultValue("${" + CoreAttributes.MIME_TYPE.key() + "}")
-.addValidator(StandardValidators.NON_EMPTY_VALIDATOR)
-.build();
+.name("Content-Type")
+.description("The Content-Type to specify for when content is
being transmitted through a PUT or POST. "
++ "In the case of an empty value after evaluating an
expression language expression, Content-Type defaults to " +
DEFAULT_CONTENT_TYPE + "."
++ "If and only if body is not sent, Content-Type must
be set to empty")
+.required(false)
+.expressionLanguageSupported(true)
+.defaultValue("${" + CoreAttributes.MIME_TYPE.key() + "}")
+
.addValidator(StandardValidators.createAttributeExpressionLanguageValidator(AttributeExpression.ResultType.STRING))
+.build();
+
--- End diff --
I'm not sure if we even need this change. In the case that the
PROP_SEND_BODY is false, we should always suppress setting the Content-Type
header. Therefore, I would leave this as-is a required field, with
documentation in the PROP_SEND_FIELD property describing the behavior for empty
message bodies.
> Allow empty Content-Type in InvokeHTTP processor
>
>
> Key: NIFI-1620
> URL: https://issues.apache.org/jira/browse/NIFI-1620
> Project: Apache NiFi
> Issue Type: Bug
> Components: Extensions
>Affects Versions: 0.5.1
>Reporter: Pierre Villard
>Assignee: Pierre Villard
>
> External API could expect a POST request without a Content-Type property or
> at least with this property empty:
> *Error example:*
> {quote}
> You provided a non-empty HTTP "Content-Type" header ("application/json").
> This API function requires that the header be missing or empty.
> {quote}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Commented] (NIFI-1620) Allow empty Content-Type in InvokeHTTP processor
[
https://issues.apache.org/jira/browse/NIFI-1620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205639#comment-15205639
]
ASF GitHub Bot commented on NIFI-1620:
--
Github user taftster commented on a diff in the pull request:
https://github.com/apache/nifi/pull/272#discussion_r56928549
--- Diff:
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/InvokeHTTP.java
---
@@ -444,14 +455,27 @@ public void onPropertyModified(final
PropertyDescriptor descriptor, final String
@Override
protected Collection customValidate(final
ValidationContext validationContext) {
-final List results = new ArrayList<>(1);
+final List results = new
ArrayList(3);
+
+// proxy host and port validation
final boolean proxyHostSet =
validationContext.getProperty(PROP_PROXY_HOST).isSet();
final boolean proxyPortSet =
validationContext.getProperty(PROP_PROXY_PORT).isSet();
-
if ((proxyHostSet && !proxyPortSet) || (!proxyHostSet &&
proxyPortSet)) {
results.add(new ValidationResult.Builder().subject("Proxy Host
and Port").valid(false).explanation("If Proxy Host or Proxy Port is set, both
must be set").build());
}
+// body and content-type validation
+final boolean contentTypeSet =
validationContext.getProperty(PROP_CONTENT_TYPE).isSet();
+final boolean sendBody =
validationContext.getProperty(PROP_SEND_BODY).asBoolean();
+final String contentType =
validationContext.getProperty(PROP_CONTENT_TYPE).getValue();
+if(contentTypeSet && contentType.isEmpty() && sendBody) {
+results.add(new
ValidationResult.Builder().subject("Content-Type and Send body")
+.valid(false).explanation("If Content-Type is set to
empty, Send body property must be set to false").build());
+}
+if(!sendBody && !contentType.isEmpty()) {
+results.add(new
ValidationResult.Builder().subject("Content-Type and Send
body").valid(false).explanation("If body is not sent, Content-Type must be set
to empty").build());
+}
+
return results;
--- End diff --
This custom validation rule can be removed if the content-type property is
left alone.
> Allow empty Content-Type in InvokeHTTP processor
>
>
> Key: NIFI-1620
> URL: https://issues.apache.org/jira/browse/NIFI-1620
> Project: Apache NiFi
> Issue Type: Bug
> Components: Extensions
>Affects Versions: 0.5.1
>Reporter: Pierre Villard
>Assignee: Pierre Villard
>
> External API could expect a POST request without a Content-Type property or
> at least with this property empty:
> *Error example:*
> {quote}
> You provided a non-empty HTTP "Content-Type" header ("application/json").
> This API function requires that the header be missing or empty.
> {quote}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Updated] (NIFI-1663) Add support for ORC format
[ https://issues.apache.org/jira/browse/NIFI-1663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Burgess updated NIFI-1663: --- Description: >From the Hive/ORC wiki >(https://cwiki.apache.org/confluence/display/Hive/LanguageManual+ORC): The Optimized Row Columnar (ORC) file format provides a highly efficient way to store Hive data ... Using ORC files improves performance when Hive is reading, writing, and processing data. As users are interested in NiFi integrations with Hive (NIFI-981, NIFI-1193, etc.), NiFi should be able to support ORC file format to enable users to efficiently store flow files for use by Hive. was: >From the Hive/ORC wiki >(https://cwiki.apache.org/confluence/display/Hive/LanguageManual+ORC): The Optimized Row Columnar (ORC) file format provides a highly efficient way to store Hive data ... Using ORC files improves performance when Hive is reading, writing, and processing data. As users are interested in NiFi integrations with Hive (NIFI-981, NIFI-1183, etc.), NiFi should be able to support ORC file format to enable users to efficiently store flow files for use by Hive. > Add support for ORC format > -- > > Key: NIFI-1663 > URL: https://issues.apache.org/jira/browse/NIFI-1663 > Project: Apache NiFi > Issue Type: New Feature >Reporter: Matt Burgess > > From the Hive/ORC wiki > (https://cwiki.apache.org/confluence/display/Hive/LanguageManual+ORC): > The Optimized Row Columnar (ORC) file format provides a highly efficient way > to store Hive data ... Using ORC files improves performance when Hive is > reading, writing, and processing data. > As users are interested in NiFi integrations with Hive (NIFI-981, NIFI-1193, > etc.), NiFi should be able to support ORC file format to enable users to > efficiently store flow files for use by Hive. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (NIFI-1663) Add support for ORC format
Matt Burgess created NIFI-1663: -- Summary: Add support for ORC format Key: NIFI-1663 URL: https://issues.apache.org/jira/browse/NIFI-1663 Project: Apache NiFi Issue Type: New Feature Reporter: Matt Burgess >From the Hive/ORC wiki >(https://cwiki.apache.org/confluence/display/Hive/LanguageManual+ORC): The Optimized Row Columnar (ORC) file format provides a highly efficient way to store Hive data ... Using ORC files improves performance when Hive is reading, writing, and processing data. As users are interested in NiFi integrations with Hive (NIFI-981, NIFI-1183, etc.), NiFi should be able to support ORC file format to enable users to efficiently store flow files for use by Hive. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[nifi] Git Push Summary
Repository: nifi Updated Tags: refs/tags/nifi-0.6.0-RC1 [created] 077be04e2
svn commit: r12806 - /dev/nifi/nifi-0.6.0/
Author: aldrin Date: Mon Mar 21 20:33:48 2016 New Revision: 12806 Log: NIFI-1634-RC1 Providing convenience binaries and artifacts for Apache NiFi 0.6.0 Added: dev/nifi/nifi-0.6.0/ dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz (with props) dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.asc dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.md5 dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.sha1 dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.sha256 dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.zip (with props) dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.zip.asc dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.zip.md5 dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.zip.sha1 dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.zip.sha256 dev/nifi/nifi-0.6.0/nifi-0.6.0-source-release.zip (with props) dev/nifi/nifi-0.6.0/nifi-0.6.0-source-release.zip.asc dev/nifi/nifi-0.6.0/nifi-0.6.0-source-release.zip.md5 dev/nifi/nifi-0.6.0/nifi-0.6.0-source-release.zip.sha1 Added: dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz == Binary file - no diff available. Propchange: dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz -- svn:mime-type = application/octet-stream Added: dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.asc == --- dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.asc (added) +++ dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.asc Mon Mar 21 20:33:48 2016 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIcBAABCgAGBQJW8FACAAoJEFMa66pM/l0A1aIP/i83eSKewJE3UJoGMagyQIAX +kQ7ZuYkNzI1d9lkAh4Zca4VrXc9VkaJN03V4i0OYq013IM+W5WNeMK3yon5xhxSp +gohCthSItu03lI68KvKc+Ed5nShCh7jml0pGEojtPd2JFgbGrlz7FFJJoGO6OYXf +YwvppXsQGX+cjxM3gSYcHZjlFJ2KRwNMNdF54yyOLUgNoqHcDFXIox6VIjJPMTNn +JsPfuIlr0AJkIa5rFLy1QmjgEKYyAwi2GnDTEKaYOQiii40QiZ/P+ZNW6FNCObqf +zWXdj6Py8idiXVlqtsJhapR9KiZsRt66IRlCXA+uDwiurnklPrto87Z17scRh7hi +ivpUwkrcWrapLfgD2NF1yxR/RBbs2nNImY1MDKcbX37YjRiEMN48vuqb+gvfHNkA +Wv/GgafkGeh7GZ8GdDJhFQvE3FVa8N5qNWmOUCivF+nFR+oVzususwbuUQad1PQq +6Sfy1KsFPrDsz+ljYzp8ctZoIIiqt//eV++DKSAZG1rtzZFyhWNOwFc3HceMs+95 +sFpGrv0YwflaA4dlj10lX/EYQpKKrrzYuJ3gfSPjlRg7b3veG1cMZ0OQfDr3EUls +YzN0+29grqqjIu/p6JoLtr1t1IJkj4jyyoLA0NsLgw9psXU7LPszFDt/FfbZ8UUC +V3WJZWsOmDLmzhm4KDoF +=AD14 +-END PGP SIGNATURE- Added: dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.md5 == --- dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.md5 (added) +++ dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.md5 Mon Mar 21 20:33:48 2016 @@ -0,0 +1 @@ +83e02fca29e0b48dc6dec8669217be28 \ No newline at end of file Added: dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.sha1 == --- dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.sha1 (added) +++ dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.sha1 Mon Mar 21 20:33:48 2016 @@ -0,0 +1 @@ +3fab8e37c7c9156d0cd3412455abd4ffbba82193 \ No newline at end of file Added: dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.sha256 == --- dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.sha256 (added) +++ dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.tar.gz.sha256 Mon Mar 21 20:33:48 2016 @@ -0,0 +1 @@ +3c3ed05b9631e36aacb24a568c3318efa884e183 \ No newline at end of file Added: dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.zip == Binary file - no diff available. Propchange: dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.zip -- svn:mime-type = application/octet-stream Added: dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.zip.asc == --- dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.zip.asc (added) +++ dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.zip.asc Mon Mar 21 20:33:48 2016 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIcBAABCgAGBQJW8E/1AAoJEFMa66pM/l0AMx4P/3EGTKBl7PDRcwCu+YJAisJN +OlSoxuGDkW8g/IVzAiLGDyU5CJhoQCxjK174s7bliLleHbbIQL0XvBjmCKrVukW1 +B04QDPPkyvuQ2jA5BLe+pCK6QCgNmbXTNmUgKa3axu/Z3G/8c7ryIBy14pkFVX73 +5mOUEiZ2vXW8qwEewDkDppiOvSgc3nDrN068b+XXpigkVCJ2OHNk9sWK4XK9+McA +a3qHEb7tE09qMqNfMcBej60bcQRhhIvAD+jQktbJHs+3qJAJiGgQmwCJ2nVVKYlD +xEMsZVjOfXVEdqLdGqrQ3rDhfY4SYrdWG1EbUsWA1BBH/BCu65YKSQO+4695rz77 +2enzM82SR8/ShAzq9vNxTn7mJs6xapYh3loy9XXbTNBCCkecgNOBzVAyWyTDAfi8 +q30YwZDMcDqQ+p6Pux7rsjwhrnNZDs89FbaJrxHDKJDv4GqE3YZe/Tzg7FGrX/zr +scqRywCzRszfRpkMa2ehVzzBfVaFlICf1mo8VjF9Kgvv9+Z9b595vH6A2efbOS9t +RTfnEqPK6fgpgvgu2RSuyfd1pq3+wr34KCZ0F33Fjs2S1oCMlqUx7rcfpTF5d9E1 +Kk6OCHcEGVXXB5UJgtpBQjjEZFW9iMyp91GcrWyn7lIwLBHuhGRYSZ0XRjKNDjP2 +lsmz4rKnz8ujQTXKO1XI +=gmTn +-END PGP SIGNATURE- Added: dev/nifi/nifi-0.6.0/nifi-0.6.0-bin.zip.md5 == ---
[jira] [Commented] (NIFI-1563) Remove storage of components' stats and bulletins from NCM
[ https://issues.apache.org/jira/browse/NIFI-1563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205036#comment-15205036 ] ASF GitHub Bot commented on NIFI-1563: -- Github user mcgilman commented on a diff in the pull request: https://github.com/apache/nifi/pull/294#discussion_r56890522 --- Diff: nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/pom.xml --- @@ -26,5 +26,13 @@ com.wordnik swagger-annotations + +org.apache.nifi +nifi-utils + + +org.apache.nifi +nifi-api + --- End diff -- Are these dependencies necessary? Would like to have this artifact as 'light' and 'portability' as possible. Should just be definitions of transport objects for using the REST API. > Remove storage of components' stats and bulletins from NCM > -- > > Key: NIFI-1563 > URL: https://issues.apache.org/jira/browse/NIFI-1563 > Project: Apache NiFi > Issue Type: Improvement > Components: Core Framework >Reporter: Mark Payne >Assignee: Mark Payne > Fix For: 1.0.0 > > Original Estimate: 168h > Remaining Estimate: 168h > > Currently, each node in a cluster sends a period heartbeat that contains the > stats for all components in the node. This happens every 5 seconds by > default. This results in quite a lot of chatter between the NCM and nodes. It > made sense to take this approach when the clustering concept was designed > because there were no Process Groups, and we had no notion of merging > responses from nodes for a web request. > However, now we should replicate the request to all nodes and then merge the > responses on demand, rather than storing this information on the NCM. This > requires far less bandwidth because we only need to pull the stats for a > particular Process Group and only on demand instead of every 5 seconds. > Additionally, this is laying groundwork for the Zero-Master clustering that > we want to have in place for 1.0.0. > In order to remove the stats from the NCM, we will also need to remove the > bulletins and stats history. These requests will all need to be federated and > the responses merged on-demand. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (NIFI-1563) Remove storage of components' stats and bulletins from NCM
[ https://issues.apache.org/jira/browse/NIFI-1563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205018#comment-15205018 ] ASF GitHub Bot commented on NIFI-1563: -- Github user mcgilman commented on the pull request: https://github.com/apache/nifi/pull/294#issuecomment-199458161 Reviewing... > Remove storage of components' stats and bulletins from NCM > -- > > Key: NIFI-1563 > URL: https://issues.apache.org/jira/browse/NIFI-1563 > Project: Apache NiFi > Issue Type: Improvement > Components: Core Framework >Reporter: Mark Payne >Assignee: Mark Payne > Fix For: 1.0.0 > > Original Estimate: 168h > Remaining Estimate: 168h > > Currently, each node in a cluster sends a period heartbeat that contains the > stats for all components in the node. This happens every 5 seconds by > default. This results in quite a lot of chatter between the NCM and nodes. It > made sense to take this approach when the clustering concept was designed > because there were no Process Groups, and we had no notion of merging > responses from nodes for a web request. > However, now we should replicate the request to all nodes and then merge the > responses on demand, rather than storing this information on the NCM. This > requires far less bandwidth because we only need to pull the stats for a > particular Process Group and only on demand instead of every 5 seconds. > Additionally, this is laying groundwork for the Zero-Master clustering that > we want to have in place for 1.0.0. > In order to remove the stats from the NCM, we will also need to remove the > bulletins and stats history. These requests will all need to be federated and > the responses merged on-demand. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (NIFI-1563) Remove storage of components' stats and bulletins from NCM
[ https://issues.apache.org/jira/browse/NIFI-1563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205013#comment-15205013 ] ASF GitHub Bot commented on NIFI-1563: -- GitHub user markap14 opened a pull request: https://github.com/apache/nifi/pull/294 NIFI-1563: Federate requests and merge responses from nodes instead o… …f storing bulletins and stats at NCM - Updating UI to support restructured status history DTO. Return 'Insufficient History' message if aggregate stats don't have enough data points, even if all nodes do (which can be the case if the node performing the aggregation has a different value for the 'nifi.components.status.snapshot.frequency' property than the other nodes) Bug fixes; code cleanup; replicate requests to bulletin board endpoint Refactored the StatusDTO objects into StatusDTO, StatusSnapshotDTO, NodeStatusSnapshotDTO objects - Introducing endpoints for accessing individual component status. - Wiring up new endpoints and updated core. - Code clean up. - Starting to handling status merging of individual components. - Nodewise breakdown has been added to Processors but the remaining components still need to be updated. Refactor so that System Diagnostics requests are replicated to nodes instead of the information being pulled from Heartbeats Replicate request for counters instead of pulling them from heartbeats Removed the getCounters / setCounters method from HeartbeatPayload - Implementing component specific endpoints. - Removing unused endpoints. - Supporting nodewise breakdown for system diagnostics and counters. - Updating DTOs to use more consistent naming. - Code clean up. - Addressing contrib issues. Removed ProcessGroupStatus from HeartbeatPayload - Removing nodewise from the system diagnostics endpoint. Had included it for testing that option but did not intend for it to be committed. You can merge this pull request into a Git repository by running: $ git pull https://github.com/markap14/nifi NIFI-1563 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/nifi/pull/294.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 #294 commit 1bbe0aa7f7c80d13a67178261b88551389a92f17 Author: Mark Payne Date: 2016-03-03T18:29:34Z NIFI-1563: Federate requests and merge responses from nodes instead of storing bulletins and stats at NCM - Updating UI to support restructured status history DTO. Return 'Insufficient History' message if aggregate stats don't have enough data points, even if all nodes do (which can be the case if the node performing the aggregation has a different value for the 'nifi.components.status.snapshot.frequency' property than the other nodes) Bug fixes; code cleanup; replicate requests to bulletin board endpoint Refactored the StatusDTO objects into StatusDTO, StatusSnapshotDTO, NodeStatusSnapshotDTO objects - Introducing endpoints for accessing individual component status. - Wiring up new endpoints and updated core. - Code clean up. - Starting to handling status merging of individual components. - Nodewise breakdown has been added to Processors but the remaining components still need to be updated. Refactor so that System Diagnostics requests are replicated to nodes instead of the information being pulled from Heartbeats Replicate request for counters instead of pulling them from heartbeats Removed the getCounters / setCounters method from HeartbeatPayload - Implementing component specific endpoints. - Removing unused endpoints. - Supporting nodewise breakdown for system diagnostics and counters. - Updating DTOs to use more consistent naming. - Code clean up. - Addressing contrib issues. Removed ProcessGroupStatus from HeartbeatPayload - Removing nodewise from the system diagnostics endpoint. Had included it for testing that option but did not intend for it to be committed. > Remove storage of components' stats and bulletins from NCM > -- > > Key: NIFI-1563 > URL: https://issues.apache.org/jira/browse/NIFI-1563 > Project: Apache NiFi > Issue Type: Improvement > Components: Core Framework >Reporter: Mark Payne >Assignee: Mark Payne > Fix For: 1.0.0 > > Original Estimate: 168h > Remaining Estimate: 168h > > Currently, each node in a cluster sends a period heartbeat that contains the > stats for all components in the node. Th
[jira] [Commented] (NIFI-1613) ConvertJSONToSQL Drops Type Information
[
https://issues.apache.org/jira/browse/NIFI-1613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205005#comment-15205005
]
ASF GitHub Bot commented on NIFI-1613:
--
GitHub user ToivoAdams opened a pull request:
https://github.com/apache/nifi/pull/293
NIFI-1613 Initial version, try to improve conversion for different SQ…
Initial version.
1. New method createSqlStringValue(), placeholder for future logic
2. New test testCreateSqlStringValue()
3. Refactored TestConvertJSONToSQL.
Setting up Connection pooling is expensive operation.
So let's do this only once and reuse MockDBCPService in each test.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ToivoAdams/nifi nifi-1613
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/nifi/pull/293.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 #293
commit 7c2eea7902f81456a880853d782615c8874a38a8
Author: Toivo Adams
Date: 2016-03-20T19:13:15Z
NIFI-1613 Initial version, try to improve conversion for different SQL
types. New test and refactored existing test to reuse DBCP service.
> ConvertJSONToSQL Drops Type Information
> ---
>
> Key: NIFI-1613
> URL: https://issues.apache.org/jira/browse/NIFI-1613
> Project: Apache NiFi
> Issue Type: Bug
> Components: Core Framework
>Affects Versions: 0.4.1, 0.5.1
> Environment: Ubuntu 14.04 LTS
>Reporter: Aaron Stephens
>Assignee: Toivo Adams
> Labels: ConvertJSONToSQL, Phoenix, SQL
>
> It appears that the ConvertJSONToSQL processor is turning Boolean (and
> possibly Integer and Float) values into Strings. This is okay for some
> drivers (like PostgreSQL) which can coerce a String back into a Boolean, but
> it causes issues for others (specifically Phoenix in my case).
> {noformat}
> org.apache.phoenix.schema.ConstraintViolationException:
> org.apache.phoenix.schema.TypeMismatchException: ERROR 203 (22005): Type
> mismatch. VARCHAR cannot be coerced to BOOLEAN
> at
> org.apache.phoenix.schema.types.PDataType.throwConstraintViolationException(PDataType.java:282)
> ~[na:na]
> at
> org.apache.phoenix.schema.types.PBoolean.toObject(PBoolean.java:136) ~[na:na]
> at
> org.apache.phoenix.jdbc.PhoenixPreparedStatement.setObject(PhoenixPreparedStatement.java:442)
> ~[na:na]
> at
> org.apache.commons.dbcp.DelegatingPreparedStatement.setObject(DelegatingPreparedStatement.java:166)
> ~[na:na]
> at
> org.apache.commons.dbcp.DelegatingPreparedStatement.setObject(DelegatingPreparedStatement.java:166)
> ~[na:na]
> at
> org.apache.nifi.processors.standard.PutSQL.setParameter(PutSQL.java:728)
> ~[na:na]
> at
> org.apache.nifi.processors.standard.PutSQL.setParameters(PutSQL.java:606)
> ~[na:na]
> at
> org.apache.nifi.processors.standard.PutSQL.onTrigger(PutSQL.java:223) ~[na:na]
> at
> org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
> ~[nifi-api-0.4.1.jar:0.4.1]
> at
> org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1146)
> ~[nifi-framework-core-0.4.1.jar:0.4.1]
> at
> org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:139)
> [nifi-framework-core-0.4.1.jar:0.4.1]
> at
> org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:49)
> [nifi-framework-core-0.4.1.jar:0.4.1]
> at
> org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:119)
> [nifi-framework-core-0.4.1.jar:0.4.1]
> at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
> [na:1.7.0_79]
> at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:304)
> [na:1.7.0_79]
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178)
> [na:1.7.0_79]
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
> [na:1.7.0_79]
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> [na:1.7.0_79]
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> [na:1.7.0_79]
> at java.lang.Thread.run(Thread.java:745) [na:1.7.0_79]
> Caused by: org.apache.phoenix.schema.TypeMismatchException: ERROR 203
> (22005): Type mismatch. VARCHAR cannot be coerced to BOOLEAN
> at
> org.apache.phoenix.exception.
[jira] [Commented] (NIFI-1634) Perform Release Management Functions for 0.6.0
[ https://issues.apache.org/jira/browse/NIFI-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205002#comment-15205002 ] ASF subversion and git services commented on NIFI-1634: --- Commit 65312fee6fb8bb7039bee4a894387bd93e9c8a29 in nifi's branch refs/heads/NIFI-1634-RC1 from [~aldrin] [ https://git-wip-us.apache.org/repos/asf?p=nifi.git;h=65312fe ] NIFI-1634-RC1 prepare for next development iteration > Perform Release Management Functions for 0.6.0 > -- > > Key: NIFI-1634 > URL: https://issues.apache.org/jira/browse/NIFI-1634 > Project: Apache NiFi > Issue Type: Task > Components: Documentation & Website, Tools and Build >Affects Versions: 0.6.0 >Reporter: Aldrin Piri >Assignee: Aldrin Piri > Labels: release > Fix For: 0.6.0 > > -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (NIFI-1634) Perform Release Management Functions for 0.6.0
[ https://issues.apache.org/jira/browse/NIFI-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15205001#comment-15205001 ] ASF subversion and git services commented on NIFI-1634: --- Commit 5d8fafbcf515a99d4d7454c362543689ba590a1b in nifi's branch refs/heads/NIFI-1634-RC1 from [~aldrin] [ https://git-wip-us.apache.org/repos/asf?p=nifi.git;h=5d8fafb ] NIFI-1634-RC1 prepare release nifi-0.6.0-RC1 > Perform Release Management Functions for 0.6.0 > -- > > Key: NIFI-1634 > URL: https://issues.apache.org/jira/browse/NIFI-1634 > Project: Apache NiFi > Issue Type: Task > Components: Documentation & Website, Tools and Build >Affects Versions: 0.6.0 >Reporter: Aldrin Piri >Assignee: Aldrin Piri > Labels: release > Fix For: 0.6.0 > > -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[4/6] nifi git commit: NIFI-1634-RC1 prepare for next development iteration
http://git-wip-us.apache.org/repos/asf/nifi/blob/65312fee/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml index c12a9e3..86ab9ef 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-http-context-map-bundle -0.6.0 +0.6.1-SNAPSHOT nifi-http-context-map-nar http://git-wip-us.apache.org/repos/asf/nifi/blob/65312fee/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml index 6d8d571..99baee7 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-http-context-map-bundle -0.6.0 +0.6.1-SNAPSHOT nifi-http-context-map http://git-wip-us.apache.org/repos/asf/nifi/blob/65312fee/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml index 4c5850d..5b600c7 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-standard-services -0.6.0 +0.6.1-SNAPSHOT nifi-http-context-map-bundle http://git-wip-us.apache.org/repos/asf/nifi/blob/65312fee/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml index 9cd4c52..5da2183 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-standard-services -0.6.0 +0.6.1-SNAPSHOT nifi-load-distribution-service-api jar http://git-wip-us.apache.org/repos/asf/nifi/blob/65312fee/nifi-nar-bundles/nifi-standard-services/nifi-ssl-context-bundle/nifi-ssl-context-nar/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-ssl-context-bundle/nifi-ssl-context-nar/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-ssl-context-bundle/nifi-ssl-context-nar/pom.xml index b2d5652..ce0bc36 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-ssl-context-bundle/nifi-ssl-context-nar/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-ssl-context-bundle/nifi-ssl-context-nar/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-ssl-context-bundle -0.6.0 +0.6.1-SNAPSHOT nifi-ssl-context-service-nar nar http://git-wip-us.apache.org/repos/asf/nifi/blob/65312fee/nifi-nar-bundles/nifi-standard-services/nifi-ssl-context-bundle/nifi-ssl-context-service/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-ssl-context-bundle/nifi-ssl-context-service/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-ssl-context-bundle/nifi-ssl-context-service/pom.xml index 38e3e3d..3e946c7 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-ssl-context-bundle/nifi-ssl-context-service/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-ssl-context-bundle/nifi-ssl-context-service/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-ssl-context-bundle -0.6.0 +0.6.1-SNAPSHOT nifi-ssl-context-service jar http://git-wip-us.apache.org/repos/asf/nifi/blob/65312fee/nifi-nar-bundles/nifi-st
[2/6] nifi git commit: NIFI-1634-RC1 prepare release nifi-0.6.0-RC1
http://git-wip-us.apache.org/repos/asf/nifi/blob/5d8fafbc/nifi-nar-bundles/nifi-framework-bundle/pom.xml -- diff --git a/nifi-nar-bundles/nifi-framework-bundle/pom.xml b/nifi-nar-bundles/nifi-framework-bundle/pom.xml index 4000f6c..eecf47f 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-framework-bundle/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-nar-bundles -0.6.0-SNAPSHOT +0.6.0 nifi-framework-bundle pom @@ -31,92 +31,92 @@ org.apache.nifi nifi-framework-cluster-protocol -0.6.0-SNAPSHOT +0.6.0 org.apache.nifi nifi-framework-cluster-web -0.6.0-SNAPSHOT +0.6.0 org.apache.nifi nifi-file-authorization-provider -0.6.0-SNAPSHOT +0.6.0 org.apache.nifi nifi-cluster-authorization-provider -0.6.0-SNAPSHOT +0.6.0 org.apache.nifi nifi-framework-cluster -0.6.0-SNAPSHOT +0.6.0 org.apache.nifi nifi-runtime -0.6.0-SNAPSHOT +0.6.0 org.apache.nifi nifi-client-dto -0.6.0-SNAPSHOT +0.6.0 org.apache.nifi nifi-web-content-access -0.6.0-SNAPSHOT +0.6.0 org.apache.nifi nifi-security -0.6.0-SNAPSHOT +0.6.0 org.apache.nifi nifi-framework-core-api -0.6.0-SNAPSHOT +0.6.0 org.apache.nifi nifi-site-to-site -0.6.0-SNAPSHOT +0.6.0 org.apache.nifi nifi-framework-core -0.6.0-SNAPSHOT +0.6.0 org.apache.nifi nifi-user-actions -0.6.0-SNAPSHOT +0.6.0 org.apache.nifi nifi-administration -0.6.0-SNAPSHOT +0.6.0 org.apache.nifi nifi-jetty -0.6.0-SNAPSHOT +0.6.0 org.apache.nifi nifi-web-optimistic-locking -0.6.0-SNAPSHOT +0.6.0 org.apache.nifi nifi-web-security -0.6.0-SNAPSHOT +0.6.0 org.apache.nifi nifi-documentation -0.6.0-SNAPSHOT +0.6.0 http://git-wip-us.apache.org/repos/asf/nifi/blob/5d8fafbc/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-nar/pom.xml -- diff --git a/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-nar/pom.xml b/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-nar/pom.xml index e3a4a07..53ac389 100644 --- a/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-nar/pom.xml +++ b/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-nar/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-geo-bundle -0.6.0-SNAPSHOT +0.6.0 nifi-geo-nar nar http://git-wip-us.apache.org/repos/asf/nifi/blob/5d8fafbc/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-processors/pom.xml -- diff --git a/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-processors/pom.xml b/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-processors/pom.xml index 742b3a2..ccd1119 100644 --- a/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-processors/pom.xml +++ b/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-processors/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-geo-bundle -0.6.0-SNAPSHOT +0.6.0 nifi-geo-processors http://git-wip-us.apache.org/repos/asf/nifi/blob/5d8fafbc/nifi-nar-bundles/nifi-geo-bundle/pom.xml -- diff --git a/nifi-nar-bundles/nifi-geo-bundle/pom.xml b/nifi-nar-bundles/nifi-geo-bundle/pom.xml index d3ec425..2b9e8fe 100644 --- a/nifi-nar-bundles/nifi-geo-bundle/pom.xml +++
[6/6] nifi git commit: NIFI-1634-RC1 prepare for next development iteration
NIFI-1634-RC1 prepare for next development iteration Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/65312fee Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/65312fee Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/65312fee Branch: refs/heads/NIFI-1634-RC1 Commit: 65312fee6fb8bb7039bee4a894387bd93e9c8a29 Parents: 5d8fafb Author: Aldrin Piri Authored: Mon Mar 21 14:38:29 2016 -0400 Committer: Aldrin Piri Committed: Mon Mar 21 14:38:29 2016 -0400 -- nifi-api/pom.xml| 2 +- nifi-assembly/pom.xml | 2 +- nifi-bootstrap/pom.xml | 2 +- nifi-commons/nifi-data-provenance-utils/pom.xml | 2 +- nifi-commons/nifi-expression-language/pom.xml | 2 +- nifi-commons/nifi-flowfile-packager/pom.xml | 2 +- nifi-commons/nifi-hadoop-utils/pom.xml | 4 +- nifi-commons/nifi-hl7-query-language/pom.xml| 2 +- nifi-commons/nifi-logging-utils/pom.xml | 2 +- nifi-commons/nifi-processor-utilities/pom.xml | 2 +- nifi-commons/nifi-properties/pom.xml| 2 +- nifi-commons/nifi-security-utils/pom.xml| 2 +- nifi-commons/nifi-site-to-site-client/pom.xml | 4 +- nifi-commons/nifi-socket-utils/pom.xml | 2 +- nifi-commons/nifi-utils/pom.xml | 4 +- nifi-commons/nifi-web-utils/pom.xml | 2 +- nifi-commons/nifi-write-ahead-log/pom.xml | 2 +- nifi-commons/pom.xml| 2 +- nifi-docs/pom.xml | 2 +- .../nifi-nifi-example-nar/pom.xml | 2 +- .../nifi-nifi-example-processors/pom.xml| 2 +- nifi-external/nifi-example-bundle/pom.xml | 4 +- nifi-external/nifi-spark-receiver/pom.xml | 2 +- nifi-external/nifi-storm-spout/pom.xml | 2 +- nifi-external/pom.xml | 2 +- .../nifi-processor-bundle-archetype/pom.xml | 2 +- .../nifi-service-bundle-archetype/pom.xml | 2 +- nifi-maven-archetypes/pom.xml | 2 +- nifi-mock/pom.xml | 2 +- .../nifi-ambari-bundle/nifi-ambari-nar/pom.xml | 4 +- .../nifi-ambari-reporting-task/pom.xml | 2 +- nifi-nar-bundles/nifi-ambari-bundle/pom.xml | 2 +- .../nifi-amqp-bundle/nifi-amqp-nar/pom.xml | 4 +- .../nifi-amqp-processors/pom.xml| 2 +- nifi-nar-bundles/nifi-amqp-bundle/pom.xml | 6 +- .../nifi-avro-bundle/nifi-avro-nar/pom.xml | 6 +- .../nifi-avro-processors/pom.xml| 2 +- nifi-nar-bundles/nifi-avro-bundle/pom.xml | 4 +- .../nifi-aws-bundle/nifi-aws-nar/pom.xml| 4 +- .../nifi-aws-bundle/nifi-aws-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-aws-bundle/pom.xml| 2 +- .../nifi-azure-bundle/nifi-azure-nar/pom.xml| 6 +- .../nifi-azure-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-azure-bundle/pom.xml | 4 +- .../nifi-cassandra-nar/pom.xml | 2 +- .../nifi-cassandra-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-cassandra-bundle/pom.xml | 4 +- .../nifi-couchbase-nar/pom.xml | 6 +- .../nifi-couchbase-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-couchbase-bundle/pom.xml | 4 +- .../nifi-elasticsearch-nar/pom.xml | 2 +- .../nifi-elasticsearch-processors/pom.xml | 2 +- .../nifi-elasticsearch-bundle/pom.xml | 4 +- .../nifi-flume-bundle/nifi-flume-nar/pom.xml| 4 +- .../nifi-flume-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-flume-bundle/pom.xml | 6 +- .../nifi-framework-nar/pom.xml | 2 +- .../nifi-framework/nifi-administration/pom.xml | 2 +- .../nifi-framework/nifi-client-dto/pom.xml | 2 +- .../nifi-cluster-authorization-provider/pom.xml | 2 +- .../nifi-framework/nifi-documentation/pom.xml | 2 +- .../nifi-file-authorization-provider/pom.xml| 2 +- .../nifi-framework-cluster-protocol/pom.xml | 2 +- .../nifi-framework-cluster-web/pom.xml | 2 +- .../nifi-framework-cluster/pom.xml | 2 +- .../nifi-framework-core-api/pom.xml | 2 +- .../nifi-framework/nifi-framework-core/pom.xml | 2 +- .../nifi-framework/nifi-nar-utils/pom.xml | 2 +- .../nifi-framework/nifi-resources/pom.xml | 2 +- .../nifi-framework/nifi-runtime/pom.xml | 2 +- .../nifi-framework/nifi-security/pom.xml| 2 +- .../nifi-framework/nifi-site-to-site/pom.xml| 2 +- .../nifi-framework/nifi-user-actions/pom.xml| 2 +- .../nifi-web/nifi-custom-ui-utilities/pom.xml | 2 +- .../nifi-framework/nifi-web/nifi-jetty/pom.xml | 2 +- .../nifi-web/nifi-ui-extension/pom.xml
[1/6] nifi git commit: NIFI-1634-RC1 prepare release nifi-0.6.0-RC1
Repository: nifi Updated Branches: refs/heads/NIFI-1634-RC1 [created] 65312fee6 http://git-wip-us.apache.org/repos/asf/nifi/blob/5d8fafbc/nifi-nar-bundles/nifi-standard-services/nifi-hbase_1_1_2-client-service-bundle/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-hbase_1_1_2-client-service-bundle/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-hbase_1_1_2-client-service-bundle/pom.xml index 3045a5c..b796db6 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-hbase_1_1_2-client-service-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-hbase_1_1_2-client-service-bundle/pom.xml @@ -19,12 +19,12 @@ org.apache.nifi nifi-standard-services -0.6.0-SNAPSHOT +0.6.0 org.apache.nifi nifi-hbase_1_1_2-client-service-bundle -0.6.0-SNAPSHOT +0.6.0 pom http://git-wip-us.apache.org/repos/asf/nifi/blob/5d8fafbc/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-api/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-api/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-api/pom.xml index 0bfafe4..a1fd641 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-api/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-api/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-standard-services -0.6.0-SNAPSHOT +0.6.0 nifi-http-context-map-api http://git-wip-us.apache.org/repos/asf/nifi/blob/5d8fafbc/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml index 9fdd005..c12a9e3 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-http-context-map-bundle -0.6.0-SNAPSHOT +0.6.0 nifi-http-context-map-nar http://git-wip-us.apache.org/repos/asf/nifi/blob/5d8fafbc/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml index 3bfe8ab..6d8d571 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-http-context-map-bundle -0.6.0-SNAPSHOT +0.6.0 nifi-http-context-map http://git-wip-us.apache.org/repos/asf/nifi/blob/5d8fafbc/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml index fc7b579..4c5850d 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-standard-services -0.6.0-SNAPSHOT +0.6.0 nifi-http-context-map-bundle http://git-wip-us.apache.org/repos/asf/nifi/blob/5d8fafbc/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml index 42ea9d6..9cd4c52 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-standard-services -0.6.0-SNAPSHOT +0.6.0 nifi-load-distribution-service-api jar http://git-wip-us.apache.org/repos/asf/nifi/blob/5d8fafbc/nifi-nar-bundles/nif
[5/6] nifi git commit: NIFI-1634-RC1 prepare for next development iteration
http://git-wip-us.apache.org/repos/asf/nifi/blob/65312fee/nifi-nar-bundles/nifi-framework-bundle/pom.xml -- diff --git a/nifi-nar-bundles/nifi-framework-bundle/pom.xml b/nifi-nar-bundles/nifi-framework-bundle/pom.xml index eecf47f..d4b3b92 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-framework-bundle/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-nar-bundles -0.6.0 +0.6.1-SNAPSHOT nifi-framework-bundle pom @@ -31,92 +31,92 @@ org.apache.nifi nifi-framework-cluster-protocol -0.6.0 +0.6.1-SNAPSHOT org.apache.nifi nifi-framework-cluster-web -0.6.0 +0.6.1-SNAPSHOT org.apache.nifi nifi-file-authorization-provider -0.6.0 +0.6.1-SNAPSHOT org.apache.nifi nifi-cluster-authorization-provider -0.6.0 +0.6.1-SNAPSHOT org.apache.nifi nifi-framework-cluster -0.6.0 +0.6.1-SNAPSHOT org.apache.nifi nifi-runtime -0.6.0 +0.6.1-SNAPSHOT org.apache.nifi nifi-client-dto -0.6.0 +0.6.1-SNAPSHOT org.apache.nifi nifi-web-content-access -0.6.0 +0.6.1-SNAPSHOT org.apache.nifi nifi-security -0.6.0 +0.6.1-SNAPSHOT org.apache.nifi nifi-framework-core-api -0.6.0 +0.6.1-SNAPSHOT org.apache.nifi nifi-site-to-site -0.6.0 +0.6.1-SNAPSHOT org.apache.nifi nifi-framework-core -0.6.0 +0.6.1-SNAPSHOT org.apache.nifi nifi-user-actions -0.6.0 +0.6.1-SNAPSHOT org.apache.nifi nifi-administration -0.6.0 +0.6.1-SNAPSHOT org.apache.nifi nifi-jetty -0.6.0 +0.6.1-SNAPSHOT org.apache.nifi nifi-web-optimistic-locking -0.6.0 +0.6.1-SNAPSHOT org.apache.nifi nifi-web-security -0.6.0 +0.6.1-SNAPSHOT org.apache.nifi nifi-documentation -0.6.0 +0.6.1-SNAPSHOT http://git-wip-us.apache.org/repos/asf/nifi/blob/65312fee/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-nar/pom.xml -- diff --git a/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-nar/pom.xml b/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-nar/pom.xml index 53ac389..7b23a6e 100644 --- a/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-nar/pom.xml +++ b/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-nar/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-geo-bundle -0.6.0 +0.6.1-SNAPSHOT nifi-geo-nar nar http://git-wip-us.apache.org/repos/asf/nifi/blob/65312fee/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-processors/pom.xml -- diff --git a/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-processors/pom.xml b/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-processors/pom.xml index ccd1119..97becee 100644 --- a/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-processors/pom.xml +++ b/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-processors/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-geo-bundle -0.6.0 +0.6.1-SNAPSHOT nifi-geo-processors http://git-wip-us.apache.org/repos/asf/nifi/blob/65312fee/nifi-nar-bundles/nifi-geo-bundle/pom.xml -- diff --git a/nifi-nar-bundles/nifi-geo-bundle/pom.xml b/nifi-nar-bundles/nifi-geo-bundle/pom.xml index 2b9e8fe..7164bbb 100644 --- a/nifi-nar-bundles/nifi-geo-bundle/pom.xml +++
[3/6] nifi git commit: NIFI-1634-RC1 prepare release nifi-0.6.0-RC1
NIFI-1634-RC1 prepare release nifi-0.6.0-RC1 Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/5d8fafbc Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/5d8fafbc Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/5d8fafbc Branch: refs/heads/NIFI-1634-RC1 Commit: 5d8fafbcf515a99d4d7454c362543689ba590a1b Parents: 7368962 Author: Aldrin Piri Authored: Mon Mar 21 14:38:18 2016 -0400 Committer: Aldrin Piri Committed: Mon Mar 21 14:38:18 2016 -0400 -- nifi-api/pom.xml| 2 +- nifi-assembly/pom.xml | 2 +- nifi-bootstrap/pom.xml | 2 +- nifi-commons/nifi-data-provenance-utils/pom.xml | 2 +- nifi-commons/nifi-expression-language/pom.xml | 2 +- nifi-commons/nifi-flowfile-packager/pom.xml | 2 +- nifi-commons/nifi-hadoop-utils/pom.xml | 4 +- nifi-commons/nifi-hl7-query-language/pom.xml| 2 +- nifi-commons/nifi-logging-utils/pom.xml | 2 +- nifi-commons/nifi-processor-utilities/pom.xml | 2 +- nifi-commons/nifi-properties/pom.xml| 2 +- nifi-commons/nifi-security-utils/pom.xml| 2 +- nifi-commons/nifi-site-to-site-client/pom.xml | 4 +- nifi-commons/nifi-socket-utils/pom.xml | 2 +- nifi-commons/nifi-utils/pom.xml | 4 +- nifi-commons/nifi-web-utils/pom.xml | 2 +- nifi-commons/nifi-write-ahead-log/pom.xml | 2 +- nifi-commons/pom.xml| 2 +- nifi-docs/pom.xml | 2 +- .../nifi-nifi-example-nar/pom.xml | 2 +- .../nifi-nifi-example-processors/pom.xml| 2 +- nifi-external/nifi-example-bundle/pom.xml | 4 +- nifi-external/nifi-spark-receiver/pom.xml | 2 +- nifi-external/nifi-storm-spout/pom.xml | 2 +- nifi-external/pom.xml | 2 +- .../nifi-processor-bundle-archetype/pom.xml | 2 +- .../nifi-service-bundle-archetype/pom.xml | 2 +- nifi-maven-archetypes/pom.xml | 2 +- nifi-mock/pom.xml | 2 +- .../nifi-ambari-bundle/nifi-ambari-nar/pom.xml | 4 +- .../nifi-ambari-reporting-task/pom.xml | 2 +- nifi-nar-bundles/nifi-ambari-bundle/pom.xml | 2 +- .../nifi-amqp-bundle/nifi-amqp-nar/pom.xml | 4 +- .../nifi-amqp-processors/pom.xml| 2 +- nifi-nar-bundles/nifi-amqp-bundle/pom.xml | 6 +- .../nifi-avro-bundle/nifi-avro-nar/pom.xml | 6 +- .../nifi-avro-processors/pom.xml| 2 +- nifi-nar-bundles/nifi-avro-bundle/pom.xml | 4 +- .../nifi-aws-bundle/nifi-aws-nar/pom.xml| 4 +- .../nifi-aws-bundle/nifi-aws-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-aws-bundle/pom.xml| 2 +- .../nifi-azure-bundle/nifi-azure-nar/pom.xml| 6 +- .../nifi-azure-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-azure-bundle/pom.xml | 4 +- .../nifi-cassandra-nar/pom.xml | 2 +- .../nifi-cassandra-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-cassandra-bundle/pom.xml | 4 +- .../nifi-couchbase-nar/pom.xml | 6 +- .../nifi-couchbase-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-couchbase-bundle/pom.xml | 4 +- .../nifi-elasticsearch-nar/pom.xml | 2 +- .../nifi-elasticsearch-processors/pom.xml | 2 +- .../nifi-elasticsearch-bundle/pom.xml | 4 +- .../nifi-flume-bundle/nifi-flume-nar/pom.xml| 4 +- .../nifi-flume-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-flume-bundle/pom.xml | 6 +- .../nifi-framework-nar/pom.xml | 2 +- .../nifi-framework/nifi-administration/pom.xml | 2 +- .../nifi-framework/nifi-client-dto/pom.xml | 2 +- .../nifi-cluster-authorization-provider/pom.xml | 2 +- .../nifi-framework/nifi-documentation/pom.xml | 2 +- .../nifi-file-authorization-provider/pom.xml| 2 +- .../nifi-framework-cluster-protocol/pom.xml | 2 +- .../nifi-framework-cluster-web/pom.xml | 2 +- .../nifi-framework-cluster/pom.xml | 2 +- .../nifi-framework-core-api/pom.xml | 2 +- .../nifi-framework/nifi-framework-core/pom.xml | 2 +- .../nifi-framework/nifi-nar-utils/pom.xml | 2 +- .../nifi-framework/nifi-resources/pom.xml | 2 +- .../nifi-framework/nifi-runtime/pom.xml | 2 +- .../nifi-framework/nifi-security/pom.xml| 2 +- .../nifi-framework/nifi-site-to-site/pom.xml| 2 +- .../nifi-framework/nifi-user-actions/pom.xml| 2 +- .../nifi-web/nifi-custom-ui-utilities/pom.xml | 2 +- .../nifi-framework/nifi-web/nifi-jetty/pom.xml | 2 +- .../nifi-web/nifi-ui-extension/pom.xml
[jira] [Updated] (NIFI-1662) Improve Expression Language to Enable Working with Decimals
[ https://issues.apache.org/jira/browse/NIFI-1662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joseph Percivall updated NIFI-1662: --- Description: Currently the math operations in Expression Language use Longs to evaluate numbers. This leads to any decimal places getting truncated when performing operations like divide. EL should be improved to enable the user to evaluate math expressions using doubles. Another desired portion of this would be to open up the static Math class [1] methods (using reflection) to further enable working with Decimals. [1] https://docs.oracle.com/javase/7/docs/api/java/lang/Math.html was: Currently the math operations in Expression Language use Longs to evaluate numbers. This leads to any decimal places getting truncated when performing operations like divide. EL should be improved to enable the user to evaluate math expressions using doubles. > Improve Expression Language to Enable Working with Decimals > --- > > Key: NIFI-1662 > URL: https://issues.apache.org/jira/browse/NIFI-1662 > Project: Apache NiFi > Issue Type: Improvement >Reporter: Joseph Percivall >Assignee: Joseph Percivall > > Currently the math operations in Expression Language use Longs to evaluate > numbers. This leads to any decimal places getting truncated when performing > operations like divide. > EL should be improved to enable the user to evaluate math expressions using > doubles. > Another desired portion of this would be to open up the static Math class [1] > methods (using reflection) to further enable working with Decimals. > [1] https://docs.oracle.com/javase/7/docs/api/java/lang/Math.html -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Assigned] (NIFI-1662) Improve Expression Language to Enable Working with Decimals
[ https://issues.apache.org/jira/browse/NIFI-1662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joseph Percivall reassigned NIFI-1662: -- Assignee: Joseph Percivall > Improve Expression Language to Enable Working with Decimals > --- > > Key: NIFI-1662 > URL: https://issues.apache.org/jira/browse/NIFI-1662 > Project: Apache NiFi > Issue Type: Improvement >Reporter: Joseph Percivall >Assignee: Joseph Percivall > > Currently the math operations in Expression Language use Longs to evaluate > numbers. This leads to any decimal places getting truncated when performing > operations like divide. > EL should be improved to enable the user to evaluate math expressions using > doubles. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (NIFI-1662) Improve Expression Language to Enable Working with Decimals
Joseph Percivall created NIFI-1662: -- Summary: Improve Expression Language to Enable Working with Decimals Key: NIFI-1662 URL: https://issues.apache.org/jira/browse/NIFI-1662 Project: Apache NiFi Issue Type: Improvement Reporter: Joseph Percivall Currently the math operations in Expression Language use Longs to evaluate numbers. This leads to any decimal places getting truncated when performing operations like divide. EL should be improved to enable the user to evaluate math expressions using doubles. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (NIFI-1661) Expression language should support a random function
Christopher McDermott created NIFI-1661:
---
Summary: Expression language should support a random function
Key: NIFI-1661
URL: https://issues.apache.org/jira/browse/NIFI-1661
Project: Apache NiFi
Issue Type: Improvement
Reporter: Christopher McDermott
Priority: Minor
Random would be a subjectless function that generates a 32? bit random number.
The random number generator need not be cryptographically secure.
A use case would be for random be to generate a random pattern across some
number of file paths to be used with putFile.
Example - puts files randomly to /my-dirs/dir-1, /my-dirs/dir-2, /my-dirs/dir-3
/my-dirs/dir-${random():mod(3):plus(1)}/
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Updated] (NIFI-1659) Enhance EvaluateJsonPath to be able to evaluate an attribute value
[ https://issues.apache.org/jira/browse/NIFI-1659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christopher McDermott updated NIFI-1659: Issue Type: Improvement (was: Bug) > Enhance EvaluateJsonPath to be able to evaluate an attribute value > -- > > Key: NIFI-1659 > URL: https://issues.apache.org/jira/browse/NIFI-1659 > Project: Apache NiFi > Issue Type: Improvement > Components: Core Framework >Affects Versions: 0.5.1 >Reporter: Christopher McDermott >Priority: Minor > > Today EvaluateJsonPath evaluates the content of a flow file. This request is > to enhance EvaluateJsonPath to evaluate either the flow file content, or an > attribute value. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (NIFI-1642) PutKafka should validate topic expression and calculated value
[ https://issues.apache.org/jira/browse/NIFI-1642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christopher McDermott updated NIFI-1642: Issue Type: Improvement (was: Bug) > PutKafka should validate topic expression and calculated value > -- > > Key: NIFI-1642 > URL: https://issues.apache.org/jira/browse/NIFI-1642 > Project: Apache NiFi > Issue Type: Improvement > Components: Core Framework >Reporter: Christopher McDermott >Priority: Minor > > PutKafka does not validate the expression supplied for the topic property, > like most other processors. It should also try to validate the evaluated > value of the topic to see if it is a legal topic name. Note I'm not > suggesting that the topic need to exist, just that the name is compliant to > what Kafka will accept. This would be most helpful because if certain > (probably not all) illegal names are used, the Kafka client throws bizarre > and most unhelpful exceptions. > - > Chris, > Assuming the client can validate #2 i am with you. Please do feel > free to fire up a JIRA for this. > Thanks > Joe > On Wed, Mar 16, 2016 at 1:24 PM, McDermott, Chris Kevin (MSDU - > STaTS/StorefrontRemote) wrote: > It turns out the root cause of the problem was an invalid topic name. > Strange error for that! > I think there are a couple of improvements could be made to PutKafka. > 1. Check the validity of the the expression in the topic property. > 2. Check the validity of the topic name before attempting to write to the > topic. > Chris > On 3/16/16, 11:41 AM, "McDermott, Chris Kevin (MSDU - > STaTS/StorefrontRemote)" wrote: > Joe, > I’ll checkout the disk-space. We are running 0.9. If disk space is not the > issue we’ll give 0.8 a try. > Thanks very much for your quick reply. > Cheers, > Chris > On 3/16/16, 11:04 AM, "Joe Witt" wrote: > Chris, > I have seen that when the diskspace kafka relies on is full. We've > seen a number of interesting exceptions recently in testing various > configurations. But recommend checking that. > Also, what version of Kafka broker are you using? With Apache NiFi > 0.5.x we moved to the kafka client 0.9. In doing that we messed up > support for 0.8. So...with the upcoming release we will move back to > the 0.8 client and thus it works great with Kafka 0.8 and 0.9 brokers > albeit without the new SSL and Kerberos support they added in their > 0.9 work. We have a JIRA item to go after that for our next feature > bearing release. > Thanks > Joe > On Wed, Mar 16, 2016 at 11:01 AM, McDermott, Chris Kevin (MSDU - > STaTS/StorefrontRemote) wrote: > I say strange because the timeout (63ms) is so very short. The communication > timeout I’ve set is 30 sec. Has anyone overseen this? > 2016-03-16 14:41:38,227 ERROR [Timer-Driven Process Thread-8] > o.apache.nifi.processors.kafka.PutKafka > PutKafka[id=852c8d42-a2fa-3478-b06b-84ceb6\ > 6f8b0b] Failed to send > StandardFlowFileRecord[uuid=a0074162-0066-49e7-918b-cea1cfc5a955,claim=StandardContentClaim > [resourceClaim=StandardResour\ > ceClaim[id=1458079089737-67, container=default, section=67], offset=377796, > length=743],offset=0,name=2349680613178720,size=743] to Kafka; routi\ > ng to 'failure'; last failure reason reported was > org.apache.kafka.common.errors.TimeoutException: Failed to update metadata > after 63 ms.;: org.\ > apache.kafka.common.errors.TimeoutException: Failed to update metadata after > 63 ms. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (NIFI-1660) Enhance the expression language support evaluateJsonPath
Christopher McDermott created NIFI-1660:
---
Summary: Enhance the expression language support evaluateJsonPath
Key: NIFI-1660
URL: https://issues.apache.org/jira/browse/NIFI-1660
Project: Apache NiFi
Issue Type: Improvement
Components: Core Framework
Affects Versions: 0.5.1
Reporter: Christopher McDermott
Priority: Minor
evaluateJsonPath would evaluate a JSON path provided as an argument against the
subject.
Example
${kafka.key:evaluateJsonPath('$.foo.bar')}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Created] (NIFI-1659) Enhance EvaluateJsonPath to be able to evaluate an attribute value
Christopher McDermott created NIFI-1659: --- Summary: Enhance EvaluateJsonPath to be able to evaluate an attribute value Key: NIFI-1659 URL: https://issues.apache.org/jira/browse/NIFI-1659 Project: Apache NiFi Issue Type: Bug Components: Core Framework Affects Versions: 0.5.1 Reporter: Christopher McDermott Priority: Minor Today EvaluateJsonPath evaluates the content of a flow file. This request is to enhance EvaluateJsonPath to evaluate either the flow file content, or an attribute value. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (NIFI-1658) Rest Api documentation layout is broken
Matt Gilman created NIFI-1658: - Summary: Rest Api documentation layout is broken Key: NIFI-1658 URL: https://issues.apache.org/jira/browse/NIFI-1658 Project: Apache NiFi Issue Type: Bug Components: Documentation & Website Reporter: Matt Gilman Priority: Minor The Rest Api documentation text overlaps and wraps when the URI is lengthy. This is primarily an issue for Connection based URIs. This documentation should be more flexible when dealing with varying length URIs and updated to offer better support for small screens. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (NIFI-1649) SplitText end of line handling is incorrect
[ https://issues.apache.org/jira/browse/NIFI-1649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204724#comment-15204724 ] ASF subversion and git services commented on NIFI-1649: --- Commit 736896246cf021dbed31d4eb1e22e0755e4705f0 in nifi's branch refs/heads/1.x from [~markap14] [ https://git-wip-us.apache.org/repos/asf?p=nifi.git;h=7368962 ] NIFI-1649: Addressed bug in SplitText that resulted in improper handling of input data if Remove Trailing Newlines is true and there is a FlowFile that is only made up of newlines > SplitText end of line handling is incorrect > --- > > Key: NIFI-1649 > URL: https://issues.apache.org/jira/browse/NIFI-1649 > Project: Apache NiFi > Issue Type: Bug > Components: Extensions >Reporter: Joseph Witt >Assignee: Mark Payne >Priority: Critical > Fix For: 0.6.0 > > Attachments: > 0001-NIFI-1649-Generated-unit-tests-to-verify-behavior-de.patch, > 0002-NIFI-1649-Addressed-issues-with-SplitText-that-cause.patch, > 0003_NIFI-1649_CauseTestFail.patch, > 0004-NIFI-1649-Addressed-issue-that-resulted-in-wrong-num.patch, > Fun_Test_of_SplitText.xml, View_Content_using_wrong_content_claim.xml > > > Lengthy discussion about this in NIFI-1118 -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (NIFI-1550) Authorizer API
[ https://issues.apache.org/jira/browse/NIFI-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204725#comment-15204725 ] ASF subversion and git services commented on NIFI-1550: --- Commit 926756010372db4c426b1b28d9ceef075996a299 in nifi's branch refs/heads/1.x from [~mcgilman] [ https://git-wip-us.apache.org/repos/asf?p=nifi.git;h=9267560 ] NIFI-1550: - Bumping artifact versions to 1.0.0. > Authorizer API > -- > > Key: NIFI-1550 > URL: https://issues.apache.org/jira/browse/NIFI-1550 > Project: Apache NiFi > Issue Type: Improvement > Components: Core Framework >Reporter: Matt Gilman >Assignee: Matt Gilman > Fix For: 1.0.0 > > > This is a parent ticket for tracking all work done for the Authorizer feature > proposal phase 1 [1]. > At a high level, all authorization decisions are delegated to a provider and > given the identity of the entity, the resource being accessed, the action, > and the context of the request. > Additionally, the Authorizer will be able to support an audit query that > presents back the recently active users including their last request, last > rejected attempts, and last mutable requests. A given implementation of an > Authorizer may or may not offer to support user request audits. > Sub tickets will be created for tracking specific units of work. Once all sub > tickets are completed, this ticket will be finished. > [1] https://cwiki.apache.org/confluence/display/NIFI/Support+Authorizer+API -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[3/4] nifi git commit: NIFI-1550: - Bumping artifact versions to 1.0.0.
http://git-wip-us.apache.org/repos/asf/nifi/blob/92675601/nifi-nar-bundles/nifi-framework-bundle/pom.xml -- diff --git a/nifi-nar-bundles/nifi-framework-bundle/pom.xml b/nifi-nar-bundles/nifi-framework-bundle/pom.xml index 4000f6c..d1b1422 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-framework-bundle/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-nar-bundles -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT nifi-framework-bundle pom @@ -31,92 +31,92 @@ org.apache.nifi nifi-framework-cluster-protocol -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-framework-cluster-web -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-file-authorization-provider -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-cluster-authorization-provider -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-framework-cluster -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-runtime -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-client-dto -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-web-content-access -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-security -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-framework-core-api -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-site-to-site -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-framework-core -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-user-actions -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-administration -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-jetty -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-web-optimistic-locking -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-web-security -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-documentation -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT http://git-wip-us.apache.org/repos/asf/nifi/blob/92675601/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-nar/pom.xml -- diff --git a/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-nar/pom.xml b/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-nar/pom.xml index e3a4a07..0f4768f 100644 --- a/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-nar/pom.xml +++ b/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-nar/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-geo-bundle -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT nifi-geo-nar nar http://git-wip-us.apache.org/repos/asf/nifi/blob/92675601/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-processors/pom.xml -- diff --git a/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-processors/pom.xml b/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-processors/pom.xml index 742b3a2..ae397a8 100644 --- a/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-processors/pom.xml +++ b/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-processors/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-geo-bundle -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT nifi-geo-processors http://git-wip-us.apache.org/repos/asf/nifi/blob/92675601/nifi-nar-bundles/nifi-geo-bundle/pom.xml -
[1/4] nifi git commit: NIFI-1649: Addressed bug in SplitText that resulted in improper handling of input data if Remove Trailing Newlines is true and there is a FlowFile that is only made up of newlin
Repository: nifi
Updated Branches:
refs/heads/1.x 28058b988 -> 926756010 (forced update)
NIFI-1649: Addressed bug in SplitText that resulted in improper handling of
input data if Remove Trailing Newlines is true and there is a FlowFile that is
only made up of newlines
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/73689624
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/73689624
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/73689624
Branch: refs/heads/1.x
Commit: 736896246cf021dbed31d4eb1e22e0755e4705f0
Parents: 38c782c
Author: Mark Payne
Authored: Mon Mar 21 13:26:32 2016 -0400
Committer: Mark Payne
Committed: Mon Mar 21 13:26:32 2016 -0400
--
.../nifi/processors/standard/SplitText.java | 234 ++--
.../nifi/processors/standard/TestSplitText.java | 359 +++
2 files changed, 559 insertions(+), 34 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/nifi/blob/73689624/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitText.java
--
diff --git
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitText.java
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitText.java
index 678919c..8c59d88 100644
---
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitText.java
+++
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitText.java
@@ -20,6 +20,7 @@ import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.ArrayList;
+import java.util.BitSet;
import java.util.Collections;
import java.util.HashMap;
import java.util.HashSet;
@@ -63,7 +64,7 @@ import org.apache.nifi.util.ObjectHolder;
@SupportsBatching
@Tags({"split", "text"})
@InputRequirement(Requirement.INPUT_REQUIRED)
-@CapabilityDescription("Splits a text file into multiple smaller text files on
line boundaries, each having up to a configured number of lines")
+@CapabilityDescription("Splits a text file into multiple smaller text files on
line boundaries, each having up to a configured number of lines.")
@WritesAttributes({
@WritesAttribute(attribute = "text.line.count", description = "The number
of lines of text from the original FlowFile that were copied to this FlowFile"),
@WritesAttribute(attribute = "fragment.identifier", description = "All
split FlowFiles produced from the same parent FlowFile will have the same
randomly generated UUID added for this attribute"),
@@ -82,7 +83,7 @@ public class SplitText extends AbstractProcessor {
public static final PropertyDescriptor LINE_SPLIT_COUNT = new
PropertyDescriptor.Builder()
.name("Line Split Count")
-.description("The number of lines that will be added to each split
file")
+.description("The number of lines that will be added to each split
file (excluding the header, if the Header Line Count property is greater than
0).")
.required(true)
.addValidator(StandardValidators.POSITIVE_INTEGER_VALIDATOR)
.build();
@@ -95,7 +96,10 @@ public class SplitText extends AbstractProcessor {
.build();
public static final PropertyDescriptor REMOVE_TRAILING_NEWLINES = new
PropertyDescriptor.Builder()
.name("Remove Trailing Newlines")
-.description("Whether to remove newlines at the end of each split
file. This should be false if you intend to merge the split files later")
+.description("Whether to remove newlines at the end of each split
file. This should be false if you intend to merge the split files later. If
this is set to "
++ "'true' and a FlowFile is generated that contains only
'empty lines' (i.e., consists only of \r and \n characters), the FlowFile will
not be emitted. "
++ "Note, however, that if the Header Line Count is greater
than 0, the resultant FlowFile will never be empty as it will consist of the
header lines, so "
++ "a FlowFile may be emitted that contians only the header
lines.")
.required(true)
.addValidator(StandardValidators.BOOLEAN_VALIDATOR)
.allowableValues("true", "false")
@@ -143,51 +147,93 @@ public class SplitText extends AbstractProcessor {
return properties;
}
-private int readLines(final InputStream in, final int maxNumLines, final
OutputStream out, final boolean keepAllNewLines) throws IOException {
+private
[2/4] nifi git commit: NIFI-1550: - Bumping artifact versions to 1.0.0.
http://git-wip-us.apache.org/repos/asf/nifi/blob/92675601/nifi-nar-bundles/nifi-standard-services/nifi-hbase_1_1_2-client-service-bundle/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-hbase_1_1_2-client-service-bundle/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-hbase_1_1_2-client-service-bundle/pom.xml index 3045a5c..6b99d56 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-hbase_1_1_2-client-service-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-hbase_1_1_2-client-service-bundle/pom.xml @@ -19,12 +19,12 @@ org.apache.nifi nifi-standard-services -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-hbase_1_1_2-client-service-bundle -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT pom http://git-wip-us.apache.org/repos/asf/nifi/blob/92675601/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-api/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-api/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-api/pom.xml index 0bfafe4..99a2cf7 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-api/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-api/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-standard-services -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT nifi-http-context-map-api http://git-wip-us.apache.org/repos/asf/nifi/blob/92675601/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml index 9fdd005..84a4ddb 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-http-context-map-bundle -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT nifi-http-context-map-nar http://git-wip-us.apache.org/repos/asf/nifi/blob/92675601/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml index 3bfe8ab..6a1481b 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-http-context-map-bundle -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT nifi-http-context-map http://git-wip-us.apache.org/repos/asf/nifi/blob/92675601/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml index fc7b579..c79952d 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-standard-services -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT nifi-http-context-map-bundle http://git-wip-us.apache.org/repos/asf/nifi/blob/92675601/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml index 42ea9d6..91e7eab 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-standard-services -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT nifi-load-distribution-service-api jar http://git-wip-us.apache.org/repos/asf/nifi/blob/92675601/nifi-nar-bundles/nifi-standard-services/n
[4/4] nifi git commit: NIFI-1550: - Bumping artifact versions to 1.0.0.
NIFI-1550: - Bumping artifact versions to 1.0.0. Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/92675601 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/92675601 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/92675601 Branch: refs/heads/1.x Commit: 926756010372db4c426b1b28d9ceef075996a299 Parents: 7368962 Author: Matt Gilman Authored: Mon Mar 21 11:46:55 2016 -0400 Committer: Matt Gilman Committed: Mon Mar 21 13:28:34 2016 -0400 -- nifi-api/pom.xml| 2 +- nifi-assembly/pom.xml | 2 +- nifi-bootstrap/pom.xml | 2 +- nifi-commons/nifi-data-provenance-utils/pom.xml | 2 +- nifi-commons/nifi-expression-language/pom.xml | 2 +- nifi-commons/nifi-flowfile-packager/pom.xml | 2 +- nifi-commons/nifi-hadoop-utils/pom.xml | 4 +- nifi-commons/nifi-hl7-query-language/pom.xml| 2 +- nifi-commons/nifi-logging-utils/pom.xml | 2 +- nifi-commons/nifi-processor-utilities/pom.xml | 2 +- nifi-commons/nifi-properties/pom.xml| 2 +- nifi-commons/nifi-security-utils/pom.xml| 2 +- nifi-commons/nifi-site-to-site-client/pom.xml | 4 +- nifi-commons/nifi-socket-utils/pom.xml | 2 +- nifi-commons/nifi-utils/pom.xml | 4 +- nifi-commons/nifi-web-utils/pom.xml | 2 +- nifi-commons/nifi-write-ahead-log/pom.xml | 2 +- nifi-commons/pom.xml| 2 +- nifi-docs/pom.xml | 2 +- .../nifi-nifi-example-nar/pom.xml | 2 +- .../nifi-nifi-example-processors/pom.xml| 2 +- nifi-external/nifi-example-bundle/pom.xml | 4 +- nifi-external/nifi-spark-receiver/pom.xml | 2 +- nifi-external/nifi-storm-spout/pom.xml | 2 +- nifi-external/pom.xml | 2 +- .../nifi-processor-bundle-archetype/pom.xml | 2 +- .../nifi-service-bundle-archetype/pom.xml | 2 +- nifi-maven-archetypes/pom.xml | 2 +- nifi-mock/pom.xml | 2 +- .../nifi-ambari-bundle/nifi-ambari-nar/pom.xml | 4 +- .../nifi-ambari-reporting-task/pom.xml | 2 +- nifi-nar-bundles/nifi-ambari-bundle/pom.xml | 2 +- .../nifi-amqp-bundle/nifi-amqp-nar/pom.xml | 4 +- .../nifi-amqp-processors/pom.xml| 2 +- nifi-nar-bundles/nifi-amqp-bundle/pom.xml | 6 +- .../nifi-avro-bundle/nifi-avro-nar/pom.xml | 6 +- .../nifi-avro-processors/pom.xml| 2 +- nifi-nar-bundles/nifi-avro-bundle/pom.xml | 4 +- .../nifi-aws-bundle/nifi-aws-nar/pom.xml| 4 +- .../nifi-aws-bundle/nifi-aws-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-aws-bundle/pom.xml| 2 +- .../nifi-azure-bundle/nifi-azure-nar/pom.xml| 6 +- .../nifi-azure-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-azure-bundle/pom.xml | 4 +- .../nifi-cassandra-nar/pom.xml | 2 +- .../nifi-cassandra-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-cassandra-bundle/pom.xml | 4 +- .../nifi-couchbase-nar/pom.xml | 6 +- .../nifi-couchbase-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-couchbase-bundle/pom.xml | 4 +- .../nifi-elasticsearch-nar/pom.xml | 2 +- .../nifi-elasticsearch-processors/pom.xml | 2 +- .../nifi-elasticsearch-bundle/pom.xml | 4 +- .../nifi-flume-bundle/nifi-flume-nar/pom.xml| 4 +- .../nifi-flume-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-flume-bundle/pom.xml | 6 +- .../nifi-framework-nar/pom.xml | 2 +- .../nifi-framework/nifi-administration/pom.xml | 2 +- .../nifi-framework/nifi-client-dto/pom.xml | 2 +- .../nifi-cluster-authorization-provider/pom.xml | 2 +- .../nifi-framework/nifi-documentation/pom.xml | 2 +- .../nifi-file-authorization-provider/pom.xml| 2 +- .../nifi-framework-cluster-protocol/pom.xml | 2 +- .../nifi-framework-cluster-web/pom.xml | 2 +- .../nifi-framework-cluster/pom.xml | 2 +- .../nifi-framework-core-api/pom.xml | 2 +- .../nifi-framework/nifi-framework-core/pom.xml | 2 +- .../nifi-framework/nifi-nar-utils/pom.xml | 2 +- .../nifi-framework/nifi-resources/pom.xml | 2 +- .../nifi-framework/nifi-runtime/pom.xml | 2 +- .../nifi-framework/nifi-security/pom.xml| 2 +- .../nifi-framework/nifi-site-to-site/pom.xml| 2 +- .../nifi-framework/nifi-user-actions/pom.xml| 2 +- .../nifi-web/nifi-custom-ui-utilities/pom.xml | 2 +- .../nifi-framework/nifi-web/nifi-jetty/pom.xml | 2 +- .../nifi-web/nifi-ui-extension/pom.xml | 2
[jira] [Commented] (NIFI-1649) SplitText end of line handling is incorrect
[ https://issues.apache.org/jira/browse/NIFI-1649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204680#comment-15204680 ] ASF subversion and git services commented on NIFI-1649: --- Commit 736896246cf021dbed31d4eb1e22e0755e4705f0 in nifi's branch refs/heads/master from [~markap14] [ https://git-wip-us.apache.org/repos/asf?p=nifi.git;h=7368962 ] NIFI-1649: Addressed bug in SplitText that resulted in improper handling of input data if Remove Trailing Newlines is true and there is a FlowFile that is only made up of newlines > SplitText end of line handling is incorrect > --- > > Key: NIFI-1649 > URL: https://issues.apache.org/jira/browse/NIFI-1649 > Project: Apache NiFi > Issue Type: Bug > Components: Extensions >Reporter: Joseph Witt >Assignee: Mark Payne >Priority: Critical > Fix For: 0.6.0 > > Attachments: > 0001-NIFI-1649-Generated-unit-tests-to-verify-behavior-de.patch, > 0002-NIFI-1649-Addressed-issues-with-SplitText-that-cause.patch, > 0003_NIFI-1649_CauseTestFail.patch, > 0004-NIFI-1649-Addressed-issue-that-resulted-in-wrong-num.patch, > Fun_Test_of_SplitText.xml, View_Content_using_wrong_content_claim.xml > > > Lengthy discussion about this in NIFI-1118 -- This message was sent by Atlassian JIRA (v6.3.4#6332)
nifi git commit: NIFI-1649: Addressed bug in SplitText that resulted in improper handling of input data if Remove Trailing Newlines is true and there is a FlowFile that is only made up of newlines
Repository: nifi
Updated Branches:
refs/heads/master 38c782c30 -> 736896246
NIFI-1649: Addressed bug in SplitText that resulted in improper handling of
input data if Remove Trailing Newlines is true and there is a FlowFile that is
only made up of newlines
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/73689624
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/73689624
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/73689624
Branch: refs/heads/master
Commit: 736896246cf021dbed31d4eb1e22e0755e4705f0
Parents: 38c782c
Author: Mark Payne
Authored: Mon Mar 21 13:26:32 2016 -0400
Committer: Mark Payne
Committed: Mon Mar 21 13:26:32 2016 -0400
--
.../nifi/processors/standard/SplitText.java | 234 ++--
.../nifi/processors/standard/TestSplitText.java | 359 +++
2 files changed, 559 insertions(+), 34 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/nifi/blob/73689624/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitText.java
--
diff --git
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitText.java
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitText.java
index 678919c..8c59d88 100644
---
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitText.java
+++
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitText.java
@@ -20,6 +20,7 @@ import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.ArrayList;
+import java.util.BitSet;
import java.util.Collections;
import java.util.HashMap;
import java.util.HashSet;
@@ -63,7 +64,7 @@ import org.apache.nifi.util.ObjectHolder;
@SupportsBatching
@Tags({"split", "text"})
@InputRequirement(Requirement.INPUT_REQUIRED)
-@CapabilityDescription("Splits a text file into multiple smaller text files on
line boundaries, each having up to a configured number of lines")
+@CapabilityDescription("Splits a text file into multiple smaller text files on
line boundaries, each having up to a configured number of lines.")
@WritesAttributes({
@WritesAttribute(attribute = "text.line.count", description = "The number
of lines of text from the original FlowFile that were copied to this FlowFile"),
@WritesAttribute(attribute = "fragment.identifier", description = "All
split FlowFiles produced from the same parent FlowFile will have the same
randomly generated UUID added for this attribute"),
@@ -82,7 +83,7 @@ public class SplitText extends AbstractProcessor {
public static final PropertyDescriptor LINE_SPLIT_COUNT = new
PropertyDescriptor.Builder()
.name("Line Split Count")
-.description("The number of lines that will be added to each split
file")
+.description("The number of lines that will be added to each split
file (excluding the header, if the Header Line Count property is greater than
0).")
.required(true)
.addValidator(StandardValidators.POSITIVE_INTEGER_VALIDATOR)
.build();
@@ -95,7 +96,10 @@ public class SplitText extends AbstractProcessor {
.build();
public static final PropertyDescriptor REMOVE_TRAILING_NEWLINES = new
PropertyDescriptor.Builder()
.name("Remove Trailing Newlines")
-.description("Whether to remove newlines at the end of each split
file. This should be false if you intend to merge the split files later")
+.description("Whether to remove newlines at the end of each split
file. This should be false if you intend to merge the split files later. If
this is set to "
++ "'true' and a FlowFile is generated that contains only
'empty lines' (i.e., consists only of \r and \n characters), the FlowFile will
not be emitted. "
++ "Note, however, that if the Header Line Count is greater
than 0, the resultant FlowFile will never be empty as it will consist of the
header lines, so "
++ "a FlowFile may be emitted that contians only the header
lines.")
.required(true)
.addValidator(StandardValidators.BOOLEAN_VALIDATOR)
.allowableValues("true", "false")
@@ -143,51 +147,93 @@ public class SplitText extends AbstractProcessor {
return properties;
}
-private int readLines(final InputStream in, final int maxNumLines, final
OutputStream out, final boolean keepAllNewLines) throws IOException {
+private int readLi
[jira] [Commented] (NIFI-1578) Create PutSlack processor
[ https://issues.apache.org/jira/browse/NIFI-1578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204510#comment-15204510 ] Adam Lamar commented on NIFI-1578: -- [~joewitt] My use case around PutSlack at this point is pretty simple. Basically the same use cases around PutEmail, but sending to a Slack channel instead of an email distribution list. This allows teams to keep an eye on their dataflows in a natural place, especially since many other Slack integrations exist (Jenkins, github, etc). To configure PutSlack, a Slack user (or maybe admin) has to add the Incoming Webhooks integration to the Slack team, then add a webhook to a specific channel. Once the user has the URL associated with this webhook, they drop the URL into PutSlack along with a webhook text template. Does that help? The use cases would probably also increase with a GetSlack processor, which when paired with PutSlack could allow one to manually trigger flows in NiFi via a chat bot. > Create PutSlack processor > - > > Key: NIFI-1578 > URL: https://issues.apache.org/jira/browse/NIFI-1578 > Project: Apache NiFi > Issue Type: Improvement > Components: Extensions >Reporter: Adam Lamar >Assignee: Adam Lamar > Fix For: 0.7.0 > > -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[3/3] nifi git commit: NIFI-1550: - Bumping artifact versions to 1.0.0.
NIFI-1550: - Bumping artifact versions to 1.0.0. Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/28058b98 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/28058b98 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/28058b98 Branch: refs/heads/1.x Commit: 28058b9883ead8e505798105b62eae1877b1f517 Parents: 38c782c Author: Matt Gilman Authored: Mon Mar 21 11:46:55 2016 -0400 Committer: Matt Gilman Committed: Mon Mar 21 11:46:55 2016 -0400 -- nifi-api/pom.xml| 2 +- nifi-assembly/pom.xml | 2 +- nifi-bootstrap/pom.xml | 2 +- nifi-commons/nifi-data-provenance-utils/pom.xml | 2 +- nifi-commons/nifi-expression-language/pom.xml | 2 +- nifi-commons/nifi-flowfile-packager/pom.xml | 2 +- nifi-commons/nifi-hadoop-utils/pom.xml | 4 +- nifi-commons/nifi-hl7-query-language/pom.xml| 2 +- nifi-commons/nifi-logging-utils/pom.xml | 2 +- nifi-commons/nifi-processor-utilities/pom.xml | 2 +- nifi-commons/nifi-properties/pom.xml| 2 +- nifi-commons/nifi-security-utils/pom.xml| 2 +- nifi-commons/nifi-site-to-site-client/pom.xml | 4 +- nifi-commons/nifi-socket-utils/pom.xml | 2 +- nifi-commons/nifi-utils/pom.xml | 4 +- nifi-commons/nifi-web-utils/pom.xml | 2 +- nifi-commons/nifi-write-ahead-log/pom.xml | 2 +- nifi-commons/pom.xml| 2 +- nifi-docs/pom.xml | 2 +- .../nifi-nifi-example-nar/pom.xml | 2 +- .../nifi-nifi-example-processors/pom.xml| 2 +- nifi-external/nifi-example-bundle/pom.xml | 4 +- nifi-external/nifi-spark-receiver/pom.xml | 2 +- nifi-external/nifi-storm-spout/pom.xml | 2 +- nifi-external/pom.xml | 2 +- .../nifi-processor-bundle-archetype/pom.xml | 2 +- .../nifi-service-bundle-archetype/pom.xml | 2 +- nifi-maven-archetypes/pom.xml | 2 +- nifi-mock/pom.xml | 2 +- .../nifi-ambari-bundle/nifi-ambari-nar/pom.xml | 4 +- .../nifi-ambari-reporting-task/pom.xml | 2 +- nifi-nar-bundles/nifi-ambari-bundle/pom.xml | 2 +- .../nifi-amqp-bundle/nifi-amqp-nar/pom.xml | 4 +- .../nifi-amqp-processors/pom.xml| 2 +- nifi-nar-bundles/nifi-amqp-bundle/pom.xml | 6 +- .../nifi-avro-bundle/nifi-avro-nar/pom.xml | 6 +- .../nifi-avro-processors/pom.xml| 2 +- nifi-nar-bundles/nifi-avro-bundle/pom.xml | 4 +- .../nifi-aws-bundle/nifi-aws-nar/pom.xml| 4 +- .../nifi-aws-bundle/nifi-aws-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-aws-bundle/pom.xml| 2 +- .../nifi-azure-bundle/nifi-azure-nar/pom.xml| 6 +- .../nifi-azure-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-azure-bundle/pom.xml | 4 +- .../nifi-cassandra-nar/pom.xml | 2 +- .../nifi-cassandra-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-cassandra-bundle/pom.xml | 4 +- .../nifi-couchbase-nar/pom.xml | 6 +- .../nifi-couchbase-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-couchbase-bundle/pom.xml | 4 +- .../nifi-elasticsearch-nar/pom.xml | 2 +- .../nifi-elasticsearch-processors/pom.xml | 2 +- .../nifi-elasticsearch-bundle/pom.xml | 4 +- .../nifi-flume-bundle/nifi-flume-nar/pom.xml| 4 +- .../nifi-flume-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-flume-bundle/pom.xml | 6 +- .../nifi-framework-nar/pom.xml | 2 +- .../nifi-framework/nifi-administration/pom.xml | 2 +- .../nifi-framework/nifi-client-dto/pom.xml | 2 +- .../nifi-cluster-authorization-provider/pom.xml | 2 +- .../nifi-framework/nifi-documentation/pom.xml | 2 +- .../nifi-file-authorization-provider/pom.xml| 2 +- .../nifi-framework-cluster-protocol/pom.xml | 2 +- .../nifi-framework-cluster-web/pom.xml | 2 +- .../nifi-framework-cluster/pom.xml | 2 +- .../nifi-framework-core-api/pom.xml | 2 +- .../nifi-framework/nifi-framework-core/pom.xml | 2 +- .../nifi-framework/nifi-nar-utils/pom.xml | 2 +- .../nifi-framework/nifi-resources/pom.xml | 2 +- .../nifi-framework/nifi-runtime/pom.xml | 2 +- .../nifi-framework/nifi-security/pom.xml| 2 +- .../nifi-framework/nifi-site-to-site/pom.xml| 2 +- .../nifi-framework/nifi-user-actions/pom.xml| 2 +- .../nifi-web/nifi-custom-ui-utilities/pom.xml | 2 +- .../nifi-framework/nifi-web/nifi-jetty/pom.xml | 2 +- .../nifi-web/nifi-ui-extension/pom.xml | 2
[2/3] nifi git commit: NIFI-1550: - Bumping artifact versions to 1.0.0.
http://git-wip-us.apache.org/repos/asf/nifi/blob/28058b98/nifi-nar-bundles/nifi-framework-bundle/pom.xml -- diff --git a/nifi-nar-bundles/nifi-framework-bundle/pom.xml b/nifi-nar-bundles/nifi-framework-bundle/pom.xml index 4000f6c..d1b1422 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-framework-bundle/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-nar-bundles -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT nifi-framework-bundle pom @@ -31,92 +31,92 @@ org.apache.nifi nifi-framework-cluster-protocol -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-framework-cluster-web -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-file-authorization-provider -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-cluster-authorization-provider -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-framework-cluster -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-runtime -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-client-dto -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-web-content-access -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-security -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-framework-core-api -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-site-to-site -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-framework-core -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-user-actions -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-administration -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-jetty -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-web-optimistic-locking -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-web-security -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-documentation -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT http://git-wip-us.apache.org/repos/asf/nifi/blob/28058b98/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-nar/pom.xml -- diff --git a/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-nar/pom.xml b/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-nar/pom.xml index e3a4a07..0f4768f 100644 --- a/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-nar/pom.xml +++ b/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-nar/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-geo-bundle -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT nifi-geo-nar nar http://git-wip-us.apache.org/repos/asf/nifi/blob/28058b98/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-processors/pom.xml -- diff --git a/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-processors/pom.xml b/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-processors/pom.xml index 742b3a2..ae397a8 100644 --- a/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-processors/pom.xml +++ b/nifi-nar-bundles/nifi-geo-bundle/nifi-geo-processors/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-geo-bundle -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT nifi-geo-processors http://git-wip-us.apache.org/repos/asf/nifi/blob/28058b98/nifi-nar-bundles/nifi-geo-bundle/pom.xml -
[1/3] nifi git commit: NIFI-1550: - Bumping artifact versions to 1.0.0.
Repository: nifi Updated Branches: refs/heads/1.x 38c782c30 -> 28058b988 http://git-wip-us.apache.org/repos/asf/nifi/blob/28058b98/nifi-nar-bundles/nifi-standard-services/nifi-hbase_1_1_2-client-service-bundle/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-hbase_1_1_2-client-service-bundle/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-hbase_1_1_2-client-service-bundle/pom.xml index 3045a5c..6b99d56 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-hbase_1_1_2-client-service-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-hbase_1_1_2-client-service-bundle/pom.xml @@ -19,12 +19,12 @@ org.apache.nifi nifi-standard-services -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT org.apache.nifi nifi-hbase_1_1_2-client-service-bundle -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT pom http://git-wip-us.apache.org/repos/asf/nifi/blob/28058b98/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-api/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-api/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-api/pom.xml index 0bfafe4..99a2cf7 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-api/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-api/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-standard-services -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT nifi-http-context-map-api http://git-wip-us.apache.org/repos/asf/nifi/blob/28058b98/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml index 9fdd005..84a4ddb 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-http-context-map-bundle -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT nifi-http-context-map-nar http://git-wip-us.apache.org/repos/asf/nifi/blob/28058b98/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml index 3bfe8ab..6a1481b 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-http-context-map-bundle -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT nifi-http-context-map http://git-wip-us.apache.org/repos/asf/nifi/blob/28058b98/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml index fc7b579..c79952d 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-standard-services -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT nifi-http-context-map-bundle http://git-wip-us.apache.org/repos/asf/nifi/blob/28058b98/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml index 42ea9d6..91e7eab 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-standard-services -0.6.0-SNAPSHOT +1.0.0-SNAPSHOT nifi-load-distribution-service-api jar http://git-wip-us.apac
[jira] [Commented] (NIFI-1550) Authorizer API
[ https://issues.apache.org/jira/browse/NIFI-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204481#comment-15204481 ] ASF subversion and git services commented on NIFI-1550: --- Commit 28058b9883ead8e505798105b62eae1877b1f517 in nifi's branch refs/heads/1.x from [~mcgilman] [ https://git-wip-us.apache.org/repos/asf?p=nifi.git;h=28058b9 ] NIFI-1550: - Bumping artifact versions to 1.0.0. > Authorizer API > -- > > Key: NIFI-1550 > URL: https://issues.apache.org/jira/browse/NIFI-1550 > Project: Apache NiFi > Issue Type: Improvement > Components: Core Framework >Reporter: Matt Gilman >Assignee: Matt Gilman > Fix For: 1.0.0 > > > This is a parent ticket for tracking all work done for the Authorizer feature > proposal phase 1 [1]. > At a high level, all authorization decisions are delegated to a provider and > given the identity of the entity, the resource being accessed, the action, > and the context of the request. > Additionally, the Authorizer will be able to support an audit query that > presents back the recently active users including their last request, last > rejected attempts, and last mutable requests. A given implementation of an > Authorizer may or may not offer to support user request audits. > Sub tickets will be created for tracking specific units of work. Once all sub > tickets are completed, this ticket will be finished. > [1] https://cwiki.apache.org/confluence/display/NIFI/Support+Authorizer+API -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (NIFI-1649) SplitText end of line handling is incorrect
[ https://issues.apache.org/jira/browse/NIFI-1649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204447#comment-15204447 ] Joseph Witt commented on NIFI-1649: --- +1. Very nice I've also attached a template for more fun. Can you please squash these patches and clean out the extraneous comments in the test? Thanks! > SplitText end of line handling is incorrect > --- > > Key: NIFI-1649 > URL: https://issues.apache.org/jira/browse/NIFI-1649 > Project: Apache NiFi > Issue Type: Bug > Components: Extensions >Reporter: Joseph Witt >Assignee: Mark Payne >Priority: Critical > Fix For: 0.6.0 > > Attachments: > 0001-NIFI-1649-Generated-unit-tests-to-verify-behavior-de.patch, > 0002-NIFI-1649-Addressed-issues-with-SplitText-that-cause.patch, > 0003_NIFI-1649_CauseTestFail.patch, > 0004-NIFI-1649-Addressed-issue-that-resulted-in-wrong-num.patch, > Fun_Test_of_SplitText.xml, View_Content_using_wrong_content_claim.xml > > > Lengthy discussion about this in NIFI-1118 -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[nifi] Git Push Summary
Repository: nifi Updated Branches: refs/heads/1.x [created] 38c782c30
[jira] [Updated] (NIFI-1649) SplitText end of line handling is incorrect
[ https://issues.apache.org/jira/browse/NIFI-1649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joseph Witt updated NIFI-1649: -- Attachment: Fun_Test_of_SplitText.xml > SplitText end of line handling is incorrect > --- > > Key: NIFI-1649 > URL: https://issues.apache.org/jira/browse/NIFI-1649 > Project: Apache NiFi > Issue Type: Bug > Components: Extensions >Reporter: Joseph Witt >Assignee: Mark Payne >Priority: Critical > Fix For: 0.6.0 > > Attachments: > 0001-NIFI-1649-Generated-unit-tests-to-verify-behavior-de.patch, > 0002-NIFI-1649-Addressed-issues-with-SplitText-that-cause.patch, > 0003_NIFI-1649_CauseTestFail.patch, > 0004-NIFI-1649-Addressed-issue-that-resulted-in-wrong-num.patch, > Fun_Test_of_SplitText.xml, View_Content_using_wrong_content_claim.xml > > > Lengthy discussion about this in NIFI-1118 -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[nifi] Git Push Summary
Repository: nifi Updated Branches: refs/heads/NIFI-655 [deleted] e22b51f3a
[nifi] Git Push Summary
Repository: nifi Updated Branches: refs/heads/NIFI-108-2 [deleted] e31c3c943
[nifi] Git Push Summary
Repository: nifi Updated Branches: refs/heads/NIFI-108 [deleted] 1f26ddd84
[jira] [Commented] (NIFI-1563) Remove storage of components' stats and bulletins from NCM
[ https://issues.apache.org/jira/browse/NIFI-1563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204412#comment-15204412 ] ASF subversion and git services commented on NIFI-1563: --- Commit d85d9f768af39491b732654565db3b13cb167a62 in nifi's branch refs/heads/NIFI-1563 from [~mcgilman] [ https://git-wip-us.apache.org/repos/asf?p=nifi.git;h=d85d9f7 ] NIFI-1563: - Removing nodewise from the system diagnostics endpoint. Had included it for testing that option but did not intend for it to be committed. > Remove storage of components' stats and bulletins from NCM > -- > > Key: NIFI-1563 > URL: https://issues.apache.org/jira/browse/NIFI-1563 > Project: Apache NiFi > Issue Type: Improvement > Components: Core Framework >Reporter: Mark Payne >Assignee: Mark Payne > Fix For: 1.0.0 > > Original Estimate: 168h > Remaining Estimate: 168h > > Currently, each node in a cluster sends a period heartbeat that contains the > stats for all components in the node. This happens every 5 seconds by > default. This results in quite a lot of chatter between the NCM and nodes. It > made sense to take this approach when the clustering concept was designed > because there were no Process Groups, and we had no notion of merging > responses from nodes for a web request. > However, now we should replicate the request to all nodes and then merge the > responses on demand, rather than storing this information on the NCM. This > requires far less bandwidth because we only need to pull the stats for a > particular Process Group and only on demand instead of every 5 seconds. > Additionally, this is laying groundwork for the Zero-Master clustering that > we want to have in place for 1.0.0. > In order to remove the stats from the NCM, we will also need to remove the > bulletins and stats history. These requests will all need to be federated and > the responses merged on-demand. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
nifi git commit: NIFI-1563: - Removing nodewise from the system diagnostics endpoint. Had included it for testing that option but did not intend for it to be committed.
Repository: nifi
Updated Branches:
refs/heads/NIFI-1563 ec4b1cebc -> d85d9f768
NIFI-1563:
- Removing nodewise from the system diagnostics endpoint. Had included it for
testing that option but did not intend for it to be committed.
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/d85d9f76
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/d85d9f76
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/d85d9f76
Branch: refs/heads/NIFI-1563
Commit: d85d9f768af39491b732654565db3b13cb167a62
Parents: ec4b1ce
Author: Matt Gilman
Authored: Mon Mar 21 11:05:28 2016 -0400
Committer: Matt Gilman
Committed: Mon Mar 21 11:05:28 2016 -0400
--
.../nifi-web-ui/src/main/webapp/js/nf/summary/nf-summary-table.js | 3 ---
1 file changed, 3 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/nifi/blob/d85d9f76/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-ui/src/main/webapp/js/nf/summary/nf-summary-table.js
--
diff --git
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-ui/src/main/webapp/js/nf/summary/nf-summary-table.js
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-ui/src/main/webapp/js/nf/summary/nf-summary-table.js
index b4f9ab2..49ad85b 100644
---
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-ui/src/main/webapp/js/nf/summary/nf-summary-table.js
+++
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-ui/src/main/webapp/js/nf/summary/nf-summary-table.js
@@ -1973,9 +1973,6 @@ nf.SummaryTable = (function () {
return $.ajax({
type: 'GET',
url: systemDiagnosticsUri,
-data: {
-nodewise: true
-},
dataType: 'json'
}).done(function (response) {
var systemDiagnostics = response.systemDiagnostics;
[jira] [Commented] (NIFI-1649) SplitText end of line handling is incorrect
[ https://issues.apache.org/jira/browse/NIFI-1649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204391#comment-15204391 ] Joseph Witt commented on NIFI-1649: --- [~markap14]full clean build w/contrib check is good. I agree with your test changes. Doing some live app testing and will report back on that asap. Definitely looks like we're closer. > SplitText end of line handling is incorrect > --- > > Key: NIFI-1649 > URL: https://issues.apache.org/jira/browse/NIFI-1649 > Project: Apache NiFi > Issue Type: Bug > Components: Extensions >Reporter: Joseph Witt >Assignee: Mark Payne >Priority: Critical > Fix For: 0.6.0 > > Attachments: > 0001-NIFI-1649-Generated-unit-tests-to-verify-behavior-de.patch, > 0002-NIFI-1649-Addressed-issues-with-SplitText-that-cause.patch, > 0003_NIFI-1649_CauseTestFail.patch, > 0004-NIFI-1649-Addressed-issue-that-resulted-in-wrong-num.patch, > View_Content_using_wrong_content_claim.xml > > > Lengthy discussion about this in NIFI-1118 -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[1/2] nifi git commit: NIFI-1650: Ensure that we seek to the appropriate offset within the Content Claim when downloading content of a FlowFile
Repository: nifi
Updated Branches:
refs/heads/master 9cde92da1 -> 38c782c30
NIFI-1650: Ensure that we seek to the appropriate offset within the Content
Claim when downloading content of a FlowFile
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/d3578a7c
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/d3578a7c
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/d3578a7c
Branch: refs/heads/master
Commit: d3578a7c03835fb55f90fa25856f6cc7ae824994
Parents: 9cde92d
Author: Mark Payne
Authored: Sat Mar 19 11:18:02 2016 -0400
Committer: Mark Payne
Committed: Mon Mar 21 10:30:23 2016 -0400
--
.../org/apache/nifi/controller/FlowController.java | 13 +++--
1 file changed, 11 insertions(+), 2 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/nifi/blob/d3578a7c/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java
--
diff --git
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java
index 6d09bf6..c9aaceb 100644
---
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java
+++
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java
@@ -158,6 +158,8 @@ import
org.apache.nifi.reporting.ReportingInitializationContext;
import org.apache.nifi.reporting.ReportingTask;
import org.apache.nifi.reporting.Severity;
import org.apache.nifi.scheduling.SchedulingStrategy;
+import org.apache.nifi.stream.io.LimitingInputStream;
+import org.apache.nifi.stream.io.StreamUtils;
import org.apache.nifi.util.FormatUtils;
import org.apache.nifi.util.NiFiProperties;
import org.apache.nifi.util.ReflectionUtils;
@@ -3381,7 +3383,7 @@ public class FlowController implements EventAccess,
ControllerServiceProvider, R
requireNonNull(requestor);
requireNonNull(requestUri);
-final InputStream stream;
+InputStream stream;
final ResourceClaim resourceClaim;
final ContentClaim contentClaim = flowFile.getContentClaim();
if (contentClaim == null) {
@@ -3390,6 +3392,12 @@ public class FlowController implements EventAccess,
ControllerServiceProvider, R
} else {
resourceClaim = flowFile.getContentClaim().getResourceClaim();
stream = contentRepository.read(flowFile.getContentClaim());
+final long contentClaimOffset = flowFile.getContentClaimOffset();
+if (contentClaimOffset > 0L) {
+StreamUtils.skip(stream, contentClaimOffset);
+}
+
+stream = new LimitingInputStream(stream, flowFile.getSize());
}
// Register a Provenance Event to indicate that we replayed the data.
@@ -3406,7 +3414,8 @@ public class FlowController implements EventAccess,
ControllerServiceProvider, R
.setDetails("Download of Content requested by " + requestor + "
for " + flowFile);
if (contentClaim != null) {
-
sendEventBuilder.setCurrentContentClaim(resourceClaim.getContainer(),
resourceClaim.getSection(), resourceClaim.getId(), contentClaim.getOffset(),
flowFile.getSize());
+
sendEventBuilder.setCurrentContentClaim(resourceClaim.getContainer(),
resourceClaim.getSection(), resourceClaim.getId(),
+contentClaim.getOffset() + flowFile.getContentClaimOffset(),
flowFile.getSize());
}
final ProvenanceEventRecord sendEvent = sendEventBuilder.build();
[jira] [Updated] (NIFI-1657) Provide support for various locales in CI builds
[ https://issues.apache.org/jira/browse/NIFI-1657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aldrin Piri updated NIFI-1657: -- Priority: Minor (was: Major) > Provide support for various locales in CI builds > > > Key: NIFI-1657 > URL: https://issues.apache.org/jira/browse/NIFI-1657 > Project: Apache NiFi > Issue Type: Task > Components: Tools and Build >Reporter: Aldrin Piri >Priority: Minor > > There were issues stemming from locale and building on more than the default > would help us catch similar issues moving forward. > From https://github.com/apache/nifi/pull/292, this can be accomplished via > something like: > -Duser.language=fr -Duser.region=FR -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (NIFI-1650) When listing queue content it appears the wrong content claim is being used
[ https://issues.apache.org/jira/browse/NIFI-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204347#comment-15204347 ] ASF subversion and git services commented on NIFI-1650: --- Commit 38c782c30bde7d687fd6d0596fbc167c1f3f2243 in nifi's branch refs/heads/master from [~markap14] [ https://git-wip-us.apache.org/repos/asf?p=nifi.git;h=38c782c ] NIFI-1650: Ensure that proper size and offset are specified for Content Claim when viewing FlowFiles still in queue > When listing queue content it appears the wrong content claim is being used > --- > > Key: NIFI-1650 > URL: https://issues.apache.org/jira/browse/NIFI-1650 > Project: Apache NiFi > Issue Type: Bug > Components: Core Framework, Core UI >Reporter: Joseph Witt >Assignee: Mark Payne >Priority: Critical > Fix For: 0.6.0 > > Attachments: > 0001-NIFI-1650-Ensure-that-we-seek-to-the-appropriate-off.patch, > 0002-NIFI-1650-Ensure-that-proper-size-and-offset-are-spe.patch, Screen Shot > 2016-03-20 at 2.11.46 PM.png, Screen Shot 2016-03-20 at 2.11.53 PM.png, > View_Content_using_wrong_content_claim.xml > > > Will attach template to reproduce. Noticed this will testing the patches for > NIFI-1634. The flow runs and 11 outputs are produced on the queue. If you > do the queue listing you can try to view content but it sees the full object > size of the original claim it appears so it shows the full object. It shows > the proper size on the attributes but then when going to view content it sees > the original/too large size. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (NIFI-1657) Provide support for various locales in CI builds
Aldrin Piri created NIFI-1657: - Summary: Provide support for various locales in CI builds Key: NIFI-1657 URL: https://issues.apache.org/jira/browse/NIFI-1657 Project: Apache NiFi Issue Type: Task Components: Tools and Build Reporter: Aldrin Piri There were issues stemming from locale and building on more than the default would help us catch similar issues moving forward. >From https://github.com/apache/nifi/pull/292, this can be accomplished via >something like: -Duser.language=fr -Duser.region=FR -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (NIFI-1656) Kite processor scanner usage presumes a particular locale
[ https://issues.apache.org/jira/browse/NIFI-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204349#comment-15204349 ] ASF GitHub Bot commented on NIFI-1656: -- Github user apiri commented on the pull request: https://github.com/apache/nifi/pull/292#issuecomment-199315775 Created a ticket to handle this task: https://issues.apache.org/jira/browse/NIFI-1657 > Kite processor scanner usage presumes a particular locale > - > > Key: NIFI-1656 > URL: https://issues.apache.org/jira/browse/NIFI-1656 > Project: Apache NiFi > Issue Type: Bug > Environment: Windows 7 pro, maven 3.3.9, Java 8 >Reporter: Pierre Villard >Assignee: Tony Kurc > > This is a JIRA which spawned from the discussion/review efforts folks did on > NIFI-1651. > Sorry for the delay... I am on a different computer than usual and forgot to > check the git property. Did a full clone again (so slow with airport wifi...) > and checked the schema (looks OK to me). The git property solved most of the > issues, but some are remaining: > Running org.apache.nifi.processors.kite.TestAvroRecordConverter > Tests run: 4, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.377 sec <<< > FAILURE! - in org.apache.nifi.processors.kite.TestAvroRecordConverter > testDefaultConversion(org.apache.nifi.processors.kite.TestAvroRecordConverter) > Time elapsed: 0.011 sec <<< ERROR! > org.apache.nifi.processors.kite.AvroRecordConverter$AvroConversionException: > Cannot convert 5.5 to double > at > org.apache.nifi.processors.kite.AvroRecordConverter.convertData(AvroRecordConverter.java:246) > at > org.apache.nifi.processors.kite.AvroRecordConverter.convert(AvroRecordConverter.java:170) > at > org.apache.nifi.processors.kite.TestAvroRecordConverter.testDefaultConversion(TestAvroRecordConverter.java:98) > Running org.apache.nifi.processors.kite.TestConfigurationProperty > Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.849 sec - > in org.apache.nifi.processors.kite.TestConfigurationProperty > Running org.apache.nifi.processors.kite.TestConvertAvroSchema > Tests run: 2, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 0.22 sec <<< > FAILURE! - in org.apache.nifi.processors.kite.TestConvertAvroSchema > testBasicConversion(org.apache.nifi.processors.kite.TestConvertAvroSchema) > Time elapsed: 0.21 sec <<< FAILURE! > java.lang.AssertionError: Should convert 2 rows expected:<2> but was:<1> > at org.junit.Assert.fail(Assert.java:88) > at org.junit.Assert.failNotEquals(Assert.java:834) > at org.junit.Assert.assertEquals(Assert.java:645) > at > org.apache.nifi.processors.kite.TestConvertAvroSchema.testBasicConversion(TestConvertAvroSchema.java:78) > Just for the record, the error is because of my local env. This is fixed by > setting the locale to US on the scanner: > scanner.useLocale(java.util.Locale.US); > I don't know if there is a way to set this at a global scale. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (NIFI-1650) When listing queue content it appears the wrong content claim is being used
[ https://issues.apache.org/jira/browse/NIFI-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204346#comment-15204346 ] ASF subversion and git services commented on NIFI-1650: --- Commit d3578a7c03835fb55f90fa25856f6cc7ae824994 in nifi's branch refs/heads/master from [~markap14] [ https://git-wip-us.apache.org/repos/asf?p=nifi.git;h=d3578a7 ] NIFI-1650: Ensure that we seek to the appropriate offset within the Content Claim when downloading content of a FlowFile > When listing queue content it appears the wrong content claim is being used > --- > > Key: NIFI-1650 > URL: https://issues.apache.org/jira/browse/NIFI-1650 > Project: Apache NiFi > Issue Type: Bug > Components: Core Framework, Core UI >Reporter: Joseph Witt >Assignee: Mark Payne >Priority: Critical > Fix For: 0.6.0 > > Attachments: > 0001-NIFI-1650-Ensure-that-we-seek-to-the-appropriate-off.patch, > 0002-NIFI-1650-Ensure-that-proper-size-and-offset-are-spe.patch, Screen Shot > 2016-03-20 at 2.11.46 PM.png, Screen Shot 2016-03-20 at 2.11.53 PM.png, > View_Content_using_wrong_content_claim.xml > > > Will attach template to reproduce. Noticed this will testing the patches for > NIFI-1634. The flow runs and 11 outputs are produced on the queue. If you > do the queue listing you can try to view content but it sees the full object > size of the original claim it appears so it shows the full object. It shows > the proper size on the attributes but then when going to view content it sees > the original/too large size. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[2/2] nifi git commit: NIFI-1650: Ensure that proper size and offset are specified for Content Claim when viewing FlowFiles still in queue
NIFI-1650: Ensure that proper size and offset are specified for Content Claim
when viewing FlowFiles still in queue
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/38c782c3
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/38c782c3
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/38c782c3
Branch: refs/heads/master
Commit: 38c782c30bde7d687fd6d0596fbc167c1f3f2243
Parents: d3578a7
Author: Mark Payne
Authored: Mon Mar 21 09:03:53 2016 -0400
Committer: Mark Payne
Committed: Mon Mar 21 10:30:24 2016 -0400
--
.../src/main/java/org/apache/nifi/web/api/dto/DtoFactory.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/nifi/blob/38c782c3/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/dto/DtoFactory.java
--
diff --git
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/dto/DtoFactory.java
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/dto/DtoFactory.java
index 78584c3..6157285 100644
---
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/dto/DtoFactory.java
+++
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/dto/DtoFactory.java
@@ -520,9 +520,9 @@ public final class DtoFactory {
dto.setContentClaimSection(resourceClaim.getSection());
dto.setContentClaimContainer(resourceClaim.getContainer());
dto.setContentClaimIdentifier(resourceClaim.getId());
-dto.setContentClaimOffset(contentClaim.getOffset());
-dto.setContentClaimFileSizeBytes(contentClaim.getLength());
-
dto.setContentClaimFileSize(FormatUtils.formatDataSize(contentClaim.getLength()));
+dto.setContentClaimOffset(contentClaim.getOffset() +
record.getContentClaimOffset());
+dto.setContentClaimFileSizeBytes(record.getSize());
+
dto.setContentClaimFileSize(FormatUtils.formatDataSize(record.getSize()));
}
return dto;
[jira] [Commented] (NIFI-1488) Add Kerberos Support to HBase processors
[ https://issues.apache.org/jira/browse/NIFI-1488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204342#comment-15204342 ] ASF GitHub Bot commented on NIFI-1488: -- Github user lordjc commented on the pull request: https://github.com/apache/nifi/pull/253#issuecomment-199314205 Closing based on comments above. > Add Kerberos Support to HBase processors > > > Key: NIFI-1488 > URL: https://issues.apache.org/jira/browse/NIFI-1488 > Project: Apache NiFi > Issue Type: Improvement >Affects Versions: 0.4.0, 0.4.1 >Reporter: Bryan Bende >Assignee: Ricky Saltzer > Fix For: 0.6.0 > > Attachments: > 0001-NIFI-1488-Adjusting-unused-imports-and-adding-licens.patch, > 0001-NIFI-1488-fixed-bug-that-returned-wrong-variable-for.patch > > > Our current HBase integration does not support communicating with a > Kerberized HBase install. We should support this just like we do for the HDFS > processors. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (NIFI-1488) Add Kerberos Support to HBase processors
[ https://issues.apache.org/jira/browse/NIFI-1488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204341#comment-15204341 ] ASF GitHub Bot commented on NIFI-1488: -- Github user lordjc closed the pull request at: https://github.com/apache/nifi/pull/253 > Add Kerberos Support to HBase processors > > > Key: NIFI-1488 > URL: https://issues.apache.org/jira/browse/NIFI-1488 > Project: Apache NiFi > Issue Type: Improvement >Affects Versions: 0.4.0, 0.4.1 >Reporter: Bryan Bende >Assignee: Ricky Saltzer > Fix For: 0.6.0 > > Attachments: > 0001-NIFI-1488-Adjusting-unused-imports-and-adding-licens.patch, > 0001-NIFI-1488-fixed-bug-that-returned-wrong-variable-for.patch > > > Our current HBase integration does not support communicating with a > Kerberized HBase install. We should support this just like we do for the HDFS > processors. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (NIFI-1650) When listing queue content it appears the wrong content claim is being used
[ https://issues.apache.org/jira/browse/NIFI-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204336#comment-15204336 ] Joseph Witt commented on NIFI-1650: --- ok +1. Checked it out. Good to go. Thanks > When listing queue content it appears the wrong content claim is being used > --- > > Key: NIFI-1650 > URL: https://issues.apache.org/jira/browse/NIFI-1650 > Project: Apache NiFi > Issue Type: Bug > Components: Core Framework, Core UI >Reporter: Joseph Witt >Assignee: Mark Payne >Priority: Critical > Fix For: 0.6.0 > > Attachments: > 0001-NIFI-1650-Ensure-that-we-seek-to-the-appropriate-off.patch, > 0002-NIFI-1650-Ensure-that-proper-size-and-offset-are-spe.patch, Screen Shot > 2016-03-20 at 2.11.46 PM.png, Screen Shot 2016-03-20 at 2.11.53 PM.png, > View_Content_using_wrong_content_claim.xml > > > Will attach template to reproduce. Noticed this will testing the patches for > NIFI-1634. The flow runs and 11 outputs are produced on the queue. If you > do the queue listing you can try to view content but it sees the full object > size of the original claim it appears so it shows the full object. It shows > the proper size on the attributes but then when going to view content it sees > the original/too large size. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[nifi] Git Push Summary
Repository: nifi Updated Branches: refs/heads/travis-ci [deleted] 989c10930
nifi git commit: NIFI-1563: Removed ProcessGroupStatus from HeartbeatPayload
Repository: nifi
Updated Branches:
refs/heads/NIFI-1563 3337ea951 -> ec4b1cebc
NIFI-1563: Removed ProcessGroupStatus from HeartbeatPayload
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/ec4b1ceb
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/ec4b1ceb
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/ec4b1ceb
Branch: refs/heads/NIFI-1563
Commit: ec4b1cebc90e5c70ae3962cfae9db8b4ba6f17c7
Parents: 3337ea9
Author: Mark Payne
Authored: Mon Mar 21 10:09:57 2016 -0400
Committer: Mark Payne
Committed: Mon Mar 21 10:09:57 2016 -0400
--
.../java/org/apache/nifi/cluster/HeartbeatPayload.java| 10 --
.../java/org/apache/nifi/controller/FlowController.java | 3 +--
2 files changed, 1 insertion(+), 12 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/nifi/blob/ec4b1ceb/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/cluster/HeartbeatPayload.java
--
diff --git
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/cluster/HeartbeatPayload.java
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/cluster/HeartbeatPayload.java
index 94ed570..1146a39 100644
---
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/cluster/HeartbeatPayload.java
+++
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/cluster/HeartbeatPayload.java
@@ -28,7 +28,6 @@ import javax.xml.bind.Unmarshaller;
import javax.xml.bind.annotation.XmlRootElement;
import org.apache.nifi.cluster.protocol.ProtocolException;
-import org.apache.nifi.controller.status.ProcessGroupStatus;
/**
* The payload of the heartbeat. The payload contains status to inform the
cluster manager the current workload of this node.
@@ -47,7 +46,6 @@ public class HeartbeatPayload {
}
}
-private ProcessGroupStatus processGroupStatus;
private int activeThreadCount;
private long totalFlowFileCount;
private long totalFlowFileBytes;
@@ -77,14 +75,6 @@ public class HeartbeatPayload {
this.totalFlowFileBytes = totalFlowFileBytes;
}
-public ProcessGroupStatus getProcessGroupStatus() {
-return processGroupStatus;
-}
-
-public void setProcessGroupStatus(final ProcessGroupStatus
processGroupStatus) {
-this.processGroupStatus = processGroupStatus;
-}
-
public long getSystemStartTime() {
return systemStartTime;
}
http://git-wip-us.apache.org/repos/asf/nifi/blob/ec4b1ceb/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java
--
diff --git
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java
index ce83baf..3c1062a 100644
---
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java
+++
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java
@@ -3684,11 +3684,10 @@ public class FlowController implements EventAccess,
ControllerServiceProvider, R
return null;
}
-final ProcessGroupStatus procGroupStatus =
getGroupStatus(bean.getRootGroup(), getProcessorStats());
// create heartbeat payload
final HeartbeatPayload hbPayload = new HeartbeatPayload();
hbPayload.setSystemStartTime(systemStartTime);
-
hbPayload.setActiveThreadCount(procGroupStatus.getActiveThreadCount());
+hbPayload.setActiveThreadCount(getActiveThreadCount());
final QueueSize queueSize =
getTotalFlowFileCount(bean.getRootGroup());
hbPayload.setTotalFlowFileCount(queueSize.getObjectCount());
[jira] [Commented] (NIFI-1563) Remove storage of components' stats and bulletins from NCM
[ https://issues.apache.org/jira/browse/NIFI-1563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204246#comment-15204246 ] ASF subversion and git services commented on NIFI-1563: --- Commit ec4b1cebc90e5c70ae3962cfae9db8b4ba6f17c7 in nifi's branch refs/heads/NIFI-1563 from [~markap14] [ https://git-wip-us.apache.org/repos/asf?p=nifi.git;h=ec4b1ce ] NIFI-1563: Removed ProcessGroupStatus from HeartbeatPayload > Remove storage of components' stats and bulletins from NCM > -- > > Key: NIFI-1563 > URL: https://issues.apache.org/jira/browse/NIFI-1563 > Project: Apache NiFi > Issue Type: Improvement > Components: Core Framework >Reporter: Mark Payne >Assignee: Mark Payne > Fix For: 1.0.0 > > Original Estimate: 168h > Remaining Estimate: 168h > > Currently, each node in a cluster sends a period heartbeat that contains the > stats for all components in the node. This happens every 5 seconds by > default. This results in quite a lot of chatter between the NCM and nodes. It > made sense to take this approach when the clustering concept was designed > because there were no Process Groups, and we had no notion of merging > responses from nodes for a web request. > However, now we should replicate the request to all nodes and then merge the > responses on demand, rather than storing this information on the NCM. This > requires far less bandwidth because we only need to pull the stats for a > particular Process Group and only on demand instead of every 5 seconds. > Additionally, this is laying groundwork for the Zero-Master clustering that > we want to have in place for 1.0.0. > In order to remove the stats from the NCM, we will also need to remove the > bulletins and stats history. These requests will all need to be federated and > the responses merged on-demand. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (NIFI-1630) Create PutUDP Processor
[ https://issues.apache.org/jira/browse/NIFI-1630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204228#comment-15204228 ] Bryan Bende commented on NIFI-1630: --- Joe/Matt, Sure... We recently added a PutSplunk processor which is essentially PutTCP + PutUDP behind the scenes, and as part of this we created AbstractPutEventProcessor in nifi-processor-utilities: https://github.com/apache/nifi/blob/master/nifi-commons/nifi-processor-utilities/src/main/java/org/apache/nifi/processor/util/put/AbstractPutEventProcessor.java We may want to consider having PutUDP extend AbstractPutEventProcessor so that everything leverages the same underlying networking code (also in nifi-processor-utilities). For reference, PutSplunk is here: https://github.com/apache/nifi/blob/master/nifi-nar-bundles/nifi-splunk-bundle/nifi-splunk-processors/src/main/java/org/apache/nifi/processors/splunk/PutSplunk.java I think the main difference between AbstractPutEventProcessor and Matt's PutUDP, is that AbstractPutEventProcessor supports two modes - one is sending a FlowFile as a datagram, and the other is breaking up an incoming FlowFIle into many datagrams based on a delimiter (think a large file of separated by new lines, and sending each line as a datagram). > Create PutUDP Processor > --- > > Key: NIFI-1630 > URL: https://issues.apache.org/jira/browse/NIFI-1630 > Project: Apache NiFi > Issue Type: New Feature > Components: Extensions >Affects Versions: 0.6.0 >Reporter: Matt Brown >Priority: Minor > Labels: beginner > Attachments: 0001-nifi-1630-PutUDP-processor-created.patch > > > Create a processor to send each FlowFile as a datagram to a UDP server. > Processor must provide properties to allow the user to configure the > destination host address and port to send to. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (NIFI-1649) SplitText end of line handling is incorrect
[ https://issues.apache.org/jira/browse/NIFI-1649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204183#comment-15204183 ] Mark Payne commented on NIFI-1649: -- [~joewitt] I attached a 0004 patch that I believe addresses the issue that you were highlighting in the 0003 patch. Of note, when I corrected this issue, one of the other unit tests that you provided failed. However, I do believe the behavior is correct. I believe you may have miscounted the number of '\n' characters in the input data, as only 1 of the assertions (the very last one in the unit test) failed, and when I counted everything out, I arrived at the conclusion that the unit test was incorrect. Please verify/advise. Thanks > SplitText end of line handling is incorrect > --- > > Key: NIFI-1649 > URL: https://issues.apache.org/jira/browse/NIFI-1649 > Project: Apache NiFi > Issue Type: Bug > Components: Extensions >Reporter: Joseph Witt >Assignee: Mark Payne >Priority: Critical > Fix For: 0.6.0 > > Attachments: > 0001-NIFI-1649-Generated-unit-tests-to-verify-behavior-de.patch, > 0002-NIFI-1649-Addressed-issues-with-SplitText-that-cause.patch, > 0003_NIFI-1649_CauseTestFail.patch, > 0004-NIFI-1649-Addressed-issue-that-resulted-in-wrong-num.patch, > View_Content_using_wrong_content_claim.xml > > > Lengthy discussion about this in NIFI-1118 -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (NIFI-1649) SplitText end of line handling is incorrect
[ https://issues.apache.org/jira/browse/NIFI-1649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Payne updated NIFI-1649: - Attachment: 0004-NIFI-1649-Addressed-issue-that-resulted-in-wrong-num.patch > SplitText end of line handling is incorrect > --- > > Key: NIFI-1649 > URL: https://issues.apache.org/jira/browse/NIFI-1649 > Project: Apache NiFi > Issue Type: Bug > Components: Extensions >Reporter: Joseph Witt >Assignee: Mark Payne >Priority: Critical > Fix For: 0.6.0 > > Attachments: > 0001-NIFI-1649-Generated-unit-tests-to-verify-behavior-de.patch, > 0002-NIFI-1649-Addressed-issues-with-SplitText-that-cause.patch, > 0003_NIFI-1649_CauseTestFail.patch, > 0004-NIFI-1649-Addressed-issue-that-resulted-in-wrong-num.patch, > View_Content_using_wrong_content_claim.xml > > > Lengthy discussion about this in NIFI-1118 -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (NIFI-1649) SplitText end of line handling is incorrect
[
https://issues.apache.org/jira/browse/NIFI-1649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204179#comment-15204179
]
Mark Payne commented on NIFI-1649:
--
[~joewitt] I see the following comment in one of the unit tests you provided:
{code}
/**
* It appears headerline should be 'HeaderLine1\n' and is for the first
* few splits then it is 'HeaderLine1' as you can see we lose a \n if we
* uncomment and use the following instead it works fine.
*/
// splits.get(3).assertContentEquals("HeaderLine1\n\n\n\n\n");
//splits.get(4).assertContentEquals("HeaderLine1\n\n\n\n\n");
//splits.get(5).assertContentEquals("HeaderLine1\n\n\n\n\n");
//splits.get(6).assertContentEquals("HeaderLine1\n\n\n\n\n");
//splits.get(7).assertContentEquals("HeaderLine1\n\n\n\n\n");
//splits.get(8).assertContentEquals("HeaderLine1\n\n\n\n\n");
//splits.get(9).assertContentEquals("HeaderLine1\nLastLine\n");
{code}
I'm not sure what to make of that. Above that, in the same unit test, you have
other assertContentEquals calls, which assert a different number of new-lines.
I believe the above ones to be correct, and they do indeed pass the unit test.
Do you disagree?
> SplitText end of line handling is incorrect
> ---
>
> Key: NIFI-1649
> URL: https://issues.apache.org/jira/browse/NIFI-1649
> Project: Apache NiFi
> Issue Type: Bug
> Components: Extensions
>Reporter: Joseph Witt
>Assignee: Mark Payne
>Priority: Critical
> Fix For: 0.6.0
>
> Attachments:
> 0001-NIFI-1649-Generated-unit-tests-to-verify-behavior-de.patch,
> 0002-NIFI-1649-Addressed-issues-with-SplitText-that-cause.patch,
> 0003_NIFI-1649_CauseTestFail.patch, View_Content_using_wrong_content_claim.xml
>
>
> Lengthy discussion about this in NIFI-1118
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Updated] (NIFI-1650) When listing queue content it appears the wrong content claim is being used
[ https://issues.apache.org/jira/browse/NIFI-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Payne updated NIFI-1650: - Attachment: 0002-NIFI-1650-Ensure-that-proper-size-and-offset-are-spe.patch > When listing queue content it appears the wrong content claim is being used > --- > > Key: NIFI-1650 > URL: https://issues.apache.org/jira/browse/NIFI-1650 > Project: Apache NiFi > Issue Type: Bug > Components: Core Framework, Core UI >Reporter: Joseph Witt >Assignee: Mark Payne >Priority: Critical > Fix For: 0.6.0 > > Attachments: > 0001-NIFI-1650-Ensure-that-we-seek-to-the-appropriate-off.patch, > 0002-NIFI-1650-Ensure-that-proper-size-and-offset-are-spe.patch, Screen Shot > 2016-03-20 at 2.11.46 PM.png, Screen Shot 2016-03-20 at 2.11.53 PM.png, > View_Content_using_wrong_content_claim.xml > > > Will attach template to reproduce. Noticed this will testing the patches for > NIFI-1634. The flow runs and 11 outputs are produced on the queue. If you > do the queue listing you can try to view content but it sees the full object > size of the original claim it appears so it shows the full object. It shows > the proper size on the attributes but then when going to view content it sees > the original/too large size. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (NIFI-1650) When listing queue content it appears the wrong content claim is being used
[ https://issues.apache.org/jira/browse/NIFI-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204145#comment-15204145 ] Mark Payne commented on NIFI-1650: -- [~joewitt] good catch! I addressed the issue that displayed the wrong size and offset for the content claim and uploaded a new patch (0002*.patch). This patch is expected to be applied on top of the 0001 patch. Thanks -Mark > When listing queue content it appears the wrong content claim is being used > --- > > Key: NIFI-1650 > URL: https://issues.apache.org/jira/browse/NIFI-1650 > Project: Apache NiFi > Issue Type: Bug > Components: Core Framework, Core UI >Reporter: Joseph Witt >Assignee: Mark Payne >Priority: Critical > Fix For: 0.6.0 > > Attachments: > 0001-NIFI-1650-Ensure-that-we-seek-to-the-appropriate-off.patch, > 0002-NIFI-1650-Ensure-that-proper-size-and-offset-are-spe.patch, Screen Shot > 2016-03-20 at 2.11.46 PM.png, Screen Shot 2016-03-20 at 2.11.53 PM.png, > View_Content_using_wrong_content_claim.xml > > > Will attach template to reproduce. Noticed this will testing the patches for > NIFI-1634. The flow runs and 11 outputs are produced on the queue. If you > do the queue listing you can try to view content but it sees the full object > size of the original claim it appears so it shows the full object. It shows > the proper size on the attributes but then when going to view content it sees > the original/too large size. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (NIFI-1656) Kite processor scanner usage presumes a particular locale
[ https://issues.apache.org/jira/browse/NIFI-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15204143#comment-15204143 ] ASF GitHub Bot commented on NIFI-1656: -- Github user apiri commented on the pull request: https://github.com/apache/nifi/pull/292#issuecomment-199261919 Yeah, can certainly figure something out with the build matrix. > Kite processor scanner usage presumes a particular locale > - > > Key: NIFI-1656 > URL: https://issues.apache.org/jira/browse/NIFI-1656 > Project: Apache NiFi > Issue Type: Bug > Environment: Windows 7 pro, maven 3.3.9, Java 8 >Reporter: Pierre Villard >Assignee: Tony Kurc > > This is a JIRA which spawned from the discussion/review efforts folks did on > NIFI-1651. > Sorry for the delay... I am on a different computer than usual and forgot to > check the git property. Did a full clone again (so slow with airport wifi...) > and checked the schema (looks OK to me). The git property solved most of the > issues, but some are remaining: > Running org.apache.nifi.processors.kite.TestAvroRecordConverter > Tests run: 4, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.377 sec <<< > FAILURE! - in org.apache.nifi.processors.kite.TestAvroRecordConverter > testDefaultConversion(org.apache.nifi.processors.kite.TestAvroRecordConverter) > Time elapsed: 0.011 sec <<< ERROR! > org.apache.nifi.processors.kite.AvroRecordConverter$AvroConversionException: > Cannot convert 5.5 to double > at > org.apache.nifi.processors.kite.AvroRecordConverter.convertData(AvroRecordConverter.java:246) > at > org.apache.nifi.processors.kite.AvroRecordConverter.convert(AvroRecordConverter.java:170) > at > org.apache.nifi.processors.kite.TestAvroRecordConverter.testDefaultConversion(TestAvroRecordConverter.java:98) > Running org.apache.nifi.processors.kite.TestConfigurationProperty > Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.849 sec - > in org.apache.nifi.processors.kite.TestConfigurationProperty > Running org.apache.nifi.processors.kite.TestConvertAvroSchema > Tests run: 2, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 0.22 sec <<< > FAILURE! - in org.apache.nifi.processors.kite.TestConvertAvroSchema > testBasicConversion(org.apache.nifi.processors.kite.TestConvertAvroSchema) > Time elapsed: 0.21 sec <<< FAILURE! > java.lang.AssertionError: Should convert 2 rows expected:<2> but was:<1> > at org.junit.Assert.fail(Assert.java:88) > at org.junit.Assert.failNotEquals(Assert.java:834) > at org.junit.Assert.assertEquals(Assert.java:645) > at > org.apache.nifi.processors.kite.TestConvertAvroSchema.testBasicConversion(TestConvertAvroSchema.java:78) > Just for the record, the error is because of my local env. This is fixed by > setting the locale to US on the scanner: > scanner.useLocale(java.util.Locale.US); > I don't know if there is a way to set this at a global scale. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
