Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
1,982 Commits 143 Branches 197 Tags 391 MiB
Commit Graph

1982 Commits

Author SHA1 Message Date
joewitt a915534e23 Merge branch 'master' into NIFI-1343 2016-01-01 14:09:23 -05:00
joewitt e16a9a0c68 NIFI-1343 added unit tests to verify behavior 2016-01-01 14:08:46 -05:00
Mark Payne 336a7f56ff This closes #134 2016-01-01 13:53:01 -05:00
Mark Payne 4ab6e3cb3f NIFI-1219: Moved the kafka-tmp directory that gets created to the target directory; added missing license info to beginning of EmbeddedKafkaProducerHelper.java 2016-01-01 13:48:22 -05:00
Oleg Zhurakousky b043d04ecf added embedded Kafka server and tests 2016-01-01 13:48:22 -05:00
Mark Payne 02b325b07e NIFI-1343: Make comparisons case sensitive if configured to do so. This closes #153. 
Signed-off-by: joewitt <joewitt@apache.org>
 2016-01-01 13:34:07 -05:00
Mark Payne 8e031c987b NIFI-1164: Fixed contrib-check issues, log message 2015-12-31 15:37:00 -05:00
Mark Payne 71544cd22b Merge branch 'NIFI-1164' of https://github.com/olegz/nifi into NIFI-1164 2015-12-31 15:22:09 -05:00
James Harrison 03730adb3f NIFI-1338 - Clarifying documentation for InvokeHTTP 
Signed-off-by: joewitt <joewitt@apache.org>
 2015-12-31 13:48:00 -05:00
Lemoda Laim 9bb77163cf NIFI-1334 fixed minor typos in expression-lang-guide documentation 
This closes #152

Signed-off-by: Aldrin Piri <aldrin@apache.org>
 2015-12-29 12:20:21 -05:00
Oleg Zhurakousky 602c4a9639 NIFI-1164 addressed latest PR comments 2015-12-28 16:26:00 -05:00
ricky c45060f703 NIFI-987 Added Riemann (PutRiemann) Reporting 
- Introduced nifi-riemann-bundle for future Riemann backed monitoring

- Added initial PutRiemann processor for writing events to Riemann
  using the Riemann batch client.

	- Values for events are provided using the NiFi expression language
		e.g. Metric -> ${latency.milliseconds:divide(1000)}
 2015-12-28 15:45:11 -05:00
Oleg Zhurakousky 0d09054d9f NIFI-1164 addressed PR comment 
Added isActive check to the StandardControllerServiceNode:280 to ensure that
the IF statement can only have a chance to succeed if service is active. The service
will be indiscriminately deactivated as soon as disable(..) operation is invoked. This itself will
eliminate the race condition discovered by Mark

NIFI-1164 addressed PR comments
fixed the race condition described by Mark during disable call

NIFI-1164 polished javadoc
 2015-12-28 15:16:32 -05:00
Oleg Zhurakousky 909c0decd6 NIFI-1164 Fixed race condition and refactored 
Changed ControllerServiceNode by adding enable(..), disable(..) and isActive() operations. See javadocs for more details in both ControllerServiceNode and StandardControllerServiceNode

Refactored service enable/disable logic in StandardProcessScheduler and StandardControllerServiceNode . Below are some of the notes:
- No need for resetting class loader since its going to derive from the class loader of the service. In other words any classes that aren’t loaded and will be loaded within the scope of the already loaded service will be loaded by the class lower of that service
- No need to control 'scheduleState.isScheduled()’ since the logic has changed to use CAS operation on state update and the service state change is now atomic.
- Removed Thread.sleep(..) and while(true) loop in favor of rescheduling re-tries achieving better thread utilization since the thread that would normally block in Thread.sleep(..) is now reused.
- Added tests and validated that the race condition no longer happening

Added additional logic that allows the initiation of the service disabling while it is in ENABLING state. See javadoc of StandardProcessScheduler.enable/disable for more details.

