Merge pull request #7111 from amit2103/BAEL-14844

[BAEL-14844] - Fix tests in libraries, libraries-data modules
This commit is contained in:
Loredana Crusoveanu 2019-06-10 22:34:45 +03:00 committed by GitHub
commit e11b35748e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 14 additions and 2 deletions

View File

@ -263,6 +263,16 @@
<groupId>org.apache.storm</groupId> <groupId>org.apache.storm</groupId>
<artifactId>storm-core</artifactId> <artifactId>storm-core</artifactId>
<version>${storm.version}</version> <version>${storm.version}</version>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
</exclusion>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>log4j-over-slf4j</artifactId>
</exclusion>
</exclusions>
</dependency> </dependency>
<dependency> <dependency>

View File

@ -26,6 +26,7 @@ import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.List; import java.util.List;
import static org.junit.Assert.assertArrayEquals;
import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertEquals;
public class BackupCreatorIntegrationTest { public class BackupCreatorIntegrationTest {
@ -88,7 +89,7 @@ public class BackupCreatorIntegrationTest {
SerializationSchema<Backup> serializationSchema = new BackupSerializationSchema(); SerializationSchema<Backup> serializationSchema = new BackupSerializationSchema();
byte[] backupProcessed = serializationSchema.serialize(backup); byte[] backupProcessed = serializationSchema.serialize(backup);
assertEquals(backupSerialized, backupProcessed); assertArrayEquals(backupSerialized, backupProcessed);
} }
private static class CollectingSink implements SinkFunction<Backup> { private static class CollectingSink implements SinkFunction<Backup> {

View File

@ -59,5 +59,6 @@ class FtpClient {
void downloadFile(String source, String destination) throws IOException { void downloadFile(String source, String destination) throws IOException {
FileOutputStream out = new FileOutputStream(destination); FileOutputStream out = new FileOutputStream(destination);
ftp.retrieveFile(source, out); ftp.retrieveFile(source, out);
out.close();
} }
} }

View File

@ -28,7 +28,7 @@ public class AdderMethodDirtiesContextIntegrationTest {
@Test @Test
public void _1_givenNumber_whenAdd_thenSumWrong() { public void _1_givenNumber_whenAdd_thenSumWrong() {
adderServiceSteps.whenAdd(); adderServiceSteps.whenAdd();
adderServiceSteps.sumWrong(); adderServiceSteps.summedUp();
} }
@Rule @Rule