[jira] [Commented] (BEAM-320) Provide Beam keyturn binary distributions embedding runners and execution runtime

[ https://issues.apache.org/jira/browse/BEAM-320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15313868#comment-15313868 ] Jean-Baptiste Onofré commented on BEAM-320: --- Good point about the multiple SDKs, and fully agree

[jira] [Created] (BEAM-307) Upgrade/Test to Kafka 0.10

Jean-Baptiste Onofré created BEAM-307: - Summary: Upgrade/Test to Kafka 0.10 Key: BEAM-307 URL: https://issues.apache.org/jira/browse/BEAM-307 Project: Beam Issue Type: Task

[jira] [Created] (BEAM-337) Cleanup NOTICE file

Jean-Baptiste Onofré created BEAM-337: - Summary: Cleanup NOTICE file Key: BEAM-337 URL: https://issues.apache.org/jira/browse/BEAM-337 Project: Beam Issue Type: Improvement

[jira] [Created] (BEAM-338) Fix licensing and usage of gutenberg files in Spark test

Jean-Baptiste Onofré created BEAM-338: - Summary: Fix licensing and usage of gutenberg files in Spark test Key: BEAM-338 URL: https://issues.apache.org/jira/browse/BEAM-338 Project: Beam

[jira] [Commented] (BEAM-287) Add new beam groupIds

[ https://issues.apache.org/jira/browse/BEAM-287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310598#comment-15310598 ] Jean-Baptiste Onofré commented on BEAM-287: --- Davor asked me to change this for two reasons

[jira] [Created] (BEAM-320) Provide Beam keyturn binary distributions embedding runners and execution runtime

Jean-Baptiste Onofré created BEAM-320: - Summary: Provide Beam keyturn binary distributions embedding runners and execution runtime Key: BEAM-320 URL: https://issues.apache.org/jira/browse/BEAM-320

[jira] [Created] (BEAM-319) Attach src distribution artifact to be take by deploy

Jean-Baptiste Onofré created BEAM-319: - Summary: Attach src distribution artifact to be take by deploy Key: BEAM-319 URL: https://issues.apache.org/jira/browse/BEAM-319 Project: Beam

[jira] [Commented] (BEAM-313) Enable the use of an existing spark context with the SparkPipelineRunner

[ https://issues.apache.org/jira/browse/BEAM-313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15307605#comment-15307605 ] Jean-Baptiste Onofré commented on BEAM-313: --- Right now, each runner provides its own context

[jira] [Assigned] (BEAM-313) Enable the use of an existing spark context with the SparkPipelineRunner

[ https://issues.apache.org/jira/browse/BEAM-313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-313: - Assignee: Jean-Baptiste Onofré > Enable the use of an existing spark cont

[jira] [Commented] (BEAM-313) Enable the use of an existing spark context with the SparkPipelineRunner

[ https://issues.apache.org/jira/browse/BEAM-313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15307533#comment-15307533 ] Ismaël Mejía commented on BEAM-313: --- [~amitsela] What do you think about this ? The use case is not pure

[jira] [Created] (BEAM-316) Support file scheme in TextIO

Jean-Baptiste Onofré created BEAM-316: - Summary: Support file scheme in TextIO Key: BEAM-316 URL: https://issues.apache.org/jira/browse/BEAM-316 Project: Beam Issue Type: Improvement

[jira] [Updated] (BEAM-357) Build doesn't pass on windows

[ https://issues.apache.org/jira/browse/BEAM-357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-357: -- Component/s: beam-model > Build doesn't pass on wind

[jira] [Assigned] (BEAM-357) Build doesn't pass on windows

[ https://issues.apache.org/jira/browse/BEAM-357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-357: - Assignee: Jean-Baptiste Onofré > Build doesn't pass on wind

[jira] [Updated] (BEAM-314) Support zip compression in TextIO

[ https://issues.apache.org/jira/browse/BEAM-314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-314: -- Fix Version/s: 0.2.0-incubating > Support zip compression in Tex

[jira] [Reopened] (BEAM-314) Support zip compression in TextIO

[ https://issues.apache.org/jira/browse/BEAM-314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reopened BEAM-314: --- Just setting the fix version field to have an updated RELEASE-NOTES for the next release

[jira] [Created] (BEAM-349) Spark runner should provide a default BoM

Jean-Baptiste Onofré created BEAM-349: - Summary: Spark runner should provide a default BoM Key: BEAM-349 URL: https://issues.apache.org/jira/browse/BEAM-349 Project: Beam Issue Type

[jira] [Commented] (BEAM-302) Add Scio Scala DSL to Beam

[ https://issues.apache.org/jira/browse/BEAM-302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15347672#comment-15347672 ] Jean-Baptiste Onofré commented on BEAM-302: --- Awesome ! Thanks. As discussed by e-mail, I started

[jira] [Commented] (BEAM-1) Import code on git

[ https://issues.apache.org/jira/browse/BEAM-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15138432#comment-15138432 ] Jean-Baptiste Onofré commented on BEAM-1: - I pushed a first simple README.md file on git to trigger

[jira] [Commented] (BEAM-52) KafkaIO - bounded/unbounded, source/sink

[ https://issues.apache.org/jira/browse/BEAM-52?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172735#comment-15172735 ] Jean-Baptiste Onofré commented on BEAM-52: -- It should also have options for partition sourcing

[jira] [Assigned] (BEAM-6) Import Spark Runner code

[ https://issues.apache.org/jira/browse/BEAM-6?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-6: --- Assignee: Jean-Baptiste Onofré > Import Spark Runner c

[jira] [Created] (BEAM-14) Add data integration DSL

Jean-Baptiste Onofré created BEAM-14: Summary: Add data integration DSL Key: BEAM-14 URL: https://issues.apache.org/jira/browse/BEAM-14 Project: Beam Issue Type: New Feature

[jira] [Commented] (BEAM-13) Create JMS IO

[ https://issues.apache.org/jira/browse/BEAM-13?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15147586#comment-15147586 ] Jean-Baptiste Onofré commented on BEAM-13: -- Added Write and generic connection factory support

[jira] [Comment Edited] (BEAM-13) Create JMS IO

[ https://issues.apache.org/jira/browse/BEAM-13?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15147586#comment-15147586 ] Jean-Baptiste Onofré edited comment on BEAM-13 at 2/15/16 5:19 PM: --- Added

[jira] [Commented] (BEAM-4) Fix link on website

[ https://issues.apache.org/jira/browse/BEAM-4?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15149210#comment-15149210 ] Jean-Baptiste Onofré commented on BEAM-4: - I'm on it. I keep you posted James. > Fix link on webs

[jira] [Commented] (BEAM-13) Create JMS IO

[ https://issues.apache.org/jira/browse/BEAM-13?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15146758#comment-15146758 ] Jean-Baptiste Onofré commented on BEAM-13: -- Sorry for the component mistake [~frances] and thanks

[jira] [Updated] (BEAM-13) Create JMS IO

[ https://issues.apache.org/jira/browse/BEAM-13?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-13: - Issue Type: New Feature (was: Bug) > Create JMS IO > - > >

[jira] [Created] (BEAM-13) Create JMS IO

Jean-Baptiste Onofré created BEAM-13: Summary: Create JMS IO Key: BEAM-13 URL: https://issues.apache.org/jira/browse/BEAM-13 Project: Beam Issue Type: Bug Components: io

[jira] [Comment Edited] (BEAM-114) Assemble and provide a source distribution

[ https://issues.apache.org/jira/browse/BEAM-114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15194498#comment-15194498 ] Jean-Baptiste Onofré edited comment on BEAM-114 at 3/15/16 1:07 AM: Yes

[jira] [Commented] (BEAM-114) Assemble and provide a source distribution

[ https://issues.apache.org/jira/browse/BEAM-114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15194498#comment-15194498 ] Jean-Baptiste Onofré commented on BEAM-114: --- Yes, we should provide a apache-beam-xxx-incubator

[jira] [Created] (BEAM-114) Assemble and provide a source distribution

Jean-Baptiste Onofré created BEAM-114: - Summary: Assemble and provide a source distribution Key: BEAM-114 URL: https://issues.apache.org/jira/browse/BEAM-114 Project: Beam Issue Type

[jira] [Resolved] (BEAM-114) Assemble and provide a source distribution

[ https://issues.apache.org/jira/browse/BEAM-114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-114. --- Resolution: Fixed > Assemble and provide a source distribut

[jira] [Commented] (BEAM-79) Gearpump runner

[ https://issues.apache.org/jira/browse/BEAM-79?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15229717#comment-15229717 ] Jean-Baptiste Onofré commented on BEAM-79: -- It sounds good to me. Thanks Manu ! > Gearpump run

[jira] [Commented] (BEAM-186) The streaming WindowedWordCount example is broken on Dataflow

[ https://issues.apache.org/jira/browse/BEAM-186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15234877#comment-15234877 ] Jean-Baptiste Onofré commented on BEAM-186: --- Is it related to Beam or Google Dataflow SDK

[jira] [Commented] (BEAM-185) XmlSink output file pattern missing "." in extension

[ https://issues.apache.org/jira/browse/BEAM-185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15234950#comment-15234950 ] Jean-Baptiste Onofré commented on BEAM-185: --- I guess it doesn't occur with you use XmlSink.writeOf

[jira] [Commented] (BEAM-185) XmlSink output file pattern missing "." in extension

[ https://issues.apache.org/jira/browse/BEAM-185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235392#comment-15235392 ] Jean-Baptiste Onofré commented on BEAM-185: --- It's weird, because the {{XmlSink.Bound}} constructor

[jira] [Commented] (BEAM-14) Add data integration DSL

[ https://issues.apache.org/jira/browse/BEAM-14?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15227859#comment-15227859 ] Jean-Baptiste Onofré commented on BEAM-14: -- Yes, I thought also about a XML DSL on top of the model

[jira] [Updated] (BEAM-14) Add declarative DSLs

[ https://issues.apache.org/jira/browse/BEAM-14?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-14: - Summary: Add declarative DSLs (was: Add data integration DSL) > Add declarative D

[jira] [Commented] (BEAM-154) Provide Maven BOM

[ https://issues.apache.org/jira/browse/BEAM-154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235542#comment-15235542 ] Jean-Baptiste Onofré commented on BEAM-154: --- Related to that, most of the Beam modules pom.xml

[jira] [Commented] (BEAM-116) Change runners artifactId to runners-parent

[ https://issues.apache.org/jira/browse/BEAM-116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201804#comment-15201804 ] Jean-Baptiste Onofré commented on BEAM-116: --- FYI, the PR that I did about the "renaming&quo

[jira] [Created] (BEAM-137) Add implicit conf/pipeline-default.conf options file

Jean-Baptiste Onofré created BEAM-137: - Summary: Add implicit conf/pipeline-default.conf options file Key: BEAM-137 URL: https://issues.apache.org/jira/browse/BEAM-137 Project: Beam

[jira] [Created] (BEAM-138) Extend TextIO to new protocols (and maybe rename to FileIO)

Jean-Baptiste Onofré created BEAM-138: - Summary: Extend TextIO to new protocols (and maybe rename to FileIO) Key: BEAM-138 URL: https://issues.apache.org/jira/browse/BEAM-138 Project: Beam

[jira] [Commented] (BEAM-131) Write to jdbc/database

[ https://issues.apache.org/jira/browse/BEAM-131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15203962#comment-15203962 ] Jean-Baptiste Onofré commented on BEAM-131: --- I think (and it's planned) it makes sense to have

[jira] [Commented] (BEAM-137) Add implicit conf/pipeline-default.conf options file

[ https://issues.apache.org/jira/browse/BEAM-137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204664#comment-15204664 ] Jean-Baptiste Onofré commented on BEAM-137: --- Providing .fromFile(String path) in addition

[jira] [Resolved] (BEAM-138) Extend TextIO to new protocols (and maybe rename to FileIO)

[ https://issues.apache.org/jira/browse/BEAM-138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-138. --- Resolution: Duplicate > Extend TextIO to new protocols (and maybe rename to Fil

[jira] [Commented] (BEAM-138) Extend TextIO to new protocols (and maybe rename to FileIO)

[ https://issues.apache.org/jira/browse/BEAM-138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204614#comment-15204614 ] Jean-Baptiste Onofré commented on BEAM-138: --- Oh ok, it wasn't obvious to me that BEAM-59 deal

[jira] [Commented] (BEAM-131) Write to jdbc/database

[ https://issues.apache.org/jira/browse/BEAM-131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15204659#comment-15204659 ] Jean-Baptiste Onofré commented on BEAM-131: --- Fully agree, it's what I expressed in my previous

[jira] [Assigned] (BEAM-77) Reorganize Directory structure

[ https://issues.apache.org/jira/browse/BEAM-77?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-77: Assignee: Jean-Baptiste Onofré (was: Frances Perry) > Reorganize Directory struct

[jira] [Commented] (BEAM-132) Release process for Beam artifacts to Maven

[ https://issues.apache.org/jira/browse/BEAM-132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15203483#comment-15203483 ] Jean-Baptiste Onofré commented on BEAM-132: --- This will come with the renaming as we will use

[jira] [Assigned] (BEAM-132) Release process for Beam artifacts to Maven

[ https://issues.apache.org/jira/browse/BEAM-132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-132: - Assignee: Jean-Baptiste Onofré (was: Davor Bonaci) > Release process for B

[jira] [Resolved] (BEAM-20) Create build jobs on Jenkins

[ https://issues.apache.org/jira/browse/BEAM-20?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-20. -- Resolution: Fixed > Create build jobs on Jenk

[jira] [Resolved] (BEAM-132) Release process for Beam artifacts to Maven

[ https://issues.apache.org/jira/browse/BEAM-132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-132. --- Resolution: Fixed Now that the pom.xml files have been updated, we use the Apache

[jira] [Commented] (BEAM-132) Release process for Beam artifacts to Maven

[ https://issues.apache.org/jira/browse/BEAM-132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15225966#comment-15225966 ] Jean-Baptiste Onofré commented on BEAM-132: --- Catcha. I sent an e-mail on the mailing list about

[jira] [Commented] (BEAM-20) Create build jobs on Jenkins

[ https://issues.apache.org/jira/browse/BEAM-20?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15225725#comment-15225725 ] Jean-Baptiste Onofré commented on BEAM-20: -- The Jenkins jobs have been created. I proposed

[jira] [Created] (BEAM-165) Add a MapReduce runner

Jean-Baptiste Onofré created BEAM-165: - Summary: Add a MapReduce runner Key: BEAM-165 URL: https://issues.apache.org/jira/browse/BEAM-165 Project: Beam Issue Type: Wish

[jira] [Updated] (BEAM-167) TextIO can't read concatenated gzip files

[ https://issues.apache.org/jira/browse/BEAM-167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-167: -- Component/s: (was: sdk-java-core) sdk-java-extensions > TextIO ca

[jira] [Assigned] (BEAM-226) Upload JARs to Maven Central

[ https://issues.apache.org/jira/browse/BEAM-226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-226: - Assignee: Jean-Baptiste Onofré > Upload JARs to Maven Cent

[jira] [Resolved] (BEAM-226) Upload JARs to Maven Central

[ https://issues.apache.org/jira/browse/BEAM-226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-226. --- Resolution: Not A Problem It's already done: we have nightly builds containing all

[jira] [Commented] (BEAM-238) Add link URLs for sources / sinks

[ https://issues.apache.org/jira/browse/BEAM-238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263645#comment-15263645 ] Jean-Baptiste Onofré commented on BEAM-238: --- I plan to propose a PR with a complete overview

[jira] [Updated] (BEAM-238) Add link URLs for sources / sinks

[ https://issues.apache.org/jira/browse/BEAM-238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-238: -- Component/s: website > Add link URLs for sources / si

[jira] [Assigned] (BEAM-238) Add link URLs for sources / sinks

[ https://issues.apache.org/jira/browse/BEAM-238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-238: - Assignee: Jean-Baptiste Onofré > Add link URLs for sources / si

[jira] [Commented] (BEAM-52) KafkaIO - bounded/unbounded, source/sink

[ https://issues.apache.org/jira/browse/BEAM-52?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15264022#comment-15264022 ] Jean-Baptiste Onofré commented on BEAM-52: -- [~aljoscha] I planned to work on it, but not yet started

[jira] [Commented] (BEAM-238) Add link URLs for sources / sinks

[ https://issues.apache.org/jira/browse/BEAM-238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15264319#comment-15264319 ] Jean-Baptiste Onofré commented on BEAM-238: --- Oh ok, sorry [~swegner] I misunderstood the purpose

[jira] [Commented] (BEAM-228) Create a merge bot for Beam

[ https://issues.apache.org/jira/browse/BEAM-228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15257611#comment-15257611 ] Jean-Baptiste Onofré commented on BEAM-228: --- We are waiting for legal statement about

[jira] [Commented] (BEAM-286) Reorganize flink runner directories

[ https://issues.apache.org/jira/browse/BEAM-286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296511#comment-15296511 ] Jean-Baptiste Onofré commented on BEAM-286: --- I agree guys: it doesn't have an impact for end users

[jira] [Commented] (BEAM-286) Reorganize flink runner directories

[ https://issues.apache.org/jira/browse/BEAM-286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15294852#comment-15294852 ] Jean-Baptiste Onofré commented on BEAM-286: --- We discussed about that with [~davor]: the purpose

[jira] [Created] (BEAM-300) Upgrade to Flink 1.0.3

Jean-Baptiste Onofré created BEAM-300: - Summary: Upgrade to Flink 1.0.3 Key: BEAM-300 URL: https://issues.apache.org/jira/browse/BEAM-300 Project: Beam Issue Type: Sub-task

[jira] [Commented] (BEAM-297) version typo at README.md of flink runner

[ https://issues.apache.org/jira/browse/BEAM-297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15294850#comment-15294850 ] Jean-Baptiste Onofré commented on BEAM-297: --- Can you rebase and amend the commit to include

[jira] [Commented] (BEAM-79) Gearpump runner

[ https://issues.apache.org/jira/browse/BEAM-79?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296122#comment-15296122 ] Jean-Baptiste Onofré commented on BEAM-79: -- Starting to review and test. Thanks ! > Gearpump run

[jira] [Created] (BEAM-303) Add Machine Learning DSL and dedicated functions

Jean-Baptiste Onofré created BEAM-303: - Summary: Add Machine Learning DSL and dedicated functions Key: BEAM-303 URL: https://issues.apache.org/jira/browse/BEAM-303 Project: Beam Issue

[jira] [Updated] (BEAM-14) Add declarative DSLs (XML & JSON)

[ https://issues.apache.org/jira/browse/BEAM-14?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-14: - Summary: Add declarative DSLs (XML & JSON) (was: Add declarative DSLs) > Add decl

[jira] [Created] (BEAM-302) Add Beam Scala DSL

Jean-Baptiste Onofré created BEAM-302: - Summary: Add Beam Scala DSL Key: BEAM-302 URL: https://issues.apache.org/jira/browse/BEAM-302 Project: Beam Issue Type: Wish Components

[jira] [Created] (BEAM-301) Add a Beam SQL DSL

Jean-Baptiste Onofré created BEAM-301: - Summary: Add a Beam SQL DSL Key: BEAM-301 URL: https://issues.apache.org/jira/browse/BEAM-301 Project: Beam Issue Type: New Feature

[jira] [Commented] (BEAM-304) Build break: maven is picking up Kafka snapshots

[ https://issues.apache.org/jira/browse/BEAM-304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15297705#comment-15297705 ] Jean-Baptiste Onofré commented on BEAM-304: --- Regarding the version range, yes, it's normal. I

[jira] [Commented] (BEAM-242) Enable Checkstyle check for the Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15279839#comment-15279839 ] Jean-Baptiste Onofré commented on BEAM-242: --- Hi Max, yes, I have a PR on the way (I will gently

[jira] [Commented] (BEAM-242) Enable Checkstyle check for the Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15280929#comment-15280929 ] Jean-Baptiste Onofré commented on BEAM-242: --- Related to the Flink runner, there are some javadoc

[jira] [Commented] (BEAM-286) Reorganize flink runner directories

[ https://issues.apache.org/jira/browse/BEAM-286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15286492#comment-15286492 ] Jean-Baptiste Onofré commented on BEAM-286: --- Thanks for the feedback ! Much appreciated. I would

[jira] [Updated] (BEAM-290) Integrate Apache Beam into Apache Zeppelin

[ https://issues.apache.org/jira/browse/BEAM-290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-290: -- Component/s: (was: sdk-ideas) runner-ideas > Integrate Apache B

[jira] [Updated] (BEAM-290) Integrate Apache Beam into Apache Zeppelin

[ https://issues.apache.org/jira/browse/BEAM-290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-290: -- Component/s: (was: runner-spark) sdk-ideas > Integrate Apache B

[jira] [Created] (BEAM-286) Reorganize flink runner directories

Jean-Baptiste Onofré created BEAM-286: - Summary: Reorganize flink runner directories Key: BEAM-286 URL: https://issues.apache.org/jira/browse/BEAM-286 Project: Beam Issue Type: Task

[jira] [Created] (BEAM-287) Add new beam groupId

Jean-Baptiste Onofré created BEAM-287: - Summary: Add new beam groupId Key: BEAM-287 URL: https://issues.apache.org/jira/browse/BEAM-287 Project: Beam Issue Type: Task

[jira] [Created] (BEAM-293) StreamingOptions should not extend GcpOptions

Jean-Baptiste Onofré created BEAM-293: - Summary: StreamingOptions should not extend GcpOptions Key: BEAM-293 URL: https://issues.apache.org/jira/browse/BEAM-293 Project: Beam Issue Type

[jira] [Commented] (BEAM-292) TextIO.Write.to Empty Files

[ https://issues.apache.org/jira/browse/BEAM-292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15288637#comment-15288637 ] Jean-Baptiste Onofré commented on BEAM-292: --- +1 > TextIO.Write.to Empty Fi

[jira] [Created] (BEAM-294) Change properties named dataflow.* to beam.*

Jean-Baptiste Onofré created BEAM-294: - Summary: Change properties named dataflow.* to beam.* Key: BEAM-294 URL: https://issues.apache.org/jira/browse/BEAM-294 Project: Beam Issue Type

[jira] [Updated] (BEAM-286) Reorganize flink runner directories

[ https://issues.apache.org/jira/browse/BEAM-286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-286: -- Fix Version/s: 0.1-incubating > Reorganize flink runner director

[jira] [Updated] (BEAM-287) Add new beam groupIds

[ https://issues.apache.org/jira/browse/BEAM-287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-287: -- Summary: Add new beam groupIds (was: Add new beam groupId) > Add new beam group

[jira] [Updated] (BEAM-287) Add new beam groupIds

[ https://issues.apache.org/jira/browse/BEAM-287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-287: -- Fix Version/s: 0.1.0-incubating > Add new beam group

[jira] [Commented] (BEAM-254) Add maven-rat-plugin execution

[ https://issues.apache.org/jira/browse/BEAM-254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15269510#comment-15269510 ] Jean-Baptiste Onofré commented on BEAM-254: --- Checkstyle applies on Java source, rat can check any

[jira] [Created] (BEAM-254) Add maven-rat-plugin execution

Jean-Baptiste Onofré created BEAM-254: - Summary: Add maven-rat-plugin execution Key: BEAM-254 URL: https://issues.apache.org/jira/browse/BEAM-254 Project: Beam Issue Type: Task

[jira] [Assigned] (BEAM-242) Enable Checkstyle check for the Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-242: - Assignee: Jean-Baptiste Onofré > Enable Checkstyle check for the Flink Run

[jira] [Commented] (BEAM-254) Add maven-rat-plugin execution

[ https://issues.apache.org/jira/browse/BEAM-254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270899#comment-15270899 ] Jean-Baptiste Onofré commented on BEAM-254: --- Good point. Actually, I think it's better to exclude

[jira] [Updated] (BEAM-261) Apache Apex Runner

[ https://issues.apache.org/jira/browse/BEAM-261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-261: -- Issue Type: Wish (was: Improvement) > Apache Apex Run

[jira] [Commented] (BEAM-263) Generate Processing Infrastructure Code and Code for Runners in High Level Languages

[ https://issues.apache.org/jira/browse/BEAM-263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15273751#comment-15273751 ] Jean-Baptiste Onofré commented on BEAM-263: --- You mean kind of runner translating the Beam

[jira] [Created] (BEAM-244) Create JDBC IO

Jean-Baptiste Onofré created BEAM-244: - Summary: Create JDBC IO Key: BEAM-244 URL: https://issues.apache.org/jira/browse/BEAM-244 Project: Beam Issue Type: New Feature

[jira] [Created] (BEAM-243) Remove DirectPipelineRunner and keep only the InProcessPipelineRunner

Jean-Baptiste Onofré created BEAM-243: - Summary: Remove DirectPipelineRunner and keep only the InProcessPipelineRunner Key: BEAM-243 URL: https://issues.apache.org/jira/browse/BEAM-243 Project

[jira] [Assigned] (BEAM-216) Create Storm Runner

[ https://issues.apache.org/jira/browse/BEAM-216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-216: - Assignee: Jean-Baptiste Onofré (was: Sriharsha Chintalapani) > Create St

[jira] [Resolved] (BEAM-216) Create Storm Runner

[ https://issues.apache.org/jira/browse/BEAM-216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-216. --- Resolution: Duplicate > Create Storm Run

[jira] [Commented] (BEAM-216) Create Storm Runner

[ https://issues.apache.org/jira/browse/BEAM-216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15275122#comment-15275122 ] Jean-Baptiste Onofré commented on BEAM-216: --- The Jira are duplicates: just comment and work

[jira] [Resolved] (BEAM-267) Enable Chekstyle check in Spark runner

[ https://issues.apache.org/jira/browse/BEAM-267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-267. --- Resolution: Fixed > Enable Chekstyle check in Spark run

[jira] [Commented] (BEAM-77) Reorganize Directory structure

[ https://issues.apache.org/jira/browse/BEAM-77?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15275489#comment-15275489 ] Jean-Baptiste Onofré commented on BEAM-77: -- I think we can consider this Jira as fixed, right

[jira] [Commented] (BEAM-307) Upgrade/Test to Kafka 0.10

[ https://issues.apache.org/jira/browse/BEAM-307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300250#comment-15300250 ] Jean-Baptiste Onofré commented on BEAM-307: --- Agree, as the KafkaIO uses version range, I would

  1   2   3   4   5   6   7   8   9   10   >