NIFI-1164 polishing
 2015-12-28 09:22:23 -05:00
Oleg Zhurakousky ebcefaac23 NIFI-1289 reverted new method of NiFiProperties in favor of the localized reflection call in test to refresh properties. 
Reviewed and Amended (added comments) by Tony Kurc (tkurc@apache.org). This closes #150
 2015-12-26 09:58:08 -05:00
Oleg Zhurakousky 2845e93812 NIFI-1289 added support for refreshing properties - Added _getNewInstance()_ operation to NiFiProperties to ensure there is a way to refresh/reload NiFi properties - Fixed javadocs 
Signed-off-by: Bryan Bende <bbende@apache.org>

This closes #142
 2015-12-23 14:30:08 -05:00
Bryan Bende 3189a13da1 NIFI-1328 Explicitly setting the parameters based on type in PutSQL, falling back to setObject() 
This closes #146
 2015-12-23 13:08:56 -05:00
Bryan Bende 8d46041a13 NIFI-1319 Updating JdbcCommon to check meta.isSigned(i) to determine if Avro schema should use a long or int 
Signed-off-by: Bryan Bende <bbende@apache.org>
 2015-12-23 10:03:30 -05:00
joewitt f4ac8d75c5 NIFI-1312-RC1 prepare for next development iteration 2015-12-19 00:41:04 -05:00
joewitt d624ea4866 NIFI-1312-RC1 prepare release nifi-0.4.1-RC1 2015-12-19 00:40:53 -05:00
joewitt fb51483777 Revert "NIFI-1218 upgraded Kafka to 0.9.0.0 client API Tested and validated that it is still compatible with 0.8.* Kafka brokers" 
This reverts commit 37635232c7.
 2015-12-19 00:07:34 -05:00
joewitt 51821e01b6 Revert "NIFI-1218 addressed PR comments" 
This reverts commit 7c87968260.
 2015-12-19 00:06:35 -05:00
Matt Gilman 05395eeca5 NIFI-1294: - Updating exception handling to account for a possible issue in an dependency. 
Signed-off-by: joewitt <joewitt@apache.org>
 2015-12-18 21:33:07 -05:00
Mark Payne 0a58ab47b9 NIFI-1310: Do not yield context when encountering IOException and fixed bug that caused the penalization period for a node not to get set 
Signed-off-by: joewitt <joewitt@apache.org>
 2015-12-18 17:35:46 -05:00
Matt Gilman 43c7ecd221 NIFI-1298: - Addressing too many significant digits in the processor load average and [non]heap utilization. 
Signed-off-by: joewitt <joewitt@apache.org>
 2015-12-18 17:02:40 -05:00
Matt Gilman 0436383f49 NIFI-1286: - Removing provenance option from the Label context menu 
Signed-off-by: joewitt <joewitt@apache.org>
 2015-12-18 17:02:33 -05:00
Mark Payne bef3fc8b40 NIFI-1301: Ensure that when creating site-to-site connection, if remote instance is applying backpressure that we do not block indefinitely waiting for the connection to be made 
Signed-off-by: joewitt <joewitt@apache.org>
 2015-12-18 16:08:41 -05:00
Matt Gilman 608287f9fe NIFI-1309: 
- Addressing issues around remote process groups automatically issuing new account requests.
- Ensuring authorization issues are updated with status refresh.
 2015-12-18 15:57:38 -05:00
Bryan Bende 4249fc943a NIFI-1284 Creating inner class for SiteToSiteClientConfig to fix serialization issue 2015-12-18 13:08:51 -05:00
Mark Payne bd4f31a4c2 NIFI-1279: Take the FlowFile's 1-up id into account for the newest and oldest flowfile prioritizers 
Signed-off-by: joewitt <joewitt@apache.org>
 2015-12-18 12:08:31 -05:00
Mark Payne 1869b44682 NIFI-1285: Used a BufferedInputStream when swapping in data 
Signed-off-by: joewitt <joewitt@apache.org>
 2015-12-18 12:08:23 -05:00
