Skip to content

rename and add eot to sink

Codecov / codecov/patch succeeded Oct 14, 2024 in 1s

No report found to compare against

View this Pull Request on Codecov

No report found to compare against

Annotations

Check warning on line 25 in src/main/java/io/numaproj/numaflow/mapstreamer/Service.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapstreamer/Service.java#L24-L25

Added lines #L24 - L25 were not covered by tests

Check warning on line 40 in src/main/java/io/numaproj/numaflow/mapstreamer/Service.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapstreamer/Service.java#L37-L40

Added lines #L37 - L40 were not covered by tests

Check warning on line 83 in src/main/java/io/numaproj/numaflow/mapstreamer/Service.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/mapstreamer/Service.java#L78-L83

Added lines #L78 - L83 were not covered by tests

Check warning on line 184 in src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java#L184

Added line #L184 was not covered by tests

Check warning on line 201 in src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/main/java/io/numaproj/numaflow/sinker/SinkerTestKit.java#L201

Added line #L201 was not covered by tests