-
Notifications
You must be signed in to change notification settings - Fork 147
APEXMALHAR-2120 #resolve #comment solve problems of KafkaInputOperato… #321
Conversation
@Before | ||
public void before() | ||
{ | ||
FileUtils.deleteQuietly(new File(APPLICATION_PATH)); | ||
tupleCollection.clear(); | ||
//FileUtils.deleteQuietly(new File(APPLICATION_PATH)); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Why is this commented out?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The different test case/test Scenario use difference directory. So it is not necessary to delete the directory
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Tests should always delete in case it was leftover from previous run.
f73820a
to
252a701
Compare
252a701
to
770119d
Compare
@siyuanh The NullPointerException issue should be fixed, I've tested more than 10 times. Please review and merger |
|
||
t.join(); | ||
|
||
logger.info("Number of received/expected tuples: {}/{}, testName: {}, tuples: \n{}", tupleCollection.size(), expectedReceiveCount, testName, tupleCollection); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Log this only when something goes wrong
…rTest and AbstractKafkaInputOperator
770119d
to
f2b7a85
Compare
@siyuanh Please review and merge |
…rTest and AbstractKafkaInputOperator