Mark Payne 9ca0f95d06 NIFI-1272: Added unit test to verify behavior 2015-12-18 11:51:42 -05:00
ianwww fa4c5314ca nifi-1272 Fixing a bug in StandardProcessSession.get(int) which returns incorrect number of flowfiles 
Signed-off-by: Mark Payne <markap14@hotmail.com>
 2015-12-18 11:50:39 -05:00
Mike Moser f239be289e NIFI-1302 find dynamic libraries with standard names 
Signed-off-by: joewitt <joewitt@apache.org>
 2015-12-18 09:12:32 -05:00
Matt Burgess 04e9606770 NIFI-1290 Document the need for an explicit Validator for a PropertyDescriptor 
Signed-off-by: joewitt <joewitt@apache.org>
 2015-12-17 09:24:28 -08:00
Oleg Zhurakousky 7c87968260 NIFI-1218 addressed PR comments 
Signed-off-by: jpercivall <joepercivall@yahoo.com>
 2015-12-16 14:25:28 -05:00
Oleg Zhurakousky 37635232c7 NIFI-1218 upgraded Kafka to 0.9.0.0 client API Tested and validated that it is still compatible with 0.8.* Kafka brokers 
Signed-off-by: jpercivall <joepercivall@yahoo.com>
 2015-12-16 14:25:28 -05:00
Matt Gilman b19ff7cf37 NIFI-1215: 
- Only showing the run duration setting when applicable.
- Showing the user a warning that a source processor with a non 0 run duration could lose data when NiFi is restarted.
 2015-12-16 10:53:15 -05:00
Matt Gilman 51b8ecd01b NIFI-1185: 
- Using banners from the NCM rather than replicating to a node.
 2015-12-15 12:51:14 -05:00
Matt Gilman c75b5cfcea NIFI-1119: - Addressing race condition that caused the revision to be checked before the flow was loaded. 
Signed-off-by: jpercivall <joepercivall@yahoo.com>
 2015-12-15 10:05:44 -05:00
Matt Gilman 17be1c2d9f NIFI-1206: - Only enabling the enable/disable toolbar icon when appropriate. 
Signed-off-by: Joseph Percivall <joepercivall@yahoo.com>
 2015-12-14 18:09:11 -05:00
Matt Gilman f9f04439fd NIFI-1119: 
- Also refreshing flow revision when the user clicks Refresh status.
 2015-12-14 12:41:45 -05:00
joewitt a7b09a57c5 NIFI-1122 release vote passess. Merge branch 'NIFI-1122_nifi-0.4.0-RC2' 2015-12-11 17:14:26 -05:00
Matt Gilman 8070a9f1cc NIFI-1104: 
- Using the appropriate attributes based on the content direction.
 2015-12-11 10:59:41 -05:00
joewitt d755e43ec8 NIFI-1122_nifi-0.4.0-RC2prepare for next development iteration 2015-12-08 13:00:10 -05:00
joewitt b66c029090 NIFI-1122_nifi-0.4.0-RC2prepare release nifi-0.4.0-RC2 2015-12-08 12:59:59 -05:00
Aldrin Piri 854c667bd3 NIFI-1211 Adding a .travis.yml to provide CI and adding an exclusion for this file in the RAT check configuration. Adding Travis CI build status graphic to README 2015-12-08 11:13:05 -05:00
Mark Payne fb65cf1235 NIFI-1271: Yield funnels and ports for nifi.bored.yield.duration amount of time if backpressure is applied, as we do when there are no input FlowFiles. Adjusting logic for ContinuallyRunProcessorTask#call in determining if there is appropriate availability for processor relationships. 
Signed-off-by: Aldrin Piri <aldrin@apache.org>
 2015-12-08 10:54:29 -05:00
joewitt ba2719836b NIFI-1267 addressing unused imports due to contrib-check fail 2015-12-07 22:18:31 -05:00
joewitt 10803c81d9 NIFI-1267 needed to remove permissions change 2015-12-07 21:28:07 -05:00