apache / apache/beam

Move Flink external transform dependencies into base job server project

Open
#20,348 0 comments 0 reactions 0 assignees View on GitHub
core flink improvement java P3 runners
Dominant language
Java
Stars
8.7k
Forks
4.7k
Avg merge
1d 20h
Merged PRs (30d)
196

Description

For convenience, the job server project bundles the expansion server. The Flink job server which makes use of the job server project includes additional runtime dependencies to be able to expand external transforms like Kafka and PubSub. Those dependencies should really be present in the base job server project, such that all runner job servers can make use of external transforms.

Imported from Jira [BEAM-10386](https://issues.apache.org/jira/browse/BEAM-10386). Original Jira may contain additional context.
Reported by: mxm.

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.