Apache/nifi
1
0
Fork 0
mirror of https://github.com/apache/nifi.git synced 2025-02-08 02:58:43 +00:00
Code Issues Packages Projects Releases Wiki Activity
8,232 Commits 147 Branches 203 Tags
Commit Graph

5741 Commits

Author SHA1 Message Date
Matt Burgess
b554102f4a NIFI-11305: Fix logic to correctly stop CaptureChangeMySQL (#7059) 2023-03-20 16:05:02 -04:00
Mark Bathori
835c95fca0 NIFI-11204: Add configurable retry logic for table commits in PutIceberg processor 
This closes #6976.

Signed-off-by: Peter Turcsanyi <turcsanyi@apache.org>
 2023-03-20 19:24:21 +01:00
simonbence
4a6e6751d5 NIFI-11213 Showing version change in older (pre 1.18.0) contained version flows properly (#7017) 2023-03-20 16:59:05 +01:00
Dustin Rodrigues
c15f47da92
NIFI-11301 Fixed typos in ISPEnrichIP and DistributeLoad 
This closes #7056

Signed-off-by: David Handermann <exceptionfactory@apache.org>
 2023-03-20 08:56:11 -05:00
Mark Bathori
171c2ae670
NIFI-11263: Backported. Add case-insensitive and order independent field mapping to PutIceberg record converter 
This closes #7026.

Signed-off-by: Nandor Soma Abonyi <nsabonyi@apache.org>
 2023-03-17 23:17:38 +01:00
Peter Turcsanyi
916e58a0a9
NIFI-11296 Backported improved code reusability of GRPC modules 
This closes #7053

Signed-off-by: David Handermann <exceptionfactory@apache.org>
 2023-03-17 15:39:52 -05:00
johnAlJunior
f87e7f5478
NIFI-11269 Added snappy-java to nifi-avro-processors 
This closes #7035

Signed-off-by: David Handermann <exceptionfactory@apache.org>
 2023-03-16 08:54:10 -05:00
Joe Gresock
957c9e2931
NIFI-11291: Ensuring exceptional EventIterators are closed in PartitionedEventStore 
This closes #7047

Signed-off-by: David Handermann <exceptionfactory@apache.org>
 2023-03-16 08:27:38 -05:00
exceptionfactory
12774b97fb
NIFI-10792 Replaced PrintStream with OutputStream for Java 8 2023-03-15 17:18:56 -05:00
dan-s1
f7f8c22239
NIFI-10792 Updated ConvertExcelToCSV to handle files over 10 MB 
- Refactored to reduce the cognitive complexity in the onTrigger method
- Added log4j-to-slf4j library and adjusted formatting
- Removed unnecessary graphics2d dependency

This closes #7016

Signed-off-by: David Handermann <exceptionfactory@apache.org>
 2023-03-15 15:26:46 -05:00
Mark Payne
f571d5704e
NIFI-11289: Avoid obtaining read locks on queues when fetching Group Status, except in those few specific situations where it's needed. 
This closes #7046

Signed-off-by: David Handermann <exceptionfactory@apache.org>
 2023-03-15 15:26:44 -05:00
Matt Burgess
9e804fec4e NIFI-11279: Allow event stream processing to continue in CaptureChangeMySQL after sync issue (#7039) 2023-03-14 16:30:41 -04:00
exceptionfactory
7b40dfe440
NIFI-11281 Corrected Accumulo NAR dependencies 
- Set accumulo-core to provided in NAR and Services NAR modules
- Removed unused dependencies

Signed-off-by: Pierre Villard <pierre.villard.fr@gmail.com>

This closes #7042.
 2023-03-14 15:15:55 -05:00
Chris Sampson
63bb245a2a
NIFI-11274 only add @timestamp to PutElasticsearchRecord document if not null 
This closes #7036.

Signed-off-by: Kevin Doran <kdoran@apache.org>
 2023-03-13 14:12:50 -04:00
Peter Turcsanyi
ae24bccfd9
NIFI-11260 Added STS SSL Context Service for AWS Credentials Provider 
This closes #7021

Signed-off-by: David Handermann <exceptionfactory@apache.org>
 2023-03-13 09:42:11 -05:00
Matt Burgess
7843a4a30a
NIFI-5501: Fixed classloader issue leading to multiple abandoned threads (#7031) 2023-03-10 15:43:12 -05:00
exceptionfactory
8511191ad1 NIFI-11261 Added Primary Node State handling to GetAzureEventHub 
- Updated Qpid Proton J from 0.34.0 to 0.34.1

This closes #7023.

Signed-off-by: Peter Turcsanyi <turcsanyi@apache.org>
 2023-03-09 22:33:57 +01:00
Nandor Soma Abonyi
dab3d6bfee
NIFI-11205 Added logging for deprecated Kafka 2_6 Kerberos properties 
- Added Kerberos User Service property to KafkaRecordSink_2_6

This closes #6990

Signed-off-by: David Handermann <exceptionfactory@apache.org>
 2023-03-09 15:25:26 -06:00
exceptionfactory
cc1e5b314b
NIFI-11194 Remove gzip CSS and JS from nifi-web-ui (#6968) 
* NIFI-11194 Removed gzip CSS and JS from nifi-web-ui

* NIFI-11194 Updated comment for static content aggregation

This closes #6968
 2023-03-08 11:10:03 -06:00
Nandor Soma Abonyi
9ee34eeb01 NIFI-11144 Fix failing tests for ConsumeJMS/PublishJMS 
This closes #6930.

Signed-off-by: Tamas Palfy <tpalfy@apache.org>
 2023-03-08 14:43:49 +01:00
Lehel Boér
03625bb679 NIFI-11147 Backport - Fix Java8 compatibility issues. 2023-03-08 14:38:30 +01:00
Lehel Boér
203de77bb9 NIFI-11234: Fix RecordWriter NPE in QuerySalesforceObject 
This closes #6997.

Signed-off-by: Tamas Palfy <tpalfy@apache.org>
 2023-03-08 14:38:30 +01:00
Lehel Boér
61a3ced5cc NIFI-10966: Add option to QuerySalesforceObject to run custom query 
This closes #6794.

Signed-off-by: Tamas Palfy <tpalfy@apache.org>
 2023-03-08 14:38:30 +01:00
Lehel Boér
e0c1f0a89b NIFI-11147: Query all fields in QuerySalesforceObject 
Fix review comments
 2023-03-08 14:38:30 +01:00
Peter Turcsanyi
cdd94eaf72
NIFI-11256 Improved documentation for Azure Event Hubs Processors 
- used the same ordering of 'Event Hub Namespace', 'Event Hub Name' and 'Service Bus Endpoint' properties
- removed "Primary" tag from 'Shared Access Policy Key' property name
- added some notes on clustering and consumer group in the documentation

This closes #7018

Signed-off-by: David Handermann <exceptionfactory@apache.org>
 2023-03-07 15:34:10 -06:00
Joe Gresock
a6687ae71a
NIFI-11247: Using parameterContextName instead of group name when fetching parameters (#7011) 
Merged #7011.

Signed-off-by: Pierre Villard <pierre.villard.fr@gmail.com>
 2023-03-07 19:07:13 +01:00
Nissim Shiman
81aa752265
NIFI-4718 Improved detection of FlowFile V3 in IdentityMimeType 
This closes #7009

Signed-off-by: David Handermann <exceptionfactory@apache.org>
 2023-03-07 09:24:47 -06:00
Lehel Boér
b3242304f8 NIFI-11151: Improving code reusability of DBCP services 
This closes #6935.

Signed-off-by: Peter Turcsanyi <turcsanyi@apache.org>
 2023-03-07 14:48:44 +01:00
Nandor Soma Abonyi
609e25b3aa
NIFI-11249 Deprecated Kafka 2_0 Components 
This closes #7012

Signed-off-by: David Handermann <exceptionfactory@apache.org>
 2023-03-06 08:56:28 -06:00
Robert Kalmar
84569ef907
NIFI-11246 Document differences in GetAzureEventHub and ConsumeAzureEventHub 
This closes #7006

Signed-off-by: David Handermann <exceptionfactory@apache.org>
 2023-03-06 07:59:54 -06:00
Pierre Villard
1b43be6f3c NIFI-11157 - Doc update for scheduling strategy for MergeContent/Record 
This closes #6999.

Signed-off-by: Peter Turcsanyi <turcsanyi@apache.org>
 2023-03-06 12:03:47 +01:00
exceptionfactory
b6c58ed4b2
NIFI-11210 Removed unused import from TestDistributedMapCacheClientService 
- Missed commit from #6994

Signed-off-by: David Handermann <exceptionfactory@apache.org>
 2023-03-03 15:34:08 -06:00
Paul Grey
853586fedb
NIFI-11210 Added read timeout to DistributedMapCacheClientService 
This closes #6994

Co-authored-by: David Handermann <exceptionfactory@apache.org>
Signed-off-by: David Handermann <exceptionfactory@apache.org>
 2023-03-03 15:22:18 -06:00
Joe Gresock
bf75070071
NIFI-11238: Creating missing parameter providers when importing inherited provided contexts 
Signed-off-by: Pierre Villard <pierre.villard.fr@gmail.com>

This closes #7002.
 2023-03-03 22:13:38 +01:00
Robert Kalmar
f7d3b75bcd NIFI-11150 Add Service Account JSON credentials support to Google Pub/Sub Lite procesors 
This closes #6933.

Signed-off-by: Peter Turcsanyi <turcsanyi@apache.org>
 2023-03-03 19:04:39 +01:00
krisztina-zsihovszki
1273152d78 NIFI-11158 PutSalesforceObject processor improvements 
This closes #6959.

Reviewed-by: Lehel <lehel44@hotmail.com>
Reviewed-by: Mark Bathori <bathori.mark@gmail.com>

Signed-off-by: Peter Turcsanyi <turcsanyi@apache.org>
 2023-03-03 18:21:11 +01:00
Lehel
7475232bb0 NIFI-11045: Sensitive dynamic property support for parameterized queries in ExecuteSQL and ExecuteSQLRecord 
This closes #6853.

Signed-off-by: Peter Turcsanyi <turcsanyi@apache.org>
 2023-03-03 18:19:52 +01:00
Lehel
9438eb8b86 NIFI-11190: Added provenance events to GetHubSpot and GetShopify 
This closes #6965.

Signed-off-by: Peter Turcsanyi <turcsanyi@apache.org>
 2023-03-03 18:19:42 +01:00
Nandor Soma Abonyi
b9a0216ee6 NIFI-11173 Add default values to DeleteAzureBlobStorage_v12 
This closes #6945.

Signed-off-by: Peter Turcsanyi <turcsanyi@apache.org>
 2023-03-03 18:19:29 +01:00
krisztina-zsihovszki
20914c1af9 NIFI-11146 Proxy usage in BoxFile processors 
This closes #6932.

Signed-off-by: Peter Turcsanyi <turcsanyi@apache.org>
 2023-03-03 18:19:14 +01:00
Mark Bathori
85b36cac60 NIFI-11124: Add hadoop.file.url attribute to HDFS processors 
This closes #6916.

Signed-off-by: Peter Turcsanyi <turcsanyi@apache.org>
 2023-03-03 18:19:04 +01:00
exceptionfactory
88d2c03b37 NIFI-11245 Corrected reducing Maximum Thread Count while running (#7005) 
- Corrected implementation to allow reducing Maximum Thread Count below the default of 10
 2023-03-03 11:38:00 -05:00
Matthew Burgess
be4d2d4e1c NIFI-11094: Allow CaptureChangeMySQL to send multiple events per FlowFile 
This closes #6907.

Co-authored-by: Tamas Palfy <tpalfy@apache.org>

Signed-off-by: Tamas Palfy <tpalfy@apache.org>
 2023-03-03 13:09:38 +01:00
Mark Payne
51577ff20a
NIFI-11176: When comparing a VersionedConnection with an existing connection, we examined the source component's VersionedComponentId. But the existing component may not have a VersionedComponentId. We should only be comparing these if they are populated 
Signed-off-by: Joe Witt <joewitt@apache.org>
 2023-03-02 11:16:50 -07:00
exceptionfactory
68b7e1aca0
NIFI-11152 Upgraded Splunk SDK from 1.9.1 to 1.9.3 
Signed-off-by: Pierre Villard <pierre.villard.fr@gmail.com>

This closes #6934.
 2023-03-01 15:35:23 -06:00
Mark Bean
443ef1d9e2
NIFI-11134 Added Label auditing to Flow Configuration History 
This closes #6949

Co-authored-by: David Handermann <exceptionfactory@apache.org>
Signed-off-by: David Handermann <exceptionfactory@apache.org>
 2023-02-27 13:02:28 -06:00
Matthew Burgess
3e377d0263
NIFI-11209: Include newly-added columns in output for UpdateTable processors when Update Field Names is true 
Signed-off-by: Pierre Villard <pierre.villard.fr@gmail.com>

This closes #6986.
 2023-02-27 14:13:18 +01:00
exceptionfactory
f9d713494f NIFI-11219 Set Qpid Proton J 0.34.0 for Azure EventHubs 
- Overrides Qpid Proton J 0.33.8 from azure-core-amqp 2.8.1 to resolve PROTON-2347

This closes #6988.

Signed-off-by: Peter Turcsanyi <turcsanyi@apache.org>
 2023-02-26 18:37:49 +01:00
Mark Payne
6b15c2544a
NIFI-11192: Ensure that if ports moved between parent/child group in between flow versions that we can properly handle that. Added system tests to verify. 
NIFI-11192: If a failure is encountered when changing the version of a flow from 1 version to another, attempt to rollback the changes instead of just failing with the flow in a bad state
Signed-off-by: Matthew Burgess <mattyb149@apache.org>

This closes #6981
 2023-02-22 15:46:11 -05:00
exceptionfactory
8c65b78ff3 NIFI-11184 Deprecated HashAttribute and CryptographicHashAttribute 
This closes #6956

Signed-off-by: Mike Thomsen <mthomsen@apache.org>
 2023-02-21 20:07:58 -05:00