[
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
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
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
[
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
>
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
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
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
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
[
https://issues.apache.org/jira/browse/SAMZA-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16914712#comment-16914712
]
Aditya commented on SAMZA-1990:
---
Filed https://issues.apache.org/jira/browse/SAMZA-2310
> Samza framework
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:
[
https://issues.apache.org/jira/browse/SAMZA-2310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16914710#comment-16914710
]
Aditya commented on SAMZA-2310:
---
cc [~pmaheshwari], [~psrinivasulu]
> Samza framework should differentiate
[
https://issues.apache.org/jira/browse/SAMZA-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16914287#comment-16914287
]
Aditya commented on SAMZA-1990:
---
Discussed with [~psrinivasulu]. While changing createStream implementation
[
https://issues.apache.org/jira/browse/SAMZA-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16913370#comment-16913370
]
Aditya commented on SAMZA-1990:
---
Unfortunately, this is not completely resolved. The stream which is both
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:
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:
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
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
[
https://issues.apache.org/jira/browse/SAMZA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796547#comment-16796547
]
Aditya commented on SAMZA-1772:
---
[~pmaheshwari] this is done. It could be marked fixed.
> Support Table
[
https://issues.apache.org/jira/browse/SAMZA-1955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796546#comment-16796546
]
Aditya commented on SAMZA-1955:
---
Is it about the backdoor user configs to override the generated configs ?
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:
[
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
[
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
[
https://issues.apache.org/jira/browse/SAMZA-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16772367#comment-16772367
]
Aditya commented on SAMZA-1990:
---
[~pmaheshwari]: Could we take a look at this for the table, where input
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
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
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
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
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:
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
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:
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
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
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
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:
[
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
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:
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
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
[
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
>
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
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
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
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
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
[
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
[
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
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:
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
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
[
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
> --
>
>
[
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
>
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:
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
[
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
>
[
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
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
[
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
> ---
>
>
[
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
>
[
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
>
[
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
>
[
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
> ---
[
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
>
[
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
> --
>
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:
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
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
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
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
[
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
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
[
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
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
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
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:
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
[
https://issues.apache.org/jira/browse/SAMZA-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16394543#comment-16394543
]
Aditya commented on SAMZA-1612:
---
[~weisong44] is aware of this bug and is planning to fix it.
>
Aditya created SAMZA-1612:
-
Summary: 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
Key: SAMZA-1612
URL:
Aditya created SAMZA-1611:
-
Summary: BootstrappingChooser should use systemAdmin
offsetComparator API to compare the offsets
Key: SAMZA-1611
URL: https://issues.apache.org/jira/browse/SAMZA-1611
Project:
Aditya created SAMZA-1606:
-
Summary: Samza-Sql Stream-table join: Add a way to validate the
primary key for table
Key: SAMZA-1606
URL: https://issues.apache.org/jira/browse/SAMZA-1606
Project: Samza
Aditya created SAMZA-1605:
-
Summary: Samza-Sql: Support stream-table join without join keyword
in the sql query
Key: SAMZA-1605
URL: https://issues.apache.org/jira/browse/SAMZA-1605
Project: Samza
Aditya created SAMZA-1604:
-
Summary: Samza-Sql: Support constant equality check in
stream-table join condition
Key: SAMZA-1604
URL: https://issues.apache.org/jira/browse/SAMZA-1604
Project: Samza
Aditya created SAMZA-1603:
-
Summary: Samza-Sql: Support deep conversion of avro to samza rel
message
Key: SAMZA-1603
URL: https://issues.apache.org/jira/browse/SAMZA-1603
Project: Samza
Issue Type:
[
https://issues.apache.org/jira/browse/SAMZA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aditya updated SAMZA-1601:
--
Issue Type: Task (was: Bug)
> Add stream-table join support for Samza Sql
>
[
https://issues.apache.org/jira/browse/SAMZA-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aditya resolved SAMZA-1502.
---
Resolution: Fixed
> Make AllSspToSingleTaskGrouper work with Yarn and ZK JobCoordinator
>
[
https://issues.apache.org/jira/browse/SAMZA-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aditya resolved SAMZA-1536.
---
Resolution: Fixed
> Add docs for Kinesis consumer
> -
>
> Key:
Aditya created SAMZA-1536:
-
Summary: Add docs for Kinesis consumer
Key: SAMZA-1536
URL: https://issues.apache.org/jira/browse/SAMZA-1536
Project: Samza
Issue Type: Bug
Reporter: Aditya
Aditya created SAMZA-1522:
-
Summary: Add ZkJobCoordinator API that checks if the leader
election is complete
Key: SAMZA-1522
URL: https://issues.apache.org/jira/browse/SAMZA-1522
Project: Samza
[
https://issues.apache.org/jira/browse/SAMZA-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aditya updated SAMZA-1522:
--
Priority: Minor (was: Major)
> Add ZkJobCoordinator API that checks if the leader election is complete
>
Aditya created SAMZA-1521:
-
Summary: Introduce JobCoordinator observer interface which does
only read operations on the JobCoordinator
Key: SAMZA-1521
URL: https://issues.apache.org/jira/browse/SAMZA-1521
Aditya created SAMZA-1502:
-
Summary: Make AllSspToSingleTaskGrouper work with Yarn and ZK
JobCoordinator
Key: SAMZA-1502
URL: https://issues.apache.org/jira/browse/SAMZA-1502
Project: Samza
Issue
90 matches
Mail list logo
