This is an automated email from the ASF dual-hosted git repository.
rongr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 8170d435c5 Changed Lists.of to ImmutableList.of for test in java8
(#10972)
8170d435c5 is described below
commit 8170d435c5e8999daae9bb393e9d172aea2bdbd7
Author: Subbu Subramaniam <[email protected]>
AuthorDate: Mon Jun 26 08:38:20 2023 -0700
Changed Lists.of to ImmutableList.of for test in java8 (#10972)
---
.../apache/pinot/integration/tests/UpsertTableIntegrationTest.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git
a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/UpsertTableIntegrationTest.java
b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/UpsertTableIntegrationTest.java
index 5eb5469432..a9aac6e37c 100644
---
a/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/UpsertTableIntegrationTest.java
+++
b/pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/UpsertTableIntegrationTest.java
@@ -18,6 +18,7 @@
*/
package org.apache.pinot.integration.tests;
+import com.google.common.collect.ImmutableList;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
@@ -191,7 +192,7 @@ public class UpsertTableIntegrationTest extends
BaseClusterIntegrationTestSet {
// TEST 1: Delete existing primary key
// Push 2 records with deleted = true - deletes pks 100 and 102
- List<String> deleteRecords =
List.of("102,Clifford,counter-strike,102,1681054200000,true",
+ List<String> deleteRecords =
ImmutableList.of("102,Clifford,counter-strike,102,1681054200000,true",
"100,Zook,counter-strike,2050,1681377200000,true");
pushCsvIntoKafka(deleteRecords, kafkaTopicName, 0);
@@ -297,7 +298,7 @@ public class UpsertTableIntegrationTest extends
BaseClusterIntegrationTestSet {
// TEST 1: Delete existing primary key
// Push 2 records with deleted = true - deletes pks 100 and 102
- List<String> deleteRecords =
List.of("102,Clifford,counter-strike,102,1681054200000,true",
+ List<String> deleteRecords =
ImmutableList.of("102,Clifford,counter-strike,102,1681054200000,true",
"100,Zook,counter-strike,2050,1681377200000,true");
pushCsvIntoKafka(deleteRecords, kafkaTopicName, 0);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
