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
Copy link
Copy Markdown
Collaborator

@pyalex pyalex commented Jun 24, 2020

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
Copy link
Copy Markdown
Collaborator Author

pyalex commented Jun 24, 2020

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

@pyalex
Copy link
Copy Markdown
Collaborator Author

pyalex commented Jun 24, 2020

/retest

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

feast-ci-bot commented Jun 24, 2020

@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
Copy link
Copy Markdown
Collaborator Author

pyalex commented Jun 24, 2020

/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
Copy link
Copy Markdown
Member

woop commented Jun 25, 2020

/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
Copy link
Copy Markdown
Member

woop commented Jun 25, 2020

/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