[jira] [Comment Edited] (BEAM-9239) Dependency conflict with Spark using aws io

[ https://issues.apache.org/jira/browse/BEAM-9239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120035#comment-17120035 ] Kai Jiang edited comment on BEAM-9239 at 5/30/20, 12:23 AM: Spark has two

[jira] [Commented] (BEAM-9239) Dependency conflict with Spark using aws io

[ https://issues.apache.org/jira/browse/BEAM-9239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120038#comment-17120038 ] Kai Jiang commented on BEAM-9239: - Maybe vendor relocated com.fasterxml.jackson library could be long term

[jira] [Commented] (BEAM-9239) Dependency conflict with Spark using aws io

[ https://issues.apache.org/jira/browse/BEAM-9239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120035#comment-17120035 ] Kai Jiang commented on BEAM-9239: - Spark has two experimental configs `spark.driver.userClassPathFirst`

[jira] [Commented] (BEAM-10000) Support BIT_XOR aggregation function in BeamSQL

[ https://issues.apache.org/jira/browse/BEAM-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107787#comment-17107787 ] Kai Jiang commented on BEAM-1: -- wow! #1 > Support BIT_XOR aggregation function in BeamSQL >

[jira] [Resolved] (BEAM-9121) Bump vendored calcite to 1.21.0

[ https://issues.apache.org/jira/browse/BEAM-9121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Jiang resolved BEAM-9121. - Fix Version/s: 2.20.0 Resolution: Won't Fix > Bump vendored calcite to 1.21.0 >

[jira] [Updated] (BEAM-9121) Bump vendored calcite to 1.21.0

[ https://issues.apache.org/jira/browse/BEAM-9121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Jiang updated BEAM-9121: Summary: Bump vendored calcite to 1.21.0 (was: Bump vendored calcite to 1.22.0) > Bump vendored calcite

[jira] [Assigned] (BEAM-9121) Bump vendored calcite to 1.22.0

[ https://issues.apache.org/jira/browse/BEAM-9121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Jiang reassigned BEAM-9121: --- Assignee: Kai Jiang > Bump vendored calcite to 1.22.0 > --- > >

[jira] [Updated] (BEAM-9121) Bump vendored calcite to 1.22.0

[ https://issues.apache.org/jira/browse/BEAM-9121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Jiang updated BEAM-9121: Summary: Bump vendored calcite to 1.22.0 (was: Bump vendored calcite to 1.21.0) > Bump vendored calcite

[jira] [Assigned] (BEAM-9121) Bump vendored calcite to 1.21.0

[ https://issues.apache.org/jira/browse/BEAM-9121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Jiang reassigned BEAM-9121: --- Assignee: (was: Kai Jiang) > Bump vendored calcite to 1.21.0 > --- >

[jira] [Assigned] (BEAM-9412) Fix linkage errors in vendored calcite

[ https://issues.apache.org/jira/browse/BEAM-9412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Jiang reassigned BEAM-9412: --- Assignee: Kai Jiang > Fix linkage errors in vendored calcite >

[jira] [Updated] (BEAM-8331) Vendored calcite breaks if another calcite is on the class path

[ https://issues.apache.org/jira/browse/BEAM-8331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Jiang updated BEAM-8331: Parent: BEAM-9121 Issue Type: Sub-task (was: Bug) > Vendored calcite breaks if another calcite is

[jira] [Updated] (BEAM-9121) Bump vendored calcite to 1.21.0

[ https://issues.apache.org/jira/browse/BEAM-9121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Jiang updated BEAM-9121: Status: Open (was: Triage Needed) > Bump vendored calcite to 1.21.0 > --- > >

[jira] [Created] (BEAM-9121) Bump vendored calcite to 1.21.0

Kai Jiang created BEAM-9121: --- Summary: Bump vendored calcite to 1.21.0 Key: BEAM-9121 URL: https://issues.apache.org/jira/browse/BEAM-9121 Project: Beam Issue Type: Task Components:

[jira] [Comment Edited] (BEAM-8331) Vendored calcite breaks if another calcite is on the class path

[ https://issues.apache.org/jira/browse/BEAM-8331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012693#comment-17012693 ] Kai Jiang edited comment on BEAM-8331 at 1/10/20 10:41 AM: --- I have built a

[jira] [Commented] (BEAM-8331) Vendored calcite breaks if another calcite is on the class path

[ https://issues.apache.org/jira/browse/BEAM-8331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012693#comment-17012693 ] Kai Jiang commented on BEAM-8331: - I have built a vendored calcite with rewriting jdbc url locally.

[jira] [Commented] (BEAM-8496) remove SDF translators in flink streaming transform translator

[ https://issues.apache.org/jira/browse/BEAM-8496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011288#comment-17011288 ] Kai Jiang commented on BEAM-8496: - For failed nexmark on flink job, it was fixed by 

[jira] [Resolved] (BEAM-4663) Implement Cost calculations for Cost-Based Optimization (CBO)

[ https://issues.apache.org/jira/browse/BEAM-4663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Jiang resolved BEAM-4663. - Fix Version/s: Not applicable Resolution: Invalid > Implement Cost calculations for Cost-Based

[jira] [Created] (BEAM-8496) remove SDF translators in flink streaming transform translator

Kai Jiang created BEAM-8496: --- Summary: remove SDF translators in flink streaming transform translator Key: BEAM-8496 URL: https://issues.apache.org/jira/browse/BEAM-8496 Project: Beam Issue Type:

[jira] [Assigned] (BEAM-8331) Vendored calcite breaks if another calcite is on the class path

[ https://issues.apache.org/jira/browse/BEAM-8331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Jiang reassigned BEAM-8331: --- Assignee: Kai Jiang > Vendored calcite breaks if another calcite is on the class path >

[jira] [Commented] (BEAM-8331) Vendored calcite breaks if another calcite is on the class path

[ https://issues.apache.org/jira/browse/BEAM-8331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943340#comment-16943340 ] Kai Jiang commented on BEAM-8331: - sure. I assigned to myself. > Vendored calcite breaks if another

[jira] [Commented] (BEAM-2466) Add Kafka Streams runner

[ https://issues.apache.org/jira/browse/BEAM-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16918157#comment-16918157 ] Kai Jiang commented on BEAM-2466: - Nice progress. I reassigned the ticket to [~winkelman.kyle].

[jira] [Assigned] (BEAM-2466) Add Kafka Streams runner

[ https://issues.apache.org/jira/browse/BEAM-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Jiang reassigned BEAM-2466: --- Assignee: Kyle Winkelman (was: Kai Jiang) > Add Kafka Streams runner > > >

[jira] [Assigned] (BEAM-5820) Vendor Calcite

[ https://issues.apache.org/jira/browse/BEAM-5820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Jiang reassigned BEAM-5820: --- Assignee: Kai Jiang > Vendor Calcite > -- > > Key: BEAM-5820 >

[jira] [Resolved] (BEAM-7728) Support ParquetTable in SQL

[ https://issues.apache.org/jira/browse/BEAM-7728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Jiang resolved BEAM-7728. - Resolution: Fixed Fix Version/s: 2.15.0 > Support ParquetTable in SQL >

[jira] [Comment Edited] (BEAM-7728) Support ParquetTable in SQL

[ https://issues.apache.org/jira/browse/BEAM-7728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16896822#comment-16896822 ] Kai Jiang edited comment on BEAM-7728 at 7/31/19 6:49 AM: -- to be implemented

[jira] [Commented] (BEAM-7728) Support ParquetTable in SQL

[ https://issues.apache.org/jira/browse/BEAM-7728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16896822#comment-16896822 ] Kai Jiang commented on BEAM-7728: - to be implement writer > Support ParquetTable in SQL >

[jira] [Created] (BEAM-7728) Support ParquetTable in SQL

Kai Jiang created BEAM-7728: --- Summary: Support ParquetTable in SQL Key: BEAM-7728 URL: https://issues.apache.org/jira/browse/BEAM-7728 Project: Beam Issue Type: New Feature Components:

[jira] [Assigned] (BEAM-5822) Vendor bytebuddy

[ https://issues.apache.org/jira/browse/BEAM-5822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Jiang reassigned BEAM-5822: --- Assignee: Kai Jiang > Vendor bytebuddy > > > Key: BEAM-5822 >

[jira] [Commented] (BEAM-2466) Add Kafka Streams runner

[ https://issues.apache.org/jira/browse/BEAM-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767394#comment-16767394 ] Kai Jiang commented on BEAM-2466: - [~teabot] IMHO, There should not exist a 'batch processing' concept for

[jira] [Commented] (BEAM-3386) Dependency conflict when Calcite is included in a project.

[ https://issues.apache.org/jira/browse/BEAM-3386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16751942#comment-16751942 ] Kai Jiang commented on BEAM-3386: - [~kenn] this (without relocation) sounds pretty useful. let me checkout

[jira] [Commented] (BEAM-3386) Dependency conflict when Calcite is included in a project.

[ https://issues.apache.org/jira/browse/BEAM-3386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16751928#comment-16751928 ] Kai Jiang commented on BEAM-3386: - [~iemejia] Thanks! I will take some time trying to work on vendor

[jira] [Assigned] (BEAM-5130) Support ALL (sub query)

[ https://issues.apache.org/jira/browse/BEAM-5130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Jiang reassigned BEAM-5130: --- Assignee: Kai Jiang > Support ALL (sub query) > --- > > Key: