GitHub user katsiapis opened a pull request:
https://github.com/apache/incubator-beam/pull/940
[BEAM-] Making Dataflow Python Materialized PCollection
representation more efficient (3 of several).
Be sure to do all of the following to help us incorporate your contribution
Konstantinos Katsiapis created BEAM-625:
---
Summary: Make Dataflow Python Materialized PCollection
representation more efficient
Key: BEAM-625
URL: https://issues.apache.org/jira/browse/BEAM-625
Github user charlesccychen closed the pull request at:
https://github.com/apache/incubator-beam/pull/865
---
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
[
https://issues.apache.org/jira/browse/BEAM-495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mark Liu closed BEAM-495.
-
> Generalize FileChecksumMatcher used for all E2E test
>
>
>
[
https://issues.apache.org/jira/browse/BEAM-624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mark Liu resolved BEAM-624.
---
Resolution: Fixed
Fix Version/s: Not applicable
> NoClassDefFoundError Failed Dataflow Streaming Job
>
[
https://issues.apache.org/jira/browse/BEAM-624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mark Liu closed BEAM-624.
-
> NoClassDefFoundError Failed Dataflow Streaming Job
> --
>
>
GitHub user charlesccychen opened a pull request:
https://github.com/apache/incubator-beam/pull/939
Use cStringIO instead of StringIO
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/charlesccychen/incubator-beam fix-stringio
[
https://issues.apache.org/jira/browse/BEAM-624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15478121#comment-15478121
]
ASF GitHub Bot commented on BEAM-624:
-
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-beam/pull/938
---
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
Repository: incubator-beam
Updated Branches:
refs/heads/master e9326c8b1 -> 82ebfd487
Revert Backoff Classes to Fix Worker Dependency Error
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/51c73a29
Tree:
Closes #938
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/82ebfd48
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/82ebfd48
Diff:
Closes #933
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/009230e8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/009230e8
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk 76a6d6bdc -> 009230e8b
Update 404 link to setuptools docs
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f04e6e21
Tree:
[
https://issues.apache.org/jira/browse/BEAM-624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15477705#comment-15477705
]
ASF GitHub Bot commented on BEAM-624:
-
GitHub user markflyhigh opened a pull request:
GitHub user markflyhigh opened a pull request:
https://github.com/apache/incubator-beam/pull/938
[BEAM-624] Revert Backoff Classes to Fix NoClassDefFoundError in Dataflow
Streaming Job
Be sure to do all of the following to help us incorporate your contribution
quickly and
Mark Liu created BEAM-624:
-
Summary: NoClassDefFoundError Failed Dataflow Streaming Job
Key: BEAM-624
URL: https://issues.apache.org/jira/browse/BEAM-624
Project: Beam
Issue Type: Bug
GitHub user tgroh opened a pull request:
https://github.com/apache/incubator-beam/pull/937
Remove EvaluationContext as a forApplication Parameter
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR
Maximilian Michels created BEAM-623:
---
Summary: Integate Flink's RestartStrategies in FlinkPipelineOptions
Key: BEAM-623
URL: https://issues.apache.org/jira/browse/BEAM-623
Project: Beam
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-beam/pull/929
---
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
This closes #929
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e9326c8b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e9326c8b
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master b6205ffa3 -> e9326c8b1
[flink] initialize watermarkTimeQueue with Comparator
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/de6ec823
Tree:
Maximilian Michels created BEAM-622:
---
Summary: Add checkpointing tests for DoFnOperator and
WindowDoFnOperator
Key: BEAM-622
URL: https://issues.apache.org/jira/browse/BEAM-622
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved BEAM-333.
-
Resolution: Fixed
Fix Version/s: 0.3.0-incubating
Stop is also supported on the
[
https://issues.apache.org/jira/browse/BEAM-619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15477147#comment-15477147
]
ASF GitHub Bot commented on BEAM-619:
-
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/BEAM-619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed BEAM-619.
---
Resolution: Fixed
Fix Version/s: 0.3.0-incubating
> UnboundedSourceWrapper snapshotting
[
https://issues.apache.org/jira/browse/BEAM-333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15477146#comment-15477146
]
ASF GitHub Bot commented on BEAM-333:
-
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-beam/pull/927
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-beam/pull/924
---
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
[BEAM-333][flink] make bounded/unbounded sources stoppable
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7e2820b0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7e2820b0
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master a96ea98a4 -> b6205ffa3
[BEAM-619] keep track of local split sources in UnboundedSourceWrapper
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit:
This closes #927
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b6205ffa
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b6205ffa
Diff:
[BEAM-619] extend test case to be parameterized
- extend test case with number of tasks and splits parameters
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4afd25a7
Tree:
This closes #924
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c78db9ad
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c78db9ad
Diff:
[
https://issues.apache.org/jira/browse/BEAM-617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed BEAM-617.
---
Resolution: Fixed
Fix Version/s: 0.3.0-incubating
> Allow setting of StateBackend on
[
https://issues.apache.org/jira/browse/BEAM-617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15477127#comment-15477127
]
ASF GitHub Bot commented on BEAM-617:
-
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-beam/pull/923
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-beam/pull/928
---
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
[BEAM-617][flink] introduce option to set state backend
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d4f85912
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d4f85912
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master 817515fe4 -> a96ea98a4
[flink] use exploded WindowValue in FlinkDoFnFunction
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3461ce21
Tree:
This closes #923
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0399dbc7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0399dbc7
Diff:
This closes #928
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a96ea98a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a96ea98a
Diff:
Jean-Baptiste Onofré created BEAM-621:
-
Summary: Add MapValues and MapKeys functions
Key: BEAM-621
URL: https://issues.apache.org/jira/browse/BEAM-621
Project: Beam
Issue Type: New
42 matches
Mail list logo