Skip to content

Commit e71a0ec

Browse files
committed
updated the SDK build number
1 parent 5d0fd41 commit e71a0ec

File tree

1 file changed

+2
-15
lines changed

1 file changed

+2
-15
lines changed

javav2/example_code/firehose/src/test/java/FirehoseTest.java

Lines changed: 2 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -105,30 +105,17 @@ public void PutRecord() throws IOException, InterruptedException {
105105
System.out.println("Test 2 passed");
106106
}
107107

108-
@Test
108+
@Test
109109
@Tag("IntegrationTest")
110110
@Order(3)
111-
public void PutBatchRecords() throws IOException {
112-
String jsonContent = FirehoseScenario.readJsonFile("sample_records.json");
113-
ObjectMapper objectMapper = new ObjectMapper();
114-
List<Map<String, Object>> sampleData = objectMapper.readValue(jsonContent, new TypeReference<>() {});
115-
116-
// Process individual records.
117-
FirehoseScenario.putRecordBatch(sampleData.subList(100, sampleData.size()), 500, newStream);
118-
System.out.println("Test 3 passed");
119-
}
120-
121-
@Test
122-
@Tag("IntegrationTest")
123-
@Order(4)
124111
public void ListDeliveryStreams() {
125112
assertDoesNotThrow(() -> ListDeliveryStreams.listStreams(firehoseClient));
126113
System.out.println("Test 4 passed");
127114
}
128115

129116
@Test
130117
@Tag("IntegrationTest")
131-
@Order(5)
118+
@Order(4)
132119
public void DeleteStream() {
133120
assertDoesNotThrow(() -> DeleteStream.delStream(firehoseClient, newStream));
134121
System.out.println("Test 5 passed");

0 commit comments

Comments
 (0)