[jira] [Closed] (SPARK-38326) aditya

2022-02-27 Thread Vallepu Durga Aditya (Jira)
[ https://issues.apache.org/jira/browse/SPARK-38326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vallepu Durga Aditya closed SPARK-38326. final > aditya > -- > > Key: SPARK-38326 > URL: h

[jira] [Created] (SPARK-38326) aditya

2022-02-24 Thread Vallepu Durga Aditya (Jira)
Vallepu Durga Aditya created SPARK-38326: Summary: aditya Key: SPARK-38326 URL: https://issues.apache.org/jira/browse/SPARK-38326 Project: Spark Issue Type: New Feature Comp

[jira] [Created] (IGNITE-15258) IgniteSourceTask code issue

2021-08-05 Thread Aditya (Jira)
Aditya created IGNITE-15258: --- Summary: IgniteSourceTask code issue Key: IGNITE-15258 URL: https://issues.apache.org/jira/browse/IGNITE-15258 Project: Ignite Issue Type: Bug Reporter: Ad

[jira] [Commented] (IGNITE-13442) Implement removals support in Ignite Kafka sink connector

2021-06-23 Thread Aditya (Jira)
[ https://issues.apache.org/jira/browse/IGNITE-13442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368621#comment-17368621 ] Aditya commented on IGNITE-13442: - Hi team. Can someone please check this? It's been a

[jira] [Created] (IGNITE-13424) Ignite Sink Task issue in Kafka integration

2020-09-10 Thread Aditya (Jira)
Aditya created IGNITE-13424: --- Summary: Ignite Sink Task issue in Kafka integration Key: IGNITE-13424 URL: https://issues.apache.org/jira/browse/IGNITE-13424 Project: Ignite Issue Type: Bug

[jira] [Created] (IGNITE-13424) Ignite Sink Task issue in Kafka integration

2020-09-10 Thread Aditya (Jira)
Aditya created IGNITE-13424: --- Summary: Ignite Sink Task issue in Kafka integration Key: IGNITE-13424 URL: https://issues.apache.org/jira/browse/IGNITE-13424 Project: Ignite Issue Type: Bug

[jira] [Updated] (AIRFLOW-7035) Increment the pip version in Airflow Dockerfile

2020-03-10 Thread Aditya (Jira)
[ https://issues.apache.org/jira/browse/AIRFLOW-7035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya updated AIRFLOW-7035: Description: The current pip version in ([https://github.com/apache/airflow/blob/master/Dockerfile#L298)

[jira] [Created] (AIRFLOW-7035) Increment the pip version in Airflow Dockerfile

2020-03-10 Thread Aditya (Jira)
Aditya created AIRFLOW-7035: --- Summary: Increment the pip version in Airflow Dockerfile Key: AIRFLOW-7035 URL: https://issues.apache.org/jira/browse/AIRFLOW-7035 Project: Apache Airflow Issue Type:

[jira] [Created] (IGNITE-12603) Questions regarding Data Availability/Replication.

2020-01-29 Thread Aditya (Jira)
Aditya created IGNITE-12603: --- Summary: Questions regarding Data Availability/Replication. Key: IGNITE-12603 URL: https://issues.apache.org/jira/browse/IGNITE-12603 Project: Ignite Issue Type: Wish

[jira] [Created] (IGNITE-12603) Questions regarding Data Availability/Replication.

2020-01-29 Thread Aditya (Jira)
Aditya created IGNITE-12603: --- Summary: Questions regarding Data Availability/Replication. Key: IGNITE-12603 URL: https://issues.apache.org/jira/browse/IGNITE-12603 Project: Ignite Issue Type: Wish

[jira] [Commented] (IGNITE-12584) Query execution is too long issue!

2020-01-27 Thread Aditya (Jira)
[ https://issues.apache.org/jira/browse/IGNITE-12584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024265#comment-17024265 ] Aditya commented on IGNITE-12584: - The Igntie metric when the warning is thrown is as f

[jira] [Created] (IGNITE-12584) Query execution is too long issue!

2020-01-27 Thread Aditya (Jira)
Aditya created IGNITE-12584: --- Summary: Query execution is too long issue! Key: IGNITE-12584 URL: https://issues.apache.org/jira/browse/IGNITE-12584 Project: Ignite Issue Type: Bug Repor

[jira] [Created] (IGNITE-12584) Query execution is too long issue!

2020-01-27 Thread Aditya (Jira)
Aditya created IGNITE-12584: --- Summary: Query execution is too long issue! Key: IGNITE-12584 URL: https://issues.apache.org/jira/browse/IGNITE-12584 Project: Ignite Issue Type: Bug Repor

[jira] [Updated] (BEAM-8423) Japanese characters encoding issue

2019-10-17 Thread Jyoti Aditya (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jyoti Aditya updated BEAM-8423: --- Description: I am running apache beam job to parse japanese html pages. While running the job, I see

[jira] [Updated] (BEAM-8423) Japanese characters encoding issue

2019-10-17 Thread Jyoti Aditya (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jyoti Aditya updated BEAM-8423: --- Description: I am running apache beam job to parse japanese html pages. While running the job, I see

[jira] [Created] (BEAM-8423) Japanese characters encoding issue

2019-10-17 Thread Jyoti Aditya (Jira)
Jyoti Aditya created BEAM-8423: -- Summary: Japanese characters encoding issue Key: BEAM-8423 URL: https://issues.apache.org/jira/browse/BEAM-8423 Project: Beam Issue Type: Bug Componen

[jira] [Updated] (SAMZA-2321) Samza-sql: Introduce REAL Samza sql schema type

2019-09-16 Thread Aditya (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya updated SAMZA-2321: -- Description: In Sql, REAL is 4-bytes while FLOAT and DOUBLE are both 8-bytes. While is Java and Avro, FLOAT is

[jira] [Created] (SAMZA-2321) Samza-sql: Introduce REAL Samza sql schema type

2019-09-16 Thread Aditya (Jira)
Aditya created SAMZA-2321: - Summary: Samza-sql: Introduce REAL Samza sql schema type Key: SAMZA-2321 URL: https://issues.apache.org/jira/browse/SAMZA-2321 Project: Samza Issue Type: Bug R

[jira] [Created] (SAMZA-2320) Samza-sql: Refactor validation to cover more cases and make it more extensible.

2019-09-13 Thread Aditya (Jira)
Aditya created SAMZA-2320: - Summary: Samza-sql: Refactor validation to cover more cases and make it more extensible. Key: SAMZA-2320 URL: https://issues.apache.org/jira/browse/SAMZA-2320 Project: Samza

[jira] [Assigned] (SAMZA-2314) Samza-sql: Validate Udf arguments in sql statement with the Udf syntax

2019-09-06 Thread Aditya (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya reassigned SAMZA-2314: - Assignee: Srinivasulu Punuru > Samza-sql: Validate Udf arguments in sql statement with the Udf syntax >

[jira] [Created] (SAMZA-2316) Samza-sql: Validate that all non-default value fields in output schema are set in the projected fields.

2019-09-03 Thread Aditya (Jira)
Aditya created SAMZA-2316: - Summary: Samza-sql: Validate that all non-default value fields in output schema are set in the projected fields. Key: SAMZA-2316 URL: https://issues.apache.org/jira/browse/SAMZA-2316

[jira] [Created] (SAMZA-2315) Samza-sql: Validate the operators that are supported by Calcite but not by Samza Sql.

2019-09-03 Thread Aditya (Jira)
Aditya created SAMZA-2315: - Summary: Samza-sql: Validate the operators that are supported by Calcite but not by Samza Sql. Key: SAMZA-2315 URL: https://issues.apache.org/jira/browse/SAMZA-2315 Project: Samza

[jira] [Created] (SAMZA-2314) Samza-sql: Validate Udf arguments in sql statement with the Udf syntax

2019-09-03 Thread Aditya (Jira)
Aditya created SAMZA-2314: - Summary: Samza-sql: Validate Udf arguments in sql statement with the Udf syntax Key: SAMZA-2314 URL: https://issues.apache.org/jira/browse/SAMZA-2314 Project: Samza Issue

[jira] [Created] (SAMZA-2313) Samza-sql: Add validation for Samza sql statements

2019-08-30 Thread Aditya (Jira)
Aditya created SAMZA-2313: - Summary: Samza-sql: Add validation for Samza sql statements Key: SAMZA-2313 URL: https://issues.apache.org/jira/browse/SAMZA-2313 Project: Samza Issue Type: Bug

[jira] [Commented] (SAMZA-1990) Samza framework should let using the same system stream as both input and output.

2019-08-23 Thread Aditya (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16914712#comment-16914712 ] Aditya commented on SAMZA-1990: --- Filed https://issues.apache.org/jira/browse/SAMZA-2310 >

[jira] [Created] (SAMZA-2310) Samza framework should differentiate between implicit and explicit intermediate streams

2019-08-23 Thread Aditya (Jira)
Aditya created SAMZA-2310: - Summary: Samza framework should differentiate between implicit and explicit intermediate streams Key: SAMZA-2310 URL: https://issues.apache.org/jira/browse/SAMZA-2310 Project: Samz

[jira] [Commented] (SAMZA-2310) Samza framework should differentiate between implicit and explicit intermediate streams

2019-08-23 Thread Aditya (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16914710#comment-16914710 ] Aditya commented on SAMZA-2310: --- cc [~pmaheshwari], [~psrinivasulu] > Samza framework shou

[jira] [Commented] (SAMZA-1990) Samza framework should let using the same system stream as both input and output.

2019-08-23 Thread Aditya (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16914287#comment-16914287 ] Aditya commented on SAMZA-1990: --- Discussed with [~psrinivasulu]. While changing createStrea

[jira] [Commented] (SAMZA-1990) Samza framework should let using the same system stream as both input and output.

2019-08-22 Thread Aditya (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16913370#comment-16913370 ] Aditya commented on SAMZA-1990: --- Unfortunately, this is not completely resolved. The stream

[jira] [Created] (SAMZA-2289) BuildOutputRecord hits OutOfBoundary exception

2019-08-01 Thread Aditya (JIRA)
Aditya created SAMZA-2289: - Summary: BuildOutputRecord hits OutOfBoundary exception Key: SAMZA-2289 URL: https://issues.apache.org/jira/browse/SAMZA-2289 Project: Samza Issue Type: Bug Re

[jira] [Created] (SAMZA-2288) Samza-sql: Make Udfs case-insensitive.

2019-08-01 Thread Aditya (JIRA)
Aditya created SAMZA-2288: - Summary: Samza-sql: Make Udfs case-insensitive. Key: SAMZA-2288 URL: https://issues.apache.org/jira/browse/SAMZA-2288 Project: Samza Issue Type: Bug Reporter:

[jira] [Updated] (FALCON-2344) Falcon Server Fails to start

2019-07-25 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/FALCON-2344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya updated FALCON-2344: --- Description: ``` root@sandbox-hdp falcon-0.11]# ./bin/falcon admin -version Hadoop is installed, adding h

[jira] [Created] (FALCON-2344) Falcon Server Fails to start

2019-07-25 Thread Aditya (JIRA)
Aditya created FALCON-2344: -- Summary: Falcon Server Fails to start Key: FALCON-2344 URL: https://issues.apache.org/jira/browse/FALCON-2344 Project: Falcon Issue Type: Bug Reporter: Adity

[jira] [Created] (SAMZA-2281) Samza-sql: Make Udfs case insensitive

2019-07-25 Thread Aditya (JIRA)
Aditya created SAMZA-2281: - Summary: Samza-sql: Make Udfs case insensitive Key: SAMZA-2281 URL: https://issues.apache.org/jira/browse/SAMZA-2281 Project: Samza Issue Type: Bug Reporter: A

[jira] [Created] (SAMZA-2270) Samza-sql: Fix ConsoleLoggingSystemFactory to handle null message value

2019-07-11 Thread Aditya (JIRA)
Aditya created SAMZA-2270: - Summary: Samza-sql: Fix ConsoleLoggingSystemFactory to handle null message value Key: SAMZA-2270 URL: https://issues.apache.org/jira/browse/SAMZA-2270 Project: Samza Issu

[jira] [Created] (SAMZA-2269) Making Samza Sql shell environment variable case sensitive as samza configs are case sensitive.

2019-07-10 Thread Aditya (JIRA)
Aditya created SAMZA-2269: - Summary: Making Samza Sql shell environment variable case sensitive as samza configs are case sensitive. Key: SAMZA-2269 URL: https://issues.apache.org/jira/browse/SAMZA-2269 Proje

[jira] [Created] (SPARK-28336) Tried running same code in local machine in IDE pycharm it running fine but issue arises when i setup all on EC2 my RDD has Json Value and convert it to data frame and s

2019-07-10 Thread Aditya (JIRA)
Aditya created SPARK-28336: -- Summary: Tried running same code in local machine in IDE pycharm it running fine but issue arises when i setup all on EC2 my RDD has Json Value and convert it to data frame and show dataframe by Show method it fails to show

[jira] [Commented] (SAMZA-1772) Support Table API for low-level Tasks with ExecutionPlanner

2019-03-19 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16796547#comment-16796547 ] Aditya commented on SAMZA-1772: --- [~pmaheshwari] this is done. It could be marked fixed. >

[jira] [Commented] (SAMZA-1955) TableConfigGenerator.generateConfigsForTableSpecs should take in original user provided configs

2019-03-19 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16796546#comment-16796546 ] Aditya commented on SAMZA-1955: --- Is it about the backdoor user configs to override the gene

[jira] [Created] (SAMZA-2111) Refactoring ApplicationRunnerMain code

2019-02-20 Thread Aditya (JIRA)
Aditya created SAMZA-2111: - Summary: Refactoring ApplicationRunnerMain code Key: SAMZA-2111 URL: https://issues.apache.org/jira/browse/SAMZA-2111 Project: Samza Issue Type: Bug Reporter:

[jira] [Updated] (SAMZA-1990) Samza framework should let using the same system stream as both input and output.

2019-02-20 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya updated SAMZA-1990: -- Description: Consider the following scenario: A StreamApplication containing two pipelines with the output Str

[jira] [Updated] (SAMZA-1990) Samza framework should let using the same system stream as both input and output.

2019-02-19 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya updated SAMZA-1990: -- Comment: was deleted (was: [~pmaheshwari]: Could we take a look at this for the table, where input and output

[jira] [Commented] (SAMZA-1990) Samza framework should let using the same system stream as both input and output.

2019-02-19 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16772367#comment-16772367 ] Aditya commented on SAMZA-1990: --- [~pmaheshwari]: Could we take a look at this for the table

[jira] [Created] (SAMZA-2047) Samza-sql: Fixing udfs that return samzasqlrelrecord type and other such types to work with joins.

2018-12-20 Thread Aditya (JIRA)
Aditya created SAMZA-2047: - Summary: Samza-sql: Fixing udfs that return samzasqlrelrecord type and other such types to work with joins. Key: SAMZA-2047 URL: https://issues.apache.org/jira/browse/SAMZA-2047 P

[jira] [Created] (SAMZA-2035) Samza-sql: Detect CachingTableDescritor as remote table for joins

2018-12-11 Thread Aditya (JIRA)
Aditya created SAMZA-2035: - Summary: Samza-sql: Detect CachingTableDescritor as remote table for joins Key: SAMZA-2035 URL: https://issues.apache.org/jira/browse/SAMZA-2035 Project: Samza Issue Type

[jira] [Created] (SAMZA-2021) Samza-sql: Adding an API to rel converter to filter out system messages.

2018-12-03 Thread Aditya (JIRA)
Aditya created SAMZA-2021: - Summary: Samza-sql: Adding an API to rel converter to filter out system messages. Key: SAMZA-2021 URL: https://issues.apache.org/jira/browse/SAMZA-2021 Project: Samza Iss

[jira] [Created] (SAMZA-2017) Update committer doc

2018-11-30 Thread Aditya (JIRA)
Aditya created SAMZA-2017: - Summary: Update committer doc Key: SAMZA-2017 URL: https://issues.apache.org/jira/browse/SAMZA-2017 Project: Samza Issue Type: Bug Reporter: Aditya

[jira] [Created] (SAMZA-2014) Samza-sql: Support table as both source (for join) and destination in the same application

2018-11-30 Thread Aditya (JIRA)
Aditya created SAMZA-2014: - Summary: Samza-sql: Support table as both source (for join) and destination in the same application Key: SAMZA-2014 URL: https://issues.apache.org/jira/browse/SAMZA-2014 Project: S

[jira] [Created] (SAMZA-2007) Samza-sql: Fix Samza-SQL to not expect LogicalTableModify in the Calcite plan.

2018-11-27 Thread Aditya (JIRA)
Aditya created SAMZA-2007: - Summary: Samza-sql: Fix Samza-SQL to not expect LogicalTableModify in the Calcite plan. Key: SAMZA-2007 URL: https://issues.apache.org/jira/browse/SAMZA-2007 Project: Samza

[jira] [Created] (SAMZA-2001) Samza-sql: Handle null records in rel converter and in joins

2018-11-19 Thread Aditya (JIRA)
Aditya created SAMZA-2001: - Summary: Samza-sql: Handle null records in rel converter and in joins Key: SAMZA-2001 URL: https://issues.apache.org/jira/browse/SAMZA-2001 Project: Samza Issue Type: Bug

[jira] [Created] (SAMZA-1994) Table API: Add missed key lookups metric for table reads

2018-11-15 Thread Aditya (JIRA)
Aditya created SAMZA-1994: - Summary: Table API: Add missed key lookups metric for table reads Key: SAMZA-1994 URL: https://issues.apache.org/jira/browse/SAMZA-1994 Project: Samza Issue Type: Bug

[jira] [Created] (SAMZA-1991) Samza-sql: Implement DSL converter plugin manager

2018-11-12 Thread Aditya (JIRA)
Aditya created SAMZA-1991: - Summary: Samza-sql: Implement DSL converter plugin manager Key: SAMZA-1991 URL: https://issues.apache.org/jira/browse/SAMZA-1991 Project: Samza Issue Type: Bug

[jira] [Created] (SAMZA-1990) Samza framework should let using the same system stream as both input and output.

2018-11-12 Thread Aditya (JIRA)
Aditya created SAMZA-1990: - Summary: Samza framework should let using the same system stream as both input and output. Key: SAMZA-1990 URL: https://issues.apache.org/jira/browse/SAMZA-1990 Project: Samza

[jira] [Created] (SAMZA-1986) Samza-sql: Use system name along with stream name for streamId

2018-11-09 Thread Aditya (JIRA)
Aditya created SAMZA-1986: - Summary: Samza-sql: Use system name along with stream name for streamId Key: SAMZA-1986 URL: https://issues.apache.org/jira/browse/SAMZA-1986 Project: Samza Issue Type: B

[jira] [Updated] (SAMZA-1968) Samza-sql: Change Calcite sql type for samza sql rel message __key__ to accept any format.

2018-10-25 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya updated SAMZA-1968: -- Description: Currently, it is set to VARCHAR. private Table createTableFromRelSchema(RelDataType relationalSch

[jira] [Created] (SAMZA-1968) Samza-sql: Change Calcite sql type for samza sql rel message __key__ to accept any format.

2018-10-25 Thread Aditya (JIRA)
Aditya created SAMZA-1968: - Summary: Samza-sql: Change Calcite sql type for samza sql rel message __key__ to accept any format. Key: SAMZA-1968 URL: https://issues.apache.org/jira/browse/SAMZA-1968 Project: S

[jira] [Created] (SAMZA-1953) Remove TableDescriptorsProvider interface

2018-10-15 Thread Aditya (JIRA)
Aditya created SAMZA-1953: - Summary: Remove TableDescriptorsProvider interface Key: SAMZA-1953 URL: https://issues.apache.org/jira/browse/SAMZA-1953 Project: Samza Issue Type: Bug Reporte

[jira] [Created] (SAMZA-1927) Samza-sql: always repartition the stream denoted as table in stream-table join

2018-09-28 Thread Aditya (JIRA)
Aditya created SAMZA-1927: - Summary: Samza-sql: always repartition the stream denoted as table in stream-table join Key: SAMZA-1927 URL: https://issues.apache.org/jira/browse/SAMZA-1927 Project: Samza

[jira] [Assigned] (SAMZA-1903) Samza-sql: Fix stream-table join with UDF on the table

2018-09-24 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya reassigned SAMZA-1903: - Assignee: Aditya > Samza-sql: Fix stream-table join with UDF on the table >

[jira] [Created] (SAMZA-1903) Samza-sql: Fix stream-table join with UDF on the table

2018-09-24 Thread Aditya (JIRA)
Aditya created SAMZA-1903: - Summary: Samza-sql: Fix stream-table join with UDF on the table Key: SAMZA-1903 URL: https://issues.apache.org/jira/browse/SAMZA-1903 Project: Samza Issue Type: Bug

[jira] [Assigned] (SAMZA-1782) Make getTableSpecs API in TableConfigGenerator util class public

2018-07-24 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya reassigned SAMZA-1782: - Assignee: Aditya > Make getTableSpecs API in TableConfigGenerator util class public > --

[jira] [Created] (SAMZA-1782) Make getTableSpecs API in TableConfigGenerator util class public

2018-07-24 Thread Aditya (JIRA)
Aditya created SAMZA-1782: - Summary: Make getTableSpecs API in TableConfigGenerator util class public Key: SAMZA-1782 URL: https://issues.apache.org/jira/browse/SAMZA-1782 Project: Samza Issue Type:

[jira] [Created] (SAMZA-1779) Fix Fix SamzaSql AvroRelConverter to handle BYTES and FIXED avro schema types

2018-07-23 Thread Aditya (JIRA)
Aditya created SAMZA-1779: - Summary: Fix Fix SamzaSql AvroRelConverter to handle BYTES and FIXED avro schema types Key: SAMZA-1779 URL: https://issues.apache.org/jira/browse/SAMZA-1779 Project: Samza

[jira] [Created] (SAMZA-1774) Support low-level Table API

2018-07-19 Thread Aditya (JIRA)
Aditya created SAMZA-1774: - Summary: Support low-level Table API Key: SAMZA-1774 URL: https://issues.apache.org/jira/browse/SAMZA-1774 Project: Samza Issue Type: Bug Reporter: Aditya

[jira] [Created] (SAMZA-1772) Support Table API for low-level Tasks with ExecutionPlanner

2018-07-18 Thread Aditya (JIRA)
Aditya created SAMZA-1772: - Summary: Support Table API for low-level Tasks with ExecutionPlanner Key: SAMZA-1772 URL: https://issues.apache.org/jira/browse/SAMZA-1772 Project: Samza Issue Type: Bug

[jira] [Assigned] (SAMZA-1612) Stream-table join: Number of partitions deduced for partitionBy for the stream to be joined does not take into account the partitions in the table

2018-07-13 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya reassigned SAMZA-1612: - Assignee: Ahmed Abdul Hamid > Stream-table join: Number of partitions deduced for partitionBy for the >

[jira] [Assigned] (SAMZA-1613) Stream-table join: Intermediate streams do not inherit bootstrap stream semantic

2018-07-13 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya reassigned SAMZA-1613: - Assignee: Ahmed Abdul Hamid > Stream-table join: Intermediate streams do not inherit bootstrap stream >

[jira] [Created] (SAMZA-1755) Samza-sql: Fix JsonRelConverter to recursively convert relRecords to basic java types.

2018-06-21 Thread Aditya (JIRA)
Aditya created SAMZA-1755: - Summary: Samza-sql: Fix JsonRelConverter to recursively convert relRecords to basic java types. Key: SAMZA-1755 URL: https://issues.apache.org/jira/browse/SAMZA-1755 Project: Samza

[jira] [Created] (SAMZA-1740) Samza-sql: Move SamzaSqlRelRecord class out of SamzaSqlRelMessage (for UDFs).

2018-06-05 Thread Aditya (JIRA)
Aditya created SAMZA-1740: - Summary: Samza-sql: Move SamzaSqlRelRecord class out of SamzaSqlRelMessage (for UDFs). Key: SAMZA-1740 URL: https://issues.apache.org/jira/browse/SAMZA-1740 Project: Samza

[jira] [Created] (SAMZA-1728) BootstrappingChooser: Call checkOffset only for a lagging partition while choosing.

2018-05-23 Thread Aditya (JIRA)
Aditya created SAMZA-1728: - Summary: BootstrappingChooser: Call checkOffset only for a lagging partition while choosing. Key: SAMZA-1728 URL: https://issues.apache.org/jira/browse/SAMZA-1728 Project: Samza

[jira] [Created] (HIVE-19648) Multiple left outer join in single HQL query is giving wrong result .

2018-05-22 Thread aditya (JIRA)
aditya created HIVE-19648: - Summary: Multiple left outer join in single HQL query is giving wrong result . Key: HIVE-19648 URL: https://issues.apache.org/jira/browse/HIVE-19648 Project: Hive Issue T

[jira] [Resolved] (SAMZA-1693) Samza-sql: Adding Serde for rel record

2018-04-30 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya resolved SAMZA-1693. --- Resolution: Fixed > Samza-sql: Adding Serde for rel record > -- > >

[jira] [Resolved] (SAMZA-1681) Samza-sql: Add support for handling older record schema versions in AvroRelConverter

2018-04-30 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya resolved SAMZA-1681. --- Resolution: Fixed > Samza-sql: Add support for handling older record schema versions in > AvroRelConverter >

[jira] [Created] (SAMZA-1693) Samza-sql: Adding Serde for rel record

2018-04-30 Thread Aditya (JIRA)
Aditya created SAMZA-1693: - Summary: Samza-sql: Adding Serde for rel record Key: SAMZA-1693 URL: https://issues.apache.org/jira/browse/SAMZA-1693 Project: Samza Issue Type: Bug Reporter:

[jira] [Created] (SAMZA-1681) Samza-sql: Add support for handling older record schema versions in AvroRelConverter

2018-04-23 Thread Aditya (JIRA)
Aditya created SAMZA-1681: - Summary: Samza-sql: Add support for handling older record schema versions in AvroRelConverter Key: SAMZA-1681 URL: https://issues.apache.org/jira/browse/SAMZA-1681 Project: Samza

[jira] [Assigned] (SAMZA-1681) Samza-sql: Add support for handling older record schema versions in AvroRelConverter

2018-04-23 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya reassigned SAMZA-1681: - Assignee: Aditya > Samza-sql: Add support for handling older record schema versions in > AvroRelConverte

[jira] [Updated] (SAMZA-1603) Samza-Sql: Support nested conversion of avro to samza rel message

2018-04-23 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya updated SAMZA-1603: -- Summary: Samza-Sql: Support nested conversion of avro to samza rel message (was: Samza-Sql: Support deep conver

[jira] [Created] (SAMZA-1679) Samza-sql: Add Avro schema evolution support in AvroRelConverter

2018-04-23 Thread Aditya (JIRA)
Aditya created SAMZA-1679: - Summary: Samza-sql: Add Avro schema evolution support in AvroRelConverter Key: SAMZA-1679 URL: https://issues.apache.org/jira/browse/SAMZA-1679 Project: Samza Issue Type:

[jira] [Reopened] (SAMZA-1601) Add stream-table join support for Samza Sql

2018-04-20 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya reopened SAMZA-1601: --- > Add stream-table join support for Samza Sql > --- > > Ke

[jira] [Assigned] (SAMZA-1619) Samza-sql: Support serialization of nested samza sql relational message

2018-04-20 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya reassigned SAMZA-1619: - Assignee: Aditya > Samza-sql: Support serialization of nested samza sql relational message >

[jira] [Resolved] (SAMZA-1619) Samza-sql: Support serialization of nested samza sql relational message

2018-04-20 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya resolved SAMZA-1619. --- Resolution: Fixed > Samza-sql: Support serialization of nested samza sql relational message >

[jira] [Assigned] (SAMZA-1601) Add stream-table join support for Samza Sql

2018-04-20 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya reassigned SAMZA-1601: - Assignee: Aditya > Add stream-table join support for Samza Sql >

[jira] [Resolved] (SAMZA-1601) Add stream-table join support for Samza Sql

2018-04-20 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya resolved SAMZA-1601. --- Resolution: Fixed > Add stream-table join support for Samza Sql > ---

[jira] [Assigned] (SAMZA-1651) Samza-sql: Implement GROUP BY SQL operator

2018-04-20 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya reassigned SAMZA-1651: - Assignee: Aditya > Samza-sql: Implement GROUP BY SQL operator > -

[jira] [Resolved] (SAMZA-1651) Samza-sql: Implement GROUP BY SQL operator

2018-04-20 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya resolved SAMZA-1651. --- Resolution: Fixed > Samza-sql: Implement GROUP BY SQL operator > -- >

[jira] [Created] (SAMZA-1661) Window high level API: During shutdown of RocksDb store while shutting down Samza job, RocksDb runs into an assertion

2018-04-16 Thread Aditya (JIRA)
Aditya created SAMZA-1661: - Summary: Window high level API: During shutdown of RocksDb store while shutting down Samza job, RocksDb runs into an assertion Key: SAMZA-1661 URL: https://issues.apache.org/jira/browse/SAMZA-1

[jira] [Created] (SAMZA-1652) Window high level API: End Of Stream message does not fire Window trigger

2018-04-12 Thread Aditya (JIRA)
Aditya created SAMZA-1652: - Summary: Window high level API: End Of Stream message does not fire Window trigger Key: SAMZA-1652 URL: https://issues.apache.org/jira/browse/SAMZA-1652 Project: Samza Is

[jira] [Created] (SAMZA-1651) Samza-sql: Implement GROUP BY SQL operator

2018-04-12 Thread Aditya (JIRA)
Aditya created SAMZA-1651: - Summary: Samza-sql: Implement GROUP BY SQL operator Key: SAMZA-1651 URL: https://issues.apache.org/jira/browse/SAMZA-1651 Project: Samza Issue Type: Bug Report

[jira] [Created] (SAMZA-1650) Window high level API: Trigger is not fired at the end of trigger interval for tumbling window

2018-04-12 Thread Aditya (JIRA)
Aditya created SAMZA-1650: - Summary: Window high level API: Trigger is not fired at the end of trigger interval for tumbling window Key: SAMZA-1650 URL: https://issues.apache.org/jira/browse/SAMZA-1650 Projec

[jira] [Created] (SAMZA-1641) Samza-sql: Write UTs for all translators - filter, project and join.

2018-04-09 Thread Aditya (JIRA)
Aditya created SAMZA-1641: - Summary: Samza-sql: Write UTs for all translators - filter, project and join. Key: SAMZA-1641 URL: https://issues.apache.org/jira/browse/SAMZA-1641 Project: Samza Issue T

[jira] [Created] (SAMZA-1632) KinesisConfig: Making getProxyHost and getProxyPort APIs protected

2018-03-29 Thread Aditya (JIRA)
Aditya created SAMZA-1632: - Summary: KinesisConfig: Making getProxyHost and getProxyPort APIs protected Key: SAMZA-1632 URL: https://issues.apache.org/jira/browse/SAMZA-1632 Project: Samza Issue Typ

[jira] [Resolved] (SAMZA-1611) BootstrappingChooser should use systemAdmin offsetComparator API to compare the offsets

2018-03-13 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya resolved SAMZA-1611. --- Resolution: Fixed > BootstrappingChooser should use systemAdmin offsetComparator API to compare > the offsets

[jira] [Created] (SAMZA-1620) Samza-sql stream-table join: Support UDFs in join condition

2018-03-13 Thread Aditya (JIRA)
Aditya created SAMZA-1620: - Summary: Samza-sql stream-table join: Support UDFs in join condition Key: SAMZA-1620 URL: https://issues.apache.org/jira/browse/SAMZA-1620 Project: Samza Issue Type: Bug

[jira] [Updated] (SAMZA-1619) Samza-sql: Support serialization of nested samza sql relational message

2018-03-13 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya updated SAMZA-1619: -- Summary: Samza-sql: Support serialization of nested samza sql relational message (was: Samza-sql: Support deep

[jira] [Created] (SAMZA-1619) Samza-sql: Support deep serialization of samza relational message

2018-03-13 Thread Aditya (JIRA)
Aditya created SAMZA-1619: - Summary: Samza-sql: Support deep serialization of samza relational message Key: SAMZA-1619 URL: https://issues.apache.org/jira/browse/SAMZA-1619 Project: Samza Issue Type

[jira] [Created] (SAMZA-1617) Samza-Sql: Support broadcast/global table for stream-table join

2018-03-12 Thread Aditya (JIRA)
Aditya created SAMZA-1617: - Summary: Samza-Sql: Support broadcast/global table for stream-table join Key: SAMZA-1617 URL: https://issues.apache.org/jira/browse/SAMZA-1617 Project: Samza Issue Type:

[jira] [Created] (SAMZA-1616) Samza-Sql: Support remote table for stream-table join

2018-03-12 Thread Aditya (JIRA)
Aditya created SAMZA-1616: - Summary: Samza-Sql: Support remote table for stream-table join Key: SAMZA-1616 URL: https://issues.apache.org/jira/browse/SAMZA-1616 Project: Samza Issue Type: Bug

[jira] [Created] (SAMZA-1614) Stream-table join: While doing a local table join, validate that the number of partitions in stream and table that are joined are equal.

2018-03-11 Thread Aditya (JIRA)
Aditya created SAMZA-1614: - Summary: Stream-table join: While doing a local table join, validate that the number of partitions in stream and table that are joined are equal. Key: SAMZA-1614 URL: https://issues.apache.org

[jira] [Created] (SAMZA-1613) Stream-table join: Intermediate streams do not inherit bootstrap stream semantic

2018-03-11 Thread Aditya (JIRA)
Aditya created SAMZA-1613: - Summary: Stream-table join: Intermediate streams do not inherit bootstrap stream semantic Key: SAMZA-1613 URL: https://issues.apache.org/jira/browse/SAMZA-1613 Project: Samza

[jira] [Commented] (SAMZA-1612) Stream-table join: Number of partitions deduced for partitionBy for the stream to be joined does not take into account the partitions in the table

2018-03-11 Thread Aditya (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16394543#comment-16394543 ] Aditya commented on SAMZA-1612: --- [~weisong44] is aware of this bug and is planning to fix it

  1   2   >