Github user mxm closed the pull request at:
https://github.com/apache/incubator-beam/pull/1283
---
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
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/1283
[BEAM-896] adjust ReadSourceITCase to exclude Beam temporary files
This should fix the test failures in `ReadSourceITCase` caused by #1050.
@dhalperi Wouldn't it be nice to have
This closes #1093
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6b5ff4c4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6b5ff4c4
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master a2c342cfd -> 6b5ff4c4a
[BEAM-593] avoid throwing Exception in waitUntilFinish
The current implementation of Flink's PipelineResult assumes that the
pipeline has already been processed. Hence, we can return State.Done
when
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/1093
[BEAM-593] avoid throwing Exception in waitUntilFinish
The current implementation of Flink's `PipelineResult` assumes that the
pipeline has already been processed. Hence, we can return
Repository: incubator-beam
Updated Branches:
refs/heads/master 13b45895e -> 73226168a
Fix inconsistent in formatting logs: leaveCompositeTransform always decrement
depth, but enterCompositeTransform increment depth only on ENTER_TRANSFORM
Project:
This closes #908
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/73226168
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/73226168
Diff:
This closes #1021
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a1ac
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a1ac
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master b5853a624 -> a1acd
[BEAM-615] Add Support for Processing-Time Timers in FlinkRunner Window Operator
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit:
This closes #967
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3879db03
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3879db03
Diff:
fix potential NPE in checkpointing of UnboundedSourceWrapper
This moves all the initialization code to the open() method which ensures
that no snapshot can occur before the state has been initialized correctly.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit:
Repository: incubator-beam
Updated Branches:
refs/heads/master db47c63ab -> 3879db036
[BEAM-283] finalize CheckpointMarks upon completed checkpoint
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit:
Repository: incubator-beam
Updated Branches:
refs/heads/master f62d04e22 -> 843275210
[BEAM-642] Support Flink Detached Mode for JOB execution
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/dc69bc48
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/967
[BEAM-283] finalize CheckpointMarks upon completed checkpoint
See the first commit for an addition to the `UnboundedSourceWrapper` to
call `finalizeCheckpoint()` on `CheckpointMark`s upon
This closes #929
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e9326c8b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e9326c8b
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master b6205ffa3 -> e9326c8b1
[flink] initialize watermarkTimeQueue with Comparator
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/de6ec823
Tree:
[BEAM-333][flink] make bounded/unbounded sources stoppable
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7e2820b0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7e2820b0
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master a96ea98a4 -> b6205ffa3
[BEAM-619] keep track of local split sources in UnboundedSourceWrapper
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit:
This closes #927
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b6205ffa
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b6205ffa
Diff:
[BEAM-619] extend test case to be parameterized
- extend test case with number of tasks and splits parameters
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4afd25a7
Tree:
This closes #924
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c78db9ad
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c78db9ad
Diff:
[BEAM-617][flink] introduce option to set state backend
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d4f85912
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d4f85912
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master 817515fe4 -> a96ea98a4
[flink] use exploded WindowValue in FlinkDoFnFunction
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3461ce21
Tree:
This closes #923
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0399dbc7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0399dbc7
Diff:
This closes #928
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a96ea98a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a96ea98a
Diff:
Repository: incubator-beam-site
Updated Branches:
refs/heads/asf-site e2430eb4d -> dcdd8b742
[BEAM-102] update capability matrix
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo
Commit:
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/8459da13
Tree:
This closes #39
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo
Commit:
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/dcdd8b74
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/dcdd8b74
Diff:
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/929
[flink] initialize watermarkTimeQueue with Comparator
This mitigates a ClassCastException with Comparable.
CC @aljoscha
You can merge this pull request into a Git repository
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/928
[flink] use exploded WindowValue in FlinkDoFnFunction
CC @aljoscha
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/incubator-beam fix
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/924
[BEAM-333][flink] make unbounded sources stoppable
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/incubator-beam BEAM-333
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/923
[BEAM-617][flink] introduce option to set state backend
CC @aljoscha
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/incubator-beam
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam-site/pull/39
[BEAM-102] update capability matrix
This updates the matrix to the most recent development status.
CC @aljoscha
You can merge this pull request into a Git repository by running
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/821
[flink] add missing maven config to example pom
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/incubator-beam fix
Alternatively you
Repository: incubator-beam
Updated Branches:
refs/heads/master 267136fb6 -> d02d2de09
[flink] improve example section in README
- updates the README
- repairs broken exec configuration
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit:
This closes #724
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d02d2de0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d02d2de0
Diff:
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/724
[flink] improve example section in README
- updates the README
- repairs broken exec configuration
You can merge this pull request into a Git repository by running:
$ git pull https
This closes #450
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/be05942d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/be05942d
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master 60964b611 -> be05942da
[flink] fix potential NPE in ParDoWrapper
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a2abc6a2
Tree:
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/450
[flink] fix potential NPE in ParDoWrapper
Just discovered this while checking for correct execution of the bundle
life cycle. This fixes potential NPEs in the ParDo translation wrapper
Repository: incubator-beam
Updated Branches:
refs/heads/master ffbfc66e1 -> cc448e976
[BEAM-196] provide PipelineOptions in DoFn
- fixes NPE when accessing the PipelineOptions
- adds a test to verify that the PipelineOptions are available
Project:
[BEAM-287] adjust README to changed Maven layout
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1fd0dfc7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1fd0dfc7
Diff:
[flink] improve lifecycle of ParDoBoundWrapper
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d10ae23c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d10ae23c
Diff:
This closes #415
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/cc448e97
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/cc448e97
Diff:
This closes #432
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f5583cfa
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f5583cfa
Diff:
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/432
[BEAM-196] Additional fix to ensure the PipelineOptions are available in
DoFns.
Fixes a NullPointException if `PipelineOptions` are acceessed inside a DoFn
and backs it up with a test.
You
This closes #398
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2ffecfda
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2ffecfda
Diff:
[BEAM-235] use streaming mode on unbounded sources
This change automatically discovers the execution mode of the Pipeline
during a preliminary "optimization" translation of the pipeline. When
unbounded sources are discovered, the pipeline translation mode is
switched to streaming.
Users may
Repository: incubator-beam
Updated Branches:
refs/heads/master cca2577c6 -> 36a27f538
[Beam-312] don't checkpoint if CheckpointCoder not available
This skips the checkpoint logic in the UnboundedSourceWrapper if the
UnboundedSource doesn't supply a CheckpointMarkCoder.
Project:
This closes #395
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5d2f9cd2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5d2f9cd2
Diff:
This closes #394
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/36a27f53
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/36a27f53
Diff:
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/395
[Beam-312] don't checkpoint if CheckpointCoder not available
This skips the checkpoint logic in the UnboundedSourceWrapper if the
UnboundedSource doesn't supply a CheckpointMarkCoder.
You
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/394
[BEAM-235] use streaming mode on unbounded sources
This change automatically discovers the execution mode of the Pipeline
during a preliminary "optimization" translation of th
[BEAM-103] rebuild capability matrix
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo
Commit:
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/15dd578f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/15dd578f
Diff:
This closes #19
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo
Commit:
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/65770137
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/65770137
Diff:
Repository: incubator-beam-site
Updated Branches:
refs/heads/asf-site 92fc27503 -> 657701378
[BEAM-103] update capability matrix
This reflects the changes of BEAM-103 in the Capability Matrix.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo
Commit:
This closes #344
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/cc64d654
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/cc64d654
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master d627266d8 -> cc64d654c
[flink] replace obsolete reflection call
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9f630002
Tree:
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/344
[flink] replace obsolete reflection call
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [X] Make sure the PR title is formatted
This closes #324
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/123674f4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/123674f4
Diff:
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/324
[BEAM-272][flink] remove dependency on Dataflow Runner
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [X] Make sure the PR title
fix Flink source coder handling
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/aead96ff
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/aead96ff
Diff:
Flink sink implementation
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bc847a95
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bc847a95
Diff:
This closes #266
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/661a4a89
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/661a4a89
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master 4fd9d74df -> 661a4a893
add Kafka IO examples
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/63bce07d
Tree:
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/266
Add option to use Flink's Kafka Write IO
This pull request adds the counterpart of the UnboundedFlinkSource, the
`UnboundedFlinkSink` which uses the `Write` API. Users have requested
Repository: incubator-beam
Updated Branches:
refs/heads/master b8951c231 -> d5b1d5135
[BEAM-207] Flink test flake in ReadSourceStreamingITCase
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/dd8bc93e
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/209
[BEAM-207] Flink test flake in ReadSourceStreamingITCase
The `configure(..)` life cycle method is only called on the master but not
on the worker nodes. This may lead to an incorrect
[BEAM-196] abstraction for PipelineOptions serialization
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/81577b31
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/81577b31
Diff:
This closes #200
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/70e6a131
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/70e6a131
Diff:
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/200
[BEAM-196] Pipeline options must be available Context in DoFn.startBundle
This gets rid of the custom Java serialization code by defaulting to
serialization of the `PipelineOptions` to a byte
[flink] improve InputFormat wrapper and ReadSourceITCase
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6eac35e8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6eac35e8
Diff:
[flink] improvements to UnboundedSource translation
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7c4f2dc1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7c4f2dc1
Diff:
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/104
[BEAM-158] add support for bounded sources in streaming
Apart from a few improvements, this PR introduces bounded sources in
streaming. The BoundedSource wrapper (`SourceInputFormat
This closes #94.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/96e286fe
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/96e286fe
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master 0c47cad48 -> 96e286fec
[flink] improve lifecycle handling of GroupAlsoByWindowWrapper
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit:
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/94
[flink] improve lifecycle handling of GroupAlsoByWindowWrapper
Could someone have a look if these minor changes are good to merge?
@davorbonaci @kennknowles
Note, that there are two
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/73
[BEAM-149] move language source config to pluginManagement
This fixes issues with the source/target level in IntelliJ.
You can merge this pull request into a Git repository by running
Update AutoComplete.java
Allow for the Datastore dependency of this test to be in a different project
than the main project for the job.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/834d0710
Tree:
This closes #69
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2f902582
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2f902582
Diff:
Add DisplayData builder API to SDK
This allows generating the display data which will be attached to
PTransforms.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5ecb7aa7
Tree:
Implement InProcessPipelineRunner#run
Appropriately construct an evaluation context and executor, and start
the pipeline when run is called.
Implement InProcessPipelineResult.
Apply PTransform overrides.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit:
Repository: incubator-beam
Updated Branches:
refs/heads/master 8d87ee02b -> 2f902582c
make BigtableIO#Read#withRowFilter public
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e39b5d9a
Tree:
[BEAM-143] [flink] add test for UnboundedSourceWrapper
The test ensures serialization and execution of the wrapper works as
expected.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1504ba7b
Tree:
[flink] Add FlinkRunnerRegistrar
Expose Flink runner and options via AuteService. AuteService will
at compile time populate META-INF/services so that Dataflow sdk
can seamlessly pick up FlinkRunner.
This closes #40.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit:
[BEAM-116] change runners artifactId to runners-parent
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a20e0b64
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a20e0b64
Diff:
[flink] add test case for Runner registration
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/cb5d6c2b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/cb5d6c2b
Diff:
[flink] Add FlinkRunnerRegistrar
Expose Flink runner and options via AuteService. AuteService will
at compile time populate META-INF/services so that Dataflow sdk
can seamlessly pick up FlinkRunner.
This closes #40.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit:
Repository: incubator-beam
Updated Branches:
refs/heads/master fcc6f3cfd -> c984f3ae2
[flink] add test case for Runner registration
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ba7b7a04
Tree:
Repository: incubator-beam
Updated Branches:
refs/heads/master f7aaee2ea -> fcc6f3cfd
[BEAM-116] change runners artifactId to runners-parent
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/447c8af2
Tree:
[BEAM-116] This closes #59
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fcc6f3cf
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/fcc6f3cf
Diff:
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/59
[BEAM-116] change runners artifactId to runners-parent
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/incubator-beam BEAM-116
Repository: incubator-beam
Updated Branches:
refs/heads/master 0f137169e -> ef1e32dee
[flink] improvements to the Kafka Example
- use timestamp extractor after ingestion
- fix coder runtime exception
- correct logging
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Repository: incubator-beam
Updated Branches:
refs/heads/master a9c46057e -> 0f137169e
[flink] fix UnboundedFlinkSource wrapper
- remove unnecessary PipelineOptions cache
- use the correct interface types
- improve Kafka example
Project:
Repository: incubator-beam
Updated Branches:
refs/heads/master 5b5c0e28f -> 81d5ff5a5
[BEAM-126] remove strict job name check
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/81d5ff5a
Tree:
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/071e4dd6/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/FlinkAbstractParDoWrapper.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/071e4dd6/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/SourceInputFormat.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/071e4dd6/runners/flink/runner/src/test/java/org/apache/beam/runners/flink/WordCountJoin2ITCase.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/071e4dd6/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkMultiOutputDoFnFunction.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/071e4dd6/runners/flink/src/main/java/org/apache/beam/runners/flink/io/ConsoleIO.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/071e4dd6/runners/flink/pom.xml
--
diff --git a/runners/flink/pom.xml b/runners/flink/pom.xml
index c8c5d84..31713cd 100644
--- a/runners/flink/pom.xml
+++
1 - 100 of 118 matches
Mail list logo