[beam] 01/01: Merge pull request #4931: [BEAM-3909] Add tests for Flink DoFnOperator side-input checkpointing

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit c744afd2603e1d4db8e26762e626769bbbfa271e Merge: e0aac4e aaa2ead Author: Aljoscha Krettek AuthorDate: Mon Apr 30 12:26

[beam] branch master updated (e0aac4e -> c744afd)

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from e0aac4e [BEAM-3973] Adds a parameter to the Cloud Spanner read connector that can disable batch API (#4946

[beam] branch master updated: [BEAM-2806] Fix pipeline translation mode recognition in Flink Runner

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git The following commit(s) were added to refs/heads/master by this push: new b5c31ed [BEAM-2806] Fix pipeline translation

[beam] 12/12: Merge pull request #4639: [BEAM-2140] Fix SplittableDoFn ValidatesRunner tests in Flink Streaming Runner

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 0259636661998b8aabd3bf20eff8d519bcb9fb47 Merge: 51b793a 6148a6d Author: Aljoscha Krettek AuthorDate: Fri Feb 23 11:59

[beam] 02/12: Allow overriding DoFnRunners in subclasses of Flink DoFnOperator

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit c40868fe2fc550ae97c7b2d9308dd8b58b20edab Author: Aljoscha Krettek AuthorDate: Thu Jan 11 10:52:01 2018 +0100 Allow

[beam] 03/12: Invoke finishBundle() before teardown() in DoFnOperator

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 4029e23f3075365eddcdad5187b4fc8a6e590989 Author: Aljoscha Krettek AuthorDate: Fri Jan 5 14:22:40 2018 +0100 Invoke

[beam] 01/12: Make parameter of DoFnRunners.lateDataDroppingRunner() more specific

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 50c6d9316c8c5089065dd291b097e06b0c80980e Author: Aljoscha Krettek AuthorDate: Thu Jan 11 10:56:49 2018 +0100 Make

[beam] branch master updated (51b793a -> 0259636)

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 51b793a Merge pull request #4723: [BEAM-3317] Use fixed system time for KinesisReaderTest new 50c6d93 Make

[beam] 09/12: [BEAM-2140] Enable SDF tests for Flink Streaming Runner

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit c920a39b9781ac604f55059e597e327643d58205 Author: Aljoscha Krettek AuthorDate: Fri Jan 5 14:20:19 2018 +0100 [BEAM

[beam] 05/12: [BEAM-2140] Block DoFnOperator.close() if we have pending timers

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 3eecb381f3fb412df6844cfc13b12bf265253926 Author: Aljoscha Krettek AuthorDate: Fri Jan 5 14:17:49 2018 +0100 [BEAM

[beam] 11/12: [BEAM-3727] Never shutdown sources in Flink Streaming execution mode

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 6148a6d063a0503ee435ab5084fcba3fb864b26f Author: Aljoscha Krettek AuthorDate: Thu Feb 22 14:26:16 2018 +0100 [BEAM

[beam] 06/12: [BEAM-2140] Don't use StatefulDoFnRunner when running SDF in FlinkRunner

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit d15979f2cf0d6bc47d049a6ea157d9d7b2b97848 Author: Aljoscha Krettek AuthorDate: Wed Jan 10 06:48:49 2018 +0100 [BEAM

[beam] 08/12: [BEAM-2140] Use ProcessFnRunner in DoFnRunner for executing SDF

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 74ac703bbfa40d16e7d1115912768c7a63598d52 Author: Aljoscha Krettek AuthorDate: Thu Feb 8 13:02:26 2018 +0100 [BEAM

[beam] 04/12: [BEAM-2140] Ignore event-time timers in SplittableDoFnOperator

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 2e0b192efbae72fe5c0ef61abfc7b4d1b3bb75f5 Author: Aljoscha Krettek AuthorDate: Fri Jan 5 14:16:27 2018 +0100 [BEAM

[beam] 10/12: [BEAM-2140] Enable SDF tests in gradle for Flink Streaming Runner

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 6ba3fc1ff2798764756a7188980facc31eb1ac4c Author: Aljoscha Krettek AuthorDate: Thu Feb 8 13:00:34 2018 +0100 [BEAM

[beam] 07/12: Make ProcessFnRunner constructor public

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 4ec4644952c05167f52ae0937e043140d26059ae Author: Aljoscha Krettek AuthorDate: Thu Feb 8 13:01:22 2018 +0100 Make

[beam] 01/01: Merge pull request #4767: [BEAM-3753] Fix Flink Runner integration tests

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 8ec9c813814b10eb7b8e2e1515086ef5c4dfc353 Merge: 5c1e49c f28d198 Author: Aljoscha Krettek AuthorDate: Wed Mar 7 14:27:54

[beam] branch master updated (5c1e49c -> 8ec9c81)

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 5c1e49c Merge pull request #4810 from alanmyrvold/alan-version add 788c83c [BEAM-3753] Fix failing

[beam] branch master updated (8ec9c81 -> d497bfa)

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 8ec9c81 Merge pull request #4767: [BEAM-3753] Fix Flink Runner integration tests add c6467d8 [BEAM-3043] Set

[beam] 01/01: Merge pull request #4759: [BEAM-3043] Set user-specified PTransform names on Flink operators

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit d497bfa2cbe752376cc8961ab6e6fb6754485ac2 Merge: 8ec9c81 c6467d8 Author: Aljoscha Krettek AuthorDate: Wed Mar 7 14:31:27

[beam] 03/03: Merge pull request #4563: Fixes Flink timer service restore

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 93818abf901dd996aa30445457153811b13ece43 Merge: 24804e9 6808b88 Author: Aljoscha Krettek AuthorDate: Mon Feb 5 11:57:36

[beam] 01/03: Remove erroneous cast in FlinkStreamingTransformTranslators

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 01d74b3b8381c04ffba3879281897ea2ef6fbcc5 Author: Dawid Wysakowicz AuthorDate: Mon Feb 5 11:36:33 2018 +0100 Remove

[beam] branch master updated (24804e9 -> 93818ab)

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 24804e9 Merge pull request #3978: [BEAM-230] Remove deprecated WindowedValue.valueInEmptyWindows new 01d74b3

[beam] 02/03: [BEAM-3186] Correctly use deserialized timerService in Flink Runner

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 6808b8855f90f69098bd37d2353da7d3ca329eb3 Author: Dawid Wysakowicz AuthorDate: Thu Feb 1 13:47:30 2018 +0100 [BEAM

[beam] 01/01: Merge pull request #5572: [BEAM-4311] Enforce ErrorProne analysis in Flink runner

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 358898e6c0574ec97e84081485a6644ba6dd3a30 Merge: c70d5be ef4ea06 Author: Aljoscha Krettek AuthorDate: Fri Jun 8 13:21:46

[beam] branch master updated (c70d5be -> 358898e)

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from c70d5be Merge pull request #5431 from asethia/master: Update right documentation for HCatalogIO.write add

[beam] branch master updated (8b72e5a -> ab3c38d)

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 8b72e5a Merge pull request #4940: Update generated files add f3dbd8c [BEAM-3800] Set uids on Flink operators

[beam] 01/01: Merge pull request #4903: [BEAM-3800] Set uids on Flink operators

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit ab3c38dcc3b65f850016be3cf68b36943def5645 Merge: 8b72e5a f3dbd8c Author: Aljoscha Krettek AuthorDate: Mon Mar 26 04:16

[beam] branch master updated: [BEAM-622] Add checkpointing tests for DoFnOperator and WindowDoFnOperator

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git The following commit(s) were added to refs/heads/master by this push: new ebc0fb0 [BEAM-622] Add checkpointing tests for

[beam] 03/03: Merge pull request #4895: [BEAM-2393] Make BoundedSource fault-tolerant in FlinkRunner Streaming mode

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit f93a332a20857f425fa1c1b69d2423f3c2e7880d Merge: 302b247 0e44feb Author: Aljoscha Krettek AuthorDate: Tue Mar 27 06:49

[beam] 01/03: [BEAM-3087] Make reader state update and element emission atomic

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit fef8f54be417be88730ebf2d0e8db8c55fbd013f Author: Grzegorz Kołakowski AuthorDate: Wed Feb 21 10:31:53 2018 +0100

[beam] branch master updated (302b247 -> f93a332)

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 302b247 Merge pull request #4937: [BEAM-622] Add checkpointing tests for DoFnOperator and WindowDoFnOperator

[beam] 02/03: [BEAM-2393] Make BoundedSource fault-tolerant

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 0e44feb120a73c36116b2bd6b89e4f1676d7266f Author: Grzegorz Kołakowski AuthorDate: Wed Feb 21 11:11:53 2018 +0100

[GitHub] beam pull request #3258: [BEAM-2380] Forward additional outputs to DoFnRunne...

GitHub user aljoscha opened a pull request: https://github.com/apache/beam/pull/3258 [BEAM-2380] Forward additional outputs to DoFnRunner in Flink Batch R: @iemejia or anyone, really 😃 You can merge this pull request into a Git repository by running: $ git pull https

[GitHub] beam pull request #3285: Fix race condition when outputting pushed-back elem...

GitHub user aljoscha opened a pull request: https://github.com/apache/beam/pull/3285 Fix race condition when outputting pushed-back elements in Flink Runner This affected the Flink Streaming Runner DoFnOperator. The recent fix of emitting pushed-back data when receiving a

[2/2] beam git commit: This closes #3285

/master Commit: ef56ea49569f00e098045ec01812b962adfb157d Parents: 43c4423 d17c013 Author: Aljoscha Krettek Authored: Sun Jun 4 08:14:08 2017 +0200 Committer: Aljoscha Krettek Committed: Sun Jun 4 08:14:08 2017 +0200 -- .../wrappers

[1/2] beam git commit: Fix race condition when outputting pushed-back elements in Flink Runner

132 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d17c0132 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d17c0132 Branch: refs/heads/master Commit: d17c013240a14b12992cf00f30e5151c7e97f360 Parents: 43c4423 Author: Aljoscha Krettek Authored: Fri Jun 2 15:57:01 2017 +0200 Commit

[GitHub] beam pull request #3285: Fix race condition when outputting pushed-back elem...

Github user aljoscha closed the pull request at: https://github.com/apache/beam/pull/3285 --- 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

[1/2] beam git commit: [BEAM-2401] Update Flink Runner to Flink 1.3.0

pos/asf/beam/tree/fbc6cc59 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fbc6cc59 Branch: refs/heads/master Commit: fbc6cc59bff93dfcf8676f874870a43eeb228c15 Parents: ef56ea4 Author: JingsongLi Authored: Fri Jun 2 11:31:44 2017 +0800 Committer: Aljoscha Krettek Committed: Sun Jun 4 08:18

[2/2] beam git commit: This closes #3284

/master Commit: 1866a01138ac9095aa7d8dfb1d67c955678b393e Parents: ef56ea4 fbc6cc5 Author: Aljoscha Krettek Authored: Sun Jun 4 08:30:30 2017 +0200 Committer: Aljoscha Krettek Committed: Sun Jun 4 08:30:30 2017 +0200 -- runners/flink

[GitHub] beam pull request #3294: Shutdown Flink Streaming Pipeline when reaching +In...

GitHub user aljoscha opened a pull request: https://github.com/apache/beam/pull/3294 Shutdown Flink Streaming Pipeline when reaching +Inf watermark R: @iemejia maybe you can have a look at this in the context of NEXMark You can merge this pull request into a Git repository by

[GitHub] beam pull request #3295: [BEAM-593] Refactor Flink execution as preparation ...

GitHub user aljoscha opened a pull request: https://github.com/apache/beam/pull/3295 [BEAM-593] Refactor Flink execution as preparation for async job control This is just the basic refactoring extracted from #2915. I think we should get this in rather quickly because several people

[2/3] beam git commit: [BEAM-1498] Use Flink-native side outputs

Branch: refs/heads/master Commit: b0601fd43e0929e8b925dbe566e564460f91d9fc Parents: 88f78fa Author: JingsongLi Authored: Sun Jun 4 21:56:10 2017 +0800 Committer: Aljoscha Krettek Committed: Tue Jun 6 14:33:36 2017 +0200

[1/3] beam git commit: Remove the FnOutputT parameter from DoFnOperator

pos/asf/beam/tree/e8f26085 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e8f26085 Branch: refs/heads/master Commit: e8f26085e889f8f618c0961a5458cbc42b432c01 Parents: b0601fd Author: JingsongLi Authored: Tue Jun 6 17:31:09 2017 +0800 Committer: Aljoscha Krettek Committed: Tue Jun 6 14:33

[3/3] beam git commit: This closes #3290

/master Commit: aebd3a4c5d416edd9f829e9ac1aecb230ac6 Parents: 88f78fa e8f2608 Author: Aljoscha Krettek Authored: Tue Jun 6 14:33:46 2017 +0200 Committer: Aljoscha Krettek Committed: Tue Jun 6 14:33:46 2017 +0200

[2/4] beam git commit: [BEAM-1779] Port UnboundedSourceWrapperTest to use Flink operator test harness

-us.apache.org/repos/asf/beam/diff/c1dc8f53 Branch: refs/heads/master Commit: c1dc8f53c5438b575a7e84e9f680616ead49d61e Parents: 62b942a Author: Aljoscha Krettek Authored: Wed Mar 22 11:43:30 2017 +0100 Committer: Aljoscha Krettek Committed: Wed Jun 7 19:43:11 2017 +0200

[3/4] beam git commit: [BEAM-2407] Fix Flink CoderTyperSerializer ConfigSnapshot

Branch: refs/heads/master Commit: 62b942a02ec633c172d543946be9cfe0648825ea Parents: b2de3db Author: Aljoscha Krettek Authored: Mon Jun 5 09:10:59 2017 +0200 Committer: Aljoscha Krettek Committed: Wed Jun 7 19:43:11 2017 +0200

[1/4] beam git commit: [BEAM-2408] Fix watermark emission in Flink UnboundedSourceWrapper

ads/master Commit: 8f4fa4394609504348ada988948f0a1386d54c0e Parents: c1dc8f5 Author: Aljoscha Krettek Authored: Mon Jun 5 15:46:26 2017 +0200 Committer: Aljoscha Krettek Committed: Wed Jun 7 19:43:11 2017 +0200 -- .../streaming

[4/4] beam git commit: This closes #2286

/master Commit: 609016d700c84800cf942482fb7cd2ddaa420b00 Parents: b2de3db 8f4fa43 Author: Aljoscha Krettek Authored: Wed Jun 7 19:43:19 2017 +0200 Committer: Aljoscha Krettek Committed: Wed Jun 7 19:43:19 2017 +0200

[1/2] beam git commit: [BEAM-2423] Abstract StateInternalsTest for the different state internals

git-wip-us.apache.org/repos/asf/beam/tree/8362bdb9 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/8362bdb9 Branch: refs/heads/master Commit: 8362bdb9cd35cc02ed179b3a64fd72f1264a99be Parents: 1597f3c Author: JingsongLi Authored: Thu Jun 8 01:31:34 2017 +0800 Committer: Aljoscha Kret

[2/2] beam git commit: This closes #3313

/master Commit: f9d51aa5cc718c44c82ec4773dbd16a57e7d394e Parents: 1597f3c 8362bdb Author: Aljoscha Krettek Authored: Mon Jun 12 22:35:35 2017 +0200 Committer: Aljoscha Krettek Committed: Mon Jun 12 22:35:35 2017 +0200 -- pom.xml

[4/4] beam git commit: This closes #3309

/master Commit: 7126fdc6ee5671e99a2dede3f25ba616aa0e8fa4 Parents: fe3d554 4d18606 Author: Aljoscha Krettek Authored: Tue Jun 13 11:35:43 2017 +0200 Committer: Aljoscha Krettek Committed: Tue Jun 13 11:35:43 2017 +0200 -- .../beam

[3/4] beam git commit: Use CoderTypeSerializer and remove unuse code in FlinkStateInternals

/repos/asf/beam/diff/4c365087 Branch: refs/heads/master Commit: 4c36508733a69fafce0f7dfb86c71eee5eb6bc84 Parents: fe3d554 Author: JingsongLi Authored: Wed Jun 7 14:34:25 2017 +0800 Committer: Aljoscha Krettek Committed: Tue Jun 13 11:35:17 2017 +0200

[2/4] beam git commit: [BEAM-1483] Support SetState in Flink runner and fix MapState to be consistent with InMemoryStateInternals.

/10b166b3 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/10b166b3 Branch: refs/heads/master Commit: 10b166b355a03daeae78dd1e71016fc72805939d Parents: 4c36508 Author: JingsongLi Authored: Wed Jun 7 14:40:30 2017 +0800 Committer: Aljoscha Krettek Committed: Tue Jun 13 11:35:17 2017 +0200

[1/4] beam git commit: Add set and map readable test to StateInternalsTest

org/repos/asf/beam/tree/4d186063 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4d186063 Branch: refs/heads/master Commit: 4d18606378f43c7b0d3ac05d45ca6e0570e49eef Parents: 10b166b Author: JingsongLi Authored: Tue Jun 13 10:15:33 2017 +0800 Committer: Aljoscha Krettek Committed: Tue Jun 13 11

[2/2] beam git commit: This closes #3348

/master Commit: d5261d74b2422f2876768860587f099f43ab3b0e Parents: c528fb2 581ee15 Author: Aljoscha Krettek Authored: Fri Jun 16 11:49:02 2017 +0200 Committer: Aljoscha Krettek Committed: Fri Jun 16 11:49:02 2017 +0200 -- runners/apex

[1/2] beam git commit: [BEAM-2423] Port state internals tests to the new base class StateInternalsTest

ttp://git-wip-us.apache.org/repos/asf/beam/tree/581ee152 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/581ee152 Branch: refs/heads/master Commit: 581ee1520e497fca95e8c4aa75f90050952523d0 Parents: c528fb2 Author: JingsongLi Authored: Tue Jun 13 11:26:38 2017 +0800 Committer: Aljoscha Kret

[2/3] beam-site git commit: remove extra streaming refs in capability matrix: Flink state/timers

-us.apache.org/repos/asf/beam-site/diff/87355b74 Branch: refs/heads/asf-site Commit: 87355b74e35bed4f7e65cbe2c170fbd9cbb69921 Parents: 33b1388 Author: melissa Authored: Tue Apr 11 10:22:02 2017 -0700 Committer: Aljoscha Krettek Committed: Tue Apr 18 11:57:13 2017 +0200

[1/3] beam-site git commit: Regenerate website

ite/tree/d2ac82e3 Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/d2ac82e3 Branch: refs/heads/asf-site Commit: d2ac82e386f196e09c6ea623f922d2c17df5880c Parents: 87355b7 Author: Aljoscha Krettek Authored: Tue Apr 18 11:56:01 2017 +0200 Committer: Aljoscha Krettek Committed: Tue Apr 18

[3/3] beam-site git commit: This closes #207`

Branch: refs/heads/asf-site Commit: 3e8514d352a48a5bf7b43f88b0ebc462b49f6377 Parents: 33b1388 d2ac82e Author: Aljoscha Krettek Authored: Tue Apr 18 11:57:30 2017 +0200 Committer: Aljoscha Krettek Committed: Tue Apr 18 11:57:30 2017 +0200

[1/3] beam-site git commit: Update flink page ref from language-python to language-py and add toggle

ter: Aljoscha Krettek Committed: Wed Apr 19 11:29:24 2017 +0200 -- src/documentation/runners/flink.md | 15 --- 1 file changed, 12 insertions(+), 3 deleti

[3/3] beam-site git commit: This closes #216

Branch: refs/heads/asf-site Commit: 3ecf363c2229dbbe918e00ad9acce34c45ee10e8 Parents: 97641db ab9c857 Author: Aljoscha Krettek Authored: Wed Apr 19 11:31:25 2017 +0200 Committer: Aljoscha Krettek Committed: Wed Apr 19 11:31:25 2017 +0200

[2/3] beam-site git commit: Regenerate website

Branch: refs/heads/asf-site Commit: ab9c8578359f4c9fadc11fae251298e5b57645af Parents: f936a3d Author: Aljoscha Krettek Authored: Wed Apr 19 11:31:14 2017 +0200 Committer: Aljoscha Krettek Committed: Wed Apr 19 11:31:14 2017 +0200

[GitHub] beam pull request #2611: [BEAM-1886] Remove TextIO override in Flink runner

GitHub user aljoscha opened a pull request: https://github.com/apache/beam/pull/2611 [BEAM-1886] Remove TextIO override in Flink runner This is a duplicate of #2537. The tests work locally but not on Jenkins, I'm trying to figure out why that might be. You can merge this

[1/3] beam git commit: Exclude UsesSplittableParDoWithWindowedSideInputs in Flink Stream Runner Tests

ttp://git-wip-us.apache.org/repos/asf/beam/tree/252ebf15 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/252ebf15 Branch: refs/heads/master Commit: 252ebf15e002481f3c2648035e04dd3f4b57832d Parents: 0c030d4 Author: Aljoscha Krettek Authored: Thu Apr 20 16:27:51 2017 +0200 Committer: Aljos

[3/3] beam git commit: This closes #2537

/master Commit: 56398fcba247c3e5416dc3d3f41c73193856fddc Parents: 4121ec4 252ebf1 Author: Aljoscha Krettek Authored: Thu Apr 20 18:01:28 2017 +0200 Committer: Aljoscha Krettek Committed: Thu Apr 20 18:01:28 2017 +0200 -- runners

[2/3] beam git commit: [BEAM-1886] Remove TextIO override in Flink runner

/0c030d49 Branch: refs/heads/master Commit: 0c030d49a79ce20e25a8af3110442130dab8899c Parents: 4121ec4 Author: JingsongLi Authored: Fri Apr 14 11:22:43 2017 +0800 Committer: Aljoscha Krettek Committed: Thu Apr 20 18:01:19 2017 +0200

[GitHub] beam pull request #2611: [BEAM-1886] Remove TextIO override in Flink runner

Github user aljoscha closed the pull request at: https://github.com/apache/beam/pull/2611 --- 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

[4/4] beam git commit: This closes #2300

/master Commit: 8160924e12a4723df34209a04c907d4f95466ecf Parents: b382795 217f24b Author: Aljoscha Krettek Authored: Fri Apr 21 11:59:46 2017 +0200 Committer: Aljoscha Krettek Committed: Fri Apr 21 11:59:46 2017 +0200 -- runners

[2/4] beam git commit: Add IO metrics to Flink runner

: refs/heads/master Commit: 2c69d25e3fda4ac0d9503da7cee3835e4f705506 Parents: 0a7e6c3 Author: JingsongLi Authored: Wed Mar 29 23:35:44 2017 +0800 Committer: Aljoscha Krettek Committed: Fri Apr 21 11:21:41 2017 +0200 -- .../flink

[1/4] beam git commit: Ensure all Read outputs are consumed in Flink runner

org/repos/asf/beam/tree/217f24b9 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/217f24b9 Branch: refs/heads/master Commit: 217f24b95d9c80d658afc23511e6de33220a5c5d Parents: 2c69d25 Author: JingsongLi Authored: Fri Apr 21 09:56:46 2017 +0800 Committer: Aljoscha Krettek Committed: Fri Apr 21

[3/4] beam git commit: [BEAM-773] Implement Metrics support for Flink runner

/diff/0a7e6c3d Branch: refs/heads/master Commit: 0a7e6c3d5937a19d33c9bf1945dd4af162d1e51b Parents: b382795 Author: JingsongLi Authored: Wed Mar 22 15:56:50 2017 +0800 Committer: Aljoscha Krettek Committed: Fri Apr 21 11:21:41 2017 +0200

[2/2] beam git commit: This closed #2331

/master Commit: 3178f07b9dbd913c44f29b828ae199fea2af36bf Parents: 75728a4 d4a9f60 Author: Aljoscha Krettek Authored: Tue Apr 25 16:43:42 2017 +0200 Committer: Aljoscha Krettek Committed: Tue Apr 25 16:43:42 2017 +0200 -- .../flink

[1/2] beam git commit: [BEAM-1772] Support merging WindowFn other than IntervalWindow on Flink Runner

ttp://git-wip-us.apache.org/repos/asf/beam/tree/d4a9f60d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d4a9f60d Branch: refs/heads/master Commit: d4a9f60df15f22f30869a1e19493b32de2506049 Parents: 75728a4 Author: JingsongLi Authored: Mon Mar 27 02:09:32 2017 +0800 Committer: Aljoscha Kret

[1/2] beam git commit: [BEAM-1812] Add externalized checkpoint configuration to FlinkPipelineOptions

ttp://git-wip-us.apache.org/repos/asf/beam/tree/63327dd3 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/63327dd3 Branch: refs/heads/master Commit: 63327dd3878c7b7a1891d53b64d999f40565948d Parents: 3178f07 Author: Jins George Authored: Tue Apr 4 16:05:57 2017 -0700 Committer: Aljoscha Kret

[2/2] beam git commit: This closes #2442

/master Commit: 6aed130cc293cfa30e5ec3eca09d1145eea908a2 Parents: 3178f07 63327dd Author: Aljoscha Krettek Authored: Tue Apr 25 17:42:26 2017 +0200 Committer: Aljoscha Krettek Committed: Tue Apr 25 17:42:26 2017 +0200 -- .../flink

[GitHub] beam pull request #3625: [BEAM-2571] Fix FlinkRunner Watermark issues on 2.1...

GitHub user aljoscha opened a pull request: https://github.com/apache/beam/pull/3625 [BEAM-2571] Fix FlinkRunner Watermark issues on 2.1.0 branch You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/beam jira-2571-fix-flink

[2/2] beam git commit: This closes #2421

/master Commit: 3bffe0e0014bdd6ae73dc2e8ecfc2b61d066120c Parents: 7903e59 fc4534c Author: Aljoscha Krettek Authored: Fri May 5 13:05:01 2017 +0200 Committer: Aljoscha Krettek Committed: Fri May 5 13:05:01 2017 +0200 -- .../streaming

[1/2] beam git commit: [BEAM-1862] SplittableDoFnOperator should close the ScheduledExecutorService

ttp://git-wip-us.apache.org/repos/asf/beam/tree/fc4534cd Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fc4534cd Branch: refs/heads/master Commit: fc4534cd6e5366a5f12cefebcd52ac1fe7cdde41 Parents: 7903e59 Author: JingsongLi Authored: Tue Apr 4 18:28:15 2017 +0800 Committer: Aljoscha Kret

[GitHub] beam pull request #2915: [BEAM-593] Add non-blocking pipeline execution on F...

GitHub user aljoscha opened a pull request: https://github.com/apache/beam/pull/2915 [BEAM-593] Add non-blocking pipeline execution on Flink Runner You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/beam jira-593-async

[GitHub] beam-site pull request #262: Update Flink Runner doc

GitHub user aljoscha opened a pull request: https://github.com/apache/beam-site/pull/262 Update Flink Runner doc This updates to a more recent Flink version and also adds a note about matching Scala versions. R: @jingsongli You can merge this pull request into a Git

[1/4] beam-site git commit: Add note about Scala version when setting up Flink cluster

ttp://git-wip-us.apache.org/repos/asf/beam-site/tree/218331a8 Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/218331a8 Branch: refs/heads/asf-site Commit: 218331a8b4ebf54a5ded5dae4580a3cafef7ea92 Parents: 28a94d3 Author: Aljoscha Krettek Authored: Tue Jun 27 17:31:56 2017 +0200 Commit

[3/4] beam-site git commit: Regenerate website

Branch: refs/heads/asf-site Commit: a3b781cf51e2184c6e90e0a9c72d7a81ebfb7928 Parents: 218331a Author: Aljoscha Krettek Authored: Wed Jun 28 13:47:29 2017 +0200 Committer: Aljoscha Krettek Committed: Wed Jun 28 13:47:29 2017 +0200

[4/4] beam-site git commit: This closes #262

Branch: refs/heads/asf-site Commit: b8f9c3079befa511eaa71ec8224284aa9e9b5b53 Parents: 855364b a3b781c Author: Aljoscha Krettek Authored: Wed Jun 28 13:47:42 2017 +0200 Committer: Aljoscha Krettek Committed: Wed Jun 28 13:47:42 2017 +0200

[2/4] beam-site git commit: Update to more recent Flink version in example

/beam-site/diff/28a94d37 Branch: refs/heads/asf-site Commit: 28a94d37a62e2c5834c6dbf1a07948c1fc5a478f Parents: 855364b Author: Aljoscha Krettek Authored: Tue Jun 27 17:29:43 2017 +0200 Committer: Aljoscha Krettek Committed: Wed Jun 28 12:29:28 2017 +0200

[GitHub] beam pull request #3480: [BEAM-2140] Execute Splittable DoFn directly in Fli...

GitHub user aljoscha opened a pull request: https://github.com/apache/beam/pull/3480 [BEAM-2140] Execute Splittable DoFn directly in Flink Runner Before, we were using ProcessFn. This was causing problems with the Flink Runner for two reasons: 1. StatefulDoFnRunner is

[GitHub] beam pull request #3550: [BEAM-2571] CombineTest.testSlidingWindowsCombineWi...

GitHub user aljoscha opened a pull request: https://github.com/apache/beam/pull/3550 [BEAM-2571] CombineTest.testSlidingWindowsCombineWithContext R: @kennknowles @JingsongLi You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] beam pull request #2915: [BEAM-593] Add non-blocking pipeline execution on F...

Github user aljoscha closed the pull request at: https://github.com/apache/beam/pull/2915 --- 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

[GitHub] beam pull request #3600: [BEAM-2571] CombineTest.testSlidingWindowsCombineWi...

GitHub user aljoscha opened a pull request: https://github.com/apache/beam/pull/3600 [BEAM-2571] CombineTest.testSlidingWindowsCombineWithContext This is a rebased version of #3550. I didn't want to mess with the comments and history on that other PR. R: @peihe (an

[3/4] beam git commit: [BEAM-2571] Change DoFnOperator to use Long.MAX_VALUE as max watermark

Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/84499317 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/84499317 Branch: refs/heads/master Commit: 8449931708338dd854ba90b8d6f769fe42b81493 Parents: 5f1d136 Author: Aljoscha Krettek Authored: Wed Jul 12 14:42:37 2017 +0200 Committer

[1/4] beam git commit: [BEAM-2571] Respect watermark contract in Flink DoFnOperator

repos/asf/beam/tree/18250878 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/18250878 Branch: refs/heads/master Commit: 18250878552ede370e90b89e66f17664edaf2c7e Parents: b03c4f0 Author: Aljoscha Krettek Authored: Wed Jul 12 15:38:06 2017 +0200 Committer: Aljoscha Krettek Committed: Mon Jul 24

[4/4] beam git commit: This closes #3600

/master Commit: f54072a1b156176624db5b666ed9c308f24bc2f9 Parents: 5f1d136 1825087 Author: Aljoscha Krettek Authored: Mon Jul 24 10:03:39 2017 +0200 Committer: Aljoscha Krettek Committed: Mon Jul 24 10:03:39 2017 +0200 -- .../wrappers

[GitHub] beam pull request #3550: [BEAM-2571] CombineTest.testSlidingWindowsCombineWi...

Github user aljoscha closed the pull request at: https://github.com/apache/beam/pull/3550 --- 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

[2/4] beam git commit: [BEAM-2571] Clarify pushedback variable name in DoFnOperator

/beam/diff/b03c4f07 Branch: refs/heads/master Commit: b03c4f0790fa639d739f7f3fdeaa4a703fadb8fa Parents: 8449931 Author: Aljoscha Krettek Authored: Wed Jul 12 14:39:58 2017 +0200 Committer: Aljoscha Krettek Committed: Mon Jul 24 09:47:44 2017 +0200

[2/2] beam git commit: This closes #2476

/master Commit: a0da7becae2ce4346f04d2194b555e41d0d1 Parents: 3f419db 8ef9861 Author: Aljoscha Krettek Authored: Mon May 8 20:17:39 2017 +0200 Committer: Aljoscha Krettek Committed: Mon May 8 20:17:39 2017 +0200

[1/2] beam git commit: [BEAM-1723] deduplication of UnboundedSource in Flink runner

wip-us.apache.org/repos/asf/beam/tree/8ef9861f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/8ef9861f Branch: refs/heads/master Commit: 8ef9861fb419e34978593d961eed186f5ef87406 Parents: 3f419db Author: JingsongLi Authored: Wed Apr 19 19:42:59 2017 +0800 Committer: Aljoscha Krettek Committed: Mon

[GitHub] beam pull request #2959: [BEAM-1723] deduplication of UnboundedSource in Fli...

GitHub user aljoscha opened a pull request: https://github.com/apache/beam/pull/2959 [BEAM-1723] deduplication of UnboundedSource in Flink runner You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/beam cherry-pick-1723

[GitHub] beam pull request #2959: [BEAM-1723] deduplication of UnboundedSource in Fli...

Github user aljoscha closed the pull request at: https://github.com/apache/beam/pull/2959 --- 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

[2/2] beam git commit: This closes #3826

/master Commit: c09886a4d228dc0e003a660ad298add29618f7a0 Parents: 307b036 81d0c43 Author: Aljoscha Krettek Authored: Fri Sep 15 10:27:24 2017 +0200 Committer: Aljoscha Krettek Committed: Fri Sep 15 10:27:24 2017 +0200

[1/2] beam git commit: [BEAM-2807] Fix NPE error on CoderTypeSerializerConfigSnapshot serialization

ttp://git-wip-us.apache.org/repos/asf/beam/tree/81d0c436 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/81d0c436 Branch: refs/heads/master Commit: 81d0c436691d33a7ea1bd808413e1aa08e1c4d10 Parents: 307b036 Author: djhworld Authored: Fri Sep 8 22:09:14 2017 +0100 Committer: Aljoscha Kret

  1   2   3   4   5   >