Skip to content

Tags: brightchen/DataflowJavaSDK

Tags

v1.6.1

Toggle v1.6.1's commit message
Version management: update poms to 1.6.1-SNAPSHOT

v1.6.0

Toggle v1.6.0's commit message
Version management: restore 1.6.0-SNAPSHOT for 1.6.0 release

Revert "Version management: update to 1.7.0-SNAPSHOT"

v1.5.1

Toggle v1.5.1's commit message
[BEAM-167] Fix custom source gzip input to read concatenated gzip files

This applies patch from [email protected] from https://gist.github.com/jkff/d8d984a33a41ec607328cee8e418c174

v1.5.0

Toggle v1.5.0's commit message
Merge pull request GoogleCloudPlatform#146 from kennknowles/backport-…

…pr-38

Backport apache/beam#38

v1.4.0

Toggle v1.4.0's commit message
Fixes a bug in custom unbounded readers

Custom unbounded readers are read in bundles of at most
10k elements or 10 seconds. A recent change accidentally removed
the 10k element limit. This change reintroduces it and
adds a test.

The previous test also was passing vacuously because
the iteration limit was incorrect (it would always
have only one iteration).
----Release Notes----
[]
-------------
Created by MOE: https://github.com/google/moe
MOE_MIGRATED_REVID=112723469

v1.3.0

Toggle v1.3.0's commit message
Occasionally compact combined state on write.

This is needed to avoid arbitrarily large blowup
for many-element windows.  Now, with a fixed
probability (currently 0.2%) when writing the state,
instead of doing a blind write we read in all
accumulated values, combine, and replace everything
with the final combined value.

----Release Notes----
[]
-------------
Created by MOE: https://github.com/google/moe
MOE_MIGRATED_REVID=109239045

v1.2.1

Toggle v1.2.1's commit message
Version management

Declare version 1.2.0. Prepare for version 1.2.1.

----Release Notes----
[]
-------------
Created by MOE: https://github.com/google/moe
MOE_MIGRATED_REVID=104700491

v1.2.0

Toggle v1.2.0's commit message
Handle exceptions from within the SDK while processing work

The DataflowWorkerHarness when processing work wasn't handling
general exceptions from being thrown causing the processing
threads to all die leaving a zombie worker.
----Release Notes----

[]
-------------
Created by MOE: https://github.com/google/moe
MOE_MIGRATED_REVID=104664789

v1.1.0

Toggle v1.1.0's commit message
Updates dependency google-api-services-datastore-protobuf.

----Release Notes----
Updating dependency google-api-services-datastore-protobuf from v1beta2-rev1-2.1.2 to v1beta2-rev1-3.0.2.

[]
-------------
Created by MOE: https://github.com/google/moe
MOE_MIGRATED_REVID=103114238

v1.0.0

Toggle v1.0.0's commit message
Dataflow GA: update GitHub's README.md to remove Beta language

----Release Notes----
[]
-------------
Created by MOE: http://code.google.com/p/moe-java
MOE_MIGRATED_REVID=100331508