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

Show file tree
Hide file tree
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
fix: Satisfy flink feature builder typing 
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 37accc60b0566681b8db667a56fc482ec49f210d
2 changes: 1 addition & 1 deletion sdk/python/feast/infra/compute_engines/flink/feature_builder.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ def _should_join_entity_df(self) -> bool:

def _build(self, view: Any, input_nodes: list[DAGNode] | None) -> DAGNode:
if view.data_source:
last_node = self.build_source_node(view)
last_node: DAGNode = self.build_source_node(view)

if self._should_transform(view):
last_node = self.build_transformation_node(view, [last_node])
Expand Down
4 changes: 2 additions & 2 deletions sdk/python/feast/infra/compute_engines/flink/nodes.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
import pandas as pd
import pyarrow as pa

from feast import BatchFeatureView, StreamFeatureView
from feast import BatchFeatureView, FeatureView, StreamFeatureView
from feast.aggregation import Aggregation, aggregation_specs_to_agg_ops
from feast.data_source import DataSource
from feast.infra.compute_engines.dag.context import ColumnInfo, ExecutionContext
Expand Down Expand Up @@ -697,7 +697,7 @@ class FlinkOutputNode(DAGNode):
def __init__(
self,
name: str,
feature_view: Union[BatchFeatureView, StreamFeatureView],
feature_view: Union[BatchFeatureView, FeatureView, StreamFeatureView],
table_env: Any,
split_num: int,
write_output: bool,
Expand Down
Loading