GetTCP Processor as specified in NIFI-2615 #1175
Closed
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
- Removing hidden control characters that were affecting graph styles.
Signed-off-by: jpercivall <joepercivall@yahoo.com>
…a in Kafka processor and related tests to remedy failures in Windows environments. Specifying EOF as an int instead of a byte. Signed-off-by: joewitt <joewitt@apache.org>
…f the incorrect microseconds and using historical modified times to avoid issues with second granularity of HFS+ Signed-off-by: joewitt <joewitt@apache.org>
Corrected spelling/grammatical errors This closes #327. Signed-off-by: Andy LoPresto <alopresto@apache.org>
Signed-off-by: Bryan Bende <bbende@apache.org>
…we are expiring data based on a timestamp instead of disk space usage and we have a file whose timestamp is exactly equal to our threshold for deletion Signed-off-by: joewitt <joewitt@apache.org>
… testing to avoid conflicts Signed-off-by: joewitt <joewitt@apache.org>
This closes #246. Signed-off-by: Andy LoPresto <alopresto@apache.org>
This closes #224. Signed-off-by: Aldrin Piri <aldrin@apache.org>
This closes #341. Signed-off-by: Aldrin Piri <aldrin@apache.org>
Signed-off-by: Joe Skora <jskora@apache.org>
…net and removing attributable elements from test resources. Signed-off-by: joewitt <joewitt@apache.org>
This closes #344. Signed-off-by: Joe Skora <jskora@apache.org>
Corrected button, menu item and icon inconsistencies/errors. Fixed bulleted list formatting error in "Working with Templates" section. This closes #329. Signed-off-by: Andy LoPresto <alopresto@apache.org>
This closes #336. Signed-off-by: Andy LoPresto <alopresto@apache.org>
…java.security.cert.X509Certificate and resolved user-reported ClassCastException when handling client certificates during TLS mutual authentication. Fixed nifi-utils pom.xml comment about additional dependencies. (+5 squashed commits) Squashed commits: [965b766] NIFI-1753 Removed temporary work-around of duplicate certificate conversion util method and added nifi-security-utils as dependency of nifi-utils. [cd35f9b] NIFI-1753 Replaced legacy X.509 certificate declarations with new declarations in SSLSocketChannel and EndpointConnectionPool. Temporary work-around of duplicate certificate conversion util method because nifi-utils cannot depend on nifi-security-utils. [6420897] NIFI-1753 Replaced legacy X.509 certificate declarations with new declarations in PostHTTP. [b9868ef] NIFI-1753 Added convenience method for extracting DN from peer certificate chain in SSL socket (canonical implementation to reduce code duplication and references to legacy certificate implementations). Refactored logic retrieving legacy X.509 certificates with reference to convenience method in NodeProtocolSenderImpl. Replaced logic retrieving legacy X.509 certificates with reference to convenience method in SocketProtocolListener. Cleaned up exception handling in SocketProtocolListener. Replaced legacy X.509 certificate declarations with new declarations in HandleHttpRequest (needs manual test). [e2d1c35] NIFI-1753 Added convenience methods for converting legacy X.509 certificates and abstract certificates to correct X.509 format. Added unit tests for certificate manipulation. Replaced logic retrieving legacy X.509 certificates with new logic in NodeProtocolSenderImpl. Added bcpkix (Bouncy Castle PKI implementation) dependency to nifi-standard-processors pom. This closes #346. Signed-off-by: Andy LoPresto <alopresto@apache.org>
…oved commented blocks. This closes #304. Signed-off-by: Joe Skora <jskora@apache.org>
NIFI-1777 Added unit tests to test processor removal This closes #357
… and permission denied on FetchFile processor NIFI-1724 Added unit test for logging with level This closes #348
This closes #351. Signed-off-by: Andy LoPresto <alopresto@apache.org>
- Adding example topology that creates a full loop between NiFi and Storm. - Bumping Storm to 0.10.0 NIFI-1778 Addressing code review comments This closes #361
NIFI-1785 addressed PR comment NIFI-1785 fixed white spaces This closes #365. Signed-off-by: Bryan Bende <bbende@apache.org>
This closes #367
…tion from server/client sockets. Added logic to detect server/client mode encapsulated in exposed method. Added unit tests for DN extraction. Corrected typo in Javadoc. Switched server/client socket logic for certificate extraction -- when the local socket is in client/server mode, the peer is necessarily the inverse. Fixed unit tests. Moved lazy-loading authentication access out of isDebugEnabled() control branch. This closes #611
…to fingerprint This closes #612 Signed-off-by: jpercivall <joepercivall@yahoo.com>
This closes #616 Signed-off-by: jpercivall <joepercivall@yahoo.com>
fixed imports
This closes #618. Signed-off-by: Mark Payne <markap14@hotmail.com>
…discovered found in NIFI-1157 This closes #664 Signed-off-by: jpercivall <joepercivall@yahoo.com>
This closes #674 Signed-off-by: Koji Kawamura <ijokarumawak@apache.org>
…st lastEventId in SiteToSiteProvenanceReportingTask
- fixed the logging issue NIFI-2444 by ensuring the ProcessLog is added to KafkaPublisher - fixed KafkaPublisher's isAllAcked operation to ensure that it properly reports that the flow file has failed. - added additional test
This closes #780. Signed-off-by: Bryan Bende <bbende@apache.org>
… Hadoop clusters This closes #779.
- Fixed KafkaConsumer's connection block when broker is not available - Fixed Serializer/Deserializer configs in both Consume/Publish Kafka - Added sensitive properties for SSL ket/trust stores NIFI-2322 fixed tests
Signed-off-by: Oleg Zhurakousky <oleg@suitcase.io>
This closes #801 Signed-off-by: James Wing <jvwing@gmail.com>
…nager and performed some refactoring so that we can ensure thread-safety across different components of the application, such as ProcessSession and WriteAheadFlowFile Repository when interacting with the StandardResourceClaimManager. Update DebugFlow to allow it to write to a FlowFile multiple times, which exposes the concurrency bug. Also avoided calling ContentRepository.remove() from ProcessSession whenever the content is no longer needed, as that can cause problems now that the Resource Claim is backing the content claim.
…ce when append() throws an Exception NIFI-2397 merging patch for NIFI-2376 into 0.x branch This closes #844.
… to ModifyBytes processor to allow deletion of all flow file content. * Removed @ignore annotation on class and unnecessary EOL translation of test data. Because ModifyBytes treat input as binary data, not text, line endings don't matter as long as they byte offsets are calculated correctly. * Replace validator with .allowableValues. This closes #886.
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
This P/R contains the changes to fulfill the main requirements of JIRA NIFI-2615. The extra feature of running this processor in a cluster and avoiding dual processing of messages has not been implemented at this time.