[
https://issues.apache.org/jira/browse/BEAM-456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15380486#comment-15380486
]
ASF GitHub Bot commented on BEAM-456:
-
GitHub user jbonofre opened a pull request:
GitHub user jbonofre opened a pull request:
https://github.com/apache/incubator-beam/pull/671
[BEAM-456] Add MongoDbIO
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [X] Make sure the PR title is formatted like:
Github user mdvorsky closed the pull request at:
https://github.com/apache/incubator-beam/pull/652
---
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 featu
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-beam/pull/638
---
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
Clarify RequiresWindowAccess error message
An error message is printed when a DoFn needs access to the window but does
not implement RequiresWindowAccess. This PR changes to the error message
to print the interface name instead of just "RequiresWindow", which makes it
more clear which interface th
Repository: incubator-beam
Updated Branches:
refs/heads/master 7a945a741 -> a0afd6665
Closes #638
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a0afd666
Tree: http://git-wip-us.apache.org/repos/asf/incu
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk 1305c108a -> b8e3a7b52
Make step encodings consistently use WindowedValueCoders
This change is needed for size-estimation aggregators.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-beam/pull/669
---
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
Closes #669
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b8e3a7b5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b8e3a7b5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/
GitHub user chamikaramj opened a pull request:
https://github.com/apache/incubator-beam/pull/670
Clarifies that 'TextFileSource' only supports UTF-8 and ASCII encodings.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chamikaramj
[
https://issues.apache.org/jira/browse/BEAM-457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Cwik resolved BEAM-457.
Resolution: Fixed
Fix Version/s: 0.2.0-incubating
> Upgrade Avro
>
>
> Key
[
https://issues.apache.org/jira/browse/BEAM-457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15380294#comment-15380294
]
ASF GitHub Bot commented on BEAM-457:
-
Github user asfgit closed the pull request at:
Repository: incubator-beam
Updated Branches:
refs/heads/master 695247138 -> 7a945a741
Upgrade to Avro 1.8.1
This version has some important fixes for potential memory leaks.
(It does not have a fix for [AVRO-607] yet, but still has good fixes.)
Project: http://git-wip-us.apache.org/repos/as
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-beam/pull/664
---
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
[BEAM-457] Upgrade to Avro 1.8.1
This closes #664
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7a945a74
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7a945a74
Diff: http://git-wip-us.ap
GitHub user charlesccychen opened a pull request:
https://github.com/apache/incubator-beam/pull/669
Make step encodings consistently use WindowedValueCoders
This change is needed for size-estimation aggregators.
You can merge this pull request into a Git repository by running:
Github user charlesccychen closed the pull request at:
https://github.com/apache/incubator-beam/pull/644
---
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
[
https://issues.apache.org/jira/browse/BEAM-460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Charles Chen updated BEAM-460:
--
Summary: Implement Python support for size-estimation aggregators (was:
Implement support for size-estima
[
https://issues.apache.org/jira/browse/BEAM-460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Charles Chen updated BEAM-460:
--
Component/s: sdk-py
> Implement support for size-estimation aggregators
>
Charles Chen created BEAM-460:
-
Summary: Implement support for size-estimation aggregators
Key: BEAM-460
URL: https://issues.apache.org/jira/browse/BEAM-460
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15380101#comment-15380101
]
ASF GitHub Bot commented on BEAM-439:
-
GitHub user silviulica opened a pull request:
GitHub user silviulica opened a pull request:
https://github.com/apache/incubator-beam/pull/668
[BEAM-439] Remove optional args from start/finish bundle methods
@robertwb can you please take a look?
(take II -- I abandoned previous PR due to bad merge on my part)
Techn
[
https://issues.apache.org/jira/browse/BEAM-459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jesse Anderson reassigned BEAM-459:
---
Assignee: Jesse Anderson
> Add BigInteger to TypeDescriptors
>
[
https://issues.apache.org/jira/browse/BEAM-459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15380023#comment-15380023
]
Jesse Anderson commented on BEAM-459:
-
Sure
> Add BigInteger to TypeDescriptors
> -
[
https://issues.apache.org/jira/browse/BEAM-459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15380020#comment-15380020
]
Kenneth Knowles commented on BEAM-459:
--
[~eljefe6aa] want to take this one?
> Add BigI
[
https://issues.apache.org/jira/browse/BEAM-210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kenneth Knowles updated BEAM-210:
-
Description: Today, ON_TIME panes are emitted whether or not they are
empty. We had decided that for
[
https://issues.apache.org/jira/browse/BEAM-210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kenneth Knowles updated BEAM-210:
-
Summary: Allow control of empty ON_TIME panes analogous to final panes
(was: Be consistent with emi
[
https://issues.apache.org/jira/browse/BEAM-210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kenneth Knowles reassigned BEAM-210:
Assignee: Kenneth Knowles (was: Mark Shields)
> Be consistent with emitting final empty pane
Jesse Anderson created BEAM-459:
---
Summary: Add BigInteger to TypeDescriptors
Key: BEAM-459
URL: https://issues.apache.org/jira/browse/BEAM-459
Project: Beam
Issue Type: Bug
Reporter
Sumit Chawla created BEAM-458:
-
Summary: Support for Flink Metrics
Key: BEAM-458
URL: https://issues.apache.org/jira/browse/BEAM-458
Project: Beam
Issue Type: New Feature
Components: r
[
https://issues.apache.org/jira/browse/BEAM-384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Halperin updated BEAM-384:
-
Assignee: (was: Daniel Halperin)
> Streaming BigQueryIO should support user-provided IDs
> -
[
https://issues.apache.org/jira/browse/BEAM-445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Halperin resolved BEAM-445.
--
Resolution: Fixed
Fix Version/s: Not applicable
> Beam-examples-java build failed through l
[
https://issues.apache.org/jira/browse/BEAM-285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Halperin resolved BEAM-285.
--
Resolution: Fixed
Fix Version/s: 0.2.0-incubating
> Make MinLongFn and MaxLongFn mimic SumL
[
https://issues.apache.org/jira/browse/BEAM-455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379826#comment-15379826
]
ASF GitHub Bot commented on BEAM-455:
-
GitHub user chamikaramj opened a pull request:
GitHub user chamikaramj opened a pull request:
https://github.com/apache/incubator-beam/pull/667
[BEAM-455] Adds a test harnesses and utilities framework for sources.
Helper functions and test harnesses for checking correctness of source
(``iobase.BoundedSource``) and range tracker
[
https://issues.apache.org/jira/browse/BEAM-430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pei He closed BEAM-430.
---
Resolution: Fixed
Fix Version/s: 0.2.0-incubating
> Introducing gcpTempLocation that default to tempLocation
> --
GitHub user tgroh opened a pull request:
https://github.com/apache/incubator-beam/pull/666
Make TransformEvaluatorFactory reuse Explicit
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is forma
[
https://issues.apache.org/jira/browse/BEAM-360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379759#comment-15379759
]
ASF GitHub Bot commented on BEAM-360:
-
Github user chamikaramj closed the pull request a
Github user chamikaramj closed the pull request at:
https://github.com/apache/incubator-beam/pull/599
---
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 fe
GitHub user kennknowles opened a pull request:
https://github.com/apache/incubator-beam/pull/665
Shade everything but a whitelist in core Java SDK
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure tests pass
[
https://issues.apache.org/jira/browse/BEAM-37?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379728#comment-15379728
]
Ben Chambers commented on BEAM-37:
--
Notes on remaining tasks to complete this:
1. Modify Do
Fixes several issues related to 'filebasedsource'.
Adds a method 'fileio.ChannelFactory.size_in_bytes()' that can be used to
determine the size of a single file.
Implements this method for 'ChannelFactory' implementations for GCS and local
files.
Updates 'filebasedsource' to use this method when
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk d898d56ae -> 1305c108a
Closes #599
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1305c108
Tree: http://git-wip-us.apache.org/repos/asf/
[
https://issues.apache.org/jira/browse/BEAM-391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ahmet Altay closed BEAM-391.
Resolution: Fixed
Fix Version/s: 0.2.0-incubating
> Exceptions in gcsio upload thread causes pipeline t
[
https://issues.apache.org/jira/browse/BEAM-445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379630#comment-15379630
]
Daniel Halperin commented on BEAM-445:
--
Thanks -- it's good to make sure everyone invol
[
https://issues.apache.org/jira/browse/BEAM-445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379622#comment-15379622
]
Scott Wegner commented on BEAM-445:
---
I've opened an issue with Bigtable to see if they can
Daniel Halperin created BEAM-457:
Summary: Upgrade Avro
Key: BEAM-457
URL: https://issues.apache.org/jira/browse/BEAM-457
Project: Beam
Issue Type: Improvement
Components: sdk-java-
GitHub user dhalperi opened a pull request:
https://github.com/apache/incubator-beam/pull/664
Upgrade to Avro 1.8.1
This version has some important fixes for potential memory leaks.
(It does not have a fix for [AVRO-607] yet, but still has good fixes.)
You can merge this pu
[
https://issues.apache.org/jira/browse/BEAM-450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manu Zhang reassigned BEAM-450:
---
Assignee: Manu Zhang
> Modules are shaded to the same path
> ---
>
>
GitHub user manuzhang opened a pull request:
https://github.com/apache/incubator-beam/pull/663
[BEAM-328] uses SerializableCoder for `T extends Serializable`
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure
[
https://issues.apache.org/jira/browse/BEAM-328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379536#comment-15379536
]
ASF GitHub Bot commented on BEAM-328:
-
GitHub user manuzhang opened a pull request:
[
https://issues.apache.org/jira/browse/BEAM-456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jean-Baptiste Onofré updated BEAM-456:
--
Summary: Add MongoDBIO (was: Add MongoIO)
> Add MongoDBIO
> -
>
>
Jean-Baptiste Onofré created BEAM-456:
-
Summary: Add MongoIO
Key: BEAM-456
URL: https://issues.apache.org/jira/browse/BEAM-456
Project: Beam
Issue Type: New Feature
Components:
[
https://issues.apache.org/jira/browse/BEAM-455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chamikara Jayalath updated BEAM-455:
Summary: Implement a test harness for verifying correctness of custom
sources (was: Implement
Chamikara Jayalath created BEAM-455:
---
Summary: Implement a test harness for verifying correcness of
custom sources
Key: BEAM-455
URL: https://issues.apache.org/jira/browse/BEAM-455
Project: Beam
55 matches
Mail list logo