Skip to content

Allow ingestion job grouping/consolidation to be configurable - #825

Merged
feast-ci-bot merged 4 commits into
feast-dev:masterfrom
pyalex:one-job-per-source
Jun 25, 2020
Merged

Allow ingestion job grouping/consolidation to be configurable#825
feast-ci-bot merged 4 commits into
feast-dev:masterfrom
pyalex:one-job-per-source

Conversation

@pyalex

@pyalex pyalex commented Jun 24, 2020

Copy link
Copy Markdown
Collaborator

What this PR does / why we need it:

Decision regarding how to group sources and stores into IngestionJobs is extracted from JobCoordinatorService to JobGroupingStrategy. Thus it's now configurable with feast.jobs.consolidate-jobs-per-source whether to create one job per Source (and write to all stores from one job) or one job per pair Source-Store and write only to one store in job. The latter is default.

Which issue(s) this PR fixes:

Fixes #

Does this PR introduce a user-facing change?:

It is possible to enable a job grouping strategy which allows ingestion jobs to be consolidated by source.

@pyalex

pyalex commented Jun 24, 2020

Copy link
Copy Markdown
Collaborator Author

/test test-end-to-end-batch-dataflow

@pyalex

pyalex commented Jun 24, 2020

Copy link
Copy Markdown
Collaborator Author

/retest

@pyalex pyalex changed the title [WIP] Configurable job grouping strategy Configurable IngestionJob grouping strategy Jun 24, 2020
@feast-ci-bot

feast-ci-bot commented Jun 24, 2020

Copy link
Copy Markdown
Collaborator

@pyalex: The following test failed, say /retest to rerun them all:

Test name Commit Details Rerun command
test-end-to-end-batch-dataflow 45b74c4 link /test test-end-to-end-batch-dataflow

Full PR test history

Details

Instructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the kubernetes/test-infra repository. I understand the commands that are listed here.

@pyalex

pyalex commented Jun 24, 2020

Copy link
Copy Markdown
Collaborator Author

/retest

Comment thread core/src/main/java/feast/core/config/JobConfig.java Outdated
Comment thread core/src/main/java/feast/core/config/JobConfig.java
@woop

woop commented Jun 25, 2020

Copy link
Copy Markdown
Member

/kind feature

@feast-ci-bot feast-ci-bot added kind/feature New feature or request and removed needs-kind labels Jun 25, 2020
@feast-ci-bot feast-ci-bot removed the lgtm label Jun 25, 2020
@woop woop changed the title Configurable IngestionJob grouping strategy Allow ingestion job grouping/consolidation to be configurable Jun 25, 2020
@woop

woop commented Jun 25, 2020

Copy link
Copy Markdown
Member

/lgtm

@feast-ci-bot

Copy link
Copy Markdown
Collaborator

[APPROVALNOTIFIER] This PR is APPROVED

This pull-request has been approved by: pyalex, woop

The full list of commands accepted by this bot can be found here.

The pull request process is described here

Details Needs approval from an approver in each of these files:

Approvers can indicate their approval by writing /approve in a comment
Approvers can cancel approval by writing /approve cancel in a comment

@feast-ci-bot
feast-ci-bot merged commit 26c8070 into feast-dev:master Jun 25, 2020
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants