[jira] [Resolved] (BEAM-4131) Python SDK harness container image contains SDK and dependencies

2018-04-30 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved BEAM-4131. Resolution: Fixed Fix Version/s: 2.5.0 > Python SDK harness container image contains SDK and

[jira] [Commented] (BEAM-4038) Support Kafka Headers in KafkaIO

2018-04-30 Thread Geet Kumar (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459432#comment-16459432 ] Geet Kumar commented on BEAM-4038: -- {quote} How about adding {{KafkaIO.writeRecords()}} which is a 

Build failed in Jenkins: beam_PostCommit_Python_ValidatesContainer_Dataflow #119

2018-04-30 Thread Apache Jenkins Server
See Changes: [ankurgoenka] fixing generic errors [echauchot] [BEAM-3119] ensure metrics thread is shutdown [echauchot] [BEAM-4088] Rebase on master, fix conflicts and adapt

Build failed in Jenkins: beam_PostCommit_Python_ValidatesRunner_Dataflow #1491

2018-04-30 Thread Apache Jenkins Server
See -- Started by timer [EnvInject] - Loading node environment variables. Building remotely on beam23 (beam) in workspace

[jira] [Commented] (BEAM-4215) Update Python SDK dependencies for 2.5.0 release

2018-04-30 Thread Valentyn Tymofieiev (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459407#comment-16459407 ] Valentyn Tymofieiev commented on BEAM-4215: --- Looks like we lifted the restriction to allow

[jira] [Comment Edited] (BEAM-4215) Update Python SDK dependencies for 2.5.0 release

2018-04-30 Thread Valentyn Tymofieiev (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459401#comment-16459401 ] Valentyn Tymofieiev edited comment on BEAM-4215 at 5/1/18 2:34 AM: --- With

[jira] [Comment Edited] (BEAM-4215) Update Python SDK dependencies for 2.5.0 release

2018-04-30 Thread Valentyn Tymofieiev (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459401#comment-16459401 ] Valentyn Tymofieiev edited comment on BEAM-4215 at 5/1/18 2:32 AM: --- With

[jira] [Commented] (BEAM-4215) Update Python SDK dependencies for 2.5.0 release

2018-04-30 Thread Valentyn Tymofieiev (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459403#comment-16459403 ] Valentyn Tymofieiev commented on BEAM-4215: --- cc [~chamikara], [~altay]. > Update Python SDK

[jira] [Commented] (BEAM-4215) Update Python SDK dependencies for 2.5.0 release

2018-04-30 Thread Valentyn Tymofieiev (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459401#comment-16459401 ] Valentyn Tymofieiev commented on BEAM-4215: --- With Pip 10 I am seeing several warnings about 

[jira] [Work logged] (BEAM-3972) Flink runner translates batch pipelines directly by proto

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3972?focusedWorklogId=96920=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96920 ] ASF GitHub Bot logged work on BEAM-3972: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3972) Flink runner translates batch pipelines directly by proto

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3972?focusedWorklogId=96911=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96911 ] ASF GitHub Bot logged work on BEAM-3972: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3972) Flink runner translates batch pipelines directly by proto

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3972?focusedWorklogId=96912=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96912 ] ASF GitHub Bot logged work on BEAM-3972: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3972) Flink runner translates batch pipelines directly by proto

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3972?focusedWorklogId=96919=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96919 ] ASF GitHub Bot logged work on BEAM-3972: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3972) Flink runner translates batch pipelines directly by proto

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3972?focusedWorklogId=96914=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96914 ] ASF GitHub Bot logged work on BEAM-3972: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3972) Flink runner translates batch pipelines directly by proto

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3972?focusedWorklogId=96917=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96917 ] ASF GitHub Bot logged work on BEAM-3972: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3972) Flink runner translates batch pipelines directly by proto

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3972?focusedWorklogId=96916=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96916 ] ASF GitHub Bot logged work on BEAM-3972: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3972) Flink runner translates batch pipelines directly by proto

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3972?focusedWorklogId=96915=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96915 ] ASF GitHub Bot logged work on BEAM-3972: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3972) Flink runner translates batch pipelines directly by proto

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3972?focusedWorklogId=96921=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96921 ] ASF GitHub Bot logged work on BEAM-3972: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3972) Flink runner translates batch pipelines directly by proto

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3972?focusedWorklogId=96913=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96913 ] ASF GitHub Bot logged work on BEAM-3972: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3972) Flink runner translates batch pipelines directly by proto

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3972?focusedWorklogId=96918=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96918 ] ASF GitHub Bot logged work on BEAM-3972: Author: ASF GitHub Bot

