You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by "Raghu Angadi (JIRA)" <ji...@apache.org> on 2016/06/30 18:00:14 UTC

[jira] [Created] (BEAM-395) KafkaIO tests should be marked 'NeedsRunner'

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)