Skip to content

[SPARK-57721][SQL] Fix LowLatencyMemoryStream package to match its directory#56817

Closed
dongjoon-hyun wants to merge 1 commit into
apache:masterfrom
dongjoon-hyun:SPARK-57721
Closed

[SPARK-57721][SQL] Fix LowLatencyMemoryStream package to match its directory#56817
dongjoon-hyun wants to merge 1 commit into
apache:masterfrom
dongjoon-hyun:SPARK-57721

Conversation

@dongjoon-hyun

@dongjoon-hyun dongjoon-hyun commented Jun 26, 2026

Copy link
Copy Markdown
Member

What changes were proposed in this pull request?

LowLatencyMemoryStream.scala lives in the .../streaming/sources/ directory but declared package ...streaming. This PR changes its package to ...streaming.sources to match the directory.

Why are the changes needed?

Like the other classes in sources directory, we must use a correct package name.

This was introduced at Apache Spark 4.1.0 via the following.

Does this PR introduce any user-facing change?

No.

How was this patch tested?

Pass the CIs.

Was this patch authored or co-authored using generative AI tooling?

Generated-by: Claude Opus 4.8

@dongjoon-hyun

Copy link
Copy Markdown
Member Author

cc @jerrypeng , @viirya

@dongjoon-hyun

Copy link
Copy Markdown
Member Author

Thank you again, @viirya !

dongjoon-hyun added a commit that referenced this pull request Jun 26, 2026
…directory

### What changes were proposed in this pull request?

`LowLatencyMemoryStream.scala` lives in the `.../streaming/sources/` directory but declared `package ...streaming`. This PR changes its package to `...streaming.sources` to match the directory.

### Why are the changes needed?

Like the other classes in `sources` directory, we must use a correct package name.

https://github.com/apache/spark/blob/08bf0e75e4a07633a69c615e1cb4cd9f317d6bee/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/LowLatencyMemoryStream.scala#L66

This was introduced at Apache Spark 4.1.0 via the following.
- #52502

### Does this PR introduce _any_ user-facing change?

No.

### How was this patch tested?

Pass the CIs.

### Was this patch authored or co-authored using generative AI tooling?

Generated-by: Claude Opus 4.8

Closes #56817 from dongjoon-hyun/SPARK-57721.

Authored-by: Dongjoon Hyun <dongjoon@apache.org>
Signed-off-by: Dongjoon Hyun <dongjoon@apache.org>
(cherry picked from commit 45b8b96)
Signed-off-by: Dongjoon Hyun <dongjoon@apache.org>
dongjoon-hyun added a commit that referenced this pull request Jun 26, 2026
…directory

### What changes were proposed in this pull request?

`LowLatencyMemoryStream.scala` lives in the `.../streaming/sources/` directory but declared `package ...streaming`. This PR changes its package to `...streaming.sources` to match the directory.

### Why are the changes needed?

Like the other classes in `sources` directory, we must use a correct package name.

https://github.com/apache/spark/blob/08bf0e75e4a07633a69c615e1cb4cd9f317d6bee/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/LowLatencyMemoryStream.scala#L66

This was introduced at Apache Spark 4.1.0 via the following.
- #52502

### Does this PR introduce _any_ user-facing change?

No.

### How was this patch tested?

Pass the CIs.

### Was this patch authored or co-authored using generative AI tooling?

Generated-by: Claude Opus 4.8

Closes #56817 from dongjoon-hyun/SPARK-57721.

Authored-by: Dongjoon Hyun <dongjoon@apache.org>
Signed-off-by: Dongjoon Hyun <dongjoon@apache.org>
(cherry picked from commit 45b8b96)
Signed-off-by: Dongjoon Hyun <dongjoon@apache.org>
dongjoon-hyun added a commit that referenced this pull request Jun 26, 2026
…directory

`LowLatencyMemoryStream.scala` lives in the `.../streaming/sources/` directory but declared `package ...streaming`. This PR changes its package to `...streaming.sources` to match the directory.

Like the other classes in `sources` directory, we must use a correct package name.

https://github.com/apache/spark/blob/08bf0e75e4a07633a69c615e1cb4cd9f317d6bee/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/sources/LowLatencyMemoryStream.scala#L66

This was introduced at Apache Spark 4.1.0 via the following.
- #52502

No.

Pass the CIs.

Generated-by: Claude Opus 4.8

Closes #56817 from dongjoon-hyun/SPARK-57721.

Authored-by: Dongjoon Hyun <dongjoon@apache.org>
Signed-off-by: Dongjoon Hyun <dongjoon@apache.org>
(cherry picked from commit 45b8b96)
Signed-off-by: Dongjoon Hyun <dongjoon@apache.org>
@dongjoon-hyun

Copy link
Copy Markdown
Member Author

Merged to master/4.x/4.2/4.1.

@dongjoon-hyun dongjoon-hyun deleted the SPARK-57721 branch June 26, 2026 17:33
@viirya

viirya commented Jun 26, 2026

Copy link
Copy Markdown
Member

Good catch! Thanks @dongjoon-hyun

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants