Visitar URL original
feat: Add apache flink compute engine by XuananLe · Pull Request #6476 · feast-dev/feast · GitHub
Skip to content

feat: Add apache flink compute engine #6476

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.

Sign up for GitHub

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

Merged
franciscojavierarceo merged 18 commits into from
Jun 11, 2026
Merged

feat: Add apache flink compute engine #6476

Changes from 1 commit
Commits
Show all changes
18 commits
Select commit Hold shift + click to select a range
f28e8f8
feat: Add apache flink compute engine
XuananLe Jun 6, 2026
485c606
fix: Address flink review comments
XuananLe Jun 6, 2026
b3731e6
fix: Address flink copilot review comments
XuananLe Jun 7, 2026
2aae600
fix: Refresh pixi lock for flink extra
XuananLe Jun 7, 2026
37accc6
fix: Satisfy flink feature builder typing
XuananLe Jun 7, 2026
c99bc7f
refactor: Share compute engine timestamp helpers
XuananLe Jun 7, 2026
6ba7a53
test: Cover flink transformation mode
XuananLe Jun 7, 2026
4bf1433
test: Stabilize feature server performance check
XuananLe Jun 7, 2026
7aebf78
test: Mock image extractor model loading
XuananLe Jun 7, 2026
ebbc86b
test: Use localhost for remote offline clients
XuananLe Jun 7, 2026
1a51179
test: Stabilize local Milvus integration index
XuananLe Jun 7, 2026
71f5728
test: Stabilize feature server benchmark timing
XuananLe Jun 7, 2026
77463ca
test: Clean up remote offline server processes
XuananLe Jun 7, 2026
8ef7bbb
test: Revert unrelated universal test changes
XuananLe Jun 7, 2026
9a71db1
Merge remote-tracking branch 'origin/master' into feat/add-apache-fli…
XuananLe Jun 9, 2026
88f338e
Merge branch 'master' into feat/add-apache-flink-compute-engine
XuananLe Jun 10, 2026
3af9cd7
fix: Address Flink review blockers
XuananLe Jun 11, 2026
a66fe10
Merge remote-tracking branch 'origin/master' into feat/add-apache-fli…
XuananLe Jun 11, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
test: Use localhost for remote offline clients 
Signed-off-by: Le Xuan An <anlx@viettel.com.vn>
  • Loading branch information
@XuananLe Le Xuan An
XuananLe authored and Le Xuan An committed Jun 7, 2026
commit ebbc86b011dcdb395298befeb28884b3f50bd1e0
19 changes: 11 additions & 8 deletions sdk/python/tests/universal/feature_repos/universal/data_sources/file.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -372,6 +372,7 @@ def setup(self, registry: RegistryConfig):

self.server_port = free_port()
host = "0.0.0.0"
client_host = "localhost"
cmd = [
"feast",
"-c" + str(repo_path),
Expand All @@ -388,11 +389,11 @@ def setup(self, registry: RegistryConfig):
_time_out_sec: int = 60
# Wait for server to start
wait_retry_backoff(
lambda: (None, check_port_open(host, self.server_port)),
lambda: (None, check_port_open(client_host, self.server_port)),
timeout_secs=_time_out_sec,
timeout_msg=f"Unable to start the feast remote offline server in {_time_out_sec} seconds at port={self.server_port}",
)
return "grpc+tcp://{}:{}".format(host, self.server_port)
return "grpc+tcp://{}:{}".format(client_host, self.server_port)

def teardown(self):
super().teardown()
Expand Down Expand Up @@ -441,6 +442,7 @@ def setup(self, registry: RegistryConfig):

self.server_port = free_port()
host = "0.0.0.0"
client_host = "localhost"
cmd = [
"feast",
"-c" + str(repo_path),
Expand All @@ -461,16 +463,16 @@ def setup(self, registry: RegistryConfig):
_time_out_sec: int = 60
# Wait for server to start
wait_retry_backoff(
lambda: (None, check_port_open(host, self.server_port)),
lambda: (None, check_port_open(client_host, self.server_port)),
timeout_secs=_time_out_sec,
timeout_msg=f"Unable to start the feast remote offline server in {_time_out_sec} seconds at port={self.server_port}",
)
return "grpc+tls://{}:{}".format(host, self.server_port)
return "grpc+tls://{}:{}".format(client_host, self.server_port)

def create_offline_store_config(self) -> FeastConfigBaseModel:
remote_offline_store_config = RemoteOfflineStoreConfig(
type="remote",
host="0.0.0.0",
host="localhost",
port=self.server_port,
scheme="https",
cert=self.tls_cert_path,
Expand Down Expand Up @@ -541,6 +543,7 @@ def setup(self, registry: RegistryConfig):

self.server_port = free_port()
host = "0.0.0.0"
client_host = "localhost"
cmd = [
"feast",
"-c" + repo_path,
Expand All @@ -557,15 +560,15 @@ def setup(self, registry: RegistryConfig):
_time_out_sec: int = 60
# Wait for server to start
wait_retry_backoff(
lambda: (None, check_port_open(host, self.server_port)),
lambda: (None, check_port_open(client_host, self.server_port)),
timeout_secs=_time_out_sec,
timeout_msg=f"Unable to start the feast remote offline server in {_time_out_sec} seconds at port={self.server_port}",
)
return "grpc+tcp://{}:{}".format(host, self.server_port)
return "grpc+tcp://{}:{}".format(client_host, self.server_port)

def create_offline_store_config(self) -> FeastConfigBaseModel:
remote_offline_store_config = RemoteOfflineStoreConfig(
type="remote", host="0.0.0.0", port=self.server_port
type="remote", host="localhost", port=self.server_port
)
return remote_offline_store_config

Expand Down
Loading