GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2878
Forward integrate from `master` to `DSL_SQL`
To fix the unit test failure
`org.apache.beam.examples.WordCountIT.testE2EWordCount`
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/apache/beam master
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/beam/pull/2878.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2878
----
commit ce88c88b14e963ac17fac83dd19495c835c1f6cb
Author: Luke Cwik <[email protected]>
Date: 2017-04-28T01:13:43Z
[BEAM-2005] Move getScheme from FileSystemRegistrar to FileSystem
Note that I needed to update FileSystems to instantiate the FileSystem(s)
upfront instead of remembering the mapping from scheme to registrar.
commit ddabab3faded59e782455486fedf74b2ff60b60c
Author: Luke Cwik <[email protected]>
Date: 2017-04-28T16:00:26Z
[BEAM-2005] Move getScheme from FileSystemRegistrar to FileSystem
This closes #2757
commit fa422b9a81c303616786e8198d22c70df983d28e
Author: Ismaël MejÃa <[email protected]>
Date: 2017-04-28T15:25:30Z
Remove missing references to the flink examples package after refactor
commit d08b72892bf900995667a37239e610bc2cd960d0
Author: Ismaël MejÃa <[email protected]>
Date: 2017-04-28T16:26:08Z
This closes #2760
commit 594705d717dd6e5b81c08dcf4c56f8f6e7422737
Author: Peter Gergo Barna <[email protected]>
Date: 2017-04-27T12:37:26Z
[BEAM-2094] WordCount examples produce garbage for non-English input text
commit bff84e27ce9a479d0ad0ea51d2cd08bcc970af8e
Author: Ahmet Altay <[email protected]>
Date: 2017-04-28T16:33:49Z
This closes #2740
commit 34054ab27a53546571b4b687629a0997875479dc
Author: Ismaël MejÃa <[email protected]>
Date: 2017-04-26T15:43:53Z
Fix Javadoc warnings
commit ccfff5f82a56d9027541b17ed38a7590afae8134
Author: Davor Bonaci <[email protected]>
Date: 2017-04-28T16:34:35Z
This closes #2705
commit c1ceab7c1957f2c3144307aa324cd4ec1bc49524
Author: Vikas Kedigehalli <[email protected]>
Date: 2017-04-27T22:58:26Z
Add getFilename method to ResourceId
commit a8a04a2905e1ff639f403be7d9132acb77365e84
Author: Dan Halperin <[email protected]>
Date: 2017-04-28T17:03:15Z
This closes #2754
commit 3423bfd48a3f44e0b58eaef870b6adae45db3af6
Author: Luke Cwik <[email protected]>
Date: 2017-04-28T17:55:52Z
[BEAM-2119] Fix FileSystems to have the local filesystem installed by
default.
commit 1a265e34f31a32300515c454c619a26d61ba2482
Author: Luke Cwik <[email protected]>
Date: 2017-04-28T18:01:50Z
[BEAM-2119] Fix FileSystems to have the local filesystem installed by
default.
This closes #2765
commit 4041519c6a4bc232e0956190880fdad7c80ba0f9
Author: Dan Halperin <[email protected]>
Date: 2017-04-28T16:13:47Z
ResourceId: Add #isDirectory
commit 6b97fb1c224cd996d47fcfb6f6c5ae6e05b0caf0
Author: Dan Halperin <[email protected]>
Date: 2017-04-28T18:44:48Z
This closes #2761
commit 83872f467be2043813fd69ef73c0375d343b4b13
Author: Dan Halperin <[email protected]>
Date: 2017-04-28T18:20:00Z
TextIOTest: shrink size of test data
We have assertions that the files are still big enough, so this is safe.
Speeds up TextIOTest
2x.
commit f9406c76657e7dc6cd094b1e7281242e3f5fc9e9
Author: Dan Halperin <[email protected]>
Date: 2017-04-28T18:46:12Z
This closes #2766
commit 2bd668fdb3048043610cba44b880373666d8a222
Author: Kenneth Knowles <[email protected]>
Date: 2017-04-28T19:35:24Z
This closes #2734: Fix ApexTimerInternals serialization error.
commit 4e6dbf8e1adb81147202212e3220e763075b1e26
Author: Vikas Kedigehalli <[email protected]>
Date: 2017-04-28T19:12:43Z
Remove IOChannelUtils from a few ITs
commit 0c269cc21674b6f1d863e3ddb8ab233303086212
Author: Vikas Kedigehalli <[email protected]>
Date: 2017-04-28T19:14:24Z
Use getFileName in NumberedShardedFile
commit dbd44faf32601be6f04c351a0aa3828c2e4f07c9
Author: Dan Halperin <[email protected]>
Date: 2017-04-28T21:13:32Z
This closes #2768
commit b16e29cbb7edbc2e06dee1ec8512625731980584
Author: Devon Meunier <[email protected]>
Date: 2017-04-28T19:24:36Z
[BEAM-2114] Wrap inferred KafkaIO Coders with NullableCoder
commit a3e7383ccae77705259f9830613e78c449fed092
Author: Dan Halperin <[email protected]>
Date: 2017-04-28T21:14:07Z
This closes #2767
commit 864e2ad26e3748b414d10c53c28e5e18fb4a53e7
Author: Luke Cwik <[email protected]>
Date: 2017-04-28T17:30:24Z
[BEAM-2031] Add support to pass through zero or more Hadoop configurations
through as PipelineOptions
commit 7478da9975e0c73af562946efccd10ec64b2ef0e
Author: Luke Cwik <[email protected]>
Date: 2017-04-28T23:14:58Z
[BEAM-2031] Add support to pass through zero or more Hadoop configurations
through as PipelineOptions
This closes #2762
commit 15d8eacc8514197ca18289fe4b88ef245dd3379e
Author: Davor Bonaci <[email protected]>
Date: 2017-04-28T21:19:09Z
Retire Travis-CI coverage in Apache Beam
commit 29b828235cc4c901c0dc93ff96bcd3d8f494c18c
Author: Davor Bonaci <[email protected]>
Date: 2017-04-28T23:23:52Z
This closes #2769
commit d1395dceae3f166bbe2c1a6d32c2fd3e35c839bd
Author: Kenneth Knowles <[email protected]>
Date: 2017-04-27T15:56:52Z
Rollforwards "Replace OutputTimeFn UDF with TimestampCombiner enum""
This reverts commit 83d41fcce0c7b123459e5d26ab9938de49f48dab,
which reverted commit f38e4271334fced94e8dc1dc97f47b60fa810586
commit 1a74b4ec4c362030b0aeaf9290655e6bc6bc00c6
Author: Kenneth Knowles <[email protected]>
Date: 2017-04-28T23:40:25Z
Update Dataflow worker container to 20170428-2
commit a83524c2c092d62953851d7b2885338b71ddaced
Author: Luke Cwik <[email protected]>
Date: 2017-04-28T23:27:53Z
[BEAM-2005] Swap to use Lists within MatchResult instead of arrays.
commit b236104099a920b9eaad4b09304a94b11e358081
Author: Luke Cwik <[email protected]>
Date: 2017-04-29T00:16:14Z
[BEAM-2005] Swap to use Lists within MatchResult instead of arrays.
This closes #2772
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
