[
https://issues.apache.org/jira/browse/FLINK-12406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-12406:
---
Description:
After each job finishes, the new {{BLOCKING_PERSISTENT}} result partitions are
generat
[
https://issues.apache.org/jira/browse/FLINK-12406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-12406:
---
Description:
After each job finishes, the new {{BLOCKING_PERSISTENT}} result partitions are
generat
[
https://issues.apache.org/jira/browse/FLINK-12406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-12406:
---
Description:
After each job finishes, the new {{BLOCKING_PERSISTENT}} result partitions are
generat
[
https://issues.apache.org/jira/browse/FLINK-12406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-12406:
---
Description:
After each job finishes, the new {{BLOCKING_PERSISTENT}} result partitions are
generat
[
https://issues.apache.org/jira/browse/FLINK-12405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-12405:
---
Description:
The new {{ResultPartitionType}} : {{BLOCKING_PERSISTENT}} is similar to
{{BLOCKING}} e
[
https://issues.apache.org/jira/browse/FLINK-12405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-12405:
---
Description:
The new {{ResultPartitionType}} : {{BLOCKING_PERSISTENT}} is similar to
{{BLOCKING}} e
[
https://issues.apache.org/jira/browse/FLINK-12406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-12406:
---
Component/s: API / DataSet
> Report BLOCKING_PERSISTENT result partition meta back to client
> -
[
https://issues.apache.org/jira/browse/FLINK-12420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-12420:
---
Component/s: Table SQL / API
> Add support of cache/invalidateCache for TableAPI
> -
Ruidong Li created FLINK-12420:
--
Summary: Add support of cache/invalidateCache for TableAPI
Key: FLINK-12420
URL: https://issues.apache.org/jira/browse/FLINK-12420
Project: Flink
Issue Type: Sub
Ruidong Li created FLINK-12419:
--
Summary: Add support for consuming BLOCKING_PERSISTENT
ResultPartition
Key: FLINK-12419
URL: https://issues.apache.org/jira/browse/FLINK-12419
Project: Flink
Is
Ruidong Li created FLINK-12406:
--
Summary: Report BLOCKING_PERSISTENT result partition meta back to
client
Key: FLINK-12406
URL: https://issues.apache.org/jira/browse/FLINK-12406
Project: Flink
Ruidong Li created FLINK-12405:
--
Summary: Introduce BLOCKING_PERSISTENT result partition type
Key: FLINK-12405
URL: https://issues.apache.org/jira/browse/FLINK-12405
Project: Flink
Issue Type: S
Ruidong Li created FLINK-12000:
--
Summary: Introduce TableServiceManager to TableEnvironment
Key: FLINK-12000
URL: https://issues.apache.org/jira/browse/FLINK-12000
Project: Flink
Issue Type: Sub
Ruidong Li created FLINK-11999:
--
Summary: Introduce cache and invalidateCache API to Table
Key: FLINK-11999
URL: https://issues.apache.org/jira/browse/FLINK-11999
Project: Flink
Issue Type: Sub-
Ruidong Li created FLINK-11998:
--
Summary: Flink Interactive Programming (Umbrella JIRA)
Key: FLINK-11998
URL: https://issues.apache.org/jira/browse/FLINK-11998
Project: Flink
Issue Type: Improve
[
https://issues.apache.org/jira/browse/FLINK-6441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16706587#comment-16706587
]
Ruidong Li commented on FLINK-6441:
---
Thanks for [~twalthr] and [~hequn8128], This issue
[
https://issues.apache.org/jira/browse/FLINK-8921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li reassigned FLINK-8921:
-
Assignee: xueyu (was: Ruidong Li)
> Split code generated call expression
> ---
[
https://issues.apache.org/jira/browse/FLINK-8921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16662436#comment-16662436
]
Ruidong Li commented on FLINK-8921:
---
[~xueyu] thanks for you contribution, I assign thi
Ruidong Li created FLINK-10670:
--
Summary: Fix Correlate codegen error
Key: FLINK-10670
URL: https://issues.apache.org/jira/browse/FLINK-10670
Project: Flink
Issue Type: Bug
Components:
Ruidong Li created FLINK-10451:
--
Summary: TableFunctionCollector should handle the life cycle of
ScalarFunction
Key: FLINK-10451
URL: https://issues.apache.org/jira/browse/FLINK-10451
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586971#comment-16586971
]
Ruidong Li commented on FLINK-8868:
---
[~hequn8128] I've tried that SQL without 'Lateral'
[
https://issues.apache.org/jira/browse/FLINK-8868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-8868:
--
Description:
for stream sql:
support SQL like: SELECT * FROM TABLE(tf("a"))
for batch sql:
udtf might
[
https://issues.apache.org/jira/browse/FLINK-9716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16585380#comment-16585380
]
Ruidong Li edited comment on FLINK-9716 at 8/20/18 3:25 AM:
h
[
https://issues.apache.org/jira/browse/FLINK-9716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16585380#comment-16585380
]
Ruidong Li commented on FLINK-9716:
---
https://issues.apache.org/jira/browse/FLINK-8868
d
[
https://issues.apache.org/jira/browse/FLINK-9716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li reassigned FLINK-9716:
-
Assignee: Ruidong Li
> Support scans from table version function
> -
[
https://issues.apache.org/jira/browse/FLINK-8868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-8868:
--
Description:
for stream sql:
support SQL like: SELECT * FROM Lateral TABLE(tf("a"))
for batch sql:
udt
[
https://issues.apache.org/jira/browse/FLINK-8868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-8868:
--
Summary: Support Table Function as Table for Stream Sql (was: Support
Table Function as Table for stre
[
https://issues.apache.org/jira/browse/FLINK-8868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-8868:
--
Summary: Support Table Function as Table for stream sql (was: Support
Table Function as Table)
> Supp
[
https://issues.apache.org/jira/browse/FLINK-9433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574704#comment-16574704
]
Ruidong Li edited comment on FLINK-9433 at 8/9/18 12:07 PM:
H
[
https://issues.apache.org/jira/browse/FLINK-9433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574704#comment-16574704
]
Ruidong Li commented on FLINK-9433:
---
How about add a clear thread with Java DelayQueue
[
https://issues.apache.org/jira/browse/FLINK-10108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li reassigned FLINK-10108:
--
Assignee: Ruidong Li
> DATE_FORMAT function in sql test throws a NumberFormatException
>
[
https://issues.apache.org/jira/browse/FLINK-9997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16571818#comment-16571818
]
Ruidong Li commented on FLINK-9997:
---
Adding the Calc normalization to the logical optim
[
https://issues.apache.org/jira/browse/FLINK-9997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-9997:
--
Description:
There's no Calc node at normalize plans, so ReduceExpressionRule.CALC does not
match any
[
https://issues.apache.org/jira/browse/FLINK-9963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-9963:
--
Description:
Sometimes it might be useful to just read or write a single value into Kafka or
other con
[
https://issues.apache.org/jira/browse/FLINK-9963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-9963:
--
Description:
Sometimes it might be useful to just read or write a single value into Kafka or
other con
[
https://issues.apache.org/jira/browse/FLINK-9963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-9963:
--
Summary: Add a single value table format factory (was: Add a string table
format factory)
> Add a sin
[
https://issues.apache.org/jira/browse/FLINK-10008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li reassigned FLINK-10008:
--
Assignee: Ruidong Li
> Improve the LOG function in Table to support bases less than 1
> -
[
https://issues.apache.org/jira/browse/FLINK-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li reassigned FLINK-10009:
--
Assignee: Ruidong Li
> Fix the casting problem for function TIMESTAMPADD in Table
> -
[
https://issues.apache.org/jira/browse/FLINK-9905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563218#comment-16563218
]
Ruidong Li commented on FLINK-9905:
---
hi [~gfee-lyft], can you give me the program of yo
[
https://issues.apache.org/jira/browse/FLINK-9997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-9997:
--
Summary: Improve Expression Reduce (was: Improve ExpressionReduce)
> Improve Expression Reduce
> -
Ruidong Li created FLINK-9997:
-
Summary: Improve ExpressionReduce
Key: FLINK-9997
URL: https://issues.apache.org/jira/browse/FLINK-9997
Project: Flink
Issue Type: Improvement
Components
[
https://issues.apache.org/jira/browse/FLINK-9984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li reassigned FLINK-9984:
-
Assignee: Ruidong Li
> Add a byte array table format factory
> -
[
https://issues.apache.org/jira/browse/FLINK-9965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li reassigned FLINK-9965:
-
Assignee: Ruidong Li
> Support schema derivation in Avro table format factory
>
[
https://issues.apache.org/jira/browse/FLINK-9963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li reassigned FLINK-9963:
-
Assignee: Ruidong Li
> Add a string table format factory
> -
>
>
Ruidong Li created FLINK-9958:
-
Summary: Fix potential NPE for delta iteration of DataSet
Key: FLINK-9958
URL: https://issues.apache.org/jira/browse/FLINK-9958
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16493560#comment-16493560
]
Ruidong Li commented on FLINK-9422:
---
[~fhueske], I'm working on the issue. I have some
[
https://issues.apache.org/jira/browse/FLINK-9344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-9344:
--
Description: support non-window intersect and non-window intersect all for
both SQL and TableAPI (was:
[
https://issues.apache.org/jira/browse/FLINK-9433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16490484#comment-16490484
]
Ruidong Li commented on FLINK-9433:
---
One thread per task will not work, I think it shoul
Ruidong Li created FLINK-9433:
-
Summary: SystemProcessingTimeService does not work properly
Key: FLINK-9433
URL: https://issues.apache.org/jira/browse/FLINK-9433
Project: Flink
Issue Type: Improv
[
https://issues.apache.org/jira/browse/FLINK-9420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li reassigned FLINK-9420:
-
Assignee: Ruidong Li
> Add tests for SQL IN sub-query operator in streaming
> ---
[
https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li reassigned FLINK-9422:
-
Assignee: Ruidong Li
> Dedicated operator for UNION on streaming tables with time attributes
> --
[
https://issues.apache.org/jira/browse/FLINK-7814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7814:
--
Summary: Add BETWEEN and NOT BETWEEN expression to Table API (was: Add
BETWEEN expression to Table API
[
https://issues.apache.org/jira/browse/FLINK-7814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li reassigned FLINK-7814:
-
Assignee: Ruidong Li
> Add BETWEEN expression to Table API
> ---
Ruidong Li created FLINK-9346:
-
Summary: Update documents for supporting intersect/except in
streaming
Key: FLINK-9346
URL: https://issues.apache.org/jira/browse/FLINK-9346
Project: Flink
Issue
Ruidong Li created FLINK-9345:
-
Summary: Support EXCEPT and EXCEPT ALL for streaming
Key: FLINK-9345
URL: https://issues.apache.org/jira/browse/FLINK-9345
Project: Flink
Issue Type: Improvement
Ruidong Li created FLINK-9344:
-
Summary: Support INTERSECT and INTERSECT ALL for streaming
Key: FLINK-9344
URL: https://issues.apache.org/jira/browse/FLINK-9344
Project: Flink
Issue Type: Improve
Ruidong Li created FLINK-9332:
-
Summary: Fix Codegen error of CallGenerator
Key: FLINK-9332
URL: https://issues.apache.org/jira/browse/FLINK-9332
Project: Flink
Issue Type: Bug
Compon
Ruidong Li created FLINK-9216:
-
Summary: Fix comparator violation
Key: FLINK-9216
URL: https://issues.apache.org/jira/browse/FLINK-9216
Project: Flink
Issue Type: Bug
Components: Stream
[
https://issues.apache.org/jira/browse/FLINK-8921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li reassigned FLINK-8921:
-
Assignee: Ruidong Li
> Split code generated call expression
> --
Ruidong Li created FLINK-8868:
-
Summary: Support Table Function as Table
Key: FLINK-8868
URL: https://issues.apache.org/jira/browse/FLINK-8868
Project: Flink
Issue Type: Improvement
Com
[
https://issues.apache.org/jira/browse/FLINK-8821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-8821:
--
Summary: Fix non-terminating decimal error (was: Fix BigDecimal divide in
AvgAggFunction)
> Fix non-te
Ruidong Li created FLINK-8821:
-
Summary: Fix BigDecimal divide in AvgAggFunction
Key: FLINK-8821
URL: https://issues.apache.org/jira/browse/FLINK-8821
Project: Flink
Issue Type: Bug
Com
Ruidong Li created FLINK-8617:
-
Summary: Fix code generation bug while accessing Map type
Key: FLINK-8617
URL: https://issues.apache.org/jira/browse/FLINK-8617
Project: Flink
Issue Type: Bug
Ruidong Li created FLINK-8555:
-
Summary: Fix TableFunction varargs length exceeds 254 for SQL
Key: FLINK-8555
URL: https://issues.apache.org/jira/browse/FLINK-8555
Project: Flink
Issue Type: Impr
Ruidong Li created FLINK-8312:
-
Summary: Fix ScalarFunction varargs length exceeds 254 for SQL
Key: FLINK-8312
URL: https://issues.apache.org/jira/browse/FLINK-8312
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li reassigned FLINK-8277:
-
Assignee: Ruidong Li
> Optimize code generation by using local references
> -
[
https://issues.apache.org/jira/browse/FLINK-8301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-8301:
--
Summary: Support Unicode in codegen for SQL && TableAPI (was: Support
Unicode in codegen for SQL)
> Su
[
https://issues.apache.org/jira/browse/FLINK-8301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-8301:
--
Summary: Support Unicode in codegen for SQL (was: Support Unicode in
codegen for TableAPI && SQL)
> Su
[
https://issues.apache.org/jira/browse/FLINK-8301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-8301:
--
Description:
The current code generation do not support Unicode, "\u0001" will be generated
to "\\u0001
Ruidong Li created FLINK-8301:
-
Summary: Support Unicode in codegen for TableAPI && SQL
Key: FLINK-8301
URL: https://issues.apache.org/jira/browse/FLINK-8301
Project: Flink
Issue Type: Improvemen
Ruidong Li created FLINK-8274:
-
Summary: Fix Java 64K method compiling limitation for CommonCalc
Key: FLINK-8274
URL: https://issues.apache.org/jira/browse/FLINK-8274
Project: Flink
Issue Type: I
Ruidong Li created FLINK-8095:
-
Summary: Introduce ProjectSetOpTransposeRule to Flink
Key: FLINK-8095
URL: https://issues.apache.org/jira/browse/FLINK-8095
Project: Flink
Issue Type: Improvement
Ruidong Li created FLINK-7986:
-
Summary: Introduce FilterSetOpTransposeRule to Flink
Key: FLINK-7986
URL: https://issues.apache.org/jira/browse/FLINK-7986
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7971:
--
Description:
In {{GroupAggProcessFunction}}， the status of {{state}} and {{cntState}} are
not consiste
Ruidong Li created FLINK-7971:
-
Summary: Fix potential NPE with inconsistent state
Key: FLINK-7971
URL: https://issues.apache.org/jira/browse/FLINK-7971
Project: Flink
Issue Type: Bug
C
[
https://issues.apache.org/jira/browse/FLINK-7759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7759:
--
Summary: Fix Bug that fieldName with Boolean prefix can't be parsed by
ExpressionParser. (was: Fix Bug
[
https://issues.apache.org/jira/browse/FLINK-7759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7759:
--
Summary: Fix Bug that fieldName with prefix equals "true" or "false" can't
be parsed by ExpressionParser
[
https://issues.apache.org/jira/browse/FLINK-7776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7776:
--
Description:
the current group aggregation will compare the last {{Row}} and current {{Row}}
when {{gen
[
https://issues.apache.org/jira/browse/FLINK-7776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7776:
--
Summary: do not emit duplicated records in group aggregation (was: remove
duplicated records collecting
[
https://issues.apache.org/jira/browse/FLINK-7776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7776:
--
Summary: remove duplicated records collecting in group aggregation (was:
remove duplicate records colle
[
https://issues.apache.org/jira/browse/FLINK-7776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7776:
--
Summary: remove duplicate records collecting in group aggregation (was:
remove duplicate records in gro
Ruidong Li created FLINK-7776:
-
Summary: remove duplicate records in group aggregation
Key: FLINK-7776
URL: https://issues.apache.org/jira/browse/FLINK-7776
Project: Flink
Issue Type: Improvement
Ruidong Li created FLINK-7759:
-
Summary: Fix Bug that fieldName/functionName with prefix equals
"true" or "false" can't be parsed by ExpressionParser.
Key: FLINK-7759
URL: https://issues.apache.org/jira/browse/FLINK-7
[
https://issues.apache.org/jira/browse/FLINK-7621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7621:
--
Summary: Fix Inconsistency of CaseSensitive Configuration (was: Fix
inconsistency of CaseSensitive Conf
Ruidong Li created FLINK-7621:
-
Summary: Fix inconsistency of CaseSensitive Configuration
Key: FLINK-7621
URL: https://issues.apache.org/jira/browse/FLINK-7621
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-7596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7596:
--
Summary: fix bug when Set Operation handles ANY type (was: Fix bug during
Set Operation (Union, Minus .
[
https://issues.apache.org/jira/browse/FLINK-7596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7596:
--
Description:
If two inputs with Any(GenericRelDataType), when they comes to Set
Operation(Union, minus.
[
https://issues.apache.org/jira/browse/FLINK-7596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7596:
--
Description:
If two inputs with Any(GenericRelDataType), when they comes to Set
Operation(Union, minus.
[
https://issues.apache.org/jira/browse/FLINK-7596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7596:
--
Description:
If two inputs with Any(GenericRelDataType), when they comes to Set
Operation(Union, minus.
[
https://issues.apache.org/jira/browse/FLINK-7596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7596:
--
Description:
If two inputs with Any(GenericRelDataType), when they comes to Set
Operation(Union, minus.
[
https://issues.apache.org/jira/browse/FLINK-7596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7596:
--
Description:
If two inputs with Any(GenericRelDataType), when they comes to Set
Operation(Union, minus.
Ruidong Li created FLINK-7596:
-
Summary: Fix bug during Set Operation (Union, Minus ... ) with
Any(GenericRelDataType)
Key: FLINK-7596
URL: https://issues.apache.org/jira/browse/FLINK-7596
Project: Flink
Ruidong Li created FLINK-7385:
-
Summary: Fix ArrayIndexOutOfBoundsException when object-reuse is
enabled
Key: FLINK-7385
URL: https://issues.apache.org/jira/browse/FLINK-7385
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-7194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16091036#comment-16091036
]
Ruidong Li commented on FLINK-7194:
---
{{ScalarFunction.getResultType()}} has parameters w
[
https://issues.apache.org/jira/browse/FLINK-7194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16089419#comment-16089419
]
Ruidong Li commented on FLINK-7194:
---
[~fhueske]I agree to your suggestion, but the {{get
[
https://issues.apache.org/jira/browse/FLINK-7168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li closed FLINK-7168.
-
Resolution: Duplicate
> Add support for Table API & SQL steam-stream inner/left join
> --
Ruidong Li created FLINK-7168:
-
Summary: Add support for Table API & SQL steam-stream inner/left
join
Key: FLINK-7168
URL: https://issues.apache.org/jira/browse/FLINK-7168
Project: Flink
Issue
Ruidong Li created FLINK-7163:
-
Summary: Make LogicalTableFunctionCall immutable
Key: FLINK-7163
URL: https://issues.apache.org/jira/browse/FLINK-7163
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li reassigned FLINK-7014:
-
Assignee: Ruidong Li
> Expose isDeterministic interface to ScalarFunction and TableFunction
> ---
Ruidong Li created FLINK-7014:
-
Summary: Expose isDeterministic interface to ScalarFunction and
TableFunction
Key: FLINK-7014
URL: https://issues.apache.org/jira/browse/FLINK-7014
Project: Flink
1 - 100 of 117 matches
Mail list logo
