[jira] [Commented] (BEAM-2676) move BeamSqlRow and BeamSqlRowType to sdk/java/core

[ https://issues.apache.org/jira/browse/BEAM-2676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16110323#comment-16110323 ] Xu Mingmin commented on BEAM-2676: -- [~robertwb] [~takidau], get your point. I will move {{BeamRecord}}

[jira] [Commented] (BEAM-2441) DSL SQL maven module location and name

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

[GitHub] beam pull request #3666: [BEAM-2441] move dsls/sql to sdks/java/extensions/s...

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

[23/59] beam git commit: rename package org.apache.beam.dsls.sql to org.apache.beam.sdk.extensions.sql

http://git-wip-us.apache.org/repos/asf/beam/blob/c1b5482d/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/interpreter/operator/string/BeamSqlOverlayExpressionTest.java -- diff --git

[08/59] beam git commit: move dsls/sql to sdks/java/extensions/sql

http://git-wip-us.apache.org/repos/asf/beam/blob/ba493f85/sdks/java/extensions/sql/src/main/java/org/apache/beam/dsls/sql/interpreter/operator/string/BeamSqlOverlayExpression.java -- diff --git

[50/59] beam git commit: move all implementation classes/packages into impl package

http://git-wip-us.apache.org/repos/asf/beam/blob/febd044a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/rel/BeamFilterRel.java -- diff --git

[41/59] beam git commit: rename package org.apache.beam.dsls.sql to org.apache.beam.sdk.extensions.sql

http://git-wip-us.apache.org/repos/asf/beam/blob/c1b5482d/sdks/java/extensions/sql/src/main/java/org/apache/beam/dsls/sql/interpreter/operator/BeamSqlPrimitive.java -- diff --git

[11/59] beam git commit: move dsls/sql to sdks/java/extensions/sql

http://git-wip-us.apache.org/repos/asf/beam/blob/ba493f85/dsls/sql/src/test/java/org/apache/beam/dsls/sql/schema/transform/BeamAggregationTransformTest.java -- diff --git

[38/59] beam git commit: rename package org.apache.beam.dsls.sql to org.apache.beam.sdk.extensions.sql

http://git-wip-us.apache.org/repos/asf/beam/blob/c1b5482d/sdks/java/extensions/sql/src/main/java/org/apache/beam/dsls/sql/rel/BeamSortRel.java -- diff --git

[18/59] beam git commit: move dsls/sql to sdks/java/extensions/sql

http://git-wip-us.apache.org/repos/asf/beam/blob/ba493f85/dsls/sql/src/main/java/org/apache/beam/dsls/sql/interpreter/operator/string/BeamSqlConcatExpression.java -- diff --git

[10/59] beam git commit: move dsls/sql to sdks/java/extensions/sql

http://git-wip-us.apache.org/repos/asf/beam/blob/ba493f85/sdks/java/extensions/sql/src/main/java/org/apache/beam/dsls/sql/interpreter/operator/BeamSqlExpression.java -- diff --git

[04/59] beam git commit: move dsls/sql to sdks/java/extensions/sql

http://git-wip-us.apache.org/repos/asf/beam/blob/ba493f85/sdks/java/extensions/sql/src/test/java/org/apache/beam/dsls/sql/integrationtest/BeamSqlDateFunctionsIntegrationTest.java -- diff --git

[05/59] beam git commit: move dsls/sql to sdks/java/extensions/sql

http://git-wip-us.apache.org/repos/asf/beam/blob/ba493f85/sdks/java/extensions/sql/src/test/java/org/apache/beam/dsls/sql/BeamSqlApiSurfaceTest.java -- diff --git

[57/59] beam git commit: move all implementation classes/packages into impl package

http://git-wip-us.apache.org/repos/asf/beam/blob/febd044a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/operator/arithmetic/BeamSqlMinusExpression.java -- diff --git

[27/59] beam git commit: rename package org.apache.beam.dsls.sql to org.apache.beam.sdk.extensions.sql

http://git-wip-us.apache.org/repos/asf/beam/blob/c1b5482d/sdks/java/extensions/sql/src/test/java/org/apache/beam/dsls/sql/mock/MockedUnboundedTable.java -- diff --git

[06/59] beam git commit: move dsls/sql to sdks/java/extensions/sql

http://git-wip-us.apache.org/repos/asf/beam/blob/ba493f85/sdks/java/extensions/sql/src/main/java/org/apache/beam/dsls/sql/schema/BeamSqlUdf.java -- diff --git

[19/59] beam git commit: move dsls/sql to sdks/java/extensions/sql

http://git-wip-us.apache.org/repos/asf/beam/blob/ba493f85/dsls/sql/src/main/java/org/apache/beam/dsls/sql/interpreter/operator/date/BeamSqlExtractExpression.java -- diff --git

[43/59] beam git commit: move all implementation classes/packages into impl package

http://git-wip-us.apache.org/repos/asf/beam/blob/febd044a/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/schema/transform/BeamTransformBaseTest.java -- diff --git

[58/59] beam git commit: move all implementation classes/packages into impl package

move all implementation classes/packages into impl package Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/febd044a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/febd044a Diff:

[52/59] beam git commit: move all implementation classes/packages into impl package

http://git-wip-us.apache.org/repos/asf/beam/blob/febd044a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/interpreter/operator/comparison/BeamSqlGreaterThanOrEqualsExpression.java -- diff --git

[45/59] beam git commit: move all implementation classes/packages into impl package

http://git-wip-us.apache.org/repos/asf/beam/blob/febd044a/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/interpreter/operator/BeamSqlCompareExpressionTest.java -- diff --git

[26/59] beam git commit: rename package org.apache.beam.dsls.sql to org.apache.beam.sdk.extensions.sql

http://git-wip-us.apache.org/repos/asf/beam/blob/c1b5482d/sdks/java/extensions/sql/src/test/java/org/apache/beam/dsls/sql/schema/transform/BeamAggregationTransformTest.java -- diff --git

[37/59] beam git commit: rename package org.apache.beam.dsls.sql to org.apache.beam.sdk.extensions.sql

http://git-wip-us.apache.org/repos/asf/beam/blob/c1b5482d/sdks/java/extensions/sql/src/main/java/org/apache/beam/dsls/sql/schema/BeamSqlUdaf.java -- diff --git

[29/59] beam git commit: rename package org.apache.beam.dsls.sql to org.apache.beam.sdk.extensions.sql

http://git-wip-us.apache.org/repos/asf/beam/blob/c1b5482d/sdks/java/extensions/sql/src/test/java/org/apache/beam/dsls/sql/integrationtest/BeamSqlMathFunctionsIntegrationTest.java -- diff --git

[12/59] beam git commit: move dsls/sql to sdks/java/extensions/sql

http://git-wip-us.apache.org/repos/asf/beam/blob/ba493f85/dsls/sql/src/test/java/org/apache/beam/dsls/sql/interpreter/operator/string/BeamSqlUpperExpressionTest.java -- diff --git

[30/59] beam git commit: rename package org.apache.beam.dsls.sql to org.apache.beam.sdk.extensions.sql

http://git-wip-us.apache.org/repos/asf/beam/blob/c1b5482d/sdks/java/extensions/sql/src/test/java/org/apache/beam/dsls/sql/BeamSqlDslBase.java -- diff --git

[32/59] beam git commit: rename package org.apache.beam.dsls.sql to org.apache.beam.sdk.extensions.sql

http://git-wip-us.apache.org/repos/asf/beam/blob/c1b5482d/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/rel/package-info.java -- diff --git

[36/59] beam git commit: rename package org.apache.beam.dsls.sql to org.apache.beam.sdk.extensions.sql

http://git-wip-us.apache.org/repos/asf/beam/blob/c1b5482d/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/BeamSql.java -- diff --git

[55/59] beam git commit: move all implementation classes/packages into impl package

http://git-wip-us.apache.org/repos/asf/beam/blob/febd044a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/planner/BeamQueryPlanner.java -- diff --git

[20/59] beam git commit: move dsls/sql to sdks/java/extensions/sql

http://git-wip-us.apache.org/repos/asf/beam/blob/ba493f85/dsls/sql/src/main/java/org/apache/beam/dsls/sql/interpreter/operator/BeamSqlCastExpression.java -- diff --git

[51/59] beam git commit: move all implementation classes/packages into impl package

http://git-wip-us.apache.org/repos/asf/beam/blob/febd044a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/interpreter/operator/math/BeamSqlPiExpression.java -- diff --git

[31/59] beam git commit: rename package org.apache.beam.dsls.sql to org.apache.beam.sdk.extensions.sql

http://git-wip-us.apache.org/repos/asf/beam/blob/c1b5482d/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/schema/package-info.java -- diff --git

[28/59] beam git commit: rename package org.apache.beam.dsls.sql to org.apache.beam.sdk.extensions.sql

http://git-wip-us.apache.org/repos/asf/beam/blob/c1b5482d/sdks/java/extensions/sql/src/test/java/org/apache/beam/dsls/sql/interpreter/operator/date/BeamSqlCurrentTimeExpressionTest.java -- diff --git

[33/59] beam git commit: rename package org.apache.beam.dsls.sql to org.apache.beam.sdk.extensions.sql

http://git-wip-us.apache.org/repos/asf/beam/blob/c1b5482d/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/planner/BeamQueryPlanner.java -- diff --git

[34/59] beam git commit: rename package org.apache.beam.dsls.sql to org.apache.beam.sdk.extensions.sql

http://git-wip-us.apache.org/repos/asf/beam/blob/c1b5482d/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/interpreter/operator/math/BeamSqlDegreesExpression.java -- diff --git

[21/59] beam git commit: move dsls/sql to sdks/java/extensions/sql

move dsls/sql to sdks/java/extensions/sql Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ba493f85 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ba493f85 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ba493f85

[24/59] beam git commit: rename package org.apache.beam.dsls.sql to org.apache.beam.sdk.extensions.sql

http://git-wip-us.apache.org/repos/asf/beam/blob/c1b5482d/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/interpreter/operator/BeamSqlCompareExpressionTest.java -- diff --git

[25/59] beam git commit: rename package org.apache.beam.dsls.sql to org.apache.beam.sdk.extensions.sql

http://git-wip-us.apache.org/repos/asf/beam/blob/c1b5482d/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/integrationtest/BeamSqlBuiltinFunctionsIntegrationTestBase.java -- diff --git

[53/59] beam git commit: move all implementation classes/packages into impl package

http://git-wip-us.apache.org/repos/asf/beam/blob/febd044a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/utils/CalciteUtils.java -- diff --git

[49/59] beam git commit: move all implementation classes/packages into impl package

http://git-wip-us.apache.org/repos/asf/beam/blob/febd044a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/rule/BeamMinusRule.java -- diff --git

[54/59] beam git commit: move all implementation classes/packages into impl package

http://git-wip-us.apache.org/repos/asf/beam/blob/febd044a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/package-info.java -- diff --git

[46/59] beam git commit: move all implementation classes/packages into impl package

http://git-wip-us.apache.org/repos/asf/beam/blob/febd044a/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamJoinRelUnboundedVsBoundedTest.java -- diff --git

[48/59] beam git commit: move all implementation classes/packages into impl package

http://git-wip-us.apache.org/repos/asf/beam/blob/febd044a/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/BeamSqlFnExecutorTest.java -- diff --git

[42/59] beam git commit: rename package org.apache.beam.dsls.sql to org.apache.beam.sdk.extensions.sql

rename package org.apache.beam.dsls.sql to org.apache.beam.sdk.extensions.sql Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c1b5482d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c1b5482d Diff:

[40/59] beam git commit: rename package org.apache.beam.dsls.sql to org.apache.beam.sdk.extensions.sql

http://git-wip-us.apache.org/repos/asf/beam/blob/c1b5482d/sdks/java/extensions/sql/src/main/java/org/apache/beam/dsls/sql/interpreter/operator/logical/BeamSqlOrExpression.java -- diff --git

[07/59] beam git commit: move dsls/sql to sdks/java/extensions/sql

http://git-wip-us.apache.org/repos/asf/beam/blob/ba493f85/sdks/java/extensions/sql/src/main/java/org/apache/beam/dsls/sql/rel/BeamSortRel.java -- diff --git

[16/59] beam git commit: move dsls/sql to sdks/java/extensions/sql

http://git-wip-us.apache.org/repos/asf/beam/blob/ba493f85/dsls/sql/src/main/java/org/apache/beam/dsls/sql/schema/BeamSqlTable.java -- diff --git a/dsls/sql/src/main/java/org/apache/beam/dsls/sql/schema/BeamSqlTable.java

[14/59] beam git commit: move dsls/sql to sdks/java/extensions/sql

http://git-wip-us.apache.org/repos/asf/beam/blob/ba493f85/dsls/sql/src/test/java/org/apache/beam/dsls/sql/integrationtest/BeamSqlConditionalFunctionsIntegrationTest.java -- diff --git

[56/59] beam git commit: move all implementation classes/packages into impl package

http://git-wip-us.apache.org/repos/asf/beam/blob/febd044a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/operator/math/BeamSqlCotExpression.java -- diff --git

[59/59] beam git commit: [BEAM-2441] This closes #3666

[BEAM-2441] This closes #3666 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/10962a34 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/10962a34 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/10962a34 Branch:

[47/59] beam git commit: move all implementation classes/packages into impl package

http://git-wip-us.apache.org/repos/asf/beam/blob/febd044a/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/operator/date/BeamSqlExtractExpressionTest.java -- diff --git

[22/59] beam git commit: rename package org.apache.beam.dsls.sql to org.apache.beam.sdk.extensions.sql

http://git-wip-us.apache.org/repos/asf/beam/blob/c1b5482d/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/rel/BeamValuesRelTest.java -- diff --git

[15/59] beam git commit: move dsls/sql to sdks/java/extensions/sql

http://git-wip-us.apache.org/repos/asf/beam/blob/ba493f85/dsls/sql/src/main/java/org/apache/beam/dsls/sql/utils/package-info.java -- diff --git a/dsls/sql/src/main/java/org/apache/beam/dsls/sql/utils/package-info.java

[17/59] beam git commit: move dsls/sql to sdks/java/extensions/sql

http://git-wip-us.apache.org/repos/asf/beam/blob/ba493f85/dsls/sql/src/main/java/org/apache/beam/dsls/sql/rel/BeamRelNode.java -- diff --git a/dsls/sql/src/main/java/org/apache/beam/dsls/sql/rel/BeamRelNode.java

[09/59] beam git commit: move dsls/sql to sdks/java/extensions/sql

http://git-wip-us.apache.org/repos/asf/beam/blob/ba493f85/sdks/java/extensions/sql/src/main/java/org/apache/beam/dsls/sql/interpreter/operator/logical/BeamSqlLogicalExpression.java -- diff --git

[35/59] beam git commit: rename package org.apache.beam.dsls.sql to org.apache.beam.sdk.extensions.sql

http://git-wip-us.apache.org/repos/asf/beam/blob/c1b5482d/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/interpreter/operator/arithmetic/BeamSqlModExpression.java -- diff --git

[02/59] beam git commit: move dsls/sql to sdks/java/extensions/sql

http://git-wip-us.apache.org/repos/asf/beam/blob/ba493f85/sdks/java/extensions/sql/src/test/java/org/apache/beam/dsls/sql/interpreter/operator/string/BeamSqlTrimExpressionTest.java -- diff --git

[13/59] beam git commit: move dsls/sql to sdks/java/extensions/sql

http://git-wip-us.apache.org/repos/asf/beam/blob/ba493f85/dsls/sql/src/test/java/org/apache/beam/dsls/sql/interpreter/operator/arithmetic/BeamSqlArithmeticExpressionTest.java -- diff --git

[44/59] beam git commit: move all implementation classes/packages into impl package

http://git-wip-us.apache.org/repos/asf/beam/blob/febd044a/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/interpreter/operator/string/BeamSqlOverlayExpressionTest.java -- diff --git

[03/59] beam git commit: move dsls/sql to sdks/java/extensions/sql

http://git-wip-us.apache.org/repos/asf/beam/blob/ba493f85/sdks/java/extensions/sql/src/test/java/org/apache/beam/dsls/sql/interpreter/operator/arithmetic/BeamSqlArithmeticExpressionTest.java -- diff --git

[01/59] beam git commit: move dsls/sql to sdks/java/extensions/sql

Repository: beam Updated Branches: refs/heads/DSL_SQL d32aea969 -> 10962a34d http://git-wip-us.apache.org/repos/asf/beam/blob/ba493f85/sdks/java/extensions/sql/src/test/java/org/apache/beam/dsls/sql/schema/text/BeamTextCSVTableTest.java

[jira] [Commented] (BEAM-2671) CreateStreamTest.testFirstElementLate validatesRunner test fails on Spark runner

[ https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16110272#comment-16110272 ] Jean-Baptiste Onofré commented on BEAM-2671: I found the issue which cause the issue: {code}

Build failed in Jenkins: beam_PostCommit_Python_Verify #2848

See -- [...truncated 561.96 KB...] test_par_do_with_multiple_outputs_and_using_yield (apache_beam.transforms.ptransform_test.PTransformTest) ... ok

[jira] [Commented] (BEAM-1323) Add parallelism/splitting in JdbcIO

[ https://issues.apache.org/jira/browse/BEAM-1323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16110238#comment-16110238 ] Jean-Baptiste Onofré commented on BEAM-1323: Fair enough. I'm closing this Jira. > Add

[jira] [Resolved] (BEAM-1323) Add parallelism/splitting in JdbcIO

[ https://issues.apache.org/jira/browse/BEAM-1323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-1323. Resolution: Won't Fix Fix Version/s: Not applicable > Add

[jira] [Commented] (BEAM-2706) Create JdbcIO.readAll()

[ https://issues.apache.org/jira/browse/BEAM-2706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16110237#comment-16110237 ] Jean-Baptiste Onofré commented on BEAM-2706: I gonna implement this asap. Thanks for the

Jenkins build is unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3698

See

[jira] [Commented] (BEAM-1584) Support clean-up step in integration test

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

[GitHub] beam pull request #3673: [BEAM-1584] Add clean up for bigquery integration t...

GitHub user markflyhigh opened a pull request: https://github.com/apache/beam/pull/3673 [BEAM-1584] Add clean up for bigquery integration test in Python Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Make sure there is a [JIRA

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2756

See

[GitHub] beam pull request #3650: Translate ParDo and GroupByKey operations through t...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3650 --- 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/5] beam git commit: Closes #3650

Repository: beam Updated Branches: refs/heads/master 53c2c8fde -> ba5e31466 Closes #3650 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ba5e3146 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ba5e3146 Diff:

[4/5] beam git commit: More informative references in the proto representation.

More informative references in the proto representation. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2ee7422f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2ee7422f Diff:

[2/5] beam git commit: Translate GroupByKey[Only] through the Runner API.

Translate GroupByKey[Only] through the Runner API. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b179eca9 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b179eca9 Diff:

[3/5] beam git commit: Translate ParDo operations through the Runner API.

Translate ParDo operations through the Runner API. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7d64b769 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7d64b769 Diff:

[5/5] beam git commit: Streaming fixes.

Streaming fixes. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3c0c3374 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3c0c3374 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3c0c3374 Branch:

[jira] [Updated] (BEAM-2713) Support Python native types in Beam typehints

[ https://issues.apache.org/jira/browse/BEAM-2713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay updated BEAM-2713: -- Issue Type: Sub-task (was: New Feature) Parent: BEAM-1251 > Support Python native types in Beam

[jira] [Commented] (BEAM-2713) Support Python native types in Beam typehints

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

[GitHub] beam pull request #3672: [BEAM-2713] Support Python native types in Beam typ...

GitHub user chuanyu opened a pull request: https://github.com/apache/beam/pull/3672 [BEAM-2713] Support Python native types in Beam typehints Add support for Python native types in Beam typehints. You can merge this pull request into a Git repository by running: $ git pull

[jira] [Created] (BEAM-2713) Support Python native types in Beam typehints

Chuan Yu Foo created BEAM-2713: -- Summary: Support Python native types in Beam typehints Key: BEAM-2713 URL: https://issues.apache.org/jira/browse/BEAM-2713 Project: Beam Issue Type: New Feature

[jira] [Assigned] (BEAM-2712) SerializablePipelineOptions should not call FileSystems.setDefaultPipelineOptions.

[ https://issues.apache.org/jira/browse/BEAM-2712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov reassigned BEAM-2712: -- Assignee: (was: Kenneth Knowles) > SerializablePipelineOptions should not call >

[jira] [Created] (BEAM-2712) SerializablePipelineOptions should not call FileSystems.setDefaultPipelineOptions.

Eugene Kirpichov created BEAM-2712: -- Summary: SerializablePipelineOptions should not call FileSystems.setDefaultPipelineOptions. Key: BEAM-2712 URL: https://issues.apache.org/jira/browse/BEAM-2712

[jira] [Closed] (BEAM-2710) Outputing "finished" when processing is not called in ParDoTest.TestDoFn leads to unexpected ElementCount

[ https://issues.apache.org/jira/browse/BEAM-2710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rafael Fernandez closed BEAM-2710. -- Resolution: Not A Problem Fix Version/s: Not applicable The issue is broader than test --

[GitHub] beam pull request #3671: Fix typo in dataflow_runner.

GitHub user robertwb opened a pull request: https://github.com/apache/beam/pull/3671 Fix typo in dataflow_runner. Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Make sure there is a [JIRA

[jira] [Created] (BEAM-2711) ByteKeyRangeTracker.getFractionConsumed() fails when out of range positions are claimed

Chamikara Jayalath created BEAM-2711: Summary: ByteKeyRangeTracker.getFractionConsumed() fails when out of range positions are claimed Key: BEAM-2711 URL: https://issues.apache.org/jira/browse/BEAM-2711

Build failed in Jenkins: beam_PostCommit_Python_Verify #2846

See Changes: [tgroh] Remove References to CloudObject from the Java Harness -- [...truncated 559.75 KB...] Collecting pbr>=0.11 (from mock->-r

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3696

See

[jira] [Commented] (BEAM-2707) DSL_SQL branch broken by PR 3334

[ https://issues.apache.org/jira/browse/BEAM-2707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16109896#comment-16109896 ] Xu Mingmin commented on BEAM-2707: -- #3334 should not impact us as we're in DSL_SQL branch. I check out

Build failed in Jenkins: beam_PostCommit_Python_Verify #2845

See -- [...truncated 559.36 KB...] File was already downloaded /tmp/dataflow-requirements-cache/funcsigs-1.0.2.tar.gz Collecting pbr>=0.11 (from mock->-r

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2755

See

[jira] [Created] (BEAM-2710) Outputing "finished" when processing is not called in ParDoTest.TestDoFn leads to unexpected ElementCount

Rafael Fernandez created BEAM-2710: -- Summary: Outputing "finished" when processing is not called in ParDoTest.TestDoFn leads to unexpected ElementCount Key: BEAM-2710 URL:

[jira] [Commented] (BEAM-2708) Decompressing bzip2 files with multiple "streams" only reads the first stream

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

[GitHub] beam pull request #3670: [BEAM-2708] Configure BZIP2 to read all "streams"

GitHub user bjchambers opened a pull request: https://github.com/apache/beam/pull/3670 [BEAM-2708] Configure BZIP2 to read all "streams" Without this, CompressionMode.BZIP2 only supports "standard" bz2 files containing a single stream. With this change, BZIP2 also supports bz2

[jira] [Commented] (BEAM-2566) Java SDK harness should not depend on any runner

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

[GitHub] beam pull request #3647: [BEAM-2566] Remove References to CloudObject from t...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3647 --- 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/2] beam git commit: Remove References to CloudObject from the Java Harness

Remove References to CloudObject from the Java Harness Migrates to using the shared Runner API definitions. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/64cf18fc Tree:

[1/2] beam git commit: This closes #3647

Repository: beam Updated Branches: refs/heads/master 3c81766e2 -> 53c2c8fde This closes #3647 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/53c2c8fd Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/53c2c8fd Diff:

[GitHub] beam pull request #3669: [BEAM-2708] Configure BZIP2 to read all "streams"

GitHub user bjchambers opened a pull request: https://github.com/apache/beam/pull/3669 [BEAM-2708] Configure BZIP2 to read all "streams" Without this, CompressionMode.BZIP2 only supports "standard" bz2 files containing a single stream. With this change, BZIP2 also supports bz2

[jira] [Commented] (BEAM-2708) Decompressing bzip2 files with multiple "streams" only reads the first stream

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

[jira] [Commented] (BEAM-2709) Add TezRunner

[ https://issues.apache.org/jira/browse/BEAM-2709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16109754#comment-16109754 ] Brandon Scheller commented on BEAM-2709: Can this be assigned to me? > Add TezRunner >

  1   2   >