[
https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16722166#comment-16722166
]
sunjincheng commented on FLINK-9555:
[~Zentol] Why don't we solve it by file a new ji
[
https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721116#comment-16721116
]
sunjincheng commented on FLINK-11067:
-
It meant that we move `TableEnvironment ` fro
[
https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16718513#comment-16718513
]
sunjincheng commented on FLINK-11067:
-
We list the two ways users use BatchTableEnvi
[
https://issues.apache.org/jira/browse/FLINK-11125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-11125.
---
Resolution: Fixed
Fix Version/s: 1.8.0
Fixed in master: ff42f874d1016ac77df54cf162f95b278b89a
[
https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16716377#comment-16716377
]
sunjincheng commented on FLINK-10543:
-
Revert in release-1.7: d3966332d4fe37fd22f92c
[
https://issues.apache.org/jira/browse/FLINK-11123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-11123.
---
Resolution: Fixed
Fix Version/s: 1.6.3
Fixed in master: 156c09ced9a61d20e2e5d4ce5cfedab8ac4d4
[
https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16716101#comment-16716101
]
sunjincheng commented on FLINK-10543:
-
Hi [~fhueske] from the point of compatibility
sunjincheng created FLINK-11123:
---
Summary: Improve ml quick start doc
Key: FLINK-11123
URL: https://issues.apache.org/jira/browse/FLINK-11123
Project: Flink
Issue Type: Improvement
Co
[
https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-10543.
---
Resolution: Fixed
Fix Version/s: 1.7.1
1.8.0
Fixed in master: 5716e4d9f64f
[
https://issues.apache.org/jira/browse/FLINK-11091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-11091:
---
Assignee: sunjincheng
> Clear the use of deprecated methods of KeyedStream in table operato
sunjincheng created FLINK-11091:
---
Summary: Clear the use of deprecated methods of KeyedStream in
table operators
Key: FLINK-11091
URL: https://issues.apache.org/jira/browse/FLINK-11091
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-9555.
--
Resolution: Fixed
Fix Version/s: 1.7.1
1.8.0
Fixed in master: b3a378ad9608844
[
https://issues.apache.org/jira/browse/FLINK-11045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11045:
Fix Version/s: 1.7.1
1.8.0
1.6.3
> UserCodeClassLoader has n
[
https://issues.apache.org/jira/browse/FLINK-11045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-11045.
---
Resolution: Fixed
> UserCodeClassLoader has not been set correctly for RuntimeUDFContext in
> Colle
[
https://issues.apache.org/jira/browse/FLINK-11045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reopened FLINK-11045:
-
set fix version
> UserCodeClassLoader has not been set correctly for RuntimeUDFContext in
> Collec
[
https://issues.apache.org/jira/browse/FLINK-11045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-11045.
---
Resolution: Fixed
Fixed in master: 3eac4193b31dd4b9bcf0bd09e2adc02bda4a2873
Fixed in release-1.7: 65
[
https://issues.apache.org/jira/browse/FLINK-11013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-11013.
---
Resolution: Fixed
Fix Version/s: 1.7.1
Release Note: Fix distinct aggregates for group wi
sunjincheng created FLINK-11052:
---
Summary: Add Bounded(Group Window) FlatAggregate operator to batch
Table API
Key: FLINK-11052
URL: https://issues.apache.org/jira/browse/FLINK-11052
Project: Flink
sunjincheng created FLINK-11051:
---
Summary: Add Bounded(Group Window) FlatAggregate operator to
streaming Table API
Key: FLINK-11051
URL: https://issues.apache.org/jira/browse/FLINK-11051
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-10972:
Description:
With the continuous efforts from the community, the Flink system has been
continuous
[
https://issues.apache.org/jira/browse/FLINK-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16700121#comment-16700121
]
sunjincheng commented on FLINK-10009:
-
Thanks [~twalthr]
> Fix the casting problem
[
https://issues.apache.org/jira/browse/FLINK-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-10009.
---
Resolution: Fixed
Fixed in master: cd09fbf606c9f508b7d6879247b3a371ed7a1920
> Fix the casting probl
[
https://issues.apache.org/jira/browse/FLINK-10958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-10958.
---
Resolution: Fixed
Fixed in master: d9c7f97790a8d396ffed59feee6b3e0c523aa173
> Add overload support
[
https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-10972:
Description:
With the continuous efforts from the community, the Flink system has been
continuous
[
https://issues.apache.org/jira/browse/FLINK-10983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-10983.
---
Resolution: Fixed
Fixed in master: 7854e84e51f3c5fd2363cbdc51cfaa597de570f7
Fixed in release-1.7: 55
[
https://issues.apache.org/jira/browse/FLINK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-4557:
---
Component/s: (was: Table API & SQL)
> Table API Stream Aggregations
> ---
[
https://issues.apache.org/jira/browse/FLINK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-4557:
---
Component/s: Table API & SQL
> Table API Stream Aggregations
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-10980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-10980.
---
Resolution: Fixed
Fixed in master: cbf5f0c937e9181314824789bb43162a2f97716e
> Wrong statement in CE
[
https://issues.apache.org/jira/browse/FLINK-10834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-10834:
Issue Type: Sub-task (was: Bug)
Parent: FLINK-10972
> TableAPI flatten() calculated value
sunjincheng created FLINK-10978:
---
Summary: Add UnBounded FlatAggregate operator to batch Table API
Key: FLINK-10978
URL: https://issues.apache.org/jira/browse/FLINK-10978
Project: Flink
Issue T
sunjincheng created FLINK-10979:
---
Summary: Add support for group keys in Unbounded
Aggregate/FlatAggregate operator
Key: FLINK-10979
URL: https://issues.apache.org/jira/browse/FLINK-10979
Project: Flink
sunjincheng created FLINK-10977:
---
Summary: Add UnBounded FlatAggregate operator to streaming Table
API
Key: FLINK-10977
URL: https://issues.apache.org/jira/browse/FLINK-10977
Project: Flink
Is
sunjincheng created FLINK-10976:
---
Summary: Add Aggregate operator to Table API
Key: FLINK-10976
URL: https://issues.apache.org/jira/browse/FLINK-10976
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-10975:
---
Summary: Add support for TimeAttribute in Map/FlatMap operator
Key: FLINK-10975
URL: https://issues.apache.org/jira/browse/FLINK-10975
Project: Flink
Issue Typ
sunjincheng created FLINK-10974:
---
Summary: Add FlatMap to TableAPI
Key: FLINK-10974
URL: https://issues.apache.org/jira/browse/FLINK-10974
Project: Flink
Issue Type: Sub-task
Componen
sunjincheng created FLINK-10973:
---
Summary: Add Map operator to Table API
Key: FLINK-10973
URL: https://issues.apache.org/jira/browse/FLINK-10973
Project: Flink
Issue Type: Sub-task
Co
[
https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-10972:
Description:
With the continuous efforts from the community, the Flink system has been
continuous
[
https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-10972:
Issue Type: New Feature (was: Improvement)
> Enhancements to Flink Table API
> --
[
https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-10972:
Description:
With the continuous efforts from the community, the Flink system has been
continuous
sunjincheng created FLINK-10972:
---
Summary: Enhancements to Flink Table API
Key: FLINK-10972
URL: https://issues.apache.org/jira/browse/FLINK-10972
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-10875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16691161#comment-16691161
]
sunjincheng commented on FLINK-10875:
-
Thanks for the feedback [~fhueske] !
It is a
[
https://issues.apache.org/jira/browse/FLINK-10875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686220#comment-16686220
]
sunjincheng commented on FLINK-10875:
-
Hi, [~fhueske] [~twalthr] , does this change
sunjincheng created FLINK-10875:
---
Summary: Add `toTableWithTimestamp` method in
`DataStreamConversions`
Key: FLINK-10875
URL: https://issues.apache.org/jira/browse/FLINK-10875
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684704#comment-16684704
]
sunjincheng commented on FLINK-9555:
Thanks for report this issue Jeff Zhang !
+1 to
[
https://issues.apache.org/jira/browse/FLINK-10819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681469#comment-16681469
]
sunjincheng commented on FLINK-10819:
-
Thanks [~till.rohrmann], I am sorry that I di
[
https://issues.apache.org/jira/browse/FLINK-10834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681236#comment-16681236
]
sunjincheng commented on FLINK-10834:
-
Hi,[~fhueske],
Thanks for your comments!
I
[
https://issues.apache.org/jira/browse/FLINK-10834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-10834:
Description:
We have a UDF as follows:
{code:java}
object FuncRow extends ScalarFunction {
def ev
[
https://issues.apache.org/jira/browse/FLINK-10834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-10834:
Summary: TableAPI flatten() calculated value error (was: TableAPI flatten
calculated value error)
[
https://issues.apache.org/jira/browse/FLINK-10834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-10834:
Description:
We have a UDF as follows:
{code:java}
object FuncRow extends ScalarFunction {
de
sunjincheng created FLINK-10834:
---
Summary: TableAPI flatten calculated value error
Key: FLINK-10834
URL: https://issues.apache.org/jira/browse/FLINK-10834
Project: Flink
Issue Type: Bug
sunjincheng created FLINK-10819:
---
Summary: The instability problem of CI,
JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure test fail.
Key: FLINK-10819
URL: https://issues.apache.org/jira/browse/
[
https://issues.apache.org/jira/browse/FLINK-10676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-10676.
---
Resolution: Fixed
Release Note: Change the over window preceding clause from required to
optio
sunjincheng created FLINK-10676:
---
Summary: Add 'as' method for OverWindowWithOrderBy in Java API
Key: FLINK-10676
URL: https://issues.apache.org/jira/browse/FLINK-10676
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-10639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-10639.
---
Resolution: Fixed
Fixed in master: 49d56c1d3da608325cc6a4c4796ae03ce305cb6a
fixed in release-1.6: bc
sunjincheng created FLINK-10639:
---
Summary: Fix java syntax error in document
Key: FLINK-10639
URL: https://issues.apache.org/jira/browse/FLINK-10639
Project: Flink
Issue Type: Bug
Com
[
https://issues.apache.org/jira/browse/FLINK-10542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16648654#comment-16648654
]
sunjincheng commented on FLINK-10542:
-
+1, This is a very important work for flink e
[
https://issues.apache.org/jira/browse/FLINK-10265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16647218#comment-16647218
]
sunjincheng commented on FLINK-10265:
-
Hi,[~twalthr] [~yanghua] I agree that we shou
[
https://issues.apache.org/jira/browse/FLINK-8355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325903#comment-16325903
]
sunjincheng edited comment on FLINK-8355 at 1/15/18 5:41 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-8355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325903#comment-16325903
]
sunjincheng commented on FLINK-8355:
Hi [~fhueske] Thanks for your suggestion. I open
[
https://issues.apache.org/jira/browse/FLINK-7578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16317975#comment-16317975
]
sunjincheng commented on FLINK-7578:
Hi [~hequn8128] May be the issue is fixed by
htt
[
https://issues.apache.org/jira/browse/FLINK-8331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16313571#comment-16313571
]
sunjincheng commented on FLINK-8331:
Fixed in 1.4 1c7a7fa706e9b373bbe395398507378a6175
[
https://issues.apache.org/jira/browse/FLINK-8331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-8331.
--
Resolution: Fixed
Fixed in 1.5.0 9dd3a859b1609d27ccc80a3da86456e533895b7a
> FieldParsers do not correct
sunjincheng created FLINK-8355:
--
Summary: DataSet Should not union a NULL row for AGG without GROUP
BY clause.
Key: FLINK-8355
URL: https://issues.apache.org/jira/browse/FLINK-8355
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-8325:
---
Summary: Add COUNT support constant parameter, COUNT(*), COUNT(1) (was:
Add support for constant para
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-8325:
---
Summary: Add COUNT AGG support constant parameter, i.e. COUNT(*), COUNT(1)
(was: Add COUNT support c
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16309715#comment-16309715
]
sunjincheng commented on FLINK-8325:
After I check the detail I find that only `Count
[
https://issues.apache.org/jira/browse/FLINK-8331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-8331:
--
Assignee: sunjincheng
> FieldParsers do not correctly set EMPT_COLUMN error state
> ---
[
https://issues.apache.org/jira/browse/FLINK-8312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-8312.
--
Resolution: Fixed
Fixed in 91f00ec91b55b28a59114e88127af2f85f279eb5
> Fix ScalarFunction varargs lengt
[
https://issues.apache.org/jira/browse/FLINK-8169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305527#comment-16305527
]
sunjincheng commented on FLINK-8169:
Hi [~twalthr] +1 to clear the processing of time
sunjincheng created FLINK-8325:
--
Summary: Add support for constant parameters in GROUP WINDOW
aggregate
Key: FLINK-8325
URL: https://issues.apache.org/jira/browse/FLINK-8325
Project: Flink
Issu
sunjincheng created FLINK-8323:
--
Summary: Fix Mod scala function bug
Key: FLINK-8323
URL: https://issues.apache.org/jira/browse/FLINK-8323
Project: Flink
Issue Type: Sub-task
Component
[
https://issues.apache.org/jira/browse/FLINK-8301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-8301.
--
Resolution: Fixed
1.4.0 Fixed in 47c067a5924e56abeb5a3d0769b6356f19a66b1e
1.5.0 Fixed in edf10c714fb1fe
[
https://issues.apache.org/jira/browse/FLINK-8301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-8301:
---
Affects Version/s: 1.5.0
1.4.0
> Support Unicode in codegen for SQL && TableAPI
[
https://issues.apache.org/jira/browse/FLINK-7594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16297045#comment-16297045
]
sunjincheng commented on FLINK-7594:
+1, It's a good enhancement to flink.
> Add a SQ
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-7465.
--
Resolution: Workaround
> Add build-in BloomFilterCount on TableAPI&SQL
> ---
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16296981#comment-16296981
]
sunjincheng commented on FLINK-7465:
I close this issue because I notices that current
sunjincheng created FLINK-7618:
--
Summary: Add BINARY supported in FlinkTypeFactory
Key: FLINK-7618
URL: https://issues.apache.org/jira/browse/FLINK-7618
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16153054#comment-16153054
]
sunjincheng commented on FLINK-7465:
Hi [~jparkie] Thanks for your suggestion. At curr
[
https://issues.apache.org/jira/browse/FLINK-7558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-7558.
--
Resolution: Fixed
Release Note: Fixed in e6fddbc3e5bdb42764191990ac29ba382bbe6016
> Improve SQL Va
sunjincheng created FLINK-7572:
--
Summary: Improve TableSchema ValidationException message.
Key: FLINK-7572
URL: https://issues.apache.org/jira/browse/FLINK-7572
Project: Flink
Issue Type: Improv
sunjincheng created FLINK-7558:
--
Summary: Improve SQL ValidationException message.
Key: FLINK-7558
URL: https://issues.apache.org/jira/browse/FLINK-7558
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143342#comment-16143342
]
sunjincheng commented on FLINK-7465:
Hi [~jparkie]When we deal with a [Dynamic
table|
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16139810#comment-16139810
]
sunjincheng edited comment on FLINK-7465 at 8/24/17 9:33 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16139810#comment-16139810
]
sunjincheng edited comment on FLINK-7465 at 8/24/17 9:32 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16139810#comment-16139810
]
sunjincheng commented on FLINK-7465:
Hi [~jparkie] [~fhueske] [~jark], Thanks for your
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136062#comment-16136062
]
sunjincheng edited comment on FLINK-7465 at 8/22/17 9:01 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136062#comment-16136062
]
sunjincheng commented on FLINK-7465:
[~fhueske] I want add accuracy and maxElement as
sunjincheng created FLINK-7485:
--
Summary: Using DataView interface to improve
(MIN/MAX)WithRetractAggFunction.
Key: FLINK-7485
URL: https://issues.apache.org/jira/browse/FLINK-7485
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16132090#comment-16132090
]
sunjincheng commented on FLINK-7471:
We know it's poor compute if all aggregates for e
sunjincheng created FLINK-7471:
--
Summary: Improve bounded OVER support non-retract method AGG
Key: FLINK-7471
URL: https://issues.apache.org/jira/browse/FLINK-7471
Project: Flink
Issue Type: Imp
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-7465:
---
Description:
In this JIRA. use BloomFilter to implement counting functions.
BloomFilter Algorithm desc
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-7465:
---
Description:
In this JIRA. use BloomFilter to implement counting functions.
BloomFilter Algorithm desc
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-7465:
---
Description:
In this JIRA. use BloomFilter to implement counting functions.
BloomFilter Algorithm desc
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-7465:
---
Attachment: bloomfilter.png
> Add build-in BloomFilterCount on TableAPI&SQL
>
sunjincheng created FLINK-7465:
--
Summary: Add build-in BloomFilterCount on TableAPI&SQL
Key: FLINK-7465
URL: https://issues.apache.org/jira/browse/FLINK-7465
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6465:
---
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-7464
> support FIRST_VALUE on Table API
sunjincheng created FLINK-7464:
--
Summary: Add useful build-in Aggregate function into TabalAPI&SQL
Key: FLINK-7464
URL: https://issues.apache.org/jira/browse/FLINK-7464
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6465:
---
Description:
{{FIRST_VALUE}}is a over window function. In this JIRA. will add
{{FIRST_VALUE}} functio
[
https://issues.apache.org/jira/browse/FLINK-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6465:
---
Description:
{{FIRST_VALUE}} is a OVER WINDOW function. In this JIRA. will add
{{FIRST_VALUE}} functi
[
https://issues.apache.org/jira/browse/FLINK-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6465:
---
Description:
{{FIRST_VALUE}} is a OVER WINDOW function. In this JIRA. will add
{{FIRST_VALUE}} functi
701 - 800 of 1390 matches
Mail list logo