[beam] branch master updated (faa5699 -> 73def89)

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 faa5699 Merge pull request #6385: [BEAM-5337] Fix flaky test UnboundedSourceWrapperTest#testValueEmission add

[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] 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-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

[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

[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] 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

[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

[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

[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

[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 #1779

/master Commit: 9db5f746ae81c4fa755a9a8f2c4888759c8e7042 Parents: ddde353 b5bbadf Author: Aljoscha Krettek Authored: Mon Jan 23 17:38:37 2017 +0100 Committer: Aljoscha Krettek Committed: Mon Jan 23 17:38:37 2017 +0100 -- .../beam

[1/2] beam git commit: [BEAM-1273] Error with FlinkPipelineOptions serialization after setStateBackend

ttp://git-wip-us.apache.org/repos/asf/beam/tree/b5bbadf5 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b5bbadf5 Branch: refs/heads/master Commit: b5bbadf59625563d1755f66a24d27c96c5fd3492 Parents: ddde353 Author: Alexey Diomin Authored: Mon Jan 16 14:46:08 2017 +0400 Committer: Aljos

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

/master Commit: 582c4a8a4dd33d698beae2990d682848b593de21 Parents: 34b4a6d 1dcda72 Author: Aljoscha Krettek Authored: Mon Jan 30 13:48:19 2017 +0100 Committer: Aljoscha Krettek Committed: Mon Jan 30 13:48:19 2017 +0100

[1/2] beam git commit: [BEAM-843] Use New DoFn Directly in Flink Runner

pos/asf/beam/tree/1dcda726 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1dcda726 Branch: refs/heads/master Commit: 1dcda72686fa0a9a6e2033939aa53f7a7a31d548 Parents: 34b4a6d Author: JingsongLi Authored: Wed Jan 18 11:34:06 2017 +0800 Committer: Aljoscha Krettek Committed: Mon Jan 30 12:04

[GitHub] beam pull request #1883: Fix Release 0.5.0 with Reverts

GitHub user aljoscha opened a pull request: https://github.com/apache/beam/pull/1883 Fix Release 0.5.0 with Reverts I'm opening this just so that I can run PostCommit hooks on Jenkins. Sorry for the inconvenience. You can merge this pull request into a Git repository by ru

[GitHub] beam pull request #1883: Fix Release 0.5.0 with Reverts

Github user aljoscha closed the pull request at: https://github.com/apache/beam/pull/1883 --- 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 #1883: Fix Release 0.5.0 with Reverts

Github user aljoscha closed the pull request at: https://github.com/apache/beam/pull/1883 --- 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 #1883: Fix Release 0.5.0 with Reverts

GitHub user aljoscha reopened a pull request: https://github.com/apache/beam/pull/1883 Fix Release 0.5.0 with Reverts I'm opening this just so that I can run PostCommit hooks on Jenkins. Sorry for the inconvenience. You can merge this pull request into a Git repository by ru

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

/master Commit: 99f93eb078819882f622d953ff05ca419516c90f Parents: cef3109 b56f460 Author: Aljoscha Krettek Authored: Fri Feb 3 13:54:18 2017 +0100 Committer: Aljoscha Krettek Committed: Fri Feb 3 13:54:18 2017 +0100 -- runners/flink

[1/2] beam git commit: [BEAM-1036] Support for new State API in FlinkRunner (streaming)

wip-us.apache.org/repos/asf/beam/tree/b56f4609 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b56f4609 Branch: refs/heads/master Commit: b56f460974a3119804040b08fe1c7b190ff3f356 Parents: cef3109 Author: JingsongLi Authored: Tue Jan 31 12:32:26 2017 +0800 Committer: Aljoscha Krettek Committed:

[GitHub] beam pull request #2012: [BEAM-1393/1394/1445] Update to Flink 1.2.0 and fix...

GitHub user aljoscha opened a pull request: https://github.com/apache/beam/pull/2012 [BEAM-1393/1394/1445] Update to Flink 1.2.0 and fix resulting problems This is a copy of #1960. I'm hoping to be able to figure out what's causing the problems in the Maven verify hook

[GitHub] beam pull request #2012: [BEAM-1393/1394/1445] Update to Flink 1.2.0 and fix...

Github user aljoscha closed the pull request at: https://github.com/apache/beam/pull/2012 --- 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/4] beam git commit: [BEAM-1393/1394/1445] Update to Flink 1.2.0 and fix resulting problems

Repository: beam Updated Branches: refs/heads/master f03f6ac19 -> 137fee95b http://git-wip-us.apache.org/repos/asf/beam/blob/7d32b93e/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java --

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

/master Commit: 137fee95b3c1f7bd98f9983d29effcbe5acff899 Parents: f03f6ac 7d32b93 Author: Aljoscha Krettek Authored: Thu Feb 16 12:13:54 2017 +0100 Committer: Aljoscha Krettek Committed: Thu Feb 16 12:13:54 2017 +0100 -- runners

[3/4] beam git commit: [BEAM-1393/1394/1445] Update to Flink 1.2.0 and fix resulting problems

: 7d32b93e337b21286c5269956b45f76c623f8518 Parents: f03f6ac Author: JingsongLi Authored: Tue Feb 7 16:11:12 2017 +0800 Committer: Aljoscha Krettek Committed: Thu Feb 16 12:13:33 2017 +0100 -- runners/flink/pom.xml |2

[2/4] beam git commit: [BEAM-1393/1394/1445] Update to Flink 1.2.0 and fix resulting problems

http://git-wip-us.apache.org/repos/asf/beam/blob/7d32b93e/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/WindowDoFnOperator.java -- diff --git a/runners/flink/runner/src/main/java/o

[GitHub] beam pull request #2053: [BEAM-646] Get flink runner out of apply

GitHub user aljoscha opened a pull request: https://github.com/apache/beam/pull/2053 [BEAM-646] Get flink runner out of apply Just for testing, I want to refactor this once the lightweight override factories by @tgroh from #2039 are in. You can merge this pull request into a Git

[2/3] beam git commit: fix TestFlinkRunner to throw PipelineExecutionException

/diff/0e9173df Branch: refs/heads/master Commit: 0e9173df7140f4a07086d83170c1ccdfd9412863 Parents: 8cfb3d1 Author: JingsongLi Authored: Fri Feb 17 17:47:55 2017 +0800 Committer: Aljoscha Krettek Committed: Tue Feb 21 09:53:05 2017 +0100

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

/master Commit: 038ebd3bf523b916734cebed5b6e9c8790ba4f04 Parents: 8cfb3d1 f86facb Author: Aljoscha Krettek Authored: Tue Feb 21 11:03:24 2017 +0100 Committer: Aljoscha Krettek Committed: Tue Feb 21 11:03:24 2017 +0100 -- runners

[1/3] beam git commit: [BEAM-1116] Support for new Timer API in Flink runner (streaming)

wip-us.apache.org/repos/asf/beam/tree/f86facb2 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f86facb2 Branch: refs/heads/master Commit: f86facb27170c34cc9ef2d702a51bdcd7e53836d Parents: 0e9173d Author: JingsongLi Authored: Fri Feb 17 17:48:23 2017 +0800 Committer: Aljoscha Krettek Commit

[GitHub] beam pull request #2072: Move Streaming View Overrides out of the Flink Runn...

GitHub user aljoscha opened a pull request: https://github.com/apache/beam/pull/2072 Move Streaming View Overrides out of the Flink Runner These are specific to the streaming Runner and don't need to be in the FlinkRunner. This is also preparation for getting Flink out o

[6/6] beam git commit: This closes #2072

/master Commit: 453e37bc60b39e3bcc9a9eaff36c3bfd5c84060b Parents: 88e8425 e0e7e52 Author: Aljoscha Krettek Authored: Wed Feb 22 18:28:33 2017 +0100 Committer: Aljoscha Krettek Committed: Wed Feb 22 18:28:33 2017 +0100 -- .../flink

[1/6] beam git commit: Move Flink Runner classes to base package and make package private

Repository: beam Updated Branches: refs/heads/master 88e842534 -> 453e37bc6 http://git-wip-us.apache.org/repos/asf/beam/blob/e0e7e52b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/FlinkStreamingTransformTranslators.java

[4/6] beam git commit: Move Flink Runner classes to base package and make package private

: Aljoscha Krettek Authored: Wed Feb 22 15:09:22 2017 +0100 Committer: Aljoscha Krettek Committed: Wed Feb 22 18:24:15 2017 +0100 -- .../flink/FlinkBatchPipelineTranslator.java | 139 +++ .../flink

[2/6] beam git commit: Move Flink Runner classes to base package and make package private

http://git-wip-us.apache.org/repos/asf/beam/blob/e0e7e52b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/FlinkBatchTransformTranslators.java -- diff --git a/runners/flink/runner/src/main/java/org/apac

[3/6] beam git commit: Move Flink Runner classes to base package and make package private

http://git-wip-us.apache.org/repos/asf/beam/blob/e0e7e52b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/FlinkStreamingTransformTranslators.java -- diff --git a/runners/flink/runner/src/main/java/org/apache/beam/

[5/6] beam git commit: Move Streaming View Overrides out of the Flink Runner

t-wip-us.apache.org/repos/asf/beam/commit/27ad140d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/27ad140d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/27ad140d Branch: refs/heads/master Commit: 27ad140dc234245d82a0e8fe4471f9d1343e625b Parents: 88e8425 Author: Aljoscha Krettek Authored

[1/2] beam git commit: [BEAM-646] Get Flink Runner out of apply()

asf/beam/tree/0ac985c9 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0ac985c9 Branch: refs/heads/master Commit: 0ac985c92a1af1dcc6e55f199bf02d57a484b9e3 Parents: 00b3958 Author: Aljoscha Krettek Authored: Sat Feb 18 16:12:19 2017 +0100 Committer: Aljoscha Krettek Committed: Thu Feb 23 11:10

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

/master Commit: fbcde4cdc7d68de8734bf540c079b2747631a854 Parents: 00b3958 0ac985c Author: Aljoscha Krettek Authored: Thu Feb 23 11:20:47 2017 +0100 Committer: Aljoscha Krettek Committed: Thu Feb 23 11:20:47 2017 +0100 -- runners

[GitHub] beam pull request #2084: [BEAM-1389] Remove Flink Runner README.md

GitHub user aljoscha opened a pull request: https://github.com/apache/beam/pull/2084 [BEAM-1389] Remove Flink Runner README.md The information on the website is more up-to-date and more visible. I was wondering whether I should add a link to the Runner documentation on the

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

/master Commit: 3d0fe853941ec4a6190ea7891d063674b5eef067 Parents: 2c71354 5e3fb8c Author: Aljoscha Krettek Authored: Fri Feb 24 12:12:50 2017 +0100 Committer: Aljoscha Krettek Committed: Fri Feb 24 12:12:50 2017 +0100

[1/2] beam git commit: [BEAM-1456] Make UnboundedSourceWrapper snapshot to rescalable operator state in Flink Runner

ter: Aljoscha Krettek Committed: Fri Feb 24 12:04:47 2017 +0100 -- .../streaming/io/UnboundedSourceWrapper.java| 136 ++- .../streaming/UnboundedSourceWrapperTest.java | 116 +++- 2 files changed,

[2/2] beam git commit: This closes #2112: Use provided Function Runners in Flink Batch Runner

/repos/asf/beam/diff/b261d489 Branch: refs/heads/master Commit: b261d489061e9a92b7df28ca71bce00844f7dfa6 Parents: 3082178 0ae2a38 Author: Aljoscha Krettek Authored: Mon Feb 27 13:22:49 2017 +0100 Committer: Aljoscha Krettek Committed: Mon Feb 27 13:22:49 2017 +0100

[1/2] beam git commit: [BEAM-1560] Use provided Function Runners in Flink Batch Runner

wip-us.apache.org/repos/asf/beam/tree/0ae2a385 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0ae2a385 Branch: refs/heads/master Commit: 0ae2a3851cbfe1ec2f2c7237954b18c9951c76a3 Parents: 3082178 Author: JingsongLi Authored: Mon Feb 27 18:08:34 2017 +0800 Committer: Aljoscha Krettek Committed:

[1/2] beam git commit: [BEAM-1036] Support for new State API in Flink Batch Runner

wip-us.apache.org/repos/asf/beam/tree/ec5a8262 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ec5a8262 Branch: refs/heads/master Commit: ec5a82620916b2297a8b349a605af8fadeb2ceb7 Parents: 13db84b Author: JingsongLi Authored: Tue Feb 28 02:07:33 2017 +0800 Committer: Aljoscha Krettek Committed: Tue

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

/master Commit: 2a23374601d8f6079d025f41dc281a302a865512 Parents: 13db84b ec5a826 Author: Aljoscha Krettek Authored: Tue Feb 28 11:10:34 2017 +0100 Committer: Aljoscha Krettek Committed: Tue Feb 28 11:10:34 2017 +0100 -- runners

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

/master Commit: 2e072a0320b57f39e24870cc898fab7fabb44b02 Parents: 2a23374 e7f825c Author: Aljoscha Krettek Authored: Tue Feb 28 15:29:22 2017 +0100 Committer: Aljoscha Krettek Committed: Tue Feb 28 15:29:22 2017 +0100 -- runners

  1   2   3   4   5   >