[ https://issues.apache.org/jira/browse/BEAM-1205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Stas Levin updated BEAM-1205: ----------------------------- Description: At the moment one has to manually set {{enableAbandonedNodeEnforcement(false)}} in tests that do not run the TestPipeline, otherwise one gets an {{AbandonedNodeException}} on account of having nodes that were not run. This could probably be auto detected using the {{RunnableOnService}} and {{NeedsRunner}} annotations, the presence of which indicates a given test does indeed use a runner. Essentially we need to check if {{RunnableOnService}} / {{NeedsRunner}} are present on a given test and if so set {{enableAbandonedNodeEnforcement(true)}}, otherwise set {{enableAbandonedNodeEnforcement(false)}}. [~tgroh], [~kenn] was: At the moment one has to manually set {{enableAbandonedNodeEnforcement(false)}} in tests that do not run the TestPipeline, otherwise one gets an {{AbandonedNodeException}} on account of having nodes that were not run. This could probably be auto detected using the {{RunnableOnService}} and {{NeedsRunner}} annotations, the presence of which indicates a given test does indeed use a runner. Essentially we need to check if {{RunnableOnService}} / {{NeedsRunner}} is present on a given test and if so set {{enableAbandonedNodeEnforcement(true)}}, otherwise set {{enableAbandonedNodeEnforcement(false)}}. [~tgroh], [~kenn] > Auto set "enableAbandonedNodeEnforcement" in TestPipeline > --------------------------------------------------------- > > Key: BEAM-1205 > URL: https://issues.apache.org/jira/browse/BEAM-1205 > Project: Beam > Issue Type: Improvement > Components: sdk-java-core > Reporter: Stas Levin > Assignee: Stas Levin > > At the moment one has to manually set > {{enableAbandonedNodeEnforcement(false)}} in tests that do not run the > TestPipeline, otherwise one gets an {{AbandonedNodeException}} on account of > having nodes that were not run. > This could probably be auto detected using the {{RunnableOnService}} and > {{NeedsRunner}} annotations, the presence of which indicates a given test > does indeed use a runner. > Essentially we need to check if {{RunnableOnService}} / {{NeedsRunner}} are > present on a given test and if so set > {{enableAbandonedNodeEnforcement(true)}}, otherwise set > {{enableAbandonedNodeEnforcement(false)}}. > [~tgroh], [~kenn] -- This message was sent by Atlassian JIRA (v6.3.4#6332)