9750cf2fcd
NIFI-3709: Added XMLENC to L&N file. Moved inclusion of nifi-atlas-nar to a profile named include-atlas. This closes #2335 .
2017-12-18 12:24:09 -05:00
fc73c60924
NIFI-3709: Export NiFi flow dataset lineage to Apache Atlas
2017-12-18 12:23:58 -05:00
44a3ac9eff
NIFI-4706 - This closes #2348 . Bump ParCEFone version
...
Signed-off-by: joewitt <joewitt@apache.org>
2017-12-18 10:13:34 -05:00
406db4867a
NIFI-4702: When we check the next line for matches in Grok Reader, store the Map that is returned so that we don't have to re-evaluate the regexes the next time that nextRecord() is called
...
Signed-off-by: Matthew Burgess <mattyb149@apache.org>
This closes #2349
2017-12-18 09:41:05 -05:00
f50a07ec88
NIFI-4655: This closes #2347 . Fixed NPE in the InvokeHTTP processor caused when an SSLContextService was assigned without keystore properties
...
- Added check for keystore properties and only initialized keystore when necessary.
- Added TestInvokeHttpTwoWaySSL test class to test with two-way SSL
- Modified TestInvokeHttpSSL to test with one-way SSL
Signed-off-by: joewitt <joewitt@apache.org>
2017-12-18 09:11:53 -05:00
9217e2fc63
NIFI-4619: Enable expression language on AWSCredentialsProviderControllerService properties
...
Signed-off-by: James Wing <jvwing@gmail.com>
This closes #2344 .
2017-12-17 12:51:34 -08:00
463dcd8812
NIFI-4629: This closes #2345 . Put flowfiles without the grouping attribute in the default group
...
Signed-off-by: joewitt <joewitt@apache.org>
2017-12-15 10:35:13 -05:00
15eeb22116
NIFI-4479 Added DeleteMongo processor.
...
Signed-off-by: Matthew Burgess <mattyb149@apache.org>
This closes #2295
2017-12-14 20:18:20 -05:00
a12abc24e5
NIFI-4683 This closes #2339 . added a few missing license/notice entries for spark controller service and processor nars, removed dead code, cleaned up logging. This sign off is relevant to commit 52684c3ec3b7c0ee28c6cf64cfd178976996615a
...
Signed-off-by: joewitt <joewitt@apache.org>
2017-12-14 16:23:41 -05:00
2192138b06
NIFI-4683: Add ability to execute Spark jobs via Livy
2017-12-14 16:23:41 -05:00
d543cfde25
NIFI-4675 Lifted restriction on demarcator and kafka.key usage together. This closes #2326 .
2017-12-14 15:15:13 -05:00
48ae4be015
NIFI-4475 Changing the get(batchSize) method in StandardProcessSession so that it checks all connections before returning nothing. This closes #2337 .
2017-12-14 15:08:55 -05:00
57947d64cd
NIFI-4694: Make PutSFTP Disable Directory Listing a normal property. This closes #2338 .
2017-12-14 15:05:40 -05:00
b8375a681a
NIFI-3377: NiFi RPG errors when switching between transport protocols. This closes #2340 .
2017-12-14 15:02:40 -05:00
2608351113
NIFI-4667 Fix LDAP Sync Interval
...
Corrects time unit conversion for the Sync Interval config property
for LdapUserGroupProvider in authorizers.xml.
Also enforces a minimum value of 10 secs for the Sync Interval to help
catch unintentional misconfigurations, for example users upgrading
from previous versions, where tiny Sync Interval values could be set
as a workaround for NIFI-4667.
This closes #2341
2017-12-14 15:01:52 -05:00
d7347a2dc3
NIFI-4644 Fixed LookupService API to allow for more than String/String lookup pairs. This closes #2304 .
2017-12-13 16:04:23 -05:00
bfe92b9000
NIFI-3970 added changes from a code review.
...
Signed-off-by: Matthew Burgess <mattyb149@apache.org>
This closes #2334
2017-12-11 19:16:34 -05:00
63840377dd
NIFI-3970: Add CSVRecordLookupService
2017-12-11 19:14:27 -05:00
59d3c64195
NIFI-4636 Updated GetMongo to support expression language on limit, results per flowfile and batch fields.
...
NIFI-4636: Added unit tests
Signed-off-by: Matthew Burgess <mattyb149@apache.org>
This closes #2289
2017-12-11 12:49:42 -05:00
f772f2f093
NIFI-4671: This closes #2328 . Ensure that Avro Schemas that are created properly denote fields as being nullable iff the schemas says they are, for non-top-level fields
...
Signed-off-by: joewitt <joewitt@apache.org>
2017-12-11 11:46:15 -05:00
600586d6be
NIFI-3366 This closes #2332 . Added parent/child flowfile relationship between the incoming flowfile and the files that are moved from the input directory to the output directory.
...
Updated to allow tests to check for evaluation of properties that support expression language.
Fixed bug with changeOwner attempting to operate on original file rather than the moved/copied file.
Added license header to MoveHDFSTest.java
Added test for moving a directory of files that contains a subdir, ensuring non-recursive behavior
Added to the description of the processor that it is non-recursive when a directory is used as input.
Added RAT exclude for test resource .dotfile to pom.xml
Signed-off-by: joewitt <joewitt@apache.org>
2017-12-11 08:41:36 -05:00
3731fbee88
NIFI-3366 MoveHDFS processor supports expressions language for input and copy operations
...
Signed-off-by: Jeff Storck <jtswork@gmail.com>
2017-12-11 08:41:25 -05:00
c138987bb4
NIFI-4656, NIFI-4680: This closes #2330 . Fix error handling in consume/publish kafka processors. Address issue with HortonworksSchemaRegistry throwing RuntimeException when it should be IOException. Fixed bug in ConsumeerLease/ConsumKafkaRecord that caused it to report too many records received
...
Signed-off-by: joewitt <joewitt@apache.org>
2017-12-08 16:01:14 -05:00
1fc1d38fd8
NIFI-4562: This closes #2331 . If an Exception is thrown when merging FlowFiles, ensure that we remove the 'bundle' flowfile before exiting the method
...
Signed-off-by: joewitt <joewitt@apache.org>
2017-12-08 15:35:36 -05:00
3b74d2ddad
NIFI-4633: This closes #2327 . Ensure that everywhere that a FlowFile is passed into ProcessSession that we used the most up-to-date version of it
...
Ensure that when ProcessSession.clone(FlowFile) is called, we obtain the most recent version of the FlowFile before attempting to obtain FlowFile size.
Signed-off-by: joewitt <joewitt@apache.org>
2017-12-08 15:30:01 -05:00
113ad5ecfa
NIFI-4639: Updated PublishKafka 1.0 processor to use a fresh writer for each output record as well. This closes #2292 .
2017-12-08 09:14:17 -05:00
c9cc76b5c8
NIFI-4639: fresh writer for each output record
2017-12-08 08:39:22 -05:00
8e6649ba15
NIFI-2776: This closes #2315 . When joining a cluster, if a processor is stopping but cluster indicates that processor should be running, cause processor to start when its last thread finishes
...
Signed-off-by: joewitt <joewitt@apache.org>
2017-12-07 15:45:18 -05:00
a774f1df69
NIFI-4673 changed offending tests to be integration tests and fixed travis config to run the build only once and during appropriate script phase instead of install. Reviewed by Bende.
2017-12-06 16:13:42 -05:00
7e61c6333c
NIFI-2375 updated to latest Tika across codebase. Fixed
...
tests and updated L&N for Tika parsers. Turned unstable grpc test to IT
test. Updated deps due to Tika testing findings. This closes #2320
2017-12-06 11:53:15 -05:00
cdc1facf39
NIFI-4664, NIFI-4662, NIFI-4660, NIFI-4659 moved tests which are timing/threading/network dependent and brittle to integration tests and un-ignored tests that are IT. Updated travis to reduce impact on infra and appveyor now skips test runs so is just to prove build works on windows. This closes #2319
...
squash
2017-12-06 10:53:09 -05:00
a0f568b69c
NIFI-4661 no longer building and including the gprc elements by default. This closes #2318
2017-12-05 14:26:05 -05:00
9736cb9d33
NIFI-4663 This closes #2317 . Change log for document not found from warn to debug as we have a NOT_FOUND relationship
...
Signed-off-by: joewitt <joewitt@apache.org>
2017-12-05 12:44:54 -05:00
00b11e82b7
NIFI-4600: This closes #2312 . Added nifi-kafka-1-0-nar and nifi-kafka-1-0-processors modules
...
Signed-off-by: joewitt <joewitt@apache.org>
2017-12-04 16:51:59 -05:00
2c68d0e098
NIFI-4652 updating to latest apache version and updating key maven plugins, fixing versions for grpc to avoid extranous build dir, correcting checkstyle issues, resolving build problem with incorrect usage of activeByDefault in maven. Key change is now for the 'dir-only' profile it is now activated via a system property -Ddir-only instead of profile. No other activeByDefault profiles exist except to minifi the javascript but that usage is acceptible as-is. This closes #2313
2017-12-04 09:59:23 -05:00
596a329dc7
NIFI-4653: Fixed bug where Process Group DTO was not containing variables when created with the #createConciseProcessGroup method. This closes #2314 .
2017-12-04 09:31:54 -05:00
a458a139b3
NIFI-4650 This closes #2308 . Added independent hadoop.http.core.version property
...
This closes #2308
Signed-off-by: joewitt <joewitt@apache.org>
2017-12-02 12:58:29 -05:00
9fdab10c7c
NIFI-4645 now being very specific to include if not ppc. This closes #2309
2017-12-01 12:47:40 -05:00
103a345e85
NIFI-4628 Add support for ListS3Version2 API
...
Signed-off-by: James Wing <jvwing@gmail.com>
This closes #2300 .
2017-11-30 21:53:05 -08:00
dd981e87dd
NIFI-4642 updated tests to be more tolerant/variable to different system speeds. Many of these should be integration tests and not unit tests. This closes #2303 .
2017-11-30 14:59:58 -05:00
45df23b1e0
NIFI-4607, NIFI-3975, NIFI-4602, NIFI-4606: This closes #2272 . Fixed bug in TailFile that caused new Primary Node to not pull current Clustered State when File Location was set to Remote. Fixed bug that caused TailFile to occasionally become 'stuck' when the file it is tailing is renamed and a new file is created with the same name. Removed the 'Rolling Strategy' property from TailFile because it is not actually used in the processor anymore. Deleted MonitorMemoryTest because the unit test was testing the behavior of FlowController more than the behavior of the reporting task itself and in order to do so had a dependency in the pom.xml on nifi-framework-core, which means that it no longer compiles when FlowController is modified.
...
Signed-off-by: joewitt <joewitt@apache.org>
2017-11-30 11:10:46 -05:00
3b15ed855c
NIFI-4559: Add non-zero status relationship to ExecuteStreamCommand
...
NIFI-4559: Removed Penalize Non-zero Status property and updated doc per review comments
Signed-off-by: Matthew Burgess <mattyb149@apache.org>
This closes #2246
2017-11-30 10:12:00 -05:00
33281300cd
NIFI-4597 This closes #2283 . correcting imports, checkstyle issues, and adding validator
...
Add a property to override HTTP return code in ListenHTTP processor
Signed-off-by: joewitt <joewitt@apache.org>
2017-11-30 10:02:32 -05:00
3df3ff6c61
NIFI-4646: This closes #2306 .
...
- Ensuring the reason behind the SchemaNotFoundException is reported when interacting with the configured SchemaRegistry.
Signed-off-by: joewitt <joewitt@apache.org>
2017-11-30 09:02:21 -05:00
9ea9996b36
NIFI-4645 make sure the grpc bundle is only built and nar included IF not building on powerpc arch. This closes #2305
2017-11-29 13:33:17 -05:00
73fa0429f0
NIFI-4640 Sub source w/ . in nifi.sh to be POSIX compliant
...
This closes #2302
Signed-off-by: Aldrin Piri <aldrin@apache.org>
2017-11-28 20:02:58 -05:00
cec2764140
NIFI-4632: Add the local hostname to the list of validated host headers
...
This closes #2288 .
Signed-off-by: Andy LoPresto <alopresto.apache@gmail.com>
2017-11-27 19:08:29 -08:00
ecb9c5e929
NIFI-4445 on fast machines the engine ran for 0 millis so the test needs to allow this case
...
Signed-off-by: Matthew Burgess <mattyb149@apache.org>
This closes #2296
2017-11-27 11:47:54 -05:00
9766558cab
NIFI-4526: Allow Target URI's of Remote Process Groups to be changed. This closes #2298
2017-11-27 10:50:32 -05:00
16a23f5a0f
NIFI-4589: Allow multiple keys in FetchDistributedMapCache, add subMap operation to API
...
Signed-off-by: Mike Moser <mosermw@apache.org>
This closes #2260 .
2017-11-21 20:13:35 +00:00
Mark Payne
Koji Kawamura
trixpan
Josh Anderton
Marco Gaido
Mike Thomsen
joewitt
Matthew Burgess
jknulst
Joe Percivall
Kevin Doran
Jeff Storck
Gray Gwizdz
matthew-silverman
William Griffiths
Joey Frazee
aburkard
sbouchex
Matt Gilman