[jira] [Updated] (BEAM-1560) Use DoFnRunner in Flink Batch Runner

[ https://issues.apache.org/jira/browse/BEAM-1560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-1560: --- Description: This is a prerequisite for supporting the user-facing State API and Timer API in

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

This closes #2112: Use provided Function Runners in Flink Batch Runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b261d489 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b261d489 Diff:

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

Repository: beam Updated Branches: refs/heads/master 3082178b3 -> b261d4890 [BEAM-1560] Use provided Function Runners in Flink Batch Runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0ae2a385 Tree:

[GitHub] beam pull request #2112: [BEAM-1560] Use SimpleDoFnRunner to invoke and use ...

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

[jira] [Updated] (BEAM-1560) Use provided Function Runners in Flink Batch Runner

[ https://issues.apache.org/jira/browse/BEAM-1560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-1560: --- Summary: Use provided Function Runners in Flink Batch Runner (was: Use DoFnRunner in Flink

[jira] [Commented] (BEAM-1560) Use provided Function Runners in Flink Batch Runner

[ https://issues.apache.org/jira/browse/BEAM-1560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885686#comment-15885686 ] ASF GitHub Bot commented on BEAM-1560: -- Github user asfgit closed the pull request at:

[jira] [Closed] (BEAM-1560) Use provided Function Runners in Flink Batch Runner

[ https://issues.apache.org/jira/browse/BEAM-1560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed BEAM-1560. -- Resolution: Fixed > Use provided Function Runners in Flink Batch Runner >

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Dataflow #2416

See

[jira] [Updated] (BEAM-1560) Use DoFnRunner in Flink Batch Runner

[ https://issues.apache.org/jira/browse/BEAM-1560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-1560: --- Summary: Use DoFnRunner in Flink Batch Runner (was: Use SimpleDoFnRunner to invoke and use

[1/2] beam git commit: Remove periods from step name in SparkBeamMetric to avoid inconsistent hierarchies in Graphite metric sink

Repository: beam Updated Branches: refs/heads/master 4bba380cb -> 3082178b3 Remove periods from step name in SparkBeamMetric to avoid inconsistent hierarchies in Graphite metric sink Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

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

This closes #2083 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3082178b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3082178b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3082178b Branch:

[GitHub] beam pull request #2083: Remove periods from step name in SparkBeamMetric to...

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

[jira] [Updated] (BEAM-1560) Use SimpleDoFnRunner to invoke and use new CombineFnRunner in batch mode of Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-1560: --- Description: To support the user-facing State API and Timer API in Flink runner (batch) (was:

[GitHub] beam pull request #2113: sdks io for cassandra

GitHub user surpass opened a pull request: https://github.com/apache/beam/pull/2113 sdks io for cassandra Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like:

[2/3] beam git commit: Clarify side input name and remove redundant pcollection reference.

Clarify side input name and remove redundant pcollection reference. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c04e8abd Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c04e8abd Diff:

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

This closes #164 Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/b647ca56 Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/b647ca56 Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/b647ca56

[1/3] beam-site git commit: Comment Ostatic link as it has been broken for a few weeks

Repository: beam-site Updated Branches: refs/heads/asf-site 70682771d -> b647ca562 Comment Ostatic link as it has been broken for a few weeks Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/f1f7063b Tree:

[GitHub] beam-site pull request #164: Remove Ostatic link as it has been broken for a...

Github user asfgit closed the pull request at: https://github.com/apache/beam-site/pull/164 --- 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/3] beam-site git commit: Regenerate website

Regenerate website Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/1b1757bb Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/1b1757bb Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/1b1757bb

[GitHub] beam pull request #2125: [BEAM-1571] fix FlattenPCollectionList with single ...

GitHub user tweise opened a pull request: https://github.com/apache/beam/pull/2125 [BEAM-1571] fix FlattenPCollectionList with single input translation in ApexRunner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ]

[jira] [Commented] (BEAM-1571) Flatten on a single input PCollection should have a test associated with it

[ https://issues.apache.org/jira/browse/BEAM-1571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15887408#comment-15887408 ] ASF GitHub Bot commented on BEAM-1571: -- GitHub user tweise opened a pull request:

[jira] [Resolved] (BEAM-1538) Add a fast version of BufferedElementCountingOutputStream

[ https://issues.apache.org/jira/browse/BEAM-1538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vikas Kedigehalli resolved BEAM-1538. - Resolution: Fixed Fix Version/s: Not applicable No longer need this as we embed

[GitHub] beam pull request #2124: Make side inputs a map, rather than embedding the n...

GitHub user robertwb opened a pull request: https://github.com/apache/beam/pull/2124 Make side inputs a map, rather than embedding the name in the message. The "local" name only make sense in context. Be sure to do all of the following to help us incorporate your

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Apex #627

See

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Apex #628

See

[jira] [Updated] (BEAM-1563) Flatten Spark runner libraries.

[ https://issues.apache.org/jira/browse/BEAM-1563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1563: Description: Flatten Spark runner libraries into a single package (or two) so that everything is private.

[jira] [Commented] (BEAM-1556) Spark executors need to register IO factories

[ https://issues.apache.org/jira/browse/BEAM-1556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886971#comment-15886971 ] Davor Bonaci commented on BEAM-1556: It certainly is an issue in other runners as well. I wouldn't do

[GitHub] beam pull request #2122: [BEAM-1572] Adding per-stage level matching of metr...

GitHub user pabloem opened a pull request: https://github.com/apache/beam/pull/2122 [BEAM-1572] Adding per-stage level matching of metrics filters. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR

[GitHub] beam pull request #2123: (Early Draft) Provide implementation of BQIO.Read t...

GitHub user sammcveety opened a pull request: https://github.com/apache/beam/pull/2123 (Early Draft) Provide implementation of BQIO.Read that does not use Source API @tgroh (and other interested parties) does this match your understanding of what needs to be built, with respect to

[jira] [Updated] (BEAM-1076) DatastoreIO template Options

[ https://issues.apache.org/jira/browse/BEAM-1076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vikas Kedigehalli updated BEAM-1076: Summary: DatastoreIO template Options (was: Datastore Delete template) > DatastoreIO

[jira] [Commented] (BEAM-1572) Add per-stage matching of scope in metrics for the DirectRunner

[ https://issues.apache.org/jira/browse/BEAM-1572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15887219#comment-15887219 ] Aviem Zur commented on BEAM-1572: - Please note that this relates to

[jira] [Commented] (BEAM-1567) hashStream should be closed in PackageUtil#createPackageAttributes()

[ https://issues.apache.org/jira/browse/BEAM-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15887307#comment-15887307 ] Ismaël Mejía commented on BEAM-1567: Welcome [~tedyu] ! Nice to see you here, and even better with a

[jira] [Commented] (BEAM-1569) HDFSFileSource: Unable to read from filePattern with spaces in path

[ https://issues.apache.org/jira/browse/BEAM-1569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15887423#comment-15887423 ] Jean-Baptiste Onofré commented on BEAM-1569: By the way, the refactoring of the HDFS IO broke

[jira] [Commented] (BEAM-1569) HDFSFileSource: Unable to read from filePattern with spaces in path

[ https://issues.apache.org/jira/browse/BEAM-1569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15887422#comment-15887422 ] Jean-Baptiste Onofré commented on BEAM-1569: Yes, I agree. A PR would be helpful. Ready to

[3/3] beam git commit: Closes #2106

Closes #2106 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/16736a6b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/16736a6b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/16736a6b Branch: refs/heads/master

[1/3] beam git commit: Make access_pattern a URN with params.

Repository: beam Updated Branches: refs/heads/master c8dfb851c -> 16736a6b6 Make access_pattern a URN with params. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a0dcd3f9 Tree:

[GitHub] beam pull request #2106: [BEAM-115] More Runner API refinements.

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

[jira] [Commented] (BEAM-115) Beam Runner API

[ https://issues.apache.org/jira/browse/BEAM-115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15887038#comment-15887038 ] ASF GitHub Bot commented on BEAM-115: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-1572) Add per-stage matching of scope in metrics for the DirectRunner

[ https://issues.apache.org/jira/browse/BEAM-1572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15887030#comment-15887030 ] ASF GitHub Bot commented on BEAM-1572: -- GitHub user pabloem opened a pull request:

[jira] [Commented] (BEAM-1558) jetty-util 6.1.26.cloudera.4 absent from repository list

[ https://issues.apache.org/jira/browse/BEAM-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885953#comment-15885953 ] ASF GitHub Bot commented on BEAM-1558: -- Github user tom-haines closed the pull request at:

[jira] [Commented] (BEAM-1558) jetty-util 6.1.26.cloudera.4 absent from repository list

[ https://issues.apache.org/jira/browse/BEAM-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885954#comment-15885954 ] ASF GitHub Bot commented on BEAM-1558: -- GitHub user tom-haines reopened a pull request:

[GitHub] beam pull request #2110: [BEAM-1558] add cloudera repository for flink runne...

GitHub user tom-haines reopened a pull request: https://github.com/apache/beam/pull/2110 [BEAM-1558] add cloudera repository for flink runner deps When building beam from source with a fresh local repository, the org.mortbay.jetty:jetty-util:jar:6.1.26.cloudera.4 dependency is not

[GitHub] beam pull request #2110: [BEAM-1558] add cloudera repository for flink runne...

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

[jira] [Commented] (BEAM-1550) HBaseIO tests timeout precommit

[ https://issues.apache.org/jira/browse/BEAM-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886012#comment-15886012 ] Ismaël Mejía commented on BEAM-1550: I validated and there are 4 tests failing in the class, it is

[jira] [Commented] (BEAM-1558) jetty-util 6.1.26.cloudera.4 absent from repository list

[ https://issues.apache.org/jira/browse/BEAM-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886382#comment-15886382 ] Aljoscha Krettek commented on BEAM-1558: On my machine, when I run your command I get this {code}

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

This closes #2087 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9e4b140e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9e4b140e Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9e4b140e Branch:

[3/3] beam git commit: Update Dataflow Container Version

Update Dataflow Container Version Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f5c04e15 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f5c04e15 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f5c04e15 Branch:

[GitHub] beam pull request #2039: [BEAM-646] Use Surgery in the Dataflow Runner

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2039 --- 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/3] beam git commit: Get DataflowRunner out of the #apply()

Get DataflowRunner out of the #apply() Use Pipeline Surgery in the Dataflow Runner Add additional override factories for Dataflow overrides. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a6cd8c38 Tree:

[jira] [Assigned] (BEAM-1078) Modifying the links in JavaDocs to point to the Beam github repo rather than GCP

[ https://issues.apache.org/jira/browse/BEAM-1078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-1078: - Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) >

[jira] [Assigned] (BEAM-421) StateTags$CombiningValueStateTag inherits equals from super class but without incorporating its state

[ https://issues.apache.org/jira/browse/BEAM-421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-421: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) >

[jira] [Assigned] (BEAM-526) Mismatched pipelines give unclear error

[ https://issues.apache.org/jira/browse/BEAM-526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-526: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) >

[jira] [Assigned] (BEAM-659) WindowFn#isCompatible should provide a meaningful reason

[ https://issues.apache.org/jira/browse/BEAM-659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-659: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) >

[jira] [Commented] (BEAM-1518) Support deflate (zlib) in CompressedSource and FileBasedSink

[ https://issues.apache.org/jira/browse/BEAM-1518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886190#comment-15886190 ] ASF GitHub Bot commented on BEAM-1518: -- Github user asfgit closed the pull request at:

[GitHub] beam pull request #2056: [BEAM-1518] support deflate file IO

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

[jira] [Commented] (BEAM-1442) Performance improvement of the Python DirectRunner

[ https://issues.apache.org/jira/browse/BEAM-1442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886369#comment-15886369 ] Pablo Estrada commented on BEAM-1442: - You can share a draft of your proposal in Google docs with us.

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

This closes #2116 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ae6860db Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ae6860db Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ae6860db Branch:

[jira] [Closed] (BEAM-1541) Create a hadoop-common module to share common code in Hadoop based IOs

[ https://issues.apache.org/jira/browse/BEAM-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía closed BEAM-1541. -- > Create a hadoop-common module to share common code in Hadoop based IOs >

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Flink #1774

See Changes: [tgroh] Inject Sharding Strategy in the Direct Runner -- [...truncated 562.98 KB...] Caused by: java.lang.ClassNotFoundException:

[jira] [Commented] (BEAM-1567) hashStream should be closed in PackageUtil#createPackageAttributes()

[ https://issues.apache.org/jira/browse/BEAM-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886456#comment-15886456 ] Daniel Halperin commented on BEAM-1567: --- Thanks [~te...@apache.org], This indeed looks like it could

[jira] [Commented] (BEAM-111) Use SDK implementation of WritableCoder

[ https://issues.apache.org/jira/browse/BEAM-111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886485#comment-15886485 ] ASF GitHub Bot commented on BEAM-111: - GitHub user iemejia opened a pull request:

[jira] [Commented] (BEAM-1567) hashStream should be closed in PackageUtil#createPackageAttributes()

[ https://issues.apache.org/jira/browse/BEAM-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886492#comment-15886492 ] Daniel Halperin commented on BEAM-1567: --- Actually it was auto-assigned to him by default. :) So if

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #2761

See

[jira] [Commented] (BEAM-1540) Refactor HBaseIO to hide visibility of Coders/Serializable classes

[ https://issues.apache.org/jira/browse/BEAM-1540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886406#comment-15886406 ] ASF GitHub Bot commented on BEAM-1540: -- GitHub user iemejia opened a pull request:

[jira] [Resolved] (BEAM-1541) Create a hadoop-common module to share common code in Hadoop based IOs

[ https://issues.apache.org/jira/browse/BEAM-1541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-1541. Resolution: Fixed Fix Version/s: 0.6.0 > Create a hadoop-common module to share common code

[GitHub] beam pull request #2117: [BEAM-1540] Refactor HBaseIO to hide visibility of ...

GitHub user iemejia opened a pull request: https://github.com/apache/beam/pull/2117 [BEAM-1540] Refactor HBaseIO to hide visibility of Coders/Serializable classes Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x]

[jira] [Commented] (BEAM-1566) Flink doesn't support DEFLATE compression

[ https://issues.apache.org/jira/browse/BEAM-1566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886435#comment-15886435 ] ASF GitHub Bot commented on BEAM-1566: -- Github user asfgit closed the pull request at:

[GitHub] beam pull request #2116: [BEAM-1566] Flink: upgrade apache commons

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2116 --- 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: Flink: upgrade apache commons

Repository: beam Updated Branches: refs/heads/master 932bb823f -> ae6860db5 Flink: upgrade apache commons Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/223aaac0 Tree:

[jira] [Created] (BEAM-1567) hashStream should be closed in PackageUtil#createPackageAttributes()

Ted Yu created BEAM-1567: Summary: hashStream should be closed in PackageUtil#createPackageAttributes() Key: BEAM-1567 URL: https://issues.apache.org/jira/browse/BEAM-1567 Project: Beam Issue Type:

[jira] [Closed] (BEAM-1566) Flink doesn't support DEFLATE compression

[ https://issues.apache.org/jira/browse/BEAM-1566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-1566. - Resolution: Fixed Fix Version/s: Not applicable > Flink doesn't support DEFLATE compression

[jira] [Commented] (BEAM-1567) hashStream should be closed in PackageUtil#createPackageAttributes()

[ https://issues.apache.org/jira/browse/BEAM-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886471#comment-15886471 ] Ted Yu commented on BEAM-1567: -- I was looking at code under google-cloud-dataflow-java and happened to see

[GitHub] beam pull request #2118: [BEAM-111] Move WritableCoder to hadoop-common

GitHub user iemejia opened a pull request: https://github.com/apache/beam/pull/2118 [BEAM-111] Move WritableCoder to hadoop-common 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

[jira] [Assigned] (BEAM-1567) hashStream should be closed in PackageUtil#createPackageAttributes()

[ https://issues.apache.org/jira/browse/BEAM-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin reassigned BEAM-1567: - Assignee: (was: Davor Bonaci) > hashStream should be closed in

[jira] [Commented] (BEAM-646) Get runners out of the apply()

[ https://issues.apache.org/jira/browse/BEAM-646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886137#comment-15886137 ] ASF GitHub Bot commented on BEAM-646: - Github user asfgit closed the pull request at:

[jira] [Assigned] (BEAM-239) Rename RemoveDuplicates to Distinct

[ https://issues.apache.org/jira/browse/BEAM-239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-239: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Rename

[jira] [Assigned] (BEAM-879) Renaming DeDupExample to DistinctExample

[ https://issues.apache.org/jira/browse/BEAM-879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-879: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Renaming

[jira] [Assigned] (BEAM-29) Bound Instant values used as timestamps at TIMESTAMP_MIN_VALUE and TIMESTAMP_MAX_VALUE

[ https://issues.apache.org/jira/browse/BEAM-29?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-29: --- Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Bound

[1/2] beam git commit: Add Create#withTypeDescriptor

Repository: beam Updated Branches: refs/heads/master 0b7515e5e -> 063fbd4ed Add Create#withTypeDescriptor This permits creates that cannot infer a coder based on the input elements to pass a Type Descriptor and use Coder Inference, rather than requiring a coder be provided. Project:

[GitHub] beam pull request #2095: [BEAM-1446] Create with TypeDescriptor

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

[jira] [Commented] (BEAM-1446) Create should take a TypeDescriptor as an alternative to explicitly specifying the Coder

[ https://issues.apache.org/jira/browse/BEAM-1446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886194#comment-15886194 ] ASF GitHub Bot commented on BEAM-1446: -- Github user asfgit closed the pull request at:

[GitHub] beam pull request #495: Spark runner upgrade to Spark 2.0

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

[jira] [Commented] (BEAM-1442) Performance improvement of the Python DirectRunner

[ https://issues.apache.org/jira/browse/BEAM-1442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886226#comment-15886226 ] Haoxiang commented on BEAM-1442: Hi altay: I make a simple benchmark between python's wordcount and Java's

[jira] [Commented] (BEAM-1059) Create ExecIO

[ https://issues.apache.org/jira/browse/BEAM-1059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886230#comment-15886230 ] ASF GitHub Bot commented on BEAM-1059: -- Github user jbonofre closed the pull request at:

[GitHub] beam pull request #1451: [BEAM-1059] Create ExecIO

Github user jbonofre closed the pull request at: https://github.com/apache/beam/pull/1451 --- 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-1541] Create hadoop-common and refactor HdfsIO and HBaseIO to use it

Repository: beam Updated Branches: refs/heads/master b261d4890 -> 9e4b140ed [BEAM-1541] Create hadoop-common and refactor HdfsIO and HBaseIO to use it Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d1f6a8af Tree:

[GitHub] beam pull request #2087: [BEAM-1541] Create hadoop-common and refactor HdfsI...

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

[jira] [Assigned] (BEAM-1105) Adding Beam's pico Wordcount to the existing examples.

[ https://issues.apache.org/jira/browse/BEAM-1105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-1105: - Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) >

[jira] [Assigned] (BEAM-651) Add public TypedPValue.setTypeDescriptor

[ https://issues.apache.org/jira/browse/BEAM-651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-651: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Add

[jira] [Assigned] (BEAM-454) Validate Pubsub Topic exists when reading

[ https://issues.apache.org/jira/browse/BEAM-454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-454: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) > Validate

[jira] [Assigned] (BEAM-1083) Deleting the Weblink for the DatastoreWordCount based on BEAM-498

[ https://issues.apache.org/jira/browse/BEAM-1083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-1083: - Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) >

[jira] [Assigned] (BEAM-1129) Umbrella JIRA for Fixing Findbugs

[ https://issues.apache.org/jira/browse/BEAM-1129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-1129: - Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) >

[jira] [Created] (BEAM-1561) Iterating over _UnwindowedValues is slow

Ahmet Altay created BEAM-1561: - Summary: Iterating over _UnwindowedValues is slow Key: BEAM-1561 URL: https://issues.apache.org/jira/browse/BEAM-1561 Project: Beam Issue Type: Bug

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Flink #1772

See Changes: [dhalperi] Add DEFLATE to CompressedSource and TextIO [tgroh] Add Create#withTypeDescriptor -- [...truncated 562.73 KB...]

[jira] [Assigned] (BEAM-1502) CombinePerKey returns a list of lists when run locally, but something else when run on Dataflow

[ https://issues.apache.org/jira/browse/BEAM-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay reassigned BEAM-1502: - Assignee: (was: Ahmet Altay) > CombinePerKey returns a list of lists when run locally, but

[jira] [Assigned] (BEAM-410) ApproximateQuantiles$QuantileBuffer defines compareTo but not equals

[ https://issues.apache.org/jira/browse/BEAM-410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-410: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) >

[jira] [Assigned] (BEAM-420) Non-transient non-serializable instance field in WatermarkHold

[ https://issues.apache.org/jira/browse/BEAM-420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-420: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) >

[jira] [Assigned] (BEAM-400) Direct/InProcess runner should use Pubsub publish time timestamp if timestampLabel is not set

[ https://issues.apache.org/jira/browse/BEAM-400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-400: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) >

[jira] [Assigned] (BEAM-409) Incorrect use of Math.ceil in ApproximateQuantiles

[ https://issues.apache.org/jira/browse/BEAM-409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-409: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) >

[jira] [Assigned] (BEAM-419) Non-transient non-serializable instance field in CombineFnUtil$NonSerializableBoundedKeyedCombineFn

[ https://issues.apache.org/jira/browse/BEAM-419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-419: Assignee: Neelesh Srinivas Salian (was: Neelesh Srinivas Salian) >

  1   2   >