Add ability to submit ingestion job using Flink - #62

Merged

feast-ci-bot merged 9 commits into

feast-dev:masterfrom

pradithya:flink_runner

Jan 18, 2019

Commits on Jan 11, 2019

Restructure Job Management components
Pradithya Aria
committed
7f0b231
Change JobMonitor.getJobStatus to accept JobInfo
Pradithya Aria
committed
852e668
Fix compilation error on test
Pradithya Aria
committed
72d8c5b
Implement Flink job submission and status monitoring
Pradithya Aria
committed
e2ed557
Add configuration for Flink
Pradithya Aria
committed
9c0e0a4
Skip metrics if it's not for particular runner
Pradithya Aria
committed
423a376
Fix logging for DataflowJobMonitor
Pradithya Aria
committed
201dcbb

Commits on Jan 12, 2019

Add license
Pradithya Aria
committed
28d2aec
Set job status in DirectRunner to COMPLETED after submission since it runs in blocking fashion
Pradithya Aria
committed
418ee6b