[02/17] nifi git commit: NIFI-1748 removed un-used test data

2016-04-18 Thread aldrin 
NIFI-1748 removed un-used test data

This closes #344.

Signed-off-by: Joe Skora 


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/5e0476c3
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/5e0476c3
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/5e0476c3

Branch: refs/heads/NIFI-1654
Commit: 5e0476c364fe0ffcdb8a6598558217a8c4c4aaca
Parents: bfa8e2b
Author: Oleg Zhurakousky 
Authored: Sat Apr 9 17:24:37 2016 -0400
Committer: Joe Skora 
Committed: Mon Apr 11 20:00:57 2016 -0400

--
 .../processors/kafka/KafkaPublisherTest.java| 44 
 1 file changed, 7 insertions(+), 37 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/nifi/blob/5e0476c3/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
--
diff --git 
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
 
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
index 3e582a6..46507d2 100644
--- 
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
+++ 
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
@@ -43,13 +43,6 @@ import kafka.javaapi.consumer.ConsumerConnector;
 
 public class KafkaPublisherTest {
 
-private static final String sampleData = "The true sign of intelligence is 
not knowledge but imagination.\n"
-+ "It's not that I'm so smart, it's just that I stay with problems 
longer.\n"
-+ "The only source of knowledge is experience.\n"
-+ "Only two things are infinite, the universe and human stupidity, 
and I'm not sure about the former.\n";
-
-private static final String sampleData2 = "foo|bar|baz";
-
 private static EmbeddedKafka kafkaLocal;
 
 private static EmbeddedKafkaProducerHelper producerHelper;
@@ -69,7 +62,7 @@ public class KafkaPublisherTest {
 
 @Test
 public void validateSuccessfulSendAsWhole() throws Exception {
-InputStream fis = new 
ByteArrayInputStream(sampleData.getBytes(StandardCharsets.UTF_8));
+InputStream fis = new ByteArrayInputStream("Hello 
Kafka".getBytes(StandardCharsets.UTF_8));
 String topicName = "validateSuccessfulSendAsWhole";
 
 Properties kafkaProperties = this.buildProducerProperties();
@@ -93,7 +86,8 @@ public class KafkaPublisherTest {
 
 @Test
 public void validateSuccessfulSendAsDelimited() throws Exception {
-InputStream fis = new 
ByteArrayInputStream(sampleData.getBytes(StandardCharsets.UTF_8));
+InputStream fis = new ByteArrayInputStream(
+"Hello Kafka 1\nHello Kafka 2\nHello Kafka 3\nHello Kafka 
4\n".getBytes(StandardCharsets.UTF_8));
 String topicName = "validateSuccessfulSendAsDelimited";
 
 Properties kafkaProperties = this.buildProducerProperties();
@@ -118,33 +112,9 @@ public class KafkaPublisherTest {
 }
 
 @Test
-public void validateSuccessfulSendAsDelimited2() throws Exception {
-InputStream fis = new 
ByteArrayInputStream(sampleData2.getBytes(StandardCharsets.UTF_8));
-String topicName = "validateSuccessfulSendAsDelimited2";
-
-Properties kafkaProperties = this.buildProducerProperties();
-KafkaPublisher publisher = new KafkaPublisher(kafkaProperties);
-
-SplittableMessageContext messageContext = new 
SplittableMessageContext(topicName, null, "|".getBytes(StandardCharsets.UTF_8));
-
-publisher.publish(messageContext, fis, null, 2000);
-publisher.close();
-
-ConsumerIterator iter = this.buildConsumer(topicName);
-assertNotNull(iter.next());
-assertNotNull(iter.next());
-assertNotNull(iter.next());
-try {
-iter.next();
-fail();
-} catch (ConsumerTimeoutException e) {
-// that's OK since this is the Kafka mechanism to unblock
-}
-}
-
-@Test
 public void validateSuccessfulReSendOfFailedSegments() throws Exception {
-InputStream fis = new 
ByteArrayInputStream(sampleData.getBytes(StandardCharsets.UTF_8));
+InputStream fis = new ByteArrayInputStream(
+"Hello Kafka 1\nHello Kafka 2\nHello Kafka 3\nHello Kafka 
4\n".getBytes(StandardCharsets.UTF_8));
 String topicName = "validateSuccessfulReSendOfFailedSegments";
 
 Properties kafkaProperties = this.buildProducerProperties();
@@ -160,8

nifi git commit: NIFI-1748 removed un-used test data

2016-04-12 Thread joewitt 
Repository: nifi
Updated Branches:
  refs/heads/support/nifi-0.6.x abbd21531 -> 5ec79e341


NIFI-1748 removed un-used test data

This closes #344.

Signed-off-by: Joe Skora 


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/5ec79e34
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/5ec79e34
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/5ec79e34

Branch: refs/heads/support/nifi-0.6.x
Commit: 5ec79e341a03043a607a5f174df433e115b140b4
Parents: abbd215
Author: Oleg Zhurakousky 
Authored: Sat Apr 9 17:24:37 2016 -0400
Committer: joewitt 
Committed: Tue Apr 12 10:07:31 2016 -0400

--
 .../processors/kafka/KafkaPublisherTest.java| 44 
 1 file changed, 7 insertions(+), 37 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/nifi/blob/5ec79e34/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
--
diff --git 
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
 
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
index 3e582a6..46507d2 100644
--- 
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
+++ 
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
@@ -43,13 +43,6 @@ import kafka.javaapi.consumer.ConsumerConnector;
 
 public class KafkaPublisherTest {
 
-private static final String sampleData = "The true sign of intelligence is 
not knowledge but imagination.\n"
-+ "It's not that I'm so smart, it's just that I stay with problems 
longer.\n"
-+ "The only source of knowledge is experience.\n"
-+ "Only two things are infinite, the universe and human stupidity, 
and I'm not sure about the former.\n";
-
-private static final String sampleData2 = "foo|bar|baz";
-
 private static EmbeddedKafka kafkaLocal;
 
 private static EmbeddedKafkaProducerHelper producerHelper;
@@ -69,7 +62,7 @@ public class KafkaPublisherTest {
 
 @Test
 public void validateSuccessfulSendAsWhole() throws Exception {
-InputStream fis = new 
ByteArrayInputStream(sampleData.getBytes(StandardCharsets.UTF_8));
+InputStream fis = new ByteArrayInputStream("Hello 
Kafka".getBytes(StandardCharsets.UTF_8));
 String topicName = "validateSuccessfulSendAsWhole";
 
 Properties kafkaProperties = this.buildProducerProperties();
@@ -93,7 +86,8 @@ public class KafkaPublisherTest {
 
 @Test
 public void validateSuccessfulSendAsDelimited() throws Exception {
-InputStream fis = new 
ByteArrayInputStream(sampleData.getBytes(StandardCharsets.UTF_8));
+InputStream fis = new ByteArrayInputStream(
+"Hello Kafka 1\nHello Kafka 2\nHello Kafka 3\nHello Kafka 
4\n".getBytes(StandardCharsets.UTF_8));
 String topicName = "validateSuccessfulSendAsDelimited";
 
 Properties kafkaProperties = this.buildProducerProperties();
@@ -118,33 +112,9 @@ public class KafkaPublisherTest {
 }
 
 @Test
-public void validateSuccessfulSendAsDelimited2() throws Exception {
-InputStream fis = new 
ByteArrayInputStream(sampleData2.getBytes(StandardCharsets.UTF_8));
-String topicName = "validateSuccessfulSendAsDelimited2";
-
-Properties kafkaProperties = this.buildProducerProperties();
-KafkaPublisher publisher = new KafkaPublisher(kafkaProperties);
-
-SplittableMessageContext messageContext = new 
SplittableMessageContext(topicName, null, "|".getBytes(StandardCharsets.UTF_8));
-
-publisher.publish(messageContext, fis, null, 2000);
-publisher.close();
-
-ConsumerIterator iter = this.buildConsumer(topicName);
-assertNotNull(iter.next());
-assertNotNull(iter.next());
-assertNotNull(iter.next());
-try {
-iter.next();
-fail();
-} catch (ConsumerTimeoutException e) {
-// that's OK since this is the Kafka mechanism to unblock
-}
-}
-
-@Test
 public void validateSuccessfulReSendOfFailedSegments() throws Exception {
-InputStream fis = new 
ByteArrayInputStream(sampleData.getBytes(StandardCharsets.UTF_8));
+InputStream fis = new ByteArrayInputStream(
+"Hello Kafka 1\nHello Kafka 2\nHello Kafka 3\nHello Kafka 
4\n".getBytes(StandardCharsets.UTF_8));
 String topicName =

nifi git commit: NIFI-1748 removed un-used test data

2016-04-11 Thread jskora 
Repository: nifi
Updated Branches:
  refs/heads/0.x bfa8e2bd6 -> 5e0476c36


NIFI-1748 removed un-used test data

This closes #344.

Signed-off-by: Joe Skora 


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/5e0476c3
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/5e0476c3
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/5e0476c3

Branch: refs/heads/0.x
Commit: 5e0476c364fe0ffcdb8a6598558217a8c4c4aaca
Parents: bfa8e2b
Author: Oleg Zhurakousky 
Authored: Sat Apr 9 17:24:37 2016 -0400
Committer: Joe Skora 
Committed: Mon Apr 11 20:00:57 2016 -0400

--
 .../processors/kafka/KafkaPublisherTest.java| 44 
 1 file changed, 7 insertions(+), 37 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/nifi/blob/5e0476c3/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
--
diff --git 
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
 
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
index 3e582a6..46507d2 100644
--- 
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
+++ 
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
@@ -43,13 +43,6 @@ import kafka.javaapi.consumer.ConsumerConnector;
 
 public class KafkaPublisherTest {
 
-private static final String sampleData = "The true sign of intelligence is 
not knowledge but imagination.\n"
-+ "It's not that I'm so smart, it's just that I stay with problems 
longer.\n"
-+ "The only source of knowledge is experience.\n"
-+ "Only two things are infinite, the universe and human stupidity, 
and I'm not sure about the former.\n";
-
-private static final String sampleData2 = "foo|bar|baz";
-
 private static EmbeddedKafka kafkaLocal;
 
 private static EmbeddedKafkaProducerHelper producerHelper;
@@ -69,7 +62,7 @@ public class KafkaPublisherTest {
 
 @Test
 public void validateSuccessfulSendAsWhole() throws Exception {
-InputStream fis = new 
ByteArrayInputStream(sampleData.getBytes(StandardCharsets.UTF_8));
+InputStream fis = new ByteArrayInputStream("Hello 
Kafka".getBytes(StandardCharsets.UTF_8));
 String topicName = "validateSuccessfulSendAsWhole";
 
 Properties kafkaProperties = this.buildProducerProperties();
@@ -93,7 +86,8 @@ public class KafkaPublisherTest {
 
 @Test
 public void validateSuccessfulSendAsDelimited() throws Exception {
-InputStream fis = new 
ByteArrayInputStream(sampleData.getBytes(StandardCharsets.UTF_8));
+InputStream fis = new ByteArrayInputStream(
+"Hello Kafka 1\nHello Kafka 2\nHello Kafka 3\nHello Kafka 
4\n".getBytes(StandardCharsets.UTF_8));
 String topicName = "validateSuccessfulSendAsDelimited";
 
 Properties kafkaProperties = this.buildProducerProperties();
@@ -118,33 +112,9 @@ public class KafkaPublisherTest {
 }
 
 @Test
-public void validateSuccessfulSendAsDelimited2() throws Exception {
-InputStream fis = new 
ByteArrayInputStream(sampleData2.getBytes(StandardCharsets.UTF_8));
-String topicName = "validateSuccessfulSendAsDelimited2";
-
-Properties kafkaProperties = this.buildProducerProperties();
-KafkaPublisher publisher = new KafkaPublisher(kafkaProperties);
-
-SplittableMessageContext messageContext = new 
SplittableMessageContext(topicName, null, "|".getBytes(StandardCharsets.UTF_8));
-
-publisher.publish(messageContext, fis, null, 2000);
-publisher.close();
-
-ConsumerIterator iter = this.buildConsumer(topicName);
-assertNotNull(iter.next());
-assertNotNull(iter.next());
-assertNotNull(iter.next());
-try {
-iter.next();
-fail();
-} catch (ConsumerTimeoutException e) {
-// that's OK since this is the Kafka mechanism to unblock
-}
-}
-
-@Test
 public void validateSuccessfulReSendOfFailedSegments() throws Exception {
-InputStream fis = new 
ByteArrayInputStream(sampleData.getBytes(StandardCharsets.UTF_8));
+InputStream fis = new ByteArrayInputStream(
+"Hello Kafka 1\nHello Kafka 2\nHello Kafka 3\nHello Kafka 
4\n".getBytes(StandardCharsets.UTF_8));
 String topicName = "validateSuccessfulReSendOfFailedSegments";

nifi git commit: NIFI-1748 removed un-used test data

2016-04-11 Thread jskora 
Repository: nifi
Updated Branches:
  refs/heads/master e76a75c26 -> bd1f0a82a


NIFI-1748 removed un-used test data

This closes #344.

Signed-off-by: Joe Skora 


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/bd1f0a82
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/bd1f0a82
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/bd1f0a82

Branch: refs/heads/master
Commit: bd1f0a82aedb6939a74a6d9428e623d8ff83b863
Parents: e76a75c
Author: Oleg Zhurakousky 
Authored: Sat Apr 9 17:24:37 2016 -0400
Committer: Joe Skora 
Committed: Mon Apr 11 19:50:22 2016 -0400

--
 .../processors/kafka/KafkaPublisherTest.java| 44 
 1 file changed, 7 insertions(+), 37 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/nifi/blob/bd1f0a82/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
--
diff --git 
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
 
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
index 3e582a6..46507d2 100644
--- 
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
+++ 
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
@@ -43,13 +43,6 @@ import kafka.javaapi.consumer.ConsumerConnector;
 
 public class KafkaPublisherTest {
 
-private static final String sampleData = "The true sign of intelligence is 
not knowledge but imagination.\n"
-+ "It's not that I'm so smart, it's just that I stay with problems 
longer.\n"
-+ "The only source of knowledge is experience.\n"
-+ "Only two things are infinite, the universe and human stupidity, 
and I'm not sure about the former.\n";
-
-private static final String sampleData2 = "foo|bar|baz";
-
 private static EmbeddedKafka kafkaLocal;
 
 private static EmbeddedKafkaProducerHelper producerHelper;
@@ -69,7 +62,7 @@ public class KafkaPublisherTest {
 
 @Test
 public void validateSuccessfulSendAsWhole() throws Exception {
-InputStream fis = new 
ByteArrayInputStream(sampleData.getBytes(StandardCharsets.UTF_8));
+InputStream fis = new ByteArrayInputStream("Hello 
Kafka".getBytes(StandardCharsets.UTF_8));
 String topicName = "validateSuccessfulSendAsWhole";
 
 Properties kafkaProperties = this.buildProducerProperties();
@@ -93,7 +86,8 @@ public class KafkaPublisherTest {
 
 @Test
 public void validateSuccessfulSendAsDelimited() throws Exception {
-InputStream fis = new 
ByteArrayInputStream(sampleData.getBytes(StandardCharsets.UTF_8));
+InputStream fis = new ByteArrayInputStream(
+"Hello Kafka 1\nHello Kafka 2\nHello Kafka 3\nHello Kafka 
4\n".getBytes(StandardCharsets.UTF_8));
 String topicName = "validateSuccessfulSendAsDelimited";
 
 Properties kafkaProperties = this.buildProducerProperties();
@@ -118,33 +112,9 @@ public class KafkaPublisherTest {
 }
 
 @Test
-public void validateSuccessfulSendAsDelimited2() throws Exception {
-InputStream fis = new 
ByteArrayInputStream(sampleData2.getBytes(StandardCharsets.UTF_8));
-String topicName = "validateSuccessfulSendAsDelimited2";
-
-Properties kafkaProperties = this.buildProducerProperties();
-KafkaPublisher publisher = new KafkaPublisher(kafkaProperties);
-
-SplittableMessageContext messageContext = new 
SplittableMessageContext(topicName, null, "|".getBytes(StandardCharsets.UTF_8));
-
-publisher.publish(messageContext, fis, null, 2000);
-publisher.close();
-
-ConsumerIterator iter = this.buildConsumer(topicName);
-assertNotNull(iter.next());
-assertNotNull(iter.next());
-assertNotNull(iter.next());
-try {
-iter.next();
-fail();
-} catch (ConsumerTimeoutException e) {
-// that's OK since this is the Kafka mechanism to unblock
-}
-}
-
-@Test
 public void validateSuccessfulReSendOfFailedSegments() throws Exception {
-InputStream fis = new 
ByteArrayInputStream(sampleData.getBytes(StandardCharsets.UTF_8));
+InputStream fis = new ByteArrayInputStream(
+"Hello Kafka 1\nHello Kafka 2\nHello Kafka 3\nHello Kafka 
4\n".getBytes(StandardCharsets.UTF_8));
 String topicName = "validateSuccessfulReSendOfFailedSegments";

nifi git commit: NIFI-1748 removed un-used test data

2016-04-11 Thread jskora 
Repository: nifi
Updated Branches:
  refs/heads/master 5625686ea -> 95dda1d92


NIFI-1748 removed un-used test data

This closes #341.

Signed-off-by: Aldrin Piri 


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/95dda1d9
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/95dda1d9
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/95dda1d9

Branch: refs/heads/master
Commit: 95dda1d92019401e37a4e62450c30c8edf528f18
Parents: 5625686
Author: Oleg Zhurakousky 
Authored: Sat Apr 9 17:24:37 2016 -0400
Committer: Joe Skora 
Committed: Mon Apr 11 02:24:45 2016 -0400

--
 .../org/apache/nifi/processors/kafka/KafkaPublisherTest.java   | 6 --
 1 file changed, 6 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/nifi/blob/95dda1d9/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
--
diff --git 
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
 
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
index 2abb51a..3e582a6 100644
--- 
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
+++ 
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
@@ -67,12 +67,6 @@ public class KafkaPublisherTest {
 kafkaLocal.stop();
 }
 
-String test = "Khalid El Bakraoui rented an apartment in Brussels that was 
raided last week and both are suspected of having ties to "
-+ "the terror attacks in Paris in November, the source said. While 
Belgian officials say both brothers were suicide bombers, a U.S. "
-+ "official briefed earlier on preliminary evidence from the 
investigation says authorities are looking at the possibility that one of "
-+ "the airport explosions may have been caused by a bomb inside a 
suitcase and the other was a suicide bombing. But identifying the brothers "
-+ "should help spring the investigation forward, says Cedric 
Leighton, a CNN military analyst and the former deputy director for the Joint 
Chiefs of Staff.";
-
 @Test
 public void validateSuccessfulSendAsWhole() throws Exception {
 InputStream fis = new 
ByteArrayInputStream(sampleData.getBytes(StandardCharsets.UTF_8));

nifi git commit: NIFI-1748 removed un-used test data

2016-04-10 Thread aldrin 
Repository: nifi
Updated Branches:
  refs/heads/0.x 0f115a5ce -> 9eddf12a7


NIFI-1748 removed un-used test data

This closes #341.

Signed-off-by: Aldrin Piri 


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/9eddf12a
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/9eddf12a
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/9eddf12a

Branch: refs/heads/0.x
Commit: 9eddf12a775cfe5af03a2b5801e9829bb0219216
Parents: 0f115a5
Author: Oleg Zhurakousky 
Authored: Sat Apr 9 17:24:37 2016 -0400
Committer: Aldrin Piri 
Committed: Sun Apr 10 13:21:11 2016 -0400

--
 .../org/apache/nifi/processors/kafka/KafkaPublisherTest.java   | 6 --
 1 file changed, 6 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/nifi/blob/9eddf12a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
--
diff --git 
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
 
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
index 2abb51a..3e582a6 100644
--- 
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
+++ 
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
@@ -67,12 +67,6 @@ public class KafkaPublisherTest {
 kafkaLocal.stop();
 }
 
-String test = "Khalid El Bakraoui rented an apartment in Brussels that was 
raided last week and both are suspected of having ties to "
-+ "the terror attacks in Paris in November, the source said. While 
Belgian officials say both brothers were suicide bombers, a U.S. "
-+ "official briefed earlier on preliminary evidence from the 
investigation says authorities are looking at the possibility that one of "
-+ "the airport explosions may have been caused by a bomb inside a 
suitcase and the other was a suicide bombing. But identifying the brothers "
-+ "should help spring the investigation forward, says Cedric 
Leighton, a CNN military analyst and the former deputy director for the Joint 
Chiefs of Staff.";
-
 @Test
 public void validateSuccessfulSendAsWhole() throws Exception {
 InputStream fis = new 
ByteArrayInputStream(sampleData.getBytes(StandardCharsets.UTF_8));

nifi git commit: NIFI-1748 removed un-used test data

2016-04-10 Thread aldrin 
Repository: nifi
Updated Branches:
  refs/heads/support/nifi-0.6.x 3df623df0 -> ee0025a4f


NIFI-1748 removed un-used test data

This closes #341.

Signed-off-by: Aldrin Piri 


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/ee0025a4
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/ee0025a4
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/ee0025a4

Branch: refs/heads/support/nifi-0.6.x
Commit: ee0025a4f635eb16f60562b3d544556feb2a2574
Parents: 3df623d
Author: Oleg Zhurakousky 
Authored: Sat Apr 9 17:24:37 2016 -0400
Committer: Aldrin Piri 
Committed: Sun Apr 10 13:26:43 2016 -0400

--
 .../org/apache/nifi/processors/kafka/KafkaPublisherTest.java   | 6 --
 1 file changed, 6 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/nifi/blob/ee0025a4/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
--
diff --git 
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
 
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
index 2abb51a..3e582a6 100644
--- 
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
+++ 
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
@@ -67,12 +67,6 @@ public class KafkaPublisherTest {
 kafkaLocal.stop();
 }
 
-String test = "Khalid El Bakraoui rented an apartment in Brussels that was 
raided last week and both are suspected of having ties to "
-+ "the terror attacks in Paris in November, the source said. While 
Belgian officials say both brothers were suicide bombers, a U.S. "
-+ "official briefed earlier on preliminary evidence from the 
investigation says authorities are looking at the possibility that one of "
-+ "the airport explosions may have been caused by a bomb inside a 
suitcase and the other was a suicide bombing. But identifying the brothers "
-+ "should help spring the investigation forward, says Cedric 
Leighton, a CNN military analyst and the former deputy director for the Joint 
Chiefs of Staff.";
-
 @Test
 public void validateSuccessfulSendAsWhole() throws Exception {
 InputStream fis = new 
ByteArrayInputStream(sampleData.getBytes(StandardCharsets.UTF_8));

nifi git commit: NIFI-1748 removed un-used test data

2016-04-10 Thread aldrin 
Repository: nifi
Updated Branches:
  refs/heads/master e3155a8a4 -> 47cd9ff22


NIFI-1748 removed un-used test data

This closes #341.

Signed-off-by: Aldrin Piri 


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/47cd9ff2
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/47cd9ff2
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/47cd9ff2

Branch: refs/heads/master
Commit: 47cd9ff22c3fe5657822779a4a0e03615e5b12de
Parents: e3155a8
Author: Oleg Zhurakousky 
Authored: Sat Apr 9 17:24:37 2016 -0400
Committer: Aldrin Piri 
Committed: Sun Apr 10 13:21:37 2016 -0400

--
 .../org/apache/nifi/processors/kafka/KafkaPublisherTest.java   | 6 --
 1 file changed, 6 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/nifi/blob/47cd9ff2/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
--
diff --git 
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
 
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
index 2abb51a..3e582a6 100644
--- 
a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
+++ 
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
@@ -67,12 +67,6 @@ public class KafkaPublisherTest {
 kafkaLocal.stop();
 }
 
-String test = "Khalid El Bakraoui rented an apartment in Brussels that was 
raided last week and both are suspected of having ties to "
-+ "the terror attacks in Paris in November, the source said. While 
Belgian officials say both brothers were suicide bombers, a U.S. "
-+ "official briefed earlier on preliminary evidence from the 
investigation says authorities are looking at the possibility that one of "
-+ "the airport explosions may have been caused by a bomb inside a 
suitcase and the other was a suicide bombing. But identifying the brothers "
-+ "should help spring the investigation forward, says Cedric 
Leighton, a CNN military analyst and the former deputy director for the Joint 
Chiefs of Staff.";
-
 @Test
 public void validateSuccessfulSendAsWhole() throws Exception {
 InputStream fis = new 
ByteArrayInputStream(sampleData.getBytes(StandardCharsets.UTF_8));