Build failed in Jenkins: beam_PostCommit_Java_GradleBuild #243

2018-04-30 Thread Apache Jenkins Server
See Changes: [thw] [BEAM-4131] Include SDK into Python SDK harness container. [thw] cleanup -- [...truncated 18.81 MB...] INFO:

Build failed in Jenkins: beam_PostCommit_Java_GradleBuild #242

2018-04-30 Thread Apache Jenkins Server
See -- [...truncated 19.54 MB...] May 01, 2018 12:49:42 AM org.apache.beam.runners.dataflow.util.MonitoringUtil$LoggingHandler process INFO:

[jira] [Work logged] (BEAM-3972) Flink runner translates batch pipelines directly by proto

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3972?focusedWorklogId=96896=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96896 ] ASF GitHub Bot logged work on BEAM-3972: Author: ASF GitHub Bot

[jira] [Created] (BEAM-4217) Java SDK stages artifacts when talking to job server

2018-04-30 Thread Eugene Kirpichov (JIRA)
Eugene Kirpichov created BEAM-4217: -- Summary: Java SDK stages artifacts when talking to job server Key: BEAM-4217 URL: https://issues.apache.org/jira/browse/BEAM-4217 Project: Beam Issue

[jira] [Created] (BEAM-4216) Flink: Staged artifacts are delivered to the SDK container

2018-04-30 Thread Eugene Kirpichov (JIRA)
Eugene Kirpichov created BEAM-4216: -- Summary: Flink: Staged artifacts are delivered to the SDK container Key: BEAM-4216 URL: https://issues.apache.org/jira/browse/BEAM-4216 Project: Beam

[jira] [Created] (BEAM-4215) Update Python SDK dependencies for 2.5.0 release

2018-04-30 Thread Valentyn Tymofieiev (JIRA)
Valentyn Tymofieiev created BEAM-4215: - Summary: Update Python SDK dependencies for 2.5.0 release Key: BEAM-4215 URL: https://issues.apache.org/jira/browse/BEAM-4215 Project: Beam Issue

[jira] [Closed] (BEAM-4204) Python: PortableRunner - p.run() via given JobService

2018-04-30 Thread Eugene Kirpichov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov closed BEAM-4204. -- Resolution: Duplicate Fix Version/s: Not applicable This appears to be a dupe of

Build failed in Jenkins: beam_PostCommit_Java_GradleBuild #241

