You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by pv...@apache.org on 2019/01/03 10:32:23 UTC
[nifi] branch master updated: NIFI-5917 Fix
TestSelectHiveQL.testNoTimeLimit
This is an automated email from the ASF dual-hosted git repository.
pvillard pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/master by this push:
new 595a2de NIFI-5917 Fix TestSelectHiveQL.testNoTimeLimit
595a2de is described below
commit 595a2decc67d464534ce33f18440543620165bbb
Author: Koji Kawamura <ij...@apache.org>
AuthorDate: Fri Dec 28 13:09:50 2018 +0900
NIFI-5917 Fix TestSelectHiveQL.testNoTimeLimit
Signed-off-by: Pierre Villard <pi...@gmail.com>
This closes #3237.
---
.../test/java/org/apache/nifi/processors/hive/TestSelectHiveQL.java | 5 ++++-
.../test/java/org/apache/nifi/processors/hive/TestSelectHive3QL.java | 5 ++++-
2 files changed, 8 insertions(+), 2 deletions(-)
diff --git a/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/test/java/org/apache/nifi/processors/hive/TestSelectHiveQL.java b/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/test/java/org/apache/nifi/processors/hive/TestSelectHiveQL.java
index 484fa67..bb84486 100644
--- a/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/test/java/org/apache/nifi/processors/hive/TestSelectHiveQL.java
+++ b/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/test/java/org/apache/nifi/processors/hive/TestSelectHiveQL.java
@@ -134,7 +134,7 @@ public class TestSelectHiveQL {
invokeOnTrigger(QUERY_WITH_EL, true, "Avro");
final List<ProvenanceEventRecord> provenanceEvents = runner.getProvenanceEvents();
- assertEquals(2, provenanceEvents.size());
+ assertEquals(3, provenanceEvents.size());
final ProvenanceEventRecord provenance0 = provenanceEvents.get(0);
assertEquals(ProvenanceEventType.FORK, provenance0.getEventType());
@@ -142,6 +142,9 @@ public class TestSelectHiveQL {
final ProvenanceEventRecord provenance1 = provenanceEvents.get(1);
assertEquals(ProvenanceEventType.FETCH, provenance1.getEventType());
assertEquals("jdbc:derby:target/db;create=true", provenance1.getTransitUri());
+
+ final ProvenanceEventRecord provenance2 = provenanceEvents.get(2);
+ assertEquals(ProvenanceEventType.FORK, provenance2.getEventType());
}
diff --git a/nifi-nar-bundles/nifi-hive-bundle/nifi-hive3-processors/src/test/java/org/apache/nifi/processors/hive/TestSelectHive3QL.java b/nifi-nar-bundles/nifi-hive-bundle/nifi-hive3-processors/src/test/java/org/apache/nifi/processors/hive/TestSelectHive3QL.java
index 67f0dd4..77a20f8 100644
--- a/nifi-nar-bundles/nifi-hive-bundle/nifi-hive3-processors/src/test/java/org/apache/nifi/processors/hive/TestSelectHive3QL.java
+++ b/nifi-nar-bundles/nifi-hive-bundle/nifi-hive3-processors/src/test/java/org/apache/nifi/processors/hive/TestSelectHive3QL.java
@@ -134,7 +134,7 @@ public class TestSelectHive3QL {
invokeOnTrigger(QUERY_WITH_EL, true, "Avro");
final List<ProvenanceEventRecord> provenanceEvents = runner.getProvenanceEvents();
- assertEquals(2, provenanceEvents.size());
+ assertEquals(3, provenanceEvents.size());
final ProvenanceEventRecord provenance0 = provenanceEvents.get(0);
assertEquals(ProvenanceEventType.FORK, provenance0.getEventType());
@@ -142,6 +142,9 @@ public class TestSelectHive3QL {
final ProvenanceEventRecord provenance1 = provenanceEvents.get(1);
assertEquals(ProvenanceEventType.FETCH, provenance1.getEventType());
assertEquals("jdbc:derby:target/db;create=true", provenance1.getTransitUri());
+
+ final ProvenanceEventRecord provenance2 = provenanceEvents.get(2);
+ assertEquals(ProvenanceEventType.FORK, provenance2.getEventType());
}