[jira] [Commented] (FLINK-9555) Support table api in scala shell

2018-12-15 Thread sunjincheng (JIRA)
[ 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

[jira] [Commented] (FLINK-11067) Port TableEnvironments to Java

2018-12-14 Thread sunjincheng (JIRA)
[ 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

[jira] [Commented] (FLINK-11067) Port TableEnvironments to Java

2018-12-11 Thread sunjincheng (JIRA)
[ 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

[jira] [Closed] (FLINK-11125) Remove useless import

2018-12-11 Thread sunjincheng (JIRA)
[ 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

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

2018-12-10 Thread sunjincheng (JIRA)
[ 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

[jira] [Closed] (FLINK-11123) Improve ml quick start doc

2018-12-10 Thread sunjincheng (JIRA)
[ 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

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

2018-12-10 Thread sunjincheng (JIRA)
[ 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

[jira] [Created] (FLINK-11123) Improve ml quick start doc

2018-12-10 Thread sunjincheng (JIRA)
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

[jira] [Closed] (FLINK-10543) Leverage efficient timer deletion in relational operators

2018-12-09 Thread sunjincheng (JIRA)
[ 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

[jira] [Assigned] (FLINK-11091) Clear the use of deprecated methods of KeyedStream in table operators

2018-12-06 Thread sunjincheng (JIRA)
[ 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

[jira] [Created] (FLINK-11091) Clear the use of deprecated methods of KeyedStream in table operators

2018-12-06 Thread sunjincheng (JIRA)
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

[jira] [Closed] (FLINK-9555) Support table api in scala shell

2018-12-05 Thread sunjincheng (JIRA)
[ 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

[jira] [Updated] (FLINK-11045) UserCodeClassLoader has not been set correctly for RuntimeUDFContext in CollectionExecutor

2018-12-05 Thread sunjincheng (JIRA)
[ 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

[jira] [Closed] (FLINK-11045) UserCodeClassLoader has not been set correctly for RuntimeUDFContext in CollectionExecutor

2018-12-05 Thread sunjincheng (JIRA)
[ 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

[jira] [Reopened] (FLINK-11045) UserCodeClassLoader has not been set correctly for RuntimeUDFContext in CollectionExecutor

2018-12-05 Thread sunjincheng (JIRA)
[ 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

[jira] [Closed] (FLINK-11045) UserCodeClassLoader has not been set correctly for RuntimeUDFContext in CollectionExecutor

2018-12-05 Thread sunjincheng (JIRA)
[ 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

[jira] [Closed] (FLINK-11013) Fix distinct aggregates for group window in Table API

2018-12-03 Thread sunjincheng (JIRA)
[ 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

[jira] [Created] (FLINK-11052) Add Bounded(Group Window) FlatAggregate operator to batch Table API

2018-12-03 Thread sunjincheng (JIRA)
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

[jira] [Created] (FLINK-11051) Add Bounded(Group Window) FlatAggregate operator to streaming Table API

2018-12-03 Thread sunjincheng (JIRA)
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

[jira] [Updated] (FLINK-10972) Enhancements to Flink Table API

2018-12-03 Thread sunjincheng (JIRA)
[ 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

[jira] [Commented] (FLINK-10009) Fix the casting problem for function TIMESTAMPADD in Table

2018-11-27 Thread sunjincheng (JIRA)
[ 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

[jira] [Closed] (FLINK-10009) Fix the casting problem for function TIMESTAMPADD in Table

2018-11-26 Thread sunjincheng (JIRA)
[ 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

[jira] [Closed] (FLINK-10958) Add overload support for user defined function

2018-11-25 Thread sunjincheng (JIRA)
[ 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

[jira] [Updated] (FLINK-10972) Enhancements to Flink Table API

2018-11-22 Thread sunjincheng (JIRA)
[ 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

[jira] [Closed] (FLINK-10983) NonHAQueryableStateFsBackendITCase failed when run mvn install

2018-11-22 Thread sunjincheng (JIRA)
[ 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

[jira] [Updated] (FLINK-4557) Table API Stream Aggregations

2018-11-22 Thread sunjincheng (JIRA)
[ 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 > ---

[jira] [Updated] (FLINK-4557) Table API Stream Aggregations

2018-11-22 Thread sunjincheng (JIRA)
[ 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 > - > >

[jira] [Closed] (FLINK-10980) Wrong statement in CEP Scala part

2018-11-22 Thread sunjincheng (JIRA)
[ 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

[jira] [Updated] (FLINK-10834) TableAPI flatten() calculated value error

2018-11-21 Thread sunjincheng (JIRA)
[ 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

[jira] [Created] (FLINK-10978) Add UnBounded FlatAggregate operator to batch Table API

2018-11-21 Thread sunjincheng (JIRA)
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

[jira] [Created] (FLINK-10979) Add support for group keys in Unbounded Aggregate/FlatAggregate operator

2018-11-21 Thread sunjincheng (JIRA)
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

[jira] [Created] (FLINK-10977) Add UnBounded FlatAggregate operator to streaming Table API

2018-11-21 Thread sunjincheng (JIRA)
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

[jira] [Created] (FLINK-10976) Add Aggregate operator to Table API

2018-11-21 Thread sunjincheng (JIRA)
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

[jira] [Created] (FLINK-10975) Add support for TimeAttribute in Map/FlatMap operator

2018-11-21 Thread sunjincheng (JIRA)
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

[jira] [Created] (FLINK-10974) Add FlatMap to TableAPI

2018-11-21 Thread sunjincheng (JIRA)
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

[jira] [Created] (FLINK-10973) Add Map operator to Table API

2018-11-21 Thread sunjincheng (JIRA)
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

[jira] [Updated] (FLINK-10972) Enhancements to Flink Table API

2018-11-21 Thread sunjincheng (JIRA)
[ 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

[jira] [Updated] (FLINK-10972) Enhancements to Flink Table API

2018-11-21 Thread sunjincheng (JIRA)
[ 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 > --

[jira] [Updated] (FLINK-10972) Enhancements to Flink Table API

2018-11-21 Thread sunjincheng (JIRA)
[ 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

[jira] [Created] (FLINK-10972) Enhancements to Flink Table API

2018-11-21 Thread sunjincheng (JIRA)
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

[jira] [Commented] (FLINK-10875) Add `toTableWithTimestamp` method in `DataStreamConversions`

2018-11-18 Thread sunjincheng (JIRA)
[ 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

[jira] [Commented] (FLINK-10875) Add `toTableWithTimestamp` method in `DataStreamConversions`

2018-11-14 Thread sunjincheng (JIRA)
[ 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

[jira] [Created] (FLINK-10875) Add `toTableWithTimestamp` method in `DataStreamConversions`

2018-11-14 Thread sunjincheng (JIRA)
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

[jira] [Commented] (FLINK-9555) Support table api in scala shell

2018-11-12 Thread sunjincheng (JIRA)
[ 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

[jira] [Commented] (FLINK-10819) The instability problem of CI, JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure test fail.

2018-11-09 Thread sunjincheng (JIRA)
[ 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

[jira] [Commented] (FLINK-10834) TableAPI flatten() calculated value error

2018-11-09 Thread sunjincheng (JIRA)
[ 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

[jira] [Updated] (FLINK-10834) TableAPI flatten() calculated value error

2018-11-08 Thread sunjincheng (JIRA)
[ 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

[jira] [Updated] (FLINK-10834) TableAPI flatten() calculated value error

2018-11-08 Thread sunjincheng (JIRA)
[ 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)

[jira] [Updated] (FLINK-10834) TableAPI flatten calculated value error

2018-11-08 Thread sunjincheng (JIRA)
[ 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

[jira] [Created] (FLINK-10834) TableAPI flatten calculated value error

2018-11-08 Thread sunjincheng (JIRA)
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

[jira] [Created] (FLINK-10819) The instability problem of CI, JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure test fail.

2018-11-08 Thread sunjincheng (JIRA)
sunjincheng created FLINK-10819: --- Summary: The instability problem of CI, JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure test fail. Key: FLINK-10819 URL: https://issues.apache.org/jira/browse/

[jira] [Closed] (FLINK-10676) Add 'as' method for OverWindowWithOrderBy in Java API

2018-11-08 Thread sunjincheng (JIRA)
[ 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

[jira] [Created] (FLINK-10676) Add 'as' method for OverWindowWithOrderBy in Java API

2018-10-25 Thread sunjincheng (JIRA)
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

[jira] [Closed] (FLINK-10639) Fix java syntax error in document

2018-10-22 Thread sunjincheng (JIRA)
[ 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

[jira] [Created] (FLINK-10639) Fix java syntax error in document

2018-10-22 Thread sunjincheng (JIRA)
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

[jira] [Commented] (FLINK-10542) Register Hive metastore as an external catalog in TableEnvironment

2018-10-12 Thread sunjincheng (JIRA)
[ 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

[jira] [Commented] (FLINK-10265) Configure checkpointing behavior for SQL Client

2018-10-11 Thread sunjincheng (JIRA)
[ 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

[jira] [Comment Edited] (FLINK-8355) DataSet Should not union a NULL row for AGG without GROUP BY clause.

2018-01-14 Thread sunjincheng (JIRA)
[ 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: -

[jira] [Commented] (FLINK-8355) DataSet Should not union a NULL row for AGG without GROUP BY clause.

2018-01-14 Thread sunjincheng (JIRA)
[ 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

[jira] [Commented] (FLINK-7578) WindowStream should support rich AggregateFunction

2018-01-09 Thread sunjincheng (JIRA)
[ 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

[jira] [Commented] (FLINK-8331) FieldParsers do not correctly set EMPT_COLUMN error state

2018-01-05 Thread sunjincheng (JIRA)
[ 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

[jira] [Closed] (FLINK-8331) FieldParsers do not correctly set EMPT_COLUMN error state

2018-01-05 Thread sunjincheng (JIRA)
[ 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

[jira] [Created] (FLINK-8355) DataSet Should not union a NULL row for AGG without GROUP BY clause.

2018-01-03 Thread sunjincheng (JIRA)
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

[jira] [Updated] (FLINK-8325) Add COUNT support constant parameter, COUNT(*), COUNT(1)

2018-01-03 Thread sunjincheng (JIRA)
[ 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

[jira] [Updated] (FLINK-8325) Add COUNT AGG support constant parameter, i.e. COUNT(*), COUNT(1)

2018-01-03 Thread sunjincheng (JIRA)
[ 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

[jira] [Commented] (FLINK-8325) Add support for constant parameters in GROUP WINDOW aggregate

2018-01-03 Thread sunjincheng (JIRA)
[ 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

[jira] [Assigned] (FLINK-8331) FieldParsers do not correctly set EMPT_COLUMN error state

2017-12-29 Thread sunjincheng (JIRA)
[ 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 > ---

[jira] [Closed] (FLINK-8312) Fix ScalarFunction varargs length exceeds 254 for SQL

2017-12-29 Thread sunjincheng (JIRA)
[ 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

[jira] [Commented] (FLINK-8169) Document timestamp and timezone behavior for Table API & SQL

2017-12-28 Thread sunjincheng (JIRA)
[ 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

[jira] [Created] (FLINK-8325) Add support for constant parameters in GROUP WINDOW aggregate

2017-12-28 Thread sunjincheng (JIRA)
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

[jira] [Created] (FLINK-8323) Fix Mod scala function bug

2017-12-27 Thread sunjincheng (JIRA)
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

[jira] [Closed] (FLINK-8301) Support Unicode in codegen for SQL && TableAPI

2017-12-26 Thread sunjincheng (JIRA)
[ 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

[jira] [Updated] (FLINK-8301) Support Unicode in codegen for SQL && TableAPI

2017-12-26 Thread sunjincheng (JIRA)
[ 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

[jira] [Commented] (FLINK-7594) Add a SQL client

2017-12-19 Thread sunjincheng (JIRA)
[ 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

issues@flink.apache.org

2017-12-19 Thread sunjincheng (JIRA)
[ 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 > ---

issues@flink.apache.org

2017-12-19 Thread sunjincheng (JIRA)
[ 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

[jira] [Created] (FLINK-7618) Add BINARY supported in FlinkTypeFactory

2017-09-14 Thread sunjincheng (JIRA)
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

issues@flink.apache.org

2017-09-04 Thread sunjincheng (JIRA)
[ 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

[jira] [Closed] (FLINK-7558) Improve SQL ValidationException message.

2017-09-04 Thread sunjincheng (JIRA)
[ 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

[jira] [Created] (FLINK-7572) Improve TableSchema ValidationException message.

2017-09-03 Thread sunjincheng (JIRA)
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

[jira] [Created] (FLINK-7558) Improve SQL ValidationException message.

2017-08-29 Thread sunjincheng (JIRA)
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

issues@flink.apache.org

2017-08-27 Thread sunjincheng (JIRA)
[ 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|

issues@flink.apache.org

2017-08-24 Thread sunjincheng (JIRA)
[ 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: -

issues@flink.apache.org

2017-08-24 Thread sunjincheng (JIRA)
[ 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: -

issues@flink.apache.org

2017-08-24 Thread sunjincheng (JIRA)
[ 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

issues@flink.apache.org

2017-08-22 Thread sunjincheng (JIRA)
[ 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: -

issues@flink.apache.org

2017-08-21 Thread sunjincheng (JIRA)
[ 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

[jira] [Created] (FLINK-7485) Using DataView interface to improve (MIN/MAX)WithRetractAggFunction.

2017-08-21 Thread sunjincheng (JIRA)
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

[jira] [Commented] (FLINK-7471) Improve bounded OVER support non-retract method AGG

2017-08-18 Thread sunjincheng (JIRA)
[ 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

[jira] [Created] (FLINK-7471) Improve bounded OVER support non-retract method AGG

2017-08-17 Thread sunjincheng (JIRA)
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

issues@flink.apache.org

2017-08-17 Thread sunjincheng (JIRA)
[ 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

issues@flink.apache.org

2017-08-17 Thread sunjincheng (JIRA)
[ 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

issues@flink.apache.org

2017-08-17 Thread sunjincheng (JIRA)
[ 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

issues@flink.apache.org

2017-08-17 Thread sunjincheng (JIRA)
[ 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 >

issues@flink.apache.org

2017-08-17 Thread sunjincheng (JIRA)
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

[jira] [Updated] (FLINK-6465) support FIRST_VALUE on Table API & SQL

2017-08-17 Thread sunjincheng (JIRA)
[ 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

issues@flink.apache.org

2017-08-17 Thread sunjincheng (JIRA)
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

[jira] [Updated] (FLINK-6465) support FIRST_VALUE on Table API & SQL

2017-08-15 Thread sunjincheng (JIRA)
[ 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

[jira] [Updated] (FLINK-6465) support FIRST_VALUE on Table API & SQL

2017-08-15 Thread sunjincheng (JIRA)
[ 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

[jira] [Updated] (FLINK-6465) support FIRST_VALUE on Table API & SQL

2017-08-15 Thread sunjincheng (JIRA)
[ 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

<    3   4   5   6   7   8   9   10   11   12   >