2018-04-30 Thread Apache Jenkins Server
See Changes: [Pablo] Creation of utils.py whit CountingSource class on it. [Pablo] Changed import from examples.snippets to io.utils -- [...truncated

Build failed in Jenkins: beam_PerformanceTests_XmlIOIT_HDFS #113

2018-04-30 Thread Apache Jenkins Server
See Changes: [herohde] [BEAM-4175] Fix direct ouput pardo issue [kenn] Add errorprone to basic Gradle config [kenn] Fix suppressed failure in ResourceIdTester [kenn] Fix erroneous tests in

Build failed in Jenkins: beam_PerformanceTests_MongoDBIO_IT #115

2018-04-30 Thread Apache Jenkins Server
See Changes: [herohde] [BEAM-4175] Fix direct ouput pardo issue [kenn] Add errorprone to basic Gradle config [kenn] Fix suppressed failure in ResourceIdTester [kenn] Fix erroneous tests in

Jenkins build is back to normal : beam_PerformanceTests_TextIOIT_HDFS #120

2018-04-30 Thread Apache Jenkins Server
See

Build failed in Jenkins: beam_PostCommit_Python_ValidatesRunner_Dataflow #1490

2018-04-30 Thread Apache Jenkins Server
See Changes: [thw] [BEAM-4131] Include SDK into Python SDK harness container. [thw] cleanup -- Started by GitHub push by lukecwik

Jenkins build is back to normal : beam_PerformanceTests_Compressed_TextIOIT_HDFS #114

2018-04-30 Thread Apache Jenkins Server
See

Build failed in Jenkins: beam_PerformanceTests_Python #1213

2018-04-30 Thread Apache Jenkins Server
See Changes: [herohde] [BEAM-4175] Fix direct ouput pardo issue [kenn] Add errorprone to basic Gradle config [kenn] Fix suppressed failure in ResourceIdTester [kenn] Fix erroneous tests in

Build failed in Jenkins: beam_PerformanceTests_HadoopInputFormat #206

2018-04-30 Thread Apache Jenkins Server
See Changes: [herohde] [BEAM-4175] Fix direct ouput pardo issue [kenn] Add errorprone to basic Gradle config [kenn] Fix suppressed failure in ResourceIdTester [kenn] Fix erroneous tests

[jira] [Updated] (BEAM-4213) Python: Portable batch Flink runner passes all ValidatesRunner tests

2018-04-30 Thread Eugene Kirpichov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov updated BEAM-4213: --- Description: Like BEAM-4176, but 1) for Python; 2) there is no baseline; 3) the set of

[beam] 01/01: [BEAM-4131] Include SDK into Python SDK harness container.

2018-04-30 Thread lcwik
This is an automated email from the ASF dual-hosted git repository. lcwik pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 96fb76560de44abcdcb915da543df7d45f6f6b3b Merge: 9d75d06 02ba305 Author: Lukasz Cwik AuthorDate: Mon Apr

[jira] [Work logged] (BEAM-4131) Python SDK harness container image contains SDK and dependencies

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4131?focusedWorklogId=96894=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96894 ] ASF GitHub Bot logged work on BEAM-4131: Author: ASF GitHub Bot

[beam] branch master updated (9d75d06 -> 96fb765)

2018-04-30 Thread lcwik
This is an automated email from the ASF dual-hosted git repository. lcwik pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 9d75d06 Changed import from examples.snippets to io.utils add 41e02a1 [BEAM-4131] Include SDK into Python SDK

[jira] [Created] (BEAM-4214) Python ValidatesRunner test coverage is very poor

2018-04-30 Thread Eugene Kirpichov (JIRA)
Eugene Kirpichov created BEAM-4214: -- Summary: Python ValidatesRunner test coverage is very poor Key: BEAM-4214 URL: https://issues.apache.org/jira/browse/BEAM-4214 Project: Beam Issue Type:

[jira] [Created] (BEAM-4213) Python: Portable batch Flink runner passes all ValidatesRunner tests

2018-04-30 Thread Eugene Kirpichov (JIRA)
Eugene Kirpichov created BEAM-4213: -- Summary: Python: Portable batch Flink runner passes all ValidatesRunner tests Key: BEAM-4213 URL: https://issues.apache.org/jira/browse/BEAM-4213 Project: Beam

[jira] [Updated] (BEAM-4176) Java: Portable batch runner passes all ValidatesRunner tests that non-portable runner passes

2018-04-30 Thread Eugene Kirpichov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov updated BEAM-4176: --- Summary: Java: Portable batch runner passes all ValidatesRunner tests that non-portable runner

[jira] [Created] (BEAM-4212) Flink portable ValidatesRunner tests continuously run on Jenkins

2018-04-30 Thread Eugene Kirpichov (JIRA)
Eugene Kirpichov created BEAM-4212: -- Summary: Flink portable ValidatesRunner tests continuously run on Jenkins Key: BEAM-4212 URL: https://issues.apache.org/jira/browse/BEAM-4212 Project: Beam

[jira] [Created] (BEAM-4211) Python: FlinkPortableTestRunner: runs portably via self-started local Flink

2018-04-30 Thread Eugene Kirpichov (JIRA)
Eugene Kirpichov created BEAM-4211: -- Summary: Python: FlinkPortableTestRunner: runs portably via self-started local Flink Key: BEAM-4211 URL: https://issues.apache.org/jira/browse/BEAM-4211 Project:

