Raghu Angadi created BEAM-395:
---------------------------------
Summary: KafkaIO tests should be marked 'NeedsRunner'
Key: BEAM-395
URL: https://issues.apache.org/jira/browse/BEAM-395
Project: Beam
Issue Type: Bug
Components: sdk-java-extensions, testing
Affects Versions: 0.1.0-incubating
Reporter: Raghu Angadi
Assignee: Raghu Angadi
KafkaIO Tests are currently marked as 'RunnableOnService', which implies the tests can run
on any beam runner. This is not correct.
Though the tests are not runner dependent per se, they depend on mocks for Kafka consumer
and kafka producer. That requires the tests to be local to a JVM. These tests can only run
on single JVM runners like DirectRunner.
These tests should be marked 'NeedsRunner' for now.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
|