[samza] branch master updated: Fixing the testSinkEndToEndWithKeyWithNullRecords test case (#983)

[srinivasulu]

This is an automated email from the ASF dual-hosted git repository.

srinivasulu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git


The following commit(s) were added to refs/heads/master by this push:
     new 4afeb51  Fixing the testSinkEndToEndWithKeyWithNullRecords test case 
(#983)
4afeb51 is described below

commit 4afeb51cd3a3a2f68e1c76fbff14ef24f856eb96
Author: Srinivasulu Punuru <srinipun...@users.noreply.github.com>
AuthorDate: Wed Apr 3 14:32:26 2019 -0700

    Fixing the testSinkEndToEndWithKeyWithNullRecords test case (#983)
---
 .../org/apache/samza/test/samzasql/TestSamzaSqlRemoteTable.java     | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git 
a/samza-test/src/test/java/org/apache/samza/test/samzasql/TestSamzaSqlRemoteTable.java
 
b/samza-test/src/test/java/org/apache/samza/test/samzasql/TestSamzaSqlRemoteTable.java
index 94efa79..c2219e8 100644
--- 
a/samza-test/src/test/java/org/apache/samza/test/samzasql/TestSamzaSqlRemoteTable.java
+++ 
b/samza-test/src/test/java/org/apache/samza/test/samzasql/TestSamzaSqlRemoteTable.java
@@ -65,14 +65,12 @@ public class TestSamzaSqlRemoteTable extends 
SamzaSqlIntegrationTestHarness {
         SamzaSqlTestConfig.fetchStaticConfigsWithFactories(props, numMessages, 
false, true);
 
     String sql1 = "Insert into testRemoteStore.testTable.`$table` select 
__key__, id, name from testavro.SIMPLE1";
-    String sql2 = "Insert into testRemoteStore.testTable.`$table` select 
__key__, 'DELETE' as __op__ from testavro.SIMPLE1 WHERE name IS NULL";
 
-    List<String> sqlStmts = Arrays.asList(sql1, sql2);
+    List<String> sqlStmts = Arrays.asList(sql1);
     staticConfigs.put(SamzaSqlApplicationConfig.CFG_SQL_STMTS_JSON, 
JsonUtil.toJson(sqlStmts));
     runApplication(new MapConfig(staticConfigs));
 
-    Assert.assertEquals(numMessages - ((numMessages - 1) / 
TestAvroSystemFactory.NULL_RECORD_FREQUENCY + 1),
-        RemoteStoreIOResolverTestFactory.records.size());
+    Assert.assertEquals(numMessages, 
RemoteStoreIOResolverTestFactory.records.size());
   }
 
   @Test (expected = AssertionError.class)