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
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
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
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
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
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
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
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
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
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
-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
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
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
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
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
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 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
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
/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
/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 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
/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
: 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
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
/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
/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
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
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
/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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
/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
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 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
/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
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 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 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 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 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 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
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
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
/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 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
/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 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
/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
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
/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
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 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 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 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 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
/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
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 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 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
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
--
/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
: 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
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 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
/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
/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
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 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
/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
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
: 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
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
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/
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
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
/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 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
/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
ter: Aljoscha Krettek
Committed: Fri Feb 24 12:04:47 2017 +0100
--
.../streaming/io/UnboundedSourceWrapper.java| 136 ++-
.../streaming/UnboundedSourceWrapperTest.java | 116 +++-
2 files changed,
/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
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:
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
/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
/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 - 100 of 447 matches
Mail list logo