Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Stop Streaming Jobs When datasource is disabled/deleted. #2559

Merged
merged 1 commit into from
Mar 19, 2024

FlintStreamingJobCleanerTask Implementation

31a0efa
Select commit
Loading
Failed to load commit list.
Merged

Stop Streaming Jobs When datasource is disabled/deleted. #2559

FlintStreamingJobCleanerTask Implementation
31a0efa
Select commit
Loading
Failed to load commit list.
Codecov / codecov/patch failed Mar 19, 2024 in 1s

78.94% of diff hit (target 95.50%)

View this Pull Request on Codecov

78.94% of diff hit (target 95.50%)

Annotations

Check warning on line 60 in spark/src/main/java/org/opensearch/sql/spark/cluster/ClusterManagerEventListener.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

spark/src/main/java/org/opensearch/sql/spark/cluster/ClusterManagerEventListener.java#L60

Added line #L60 was not covered by tests

Check warning on line 69 in spark/src/main/java/org/opensearch/sql/spark/cluster/ClusterManagerEventListener.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

spark/src/main/java/org/opensearch/sql/spark/cluster/ClusterManagerEventListener.java#L66-L69

Added lines #L66 - L69 were not covered by tests

Check warning on line 72 in spark/src/main/java/org/opensearch/sql/spark/cluster/ClusterManagerEventListener.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

spark/src/main/java/org/opensearch/sql/spark/cluster/ClusterManagerEventListener.java#L72

Added line #L72 was not covered by tests

Check warning on line 112 in spark/src/main/java/org/opensearch/sql/spark/cluster/ClusterManagerEventListener.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

spark/src/main/java/org/opensearch/sql/spark/cluster/ClusterManagerEventListener.java#L110-L112

Added lines #L110 - L112 were not covered by tests

Check warning on line 118 in spark/src/main/java/org/opensearch/sql/spark/cluster/ClusterManagerEventListener.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

spark/src/main/java/org/opensearch/sql/spark/cluster/ClusterManagerEventListener.java#L115-L118

Added lines #L115 - L118 were not covered by tests

Check warning on line 137 in spark/src/main/java/org/opensearch/sql/spark/cluster/ClusterManagerEventListener.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

spark/src/main/java/org/opensearch/sql/spark/cluster/ClusterManagerEventListener.java#L136-L137

Added lines #L136 - L137 were not covered by tests

Check warning on line 141 in spark/src/main/java/org/opensearch/sql/spark/cluster/ClusterManagerEventListener.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

spark/src/main/java/org/opensearch/sql/spark/cluster/ClusterManagerEventListener.java#L140-L141

Added lines #L140 - L141 were not covered by tests

Check warning on line 148 in spark/src/main/java/org/opensearch/sql/spark/cluster/ClusterManagerEventListener.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

spark/src/main/java/org/opensearch/sql/spark/cluster/ClusterManagerEventListener.java#L148

Added line #L148 was not covered by tests

Check warning on line 171 in spark/src/main/java/org/opensearch/sql/spark/cluster/ClusterManagerEventListener.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

spark/src/main/java/org/opensearch/sql/spark/cluster/ClusterManagerEventListener.java#L170-L171

Added lines #L170 - L171 were not covered by tests