[jira] [Commented] (BEAM-4067) Add portable Flink test runner

2018-04-30 Thread Eugene Kirpichov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459299#comment-16459299 ] Eugene Kirpichov commented on BEAM-4067: Clarification: this should probably go through

[jira] [Updated] (BEAM-4067) Java: FlinkPortableTestRunner: runs portably via self-started local Flink

2018-04-30 Thread Eugene Kirpichov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov updated BEAM-4067: --- Summary: Java: FlinkPortableTestRunner: runs portably via self-started local Flink (was: Add

[jira] [Created] (BEAM-4210) Python: PortableRunner: p.run() starts a given JobService docker container and runs through it

2018-04-30 Thread Eugene Kirpichov (JIRA)
Eugene Kirpichov created BEAM-4210: -- Summary: Python: PortableRunner: p.run() starts a given JobService docker container and runs through it Key: BEAM-4210 URL: https://issues.apache.org/jira/browse/BEAM-4210

[jira] [Created] (BEAM-4209) Java: PortableRunner: p.run() starts a given JobService docker container and runs through it

2018-04-30 Thread Eugene Kirpichov (JIRA)
Eugene Kirpichov created BEAM-4209: -- Summary: Java: PortableRunner: p.run() starts a given JobService docker container and runs through it Key: BEAM-4209 URL: https://issues.apache.org/jira/browse/BEAM-4209

[jira] [Updated] (BEAM-4130) Portable Flink runner JobService entry point in a Docker container

2018-04-30 Thread Eugene Kirpichov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov updated BEAM-4130: --- Summary: Portable Flink runner JobService entry point in a Docker container (was: Portable

[jira] [Commented] (BEAM-4130) Portable Flink runner entry point

2018-04-30 Thread Eugene Kirpichov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459285#comment-16459285 ] Eugene Kirpichov commented on BEAM-4130: Further clarification: the entry point, like JobService

[jira] [Created] (BEAM-4208) Python: Script for running a set of ValidatesRunner tests against given JobService

2018-04-30 Thread Eugene Kirpichov (JIRA)
Eugene Kirpichov created BEAM-4208: -- Summary: Python: Script for running a set of ValidatesRunner tests against given JobService Key: BEAM-4208 URL: https://issues.apache.org/jira/browse/BEAM-4208

[jira] [Created] (BEAM-4207) Java: script for running set of ValidatesRunner tests against given JobService

2018-04-30 Thread Eugene Kirpichov (JIRA)
Eugene Kirpichov created BEAM-4207: -- Summary: Java: script for running set of ValidatesRunner tests against given JobService Key: BEAM-4207 URL: https://issues.apache.org/jira/browse/BEAM-4207

[jira] [Created] (BEAM-4206) Python: WordCount runs against manually started Flink at master

2018-04-30 Thread Eugene Kirpichov (JIRA)
Eugene Kirpichov created BEAM-4206: -- Summary: Python: WordCount runs against manually started Flink at master Key: BEAM-4206 URL: https://issues.apache.org/jira/browse/BEAM-4206 Project: Beam

[jira] [Created] (BEAM-4205) Java: WordCount runs against manually started Flink at master

2018-04-30 Thread Eugene Kirpichov (JIRA)
Eugene Kirpichov created BEAM-4205: -- Summary: Java: WordCount runs against manually started Flink at master Key: BEAM-4205 URL: https://issues.apache.org/jira/browse/BEAM-4205 Project: Beam

[jira] [Commented] (BEAM-4149) Java SDK Harness should populate worker id in control plane headers

2018-04-30 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459279#comment-16459279 ] Ankur Goenka commented on BEAM-4149: In reference to 

[jira] [Created] (BEAM-4204) Python: PortableRunner - p.run() via given JobService

2018-04-30 Thread Eugene Kirpichov (JIRA)
Eugene Kirpichov created BEAM-4204: -- Summary: Python: PortableRunner - p.run() via given JobService Key: BEAM-4204 URL: https://issues.apache.org/jira/browse/BEAM-4204 Project: Beam Issue

Build failed in Jenkins: beam_PostCommit_Java_GradleBuild #240

2018-04-30 Thread Apache Jenkins Server
See Changes: [herohde] [BEAM-4175] Fix direct ouput pardo issue -- [...truncated 19.14 MB...] Apr 30, 2018 11:35:05 PM

[jira] [Work logged] (BEAM-3972) Flink runner translates batch pipelines directly by proto

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3972?focusedWorklogId=96887=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96887 ] ASF GitHub Bot logged work on BEAM-3972: Author: ASF GitHub Bot

[jira] [Updated] (BEAM-4071) Java: PortableRunner - p.run() via given JobService

2018-04-30 Thread Eugene Kirpichov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov updated BEAM-4071: --- Summary: Java: PortableRunner - p.run() via given JobService (was: Portable Runner Job API

[jira] [Work logged] (BEAM-3972) Flink runner translates batch pipelines directly by proto

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3972?focusedWorklogId=96886=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96886 ] ASF GitHub Bot logged work on BEAM-3972: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3773) [SQL] Investigate JDBC interface for Beam SQL

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3773?focusedWorklogId=96883=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96883 ] ASF GitHub Bot logged work on BEAM-3773: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-3773) [SQL] Investigate JDBC interface for Beam SQL

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3773?focusedWorklogId=96882=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96882 ] ASF GitHub Bot logged work on BEAM-3773: Author: ASF GitHub Bot

