GitHub user alopresto opened a pull request:
https://github.com/apache/nifi/pull/443
NIFI-1822 ExecuteScript should allow concurrent execution
I have added some unit tests and fixed a few minor things in @mattyb149 's
original contribution ([PR 387](https://github.com/apache/nifi/pull/387)).
At the time I am opening the PR, I am not able to do a complete build on my
system because the Apache Maven repositories are unavailable due to a technical
issue, but all tests in the module with these changes pass, and the checkstyle
and RAT rules pass. I'll re-run the complete build when the repositories are
available.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/alopresto/nifi pr387
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/nifi/pull/443.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 #443
----
commit 23e4f685c3e6a5c83538b7e3e379f1bb1c6002b7
Author: Matt Burgess <[email protected]>
Date: 2016-04-28T13:53:16Z
NIFI-1822: Allow concurrent execution in ExecuteScript
commit fd9120c28bd84a8f88a49798e1290d32c16a024d
Author: Andy LoPresto <[email protected]>
Date: 2016-05-10T23:08:02Z
NIFI-1822 Added unit test skeleton for pooled script processor execution.
commit 8c5ba511283d3ddcbeb56a43240e8640e66a7357
Author: Andy LoPresto <[email protected]>
Date: 2016-05-14T02:03:34Z
NIFI-1822 Added variable max concurrent task field in MockProcessorContext
because it was previously hardcoded to 1. Changed setNumThreads to
setMaxConcurrentTasks to maintain naming convention.
commit 8ab0ce59a408f5090c68a954dc1496de275aded1
Author: Andy LoPresto <[email protected]>
Date: 2016-05-14T02:06:17Z
NIFI-1822 Added for loop to instantiate multiple script engines in queue.
commit 4c174c8ca76f5a9e64aa2bd2469ca2966c90b888
Author: Andy LoPresto <[email protected]>
Date: 2016-05-14T02:06:53Z
NIFI-1822 Added debugging messages to script execution.
commit 12bbe82381fb334ff236db6815ada8a277a782e7
Author: Andy LoPresto <[email protected]>
Date: 2016-05-14T02:07:53Z
NIFI-1822 Moved unit test to correct directory.
Added test script resource which generates flowfile and updates attribute
with current thread.
Added tests for single run, serial run, and pooled run (not complete).
commit bdbc4bab04ae3953087fcfc5192fac19da813e83
Author: Andy LoPresto <[email protected]>
Date: 2016-05-14T02:24:07Z
NIFI-1822 Renamed reference to MockProcessorContext#setNumThreads to
setMaxConcurrentTasks after refactor.
commit 9264428bd8515aa74b73e0a84b9f46c3cd749400
Author: Andy LoPresto <[email protected]>
Date: 2016-05-15T03:12:02Z
NIFI-1822 Removed debugging log statements for script engine queue size.
Added unit tests demonstrating pooled execution timing and thread usage.
commit cb108cd4376c61b391a5d9d3d269d874bb0f65c5
Author: Andy LoPresto <[email protected]>
Date: 2016-05-15T03:21:15Z
NIFI-1822 Added ASF License to unit test.
commit 7c5acc1ee28b711bb4878371a31ddb267fae79bd
Author: Andy LoPresto <[email protected]>
Date: 2016-05-15T03:37:05Z
NIFI-1822 Removed trailing whitespace to conform with checkstyle rules.
commit 612a7599e240d2378e94c31abf2f2525b45ce9da
Author: Andy LoPresto <[email protected]>
Date: 2016-05-15T03:37:38Z
NIFI-1822 Removed unused variable in unit test.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
