Commits

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Commits

Commits on Mar 12, 2019

Use the maxWorkItemCommitBytes value returned in the StreamingConfigTask, if there is one.

Commits on Feb 20, 2019

Parameterize StreamingDataflowWorkerTest so we run all tests with/without streaming engine. I had to implement FakeServer.getDataStream. This is super basic at the moment. Some tests are skipped in…

Commits on Feb 19, 2019

Fix job_PreCommit_Java_Examples_Dataflow glob.

Commits on Feb 18, 2019

Fix NPE in ComputationState constructor introduced by PR/7846. The root cause was assuming an empty transformUserNameToStateFamily map was passed, when instead null was passed.

Commits on Feb 16, 2019

StreamingDataflowWorker uses the per-stage transformUserNameToStateFamily.

Commits on Feb 13, 2019

Switching google_api_services_dataflow to v1b3-rev20190126 (apache#7828 )

Commits on Feb 12, 2019

Applied spotless.

Added test for streaming engine.

setMaxWorkItemCommitBytes must be only called for Streaming Engine, not for Appliance.

Commits on Feb 11, 2019

Merge branch 'max_commit_bytes' of https://github.com/scwhittle/beam into max_commit_bytes

Commits on Feb 5, 2019

Got rid of reference to windmill_service_streaming_rpc_batching experiment (apache#7728 )

Commits on Jan 30, 2019

Got rid of the WindmillServiceUseStreamingRpcs option from StreamingD… (apache#7631 )

Commits on Jan 29, 2019

Added per-computation map transform->state_family to windmill's GetConfigResponse. (apache#7566 )

Commits on Apr 24, 2017

Update pom.xml

Commits on Sep 13, 2016

Do not add DataDisks to windmill service jobs.

Commits on Aug 11, 2016

Do not add DataDisks to windmill service jobs.

Commits on Jun 12, 2015

DataflowWorker.handleWorkError should use nextReportIndex

Branch selector

User selector

Datepicker

Commit History

Commits on Mar 12, 2019

Commits on Feb 20, 2019

Commits on Feb 19, 2019

Commits on Feb 18, 2019

Commits on Feb 16, 2019

Commits on Feb 13, 2019

Commits on Feb 12, 2019

Commits on Feb 11, 2019

Commits on Feb 5, 2019

Commits on Jan 30, 2019

Commits on Jan 29, 2019

Commits on Apr 24, 2017

Commits on Sep 13, 2016

Commits on Aug 11, 2016

Commits on Jun 12, 2015