[jira] [Assigned] (BEAM-4203) Handle collect operation in BeamEnumerableConverter for all runners

2018-04-30 Thread Andrew Pilloud (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Pilloud reassigned BEAM-4203: Assignee: (was: Andrew Pilloud) > Handle collect operation in BeamEnumerableConverter

[jira] [Created] (BEAM-4203) Handle collect operation in BeamEnumerableConverter for all runners

2018-04-30 Thread Andrew Pilloud (JIRA)
Andrew Pilloud created BEAM-4203: Summary: Handle collect operation in BeamEnumerableConverter for all runners Key: BEAM-4203 URL: https://issues.apache.org/jira/browse/BEAM-4203 Project: Beam

[jira] [Work logged] (BEAM-3773) [SQL] Investigate JDBC interface for Beam SQL

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3773?focusedWorklogId=96879=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96879 ] ASF GitHub Bot logged work on BEAM-3773: Author: ASF GitHub Bot

[jira] [Assigned] (BEAM-4202) Make JDBC operation counts correct

2018-04-30 Thread Andrew Pilloud (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Pilloud reassigned BEAM-4202: Assignee: (was: Andrew Pilloud) > Make JDBC operation counts correct >

[jira] [Created] (BEAM-4202) Make JDBC operation counts correct

2018-04-30 Thread Andrew Pilloud (JIRA)
Andrew Pilloud created BEAM-4202: Summary: Make JDBC operation counts correct Key: BEAM-4202 URL: https://issues.apache.org/jira/browse/BEAM-4202 Project: Beam Issue Type: New Feature

[jira] [Work logged] (BEAM-2163) Remove the dependency on examples from ptransform_test

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2163?focusedWorklogId=96878=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96878 ] ASF GitHub Bot logged work on BEAM-2163: Author: ASF GitHub Bot

Build failed in Jenkins: beam_PostCommit_Python_ValidatesRunner_Dataflow #1489

2018-04-30 Thread Apache Jenkins Server
See Changes: [Pablo] Creation of utils.py whit CountingSource class on it. [Pablo] Changed import from examples.snippets to io.utils --

[beam] 01/02: Creation of utils.py whit CountingSource class on it.

2018-04-30 Thread pabloem
This is an automated email from the ASF dual-hosted git repository. pabloem pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit dabffc280db2a4c461df3ae5b3e75242b7b682d6 Author: Javier Antonio Gonzalez Trejo

[beam] branch master updated (8faad95 -> 9d75d06)

2018-04-30 Thread pabloem
This is an automated email from the ASF dual-hosted git repository. pabloem pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 8faad95 Merge pull request #5243: [BEAM-4175] Fix Go ParDo direct output pardo issue new dabffc2 Creation of

