[jira] [Comment Edited] (BEAM-12356) BigQueryWriteClient in DatasetServiceImpl is not closed, which causes "ManagedChannel allocation site" exceptions

[ https://issues.apache.org/jira/browse/BEAM-12356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510783#comment-17510783 ] Claire McGinty edited comment on BEAM-12356 at 3/22/22, 5:31 PM: --

[jira] [Comment Edited] (BEAM-12356) BigQueryWriteClient in DatasetServiceImpl is not closed, which causes "ManagedChannel allocation site" exceptions

[ https://issues.apache.org/jira/browse/BEAM-12356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510783#comment-17510783 ] Claire McGinty edited comment on BEAM-12356 at 3/22/22, 5:31 PM: --

[jira] [Commented] (BEAM-12356) BigQueryWriteClient in DatasetServiceImpl is not closed, which causes "ManagedChannel allocation site" exceptions

[ https://issues.apache.org/jira/browse/BEAM-12356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510783#comment-17510783 ] Claire McGinty commented on BEAM-12356: --- [~bhulette] Sure, here's an example! They'

[jira] [Commented] (BEAM-12356) BigQueryWriteClient in DatasetServiceImpl is not closed, which causes "ManagedChannel allocation site" exceptions

[ https://issues.apache.org/jira/browse/BEAM-12356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510548#comment-17510548 ] Claire McGinty commented on BEAM-12356: --- We still see this in Beam 2.36.0. > BigQu

[jira] [Commented] (BEAM-12628) AvroCoder changed underlying String class for SpecificRecords

[ https://issues.apache.org/jira/browse/BEAM-12628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17421475#comment-17421475 ] Claire McGinty commented on BEAM-12628: --- Thanks [~udim] and [~rskraba]. I think the

[jira] [Reopened] (BEAM-12628) AvroCoder changed underlying String class for SpecificRecords

[ https://issues.apache.org/jira/browse/BEAM-12628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Claire McGinty reopened BEAM-12628: --- I realized that the `useReflectApi` flag isn't supported in the `CoderProvider` implementation -

[jira] [Created] (BEAM-12948) Add .withPipelineTempDirectory() Builder setting for file-based sinks

Claire McGinty created BEAM-12948: - Summary: Add .withPipelineTempDirectory() Builder setting for file-based sinks Key: BEAM-12948 URL: https://issues.apache.org/jira/browse/BEAM-12948 Project: Beam

[jira] [Commented] (BEAM-12628) AvroCoder changed underlying String class for SpecificRecords

[ https://issues.apache.org/jira/browse/BEAM-12628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17416267#comment-17416267 ] Claire McGinty commented on BEAM-12628: --- [~rskraba] It's a bit of a "gotcha" for us

[jira] [Commented] (BEAM-12628) AvroCoder changed underlying String class for SpecificRecords

[ https://issues.apache.org/jira/browse/BEAM-12628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415152#comment-17415152 ] Claire McGinty commented on BEAM-12628: --- [~udim] there shouldn't be. I've been thin

[jira] [Commented] (BEAM-12628) AvroCoder changed underlying String class for SpecificRecords

[ https://issues.apache.org/jira/browse/BEAM-12628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401872#comment-17401872 ] Claire McGinty commented on BEAM-12628: --- [~angoenka] that's disappointing, I hoped

[jira] [Commented] (BEAM-11048) Add alternate Sorting transform as an implementation of CombineFn

[ https://issues.apache.org/jira/browse/BEAM-11048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17216737#comment-17216737 ] Claire McGinty commented on BEAM-11048: --- [~chamikara], would you mind taking a look

[jira] [Commented] (BEAM-11048) Add alternate Sorting transform as an implementation of CombineFn

[ https://issues.apache.org/jira/browse/BEAM-11048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211087#comment-17211087 ] Claire McGinty commented on BEAM-11048: --- Implementation here: https://github.com/ap

[jira] [Created] (BEAM-11048) Add alternate Sorting transform as an implementation of CombineFn

Claire McGinty created BEAM-11048: - Summary: Add alternate Sorting transform as an implementation of CombineFn Key: BEAM-11048 URL: https://issues.apache.org/jira/browse/BEAM-11048 Project: Beam

[jira] [Updated] (BEAM-10604) Remove "final" modifier from FileBasedSource#getEstimatedSizeBytes?

[ https://issues.apache.org/jira/browse/BEAM-10604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Claire McGinty updated BEAM-10604: -- Description: https://github.com/apache/beam/blob/6fdde4f4eab72b49b10a8bb1cb3be263c5c416b5/sdks/

[jira] [Updated] (BEAM-10604) Remove "final" modifier from FileBasedSource#getEstimatedSizeBytes?

[ https://issues.apache.org/jira/browse/BEAM-10604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Claire McGinty updated BEAM-10604: -- Description: https://github.com/apache/beam/blob/6fdde4f4eab72b49b10a8bb1cb3be263c5c416b5/sdks/

[jira] [Created] (BEAM-10604) Remove "final" modifier from FileBasedSource#getEstimatedSizeBytes?

Claire McGinty created BEAM-10604: - Summary: Remove "final" modifier from FileBasedSource#getEstimatedSizeBytes? Key: BEAM-10604 URL: https://issues.apache.org/jira/browse/BEAM-10604 Project: Beam

[jira] [Commented] (BEAM-10042) Add alternate constructor to improve byte encoding performance in SortValues

[ https://issues.apache.org/jira/browse/BEAM-10042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17162108#comment-17162108 ] Claire McGinty commented on BEAM-10042: --- Removing the stale label -- I'm still inte

[jira] [Updated] (BEAM-10042) Add alternate constructor to improve byte encoding performance in SortValues

[ https://issues.apache.org/jira/browse/BEAM-10042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Claire McGinty updated BEAM-10042: -- Labels: (was: stale-P2) > Add alternate constructor to improve byte encoding performance in S

[jira] [Created] (BEAM-10042) Add alternate constructor to improve byte encoding performance in SortValues

Claire McGinty created BEAM-10042: - Summary: Add alternate constructor to improve byte encoding performance in SortValues Key: BEAM-10042 URL: https://issues.apache.org/jira/browse/BEAM-10042 Project:

[jira] [Commented] (BEAM-9316) FileIO.Write.relativeFileNaming should not be public

[ https://issues.apache.org/jira/browse/BEAM-9316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17040149#comment-17040149 ] Claire McGinty commented on BEAM-9316: -- thanks for taking a look [~jkff] and [~iemeji

[jira] [Created] (BEAM-9316) FileIO.Write.relativeFileNaming should not be public

Claire McGinty created BEAM-9316: Summary: FileIO.Write.relativeFileNaming should not be public Key: BEAM-9316 URL: https://issues.apache.org/jira/browse/BEAM-9316 Project: Beam Issue Type: I

[jira] [Commented] (BEAM-8155) Add PubsubIO.readMessagesWithCoderAndParseFn method

[ https://issues.apache.org/jira/browse/BEAM-8155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16926801#comment-16926801 ] Claire McGinty commented on BEAM-8155: -- [~markflyhigh] thank you so much!! It's done

[jira] [Commented] (BEAM-8155) Add PubsubIO.readMessagesWithCoderAndParseFn method

[ https://issues.apache.org/jira/browse/BEAM-8155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16926064#comment-16926064 ] Claire McGinty commented on BEAM-8155: -- [~markflyhigh] I merged the pull request last

[jira] [Created] (BEAM-8155) Add PubsubIO.readMessagesWithCoderAndParseFn method

Claire McGinty created BEAM-8155: Summary: Add PubsubIO.readMessagesWithCoderAndParseFn method Key: BEAM-8155 URL: https://issues.apache.org/jira/browse/BEAM-8155 Project: Beam Issue Type: Im

[jira] [Commented] (BEAM-6766) Sort Merge Bucket Join support in Beam

[ https://issues.apache.org/jira/browse/BEAM-6766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16861472#comment-16861472 ] Claire McGinty commented on BEAM-6766: --  [~kenn] thanks for the feedback, that's tota

[jira] [Comment Edited] (BEAM-6766) Sort Merge Bucket Join support in Beam

[ https://issues.apache.org/jira/browse/BEAM-6766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16795093#comment-16795093 ] Claire McGinty edited comment on BEAM-6766 at 4/12/19 2:49 AM: -

[jira] [Updated] (BEAM-6766) Sort Merge Bucket Join support in Beam

[ https://issues.apache.org/jira/browse/BEAM-6766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Claire McGinty updated BEAM-6766: - Description: Hi! Spotify has been internally prototyping and testing an implementation of the sor

[jira] [Updated] (BEAM-6766) Sort Merge Bucket Join support in Beam

[ https://issues.apache.org/jira/browse/BEAM-6766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Claire McGinty updated BEAM-6766: - Description: Hi! Spotify has been internally prototyping and testing an implementation of the sor

[jira] [Commented] (BEAM-6766) Sort Merge Bucket Join support in Beam

[ https://issues.apache.org/jira/browse/BEAM-6766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16795093#comment-16795093 ] Claire McGinty commented on BEAM-6766: -- cc [~reuvenlax], can you share your thoughts

[jira] [Created] (BEAM-6766) Sort Merge Bucket Join support in Beam

Claire McGinty created BEAM-6766: Summary: Sort Merge Bucket Join support in Beam Key: BEAM-6766 URL: https://issues.apache.org/jira/browse/BEAM-6766 Project: Beam Issue Type: Improvement