[jira] [Resolved] (BEAM-6536) ParDo should allow any type with a compatible registered schema in the @Element parameter

[ https://issues.apache.org/jira/browse/BEAM-6536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax resolved BEAM-6536. -- Resolution: Fixed Fix Version/s: 2.12.0 > ParDo should allow any type with a compatible registere

[jira] [Resolved] (BEAM-7174) Add transforms for modifying schemas

[ https://issues.apache.org/jira/browse/BEAM-7174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax resolved BEAM-7174. -- Resolution: Fixed Fix Version/s: 2.12.0 > Add transforms for modifying schemas >

[jira] [Resolved] (BEAM-6602) Support schemas in BigQueryIO.Write

[ https://issues.apache.org/jira/browse/BEAM-6602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax resolved BEAM-6602. -- Resolution: Fixed Fix Version/s: 2.12.0 > Support schemas in BigQueryIO.Write > -

[jira] [Commented] (BEAM-7116) Remove KV from Schema transforms

[ https://issues.apache.org/jira/browse/BEAM-7116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841044#comment-16841044 ] Reuven Lax commented on BEAM-7116: -- Transforms like Group that return KV today should ins

[jira] [Created] (BEAM-7333) Select need the ability to rename fields

Reuven Lax created BEAM-7333: Summary: Select need the ability to rename fields Key: BEAM-7333 URL: https://issues.apache.org/jira/browse/BEAM-7333 Project: Beam Issue Type: Sub-task Co

[jira] [Created] (BEAM-7334) Create a better Schema builder

Reuven Lax created BEAM-7334: Summary: Create a better Schema builder Key: BEAM-7334 URL: https://issues.apache.org/jira/browse/BEAM-7334 Project: Beam Issue Type: Sub-task Components:

[jira] [Created] (BEAM-7335) PubSubIO.writeAvros should infer beam schemas

Reuven Lax created BEAM-7335: Summary: PubSubIO.writeAvros should infer beam schemas Key: BEAM-7335 URL: https://issues.apache.org/jira/browse/BEAM-7335 Project: Beam Issue Type: Sub-task

[jira] [Created] (BEAM-7336) KafkaIO should support inferring schemas when reading AVRO

Reuven Lax created BEAM-7336: Summary: KafkaIO should support inferring schemas when reading AVRO Key: BEAM-7336 URL: https://issues.apache.org/jira/browse/BEAM-7336 Project: Beam Issue Type: Sub

[jira] [Commented] (BEAM-7116) Remove KV from Schema transforms

[ https://issues.apache.org/jira/browse/BEAM-7116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841051#comment-16841051 ] Reuven Lax commented on BEAM-7116: -- To make this seamless, the Convert transform should b

[jira] [Resolved] (BEAM-6772) Select transform has non-intuitive semantics

[ https://issues.apache.org/jira/browse/BEAM-6772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax resolved BEAM-6772. -- Resolution: Fixed Fix Version/s: 2.12.0 > Select transform has non-intuitive semantics >

[jira] [Created] (BEAM-7337) Allow selecting slices of arrays and maps

Reuven Lax created BEAM-7337: Summary: Allow selecting slices of arrays and maps Key: BEAM-7337 URL: https://issues.apache.org/jira/browse/BEAM-7337 Project: Beam Issue Type: Sub-task C

[jira] [Commented] (BEAM-6475) SQL Connection leak when using streaming pipeline

[ https://issues.apache.org/jira/browse/BEAM-6475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841082#comment-16841082 ] Jonathan Perron commented on BEAM-6475: --- [~iemejia] thank you for updating the issue

[jira] [Work logged] (BEAM-7305) Add first version of Hazelcast Jet Runner

[ https://issues.apache.org/jira/browse/BEAM-7305?focusedWorklogId=243176&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243176 ] ASF GitHub Bot logged work on BEAM-7305: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7305) Add first version of Hazelcast Jet Runner

[ https://issues.apache.org/jira/browse/BEAM-7305?focusedWorklogId=243177&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243177 ] ASF GitHub Bot logged work on BEAM-7305: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7305) Add first version of Hazelcast Jet Runner

[ https://issues.apache.org/jira/browse/BEAM-7305?focusedWorklogId=243183&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243183 ] ASF GitHub Bot logged work on BEAM-7305: Author: ASF GitHub Bot

[jira] [Resolved] (BEAM-7302) Dependencies are broken in SNAPSHOT pom files

[ https://issues.apache.org/jira/browse/BEAM-7302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-7302. Resolution: Fixed Fix Version/s: Not applicable > Dependencies are broken in SNAPSHOT pom fil

[jira] [Commented] (BEAM-7302) Dependencies are broken in SNAPSHOT pom files

[ https://issues.apache.org/jira/browse/BEAM-7302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841127#comment-16841127 ] Ismaël Mejía commented on BEAM-7302: I want to confirm this is fixed now. Thanks [~mic

[jira] [Closed] (BEAM-7302) Dependencies are broken in SNAPSHOT pom files

[ https://issues.apache.org/jira/browse/BEAM-7302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía closed BEAM-7302. -- > Dependencies are broken in SNAPSHOT pom files > - > >

[jira] [Commented] (BEAM-6475) SQL Connection leak when using streaming pipeline

[ https://issues.apache.org/jira/browse/BEAM-6475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841135#comment-16841135 ] Ismaël Mejía commented on BEAM-6475: Thanks for confirming this [~jonperron]. > SQL C

[jira] [Work logged] (BEAM-6829) Duplicate metric warnings clutter log

[ https://issues.apache.org/jira/browse/BEAM-6829?focusedWorklogId=243203&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243203 ] ASF GitHub Bot logged work on BEAM-6829: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7240) Kinesis IO Watermark Computation Improvements

[ https://issues.apache.org/jira/browse/BEAM-7240?focusedWorklogId=243234&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243234 ] ASF GitHub Bot logged work on BEAM-7240: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-7144) Job re-scale fails on Flink 1.7

[ https://issues.apache.org/jira/browse/BEAM-7144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841178#comment-16841178 ] Jozef Vilcek commented on BEAM-7144: Yes, rescale on 1.8 works for me > Job re-scale

[jira] [Comment Edited] (BEAM-6674) The JdbcIO source should produce schemas

[ https://issues.apache.org/jira/browse/BEAM-6674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841240#comment-16841240 ] Shehzaad Nakhoda edited comment on BEAM-6674 at 5/16/19 11:38 AM: --

[jira] [Commented] (BEAM-6674) The JdbcIO source should produce schemas

[ https://issues.apache.org/jira/browse/BEAM-6674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841240#comment-16841240 ] Shehzaad Nakhoda commented on BEAM-6674: [~reuvenlax] A couple of sentences of ela

[jira] [Commented] (BEAM-6675) The JdbcIO sink should accept schemas

[ https://issues.apache.org/jira/browse/BEAM-6675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841241#comment-16841241 ] Shehzaad Nakhoda commented on BEAM-6675: [~reuvenlax] For understanding the scope

[jira] [Work logged] (BEAM-7287) beam_PostCommit_Java11_ValidatesRunner_Direct broken

[ https://issues.apache.org/jira/browse/BEAM-7287?focusedWorklogId=243276&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243276 ] ASF GitHub Bot logged work on BEAM-7287: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7287) beam_PostCommit_Java11_ValidatesRunner_Direct broken

[ https://issues.apache.org/jira/browse/BEAM-7287?focusedWorklogId=243277&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243277 ] ASF GitHub Bot logged work on BEAM-7287: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7305) Add first version of Hazelcast Jet Runner

[ https://issues.apache.org/jira/browse/BEAM-7305?focusedWorklogId=243279&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243279 ] ASF GitHub Bot logged work on BEAM-7305: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7305) Add first version of Hazelcast Jet Runner

[ https://issues.apache.org/jira/browse/BEAM-7305?focusedWorklogId=243281&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243281 ] ASF GitHub Bot logged work on BEAM-7305: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7305) Add first version of Hazelcast Jet Runner

[ https://issues.apache.org/jira/browse/BEAM-7305?focusedWorklogId=243280&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243280 ] ASF GitHub Bot logged work on BEAM-7305: Author: ASF GitHub Bot

[jira] [Issue Comment Deleted] (BEAM-6675) The JdbcIO sink should accept schemas

[ https://issues.apache.org/jira/browse/BEAM-6675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shehzaad Nakhoda updated BEAM-6675: --- Comment: was deleted (was: [~reuvenlax] For understanding the scope a bit better, could you po

[jira] [Issue Comment Deleted] (BEAM-6674) The JdbcIO source should produce schemas

[ https://issues.apache.org/jira/browse/BEAM-6674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shehzaad Nakhoda updated BEAM-6674: --- Comment: was deleted (was: [~reuvenlax] A couple of sentences of elaboration would help scope

[jira] [Work logged] (BEAM-7305) Add first version of Hazelcast Jet Runner

[ https://issues.apache.org/jira/browse/BEAM-7305?focusedWorklogId=243282&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243282 ] ASF GitHub Bot logged work on BEAM-7305: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-7144) Job re-scale fails on Flink 1.7

[ https://issues.apache.org/jira/browse/BEAM-7144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841303#comment-16841303 ] Maximilian Michels commented on BEAM-7144: -- Thanks for testing. That's very helpf

[jira] [Work logged] (BEAM-7287) beam_PostCommit_Java11_ValidatesRunner_Direct broken

[ https://issues.apache.org/jira/browse/BEAM-7287?focusedWorklogId=243323&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243323 ] ASF GitHub Bot logged work on BEAM-7287: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7287) beam_PostCommit_Java11_ValidatesRunner_Direct broken

[ https://issues.apache.org/jira/browse/BEAM-7287?focusedWorklogId=243322&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243322 ] ASF GitHub Bot logged work on BEAM-7287: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7287) beam_PostCommit_Java11_ValidatesRunner_Direct broken

[ https://issues.apache.org/jira/browse/BEAM-7287?focusedWorklogId=243329&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243329 ] ASF GitHub Bot logged work on BEAM-7287: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7287) beam_PostCommit_Java11_ValidatesRunner_Direct broken

[ https://issues.apache.org/jira/browse/BEAM-7287?focusedWorklogId=243332&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243332 ] ASF GitHub Bot logged work on BEAM-7287: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7287) beam_PostCommit_Java11_ValidatesRunner_Direct broken

[ https://issues.apache.org/jira/browse/BEAM-7287?focusedWorklogId=243338&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243338 ] ASF GitHub Bot logged work on BEAM-7287: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7302) Dependencies are broken in SNAPSHOT pom files

[ https://issues.apache.org/jira/browse/BEAM-7302?focusedWorklogId=243337&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243337 ] ASF GitHub Bot logged work on BEAM-7302: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7302) Dependencies are broken in SNAPSHOT pom files

[ https://issues.apache.org/jira/browse/BEAM-7302?focusedWorklogId=243339&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243339 ] ASF GitHub Bot logged work on BEAM-7302: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7287) beam_PostCommit_Java11_ValidatesRunner_Direct broken

[ https://issues.apache.org/jira/browse/BEAM-7287?focusedWorklogId=243343&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243343 ] ASF GitHub Bot logged work on BEAM-7287: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7287) beam_PostCommit_Java11_ValidatesRunner_Direct broken

[ https://issues.apache.org/jira/browse/BEAM-7287?focusedWorklogId=243345&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243345 ] ASF GitHub Bot logged work on BEAM-7287: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7240) Kinesis IO Watermark Computation Improvements

[ https://issues.apache.org/jira/browse/BEAM-7240?focusedWorklogId=243346&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243346 ] ASF GitHub Bot logged work on BEAM-7240: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-7302) Dependencies are broken in SNAPSHOT pom files

[ https://issues.apache.org/jira/browse/BEAM-7302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841377#comment-16841377 ] Michael Luckey commented on BEAM-7302: -- FYI: Opened [PR 8594|https://github.com/apach

[jira] [Commented] (BEAM-7230) Using JdbcIO creates huge amount of connections

[ https://issues.apache.org/jira/browse/BEAM-7230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841455#comment-16841455 ] Ismaël Mejía commented on BEAM-7230: Great to know the singleton static idea works. I

[jira] [Created] (BEAM-7338) Deprecate PoolableDataSourceProvider from JdbcIO

Ismaël Mejía created BEAM-7338: -- Summary: Deprecate PoolableDataSourceProvider from JdbcIO Key: BEAM-7338 URL: https://issues.apache.org/jira/browse/BEAM-7338 Project: Beam Issue Type: Improveme

[jira] [Updated] (BEAM-7338) Deprecate PoolableDataSourceProvider from JdbcIO

[ https://issues.apache.org/jira/browse/BEAM-7338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7338: --- Status: Open (was: Triage Needed) > Deprecate PoolableDataSourceProvider from JdbcIO > --

[jira] [Work logged] (BEAM-7230) Using JdbcIO creates huge amount of connections

[ https://issues.apache.org/jira/browse/BEAM-7230?focusedWorklogId=243409&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243409 ] ASF GitHub Bot logged work on BEAM-7230: Author: ASF GitHub Bot

[jira] [Resolved] (BEAM-7240) Kinesis IO Watermark Computation Improvements

[ https://issues.apache.org/jira/browse/BEAM-7240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko resolved BEAM-7240. Resolution: Fixed Fix Version/s: 2.14.0 > Kinesis IO Watermark Computation Improvemen

[jira] [Work logged] (BEAM-7240) Kinesis IO Watermark Computation Improvements

[ https://issues.apache.org/jira/browse/BEAM-7240?focusedWorklogId=243416&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243416 ] ASF GitHub Bot logged work on BEAM-7240: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7240) Kinesis IO Watermark Computation Improvements

[ https://issues.apache.org/jira/browse/BEAM-7240?focusedWorklogId=243417&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243417 ] ASF GitHub Bot logged work on BEAM-7240: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7240) Kinesis IO Watermark Computation Improvements

[ https://issues.apache.org/jira/browse/BEAM-7240?focusedWorklogId=243427&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243427 ] ASF GitHub Bot logged work on BEAM-7240: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7230) Using JdbcIO creates huge amount of connections

[ https://issues.apache.org/jira/browse/BEAM-7230?focusedWorklogId=243430&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243430 ] ASF GitHub Bot logged work on BEAM-7230: Author: ASF GitHub Bot

[jira] [Closed] (BEAM-7283) Have javadoc offline link dependency versions bound to versions within BeamModulePlugin.groovy

[ https://issues.apache.org/jira/browse/BEAM-7283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik closed BEAM-7283. --- Resolution: Fixed Fix Version/s: 2.14.0 > Have javadoc offline link dependency versions bound to versio

[jira] [Work logged] (BEAM-7283) Have javadoc offline link dependency versions bound to versions within BeamModulePlugin.groovy

[ https://issues.apache.org/jira/browse/BEAM-7283?focusedWorklogId=243446&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243446 ] ASF GitHub Bot logged work on BEAM-7283: Author: ASF GitHub Bot

[jira] [Resolved] (BEAM-7230) Using JdbcIO creates huge amount of connections

[ https://issues.apache.org/jira/browse/BEAM-7230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-7230. Resolution: Fixed Fix Version/s: 2.13.0 The issue is now documented and a way to vaoid it is

[jira] [Assigned] (BEAM-7333) Select need the ability to rename fields

[ https://issues.apache.org/jira/browse/BEAM-7333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yueyang Qiu reassigned BEAM-7333: - Assignee: Yueyang Qiu > Select need the ability to rename fields > --

[jira] [Commented] (BEAM-7116) Remove KV from Schema transforms

[ https://issues.apache.org/jira/browse/BEAM-7116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841545#comment-16841545 ] Brian Hulette commented on BEAM-7116: - Does this depend on https://issues.apache.org/j

[jira] [Commented] (BEAM-6877) TypeHints Py3 Error: Type inference tests fail on Python 3.6 due to bytecode changes

[ https://issues.apache.org/jira/browse/BEAM-6877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841548#comment-16841548 ] Udi Meiri commented on BEAM-6877: - Hi! Any progress on this? > TypeHints Py3 Error: Type

[jira] [Work logged] (BEAM-6988) TypeHints Py3 Error: test_non_function (apache_beam.typehints.typed_pipeline_test.MainInputTest) Fails on Python 3.7+

[ https://issues.apache.org/jira/browse/BEAM-6988?focusedWorklogId=243483&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243483 ] ASF GitHub Bot logged work on BEAM-6988: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6988) TypeHints Py3 Error: test_non_function (apache_beam.typehints.typed_pipeline_test.MainInputTest) Fails on Python 3.7+

[ https://issues.apache.org/jira/browse/BEAM-6988?focusedWorklogId=243484&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243484 ] ASF GitHub Bot logged work on BEAM-6988: Author: ASF GitHub Bot

[jira] [Closed] (BEAM-7121) Provide deterministic version of Python's ProtoCoder

[ https://issues.apache.org/jira/browse/BEAM-7121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yifan Mai closed BEAM-7121. --- Resolution: Done Fix Version/s: Not applicable > Provide deterministic version of Python's ProtoCoder >

[jira] [Commented] (BEAM-562) DoFn Reuse: Add new methods to DoFn

[ https://issues.apache.org/jira/browse/BEAM-562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841552#comment-16841552 ] Yifan Mai commented on BEAM-562: This is implemented in #7994. > DoFn Reuse: Add new metho

[jira] [Work logged] (BEAM-6988) TypeHints Py3 Error: test_non_function (apache_beam.typehints.typed_pipeline_test.MainInputTest) Fails on Python 3.7+

[ https://issues.apache.org/jira/browse/BEAM-6988?focusedWorklogId=243481&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243481 ] ASF GitHub Bot logged work on BEAM-6988: Author: ASF GitHub Bot

[jira] [Resolved] (BEAM-562) DoFn Reuse: Add new methods to DoFn

[ https://issues.apache.org/jira/browse/BEAM-562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yifan Mai resolved BEAM-562. Resolution: Done Fix Version/s: Not applicable > DoFn Reuse: Add new methods to DoFn > ---

[jira] [Work logged] (BEAM-6988) TypeHints Py3 Error: test_non_function (apache_beam.typehints.typed_pipeline_test.MainInputTest) Fails on Python 3.7+

[ https://issues.apache.org/jira/browse/BEAM-6988?focusedWorklogId=243482&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243482 ] ASF GitHub Bot logged work on BEAM-6988: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7277) Add PostCommit suite for Python 3.7

[ https://issues.apache.org/jira/browse/BEAM-7277?focusedWorklogId=243487&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243487 ] ASF GitHub Bot logged work on BEAM-7277: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7277) Add PostCommit suite for Python 3.7

[ https://issues.apache.org/jira/browse/BEAM-7277?focusedWorklogId=243490&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243490 ] ASF GitHub Bot logged work on BEAM-7277: Author: ASF GitHub Bot

[jira] [Assigned] (BEAM-6623) Dataflow ValidatesRunner test suite should also exercise ValidatesRunner tests under Python 3.

[ https://issues.apache.org/jira/browse/BEAM-6623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev reassigned BEAM-6623: - Assignee: Frederik Bode (was: Mark Liu) > Dataflow ValidatesRunner test suite sh

[jira] [Commented] (BEAM-6623) Dataflow ValidatesRunner test suite should also exercise ValidatesRunner tests under Python 3.

[ https://issues.apache.org/jira/browse/BEAM-6623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841594#comment-16841594 ] Valentyn Tymofieiev commented on BEAM-6623: --- I think there are a few remaining s

[jira] [Created] (BEAM-7339) Enable 1Gb input for Python wordcount benchmark

Mark Liu created BEAM-7339: -- Summary: Enable 1Gb input for Python wordcount benchmark Key: BEAM-7339 URL: https://issues.apache.org/jira/browse/BEAM-7339 Project: Beam Issue Type: Task Com

[jira] [Reopened] (BEAM-6623) Dataflow ValidatesRunner test suite should also exercise ValidatesRunner tests under Python 3.

[ https://issues.apache.org/jira/browse/BEAM-6623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev reopened BEAM-6623: --- [~frederik] do you think you could help with this? this will be a similar project as you

[jira] [Work logged] (BEAM-6683) Add an integration test suite for cross-language transforms for Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6683?focusedWorklogId=243526&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243526 ] ASF GitHub Bot logged work on BEAM-6683: Author: ASF GitHub Bot

[jira] [Updated] (BEAM-7339) Enable 1Gb input for Python wordcount benchmark

[ https://issues.apache.org/jira/browse/BEAM-7339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Liu updated BEAM-7339: --- Description: Requirement: - Use input from: gs://apache-beam-samples/input_small_files/* - Use TestDataflowRu

[jira] [Updated] (BEAM-7339) Enable 1Gb input for Python wordcount benchmark

[ https://issues.apache.org/jira/browse/BEAM-7339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Liu updated BEAM-7339: --- Status: Open (was: Triage Needed) > Enable 1Gb input for Python wordcount benchmark > ---

[jira] [Work started] (BEAM-7339) Enable 1Gb input for Python wordcount benchmark

[ https://issues.apache.org/jira/browse/BEAM-7339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-7339 started by Mark Liu. -- > Enable 1Gb input for Python wordcount benchmark > -

[jira] [Work logged] (BEAM-6683) Add an integration test suite for cross-language transforms for Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6683?focusedWorklogId=243546&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243546 ] ASF GitHub Bot logged work on BEAM-6683: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6683) Add an integration test suite for cross-language transforms for Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6683?focusedWorklogId=243547&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243547 ] ASF GitHub Bot logged work on BEAM-6683: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7287) beam_PostCommit_Java11_ValidatesRunner_Direct broken

[ https://issues.apache.org/jira/browse/BEAM-7287?focusedWorklogId=243550&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243550 ] ASF GitHub Bot logged work on BEAM-7287: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6683) Add an integration test suite for cross-language transforms for Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6683?focusedWorklogId=243555&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243555 ] ASF GitHub Bot logged work on BEAM-6683: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6683) Add an integration test suite for cross-language transforms for Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6683?focusedWorklogId=243557&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243557 ] ASF GitHub Bot logged work on BEAM-6683: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6683) Add an integration test suite for cross-language transforms for Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6683?focusedWorklogId=243554&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243554 ] ASF GitHub Bot logged work on BEAM-6683: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6683) Add an integration test suite for cross-language transforms for Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6683?focusedWorklogId=243553&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243553 ] ASF GitHub Bot logged work on BEAM-6683: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6683) Add an integration test suite for cross-language transforms for Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6683?focusedWorklogId=243552&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243552 ] ASF GitHub Bot logged work on BEAM-6683: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6683) Add an integration test suite for cross-language transforms for Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6683?focusedWorklogId=243551&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243551 ] ASF GitHub Bot logged work on BEAM-6683: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6683) Add an integration test suite for cross-language transforms for Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6683?focusedWorklogId=243556&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243556 ] ASF GitHub Bot logged work on BEAM-6683: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-7339) Enable 1Gb input for Python wordcount benchmark

[ https://issues.apache.org/jira/browse/BEAM-7339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841629#comment-16841629 ] Ahmet Altay commented on BEAM-7339: --- If this is for a benchmark, should we target larger

[jira] [Work logged] (BEAM-6683) Add an integration test suite for cross-language transforms for Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6683?focusedWorklogId=243560&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243560 ] ASF GitHub Bot logged work on BEAM-6683: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7339) Enable 1Gb input for Python wordcount benchmark

[ https://issues.apache.org/jira/browse/BEAM-7339?focusedWorklogId=243565&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243565 ] ASF GitHub Bot logged work on BEAM-7339: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-5510) Records including datetime to be saved as DATETIME or TIMESTAMP in BigQuery

[ https://issues.apache.org/jira/browse/BEAM-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841636#comment-16841636 ] Ahmet Altay commented on BEAM-5510: --- cc: [~chamikara] [~pabloem] > Records including da

[jira] [Work logged] (BEAM-7339) Enable 1Gb input for Python wordcount benchmark

[ https://issues.apache.org/jira/browse/BEAM-7339?focusedWorklogId=243575&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243575 ] ASF GitHub Bot logged work on BEAM-7339: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6683) Add an integration test suite for cross-language transforms for Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6683?focusedWorklogId=243577&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243577 ] ASF GitHub Bot logged work on BEAM-6683: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6683) Add an integration test suite for cross-language transforms for Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6683?focusedWorklogId=243578&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243578 ] ASF GitHub Bot logged work on BEAM-6683: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6683) Add an integration test suite for cross-language transforms for Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6683?focusedWorklogId=243576&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243576 ] ASF GitHub Bot logged work on BEAM-6683: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6683) Add an integration test suite for cross-language transforms for Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6683?focusedWorklogId=243582&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243582 ] ASF GitHub Bot logged work on BEAM-6683: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6683) Add an integration test suite for cross-language transforms for Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6683?focusedWorklogId=243583&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243583 ] ASF GitHub Bot logged work on BEAM-6683: Author: ASF GitHub Bot

[jira] [Closed] (BEAM-563) DoFn Reuse: Update DirectRunner

[ https://issues.apache.org/jira/browse/BEAM-563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yifan Mai closed BEAM-563. -- Resolution: Done Fix Version/s: Not applicable This was also done in https://github.com/apache/beam/pull/7

[jira] [Work logged] (BEAM-6683) Add an integration test suite for cross-language transforms for Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6683?focusedWorklogId=243584&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-243584 ] ASF GitHub Bot logged work on BEAM-6683: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-7230) Using JdbcIO creates huge amount of connections

[ https://issues.apache.org/jira/browse/BEAM-7230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841646#comment-16841646 ] Brachi Packter commented on BEAM-7230: -- Hi. Looked into the code, seems that like wh

  1   2   >