[beam] 02/02: Changed import from examples.snippets to io.utils

2018-04-30 Thread pabloem
This is an automated email from the ASF dual-hosted git repository. pabloem pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 9d75d06643f0d443ede4d172cca2c5d8b3c5ef65 Author: Javier Antonio Gonzalez Trejo

[jira] [Assigned] (BEAM-3870) Jars contain duplicate class definitions

2018-04-30 Thread Henning Rohde (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde reassigned BEAM-3870: --- Assignee: Kenneth Knowles (was: Henning Rohde) > Jars contain duplicate class definitions >

[jira] [Resolved] (BEAM-4175) exec.Invoke: panic: index out of range

2018-04-30 Thread Henning Rohde (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde resolved BEAM-4175. - Resolution: Fixed Fix Version/s: 2.5.0 > exec.Invoke: panic: index out of range >

[jira] [Work logged] (BEAM-4162) Wire up PubsubIO+JSON to Beam SQL

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4162?focusedWorklogId=96877=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96877 ] ASF GitHub Bot logged work on BEAM-4162: Author: ASF GitHub Bot

[jira] [Resolved] (BEAM-3978) Direct output doesn't work after GBK

2018-04-30 Thread Henning Rohde (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde resolved BEAM-3978. - Resolution: Duplicate Fix Version/s: 2.5.0 > Direct output doesn't work after GBK >

[jira] [Work logged] (BEAM-4162) Wire up PubsubIO+JSON to Beam SQL

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4162?focusedWorklogId=96873=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96873 ] ASF GitHub Bot logged work on BEAM-4162: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-4162) Wire up PubsubIO+JSON to Beam SQL

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4162?focusedWorklogId=96872=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96872 ] ASF GitHub Bot logged work on BEAM-4162: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-4063) Flink runner supports cluster-wide artifact deployments through the Distributed Cache

2018-04-30 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459219#comment-16459219 ] Thomas Weise commented on BEAM-4063: Flink 1.5 is already frozen, so the above PR isn't going to make

[jira] [Work logged] (BEAM-4162) Wire up PubsubIO+JSON to Beam SQL

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4162?focusedWorklogId=96871=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96871 ] ASF GitHub Bot logged work on BEAM-4162: Author: ASF GitHub Bot

Build failed in Jenkins: beam_PostCommit_Python_ValidatesRunner_Dataflow #1488

2018-04-30 Thread Apache Jenkins Server
See Changes: [herohde] [BEAM-4175] Fix direct ouput pardo issue -- Started by GitHub push by jasonkuster [EnvInject] - Loading node

[jira] [Work logged] (BEAM-4175) exec.Invoke: panic: index out of range

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4175?focusedWorklogId=96870=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96870 ] ASF GitHub Bot logged work on BEAM-4175: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-4175) exec.Invoke: panic: index out of range

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4175?focusedWorklogId=96869=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96869 ] ASF GitHub Bot logged work on BEAM-4175: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-4131) Python SDK harness container image contains SDK and dependencies

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4131?focusedWorklogId=96868=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96868 ] ASF GitHub Bot logged work on BEAM-4131: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-4131) Python SDK harness container image contains SDK and dependencies

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4131?focusedWorklogId=96867=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96867 ] ASF GitHub Bot logged work on BEAM-4131: Author: ASF GitHub Bot

Build failed in Jenkins: beam_PostCommit_Java_GradleBuild #239

2018-04-30 Thread Apache Jenkins Server
See Changes: [kenn] Add errorprone to basic Gradle config [kenn] Fix suppressed failure in ResourceIdTester [kenn] Fix erroneous tests in ViewTest [kenn] Add missing @Test in

[jira] [Created] (BEAM-4201) Integration Tests for PubsubIO

2018-04-30 Thread Anton Kedin (JIRA)
Anton Kedin created BEAM-4201: - Summary: Integration Tests for PubsubIO Key: BEAM-4201 URL: https://issues.apache.org/jira/browse/BEAM-4201 Project: Beam Issue Type: Improvement

[jira] [Assigned] (BEAM-4062) Performance regression in FileBasedSink

2018-04-30 Thread Pablo Estrada (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada reassigned BEAM-4062: --- Assignee: Udi Meiri (was: Ahmet Altay) > Performance regression in FileBasedSink >

[jira] [Assigned] (BEAM-4062) Performance regression in FileBasedSink

2018-04-30 Thread Pablo Estrada (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada reassigned BEAM-4062: --- Assignee: Ahmet Altay (was: Udi Meiri) > Performance regression in FileBasedSink >

[jira] [Created] (BEAM-4200) [SQL] Support Pubsub publish time as event timestamp

2018-04-30 Thread Anton Kedin (JIRA)
Anton Kedin created BEAM-4200: - Summary: [SQL] Support Pubsub publish time as event timestamp Key: BEAM-4200 URL: https://issues.apache.org/jira/browse/BEAM-4200 Project: Beam Issue Type:

[jira] [Work logged] (BEAM-4162) Wire up PubsubIO+JSON to Beam SQL

2018-04-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4162?focusedWorklogId=96860=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-96860 ] ASF GitHub Bot logged work on BEAM-4162: Author: ASF GitHub Bot

Build failed in Jenkins: beam_PostCommit_Java_GradleBuild #238

2018-04-30 Thread Apache Jenkins Server
See Changes: [iemejia] Fix gradle script to build the docker image of 'sdks/java/container' -- [...truncated 18.60 MB...]

[jira] [Resolved] (BEAM-3697) Add errorprone to gradle builds

2018-04-30 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-3697. --- Resolution: Fixed Fix Version/s: Not applicable > Add errorprone to gradle builds >

[jira] [Created] (BEAM-4199) [SQL] Add a DLQ support for Pubsub tables

2018-04-30 Thread Anton Kedin (JIRA)
Anton Kedin created BEAM-4199: - Summary: [SQL] Add a DLQ support for Pubsub tables Key: BEAM-4199 URL: https://issues.apache.org/jira/browse/BEAM-4199 Project: Beam Issue Type: Improvement

[jira] [Updated] (BEAM-4198) Automatically infer JSON schema from Pubsub messages

2018-04-30 Thread Anton Kedin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kedin updated BEAM-4198: -- Summary: Automatically infer JSON schema from Pubsub messages (was: Dynamically infer JSON schema from

[jira] [Created] (BEAM-4198) Dynamically infer JSON schema from Pubsub messages

2018-04-30 Thread Anton Kedin (JIRA)
Anton Kedin created BEAM-4198: - Summary: Dynamically infer JSON schema from Pubsub messages Key: BEAM-4198 URL: https://issues.apache.org/jira/browse/BEAM-4198 Project: Beam Issue Type:

Build failed in Jenkins: beam_PostCommit_Java_GradleBuild #237

2018-04-30 Thread Apache Jenkins Server
See Changes: [apilloud] [BEAM-3983][SQL] Add BigQuery table provider -- [...truncated 18.49 MB...] Apr 30, 2018 9:11:45 PM

[jira] [Created] (BEAM-4197) Add tests for PubsubIO.readXxx() -> Row

2018-04-30 Thread Anton Kedin (JIRA)
Anton Kedin created BEAM-4197: - Summary: Add tests for PubsubIO.readXxx() -> Row Key: BEAM-4197 URL: https://issues.apache.org/jira/browse/BEAM-4197 Project: Beam Issue Type: Improvement

Build failed in Jenkins: beam_PostCommit_Python_ValidatesRunner_Dataflow #1487

2018-04-30 Thread Apache Jenkins Server
See Changes: [kenn] Add errorprone to basic Gradle config [kenn] Fix suppressed failure in ResourceIdTester [kenn] Fix erroneous tests in ViewTest [kenn] Add missing @Test in

[jira] [Resolved] (BEAM-3914) 'Unzip' flattens before performing fusion

2018-04-30 Thread Ben Sidhom (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Sidhom resolved BEAM-3914. -- Resolution: Fixed Fix Version/s: Not applicable > 'Unzip' flattens before performing fusion >

  1   2   3   >