[jira] [Commented] (FLINK-13906) ExecutionConfigTests.test_equals_and_hash failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16920721#comment-16920721 ] Hequn Cheng commented on FLINK-13906: - Fixed in 1.10.0: 7470e44354b97a0320c35eccb80342affa654714 >

[jira] [Assigned] (FLINK-13906) ExecutionConfigTests.test_equals_and_hash failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-13906: --- Assignee: Hequn Cheng > ExecutionConfigTests.test_equals_and_hash failed on Travis >

[jira] [Assigned] (FLINK-13906) ExecutionConfigTests.test_equals_and_hash failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-13906: --- Assignee: Wei Zhong (was: Hequn Cheng) > ExecutionConfigTests.test_equals_and_hash failed

[jira] [Closed] (FLINK-13011) Release the PyFlink into PyPI

[ https://issues.apache.org/jira/browse/FLINK-13011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-13011. --- > Release the PyFlink into PyPI > - > > Key: FLINK-13011 >

[jira] [Resolved] (FLINK-13011) Release the PyFlink into PyPI

[ https://issues.apache.org/jira/browse/FLINK-13011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng resolved FLINK-13011. - Resolution: Resolved > Release the PyFlink into PyPI > - > >

[jira] [Commented] (FLINK-13011) Release the PyFlink into PyPI

[ https://issues.apache.org/jira/browse/FLINK-13011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916634#comment-16916634 ] Hequn Cheng commented on FLINK-13011: - Resolved in 1.10.0 (9eb59f59fd013232fa8b48b3517a8300573fd9b6)

[jira] [Updated] (FLINK-13011) Release the PyFlink into PyPI

[ https://issues.apache.org/jira/browse/FLINK-13011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-13011: Fix Version/s: 1.10.0 > Release the PyFlink into PyPI > - > >

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16913889#comment-16913889 ] Hequn Cheng commented on FLINK-13740: - The hotfix(b6645c0abcbbe6a94586916772b15bea15818d95) has been

[jira] [Closed] (FLINK-13772) GroupWindowTableAggregateITCase tests fail on Travis

[ https://issues.apache.org/jira/browse/FLINK-13772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-13772. --- Resolution: Fixed > GroupWindowTableAggregateITCase tests fail on Travis >

[jira] [Comment Edited] (FLINK-13772) GroupWindowTableAggregateITCase tests fail on Travis

[ https://issues.apache.org/jira/browse/FLINK-13772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16913849#comment-16913849 ] Hequn Cheng edited comment on FLINK-13772 at 8/23/19 3:03 AM: -- As discussed

[jira] [Commented] (FLINK-13772) GroupWindowTableAggregateITCase tests fail on Travis

[ https://issues.apache.org/jira/browse/FLINK-13772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16913849#comment-16913849 ] Hequn Cheng commented on FLINK-13772: - Same problem as in FLINK-13740 >

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16913845#comment-16913845 ] Hequn Cheng commented on FLINK-13740: - Hi, [~jark] [~lzljs3620320] the same problem is reported by

[jira] [Comment Edited] (FLINK-13757) Document error for `logical functions`

[ https://issues.apache.org/jira/browse/FLINK-13757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16912982#comment-16912982 ] Hequn Cheng edited comment on FLINK-13757 at 8/22/19 5:29 AM: -- Fix in

[jira] [Updated] (FLINK-13757) Document error for `logical functions`

[ https://issues.apache.org/jira/browse/FLINK-13757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-13757: Fix Version/s: 1.9.1 > Document error for `logical functions` >

[jira] [Commented] (FLINK-13757) Document error for `logical functions`

[ https://issues.apache.org/jira/browse/FLINK-13757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16912982#comment-16912982 ] Hequn Cheng commented on FLINK-13757: - Fix in master: 647563a7e0e366eb83fb59066bb5058dd41a8e0c

[jira] [Assigned] (FLINK-13809) The log directory of Flink Python API is unwritable if it is installed via "sudo"

[ https://issues.apache.org/jira/browse/FLINK-13809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-13809: --- Assignee: Wei Zhong (was: Hequn Cheng) > The log directory of Flink Python API is

[jira] [Commented] (FLINK-13809) The log directory of Flink Python API is unwritable if it is installed via "sudo"

[ https://issues.apache.org/jira/browse/FLINK-13809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16912103#comment-16912103 ] Hequn Cheng commented on FLINK-13809: - [~zhongwei] Thanks a lot for reporting the error. I have now

[jira] [Assigned] (FLINK-13809) The log directory of Flink Python API is unwritable if it is installed via "sudo"

[ https://issues.apache.org/jira/browse/FLINK-13809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-13809: --- Assignee: Hequn Cheng > The log directory of Flink Python API is unwritable if it is

[jira] [Assigned] (FLINK-13757) Document error for `logical functions`

[ https://issues.apache.org/jira/browse/FLINK-13757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-13757: --- Assignee: hehuiyuan > Document error for `logical functions` >

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16908756#comment-16908756 ] Hequn Cheng commented on FLINK-13740: - [~jark] You are right. Furthermore, we may also have to

[jira] [Comment Edited] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16908715#comment-16908715 ] Hequn Cheng edited comment on FLINK-13740 at 8/16/19 5:14 AM: --

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16908715#comment-16908715 ] Hequn Cheng commented on FLINK-13740: - [~till.rohrmann] Thanks a lot for pointing out the failure.

[jira] [Resolved] (FLINK-13637) Anchors not working in document(building.md, common.md, queryable_state.md)

[ https://issues.apache.org/jira/browse/FLINK-13637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng resolved FLINK-13637. - Resolution: Fixed > Anchors not working in document(building.md, common.md, queryable_state.md)

[jira] [Commented] (FLINK-13637) Anchors not working in document(building.md, common.md, queryable_state.md)

[ https://issues.apache.org/jira/browse/FLINK-13637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903919#comment-16903919 ] Hequn Cheng commented on FLINK-13637: - Fix in master: 56c6b487ee1bc395d700579f69f9fb8884724243 1.9:

[jira] [Resolved] (FLINK-13594) Improve the 'from_element' method of flink python api to apply to blink planner

[ https://issues.apache.org/jira/browse/FLINK-13594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng resolved FLINK-13594. - Resolution: Fixed > Improve the 'from_element' method of flink python api to apply to blink >

[jira] [Closed] (FLINK-13594) Improve the 'from_element' method of flink python api to apply to blink planner

[ https://issues.apache.org/jira/browse/FLINK-13594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-13594. --- > Improve the 'from_element' method of flink python api to apply to blink > planner >

[jira] [Commented] (FLINK-13594) Improve the 'from_element' method of flink python api to apply to blink planner

[ https://issues.apache.org/jira/browse/FLINK-13594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16902797#comment-16902797 ] Hequn Cheng commented on FLINK-13594: - As blink planner is the key feature of release-1.9. We should

[jira] [Assigned] (FLINK-13637) Anchors not working in document(building.md, common.md, queryable_state.md)

[ https://issues.apache.org/jira/browse/FLINK-13637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-13637: --- Assignee: Hequn Cheng > Anchors not working in document(building.md, common.md,

[jira] [Created] (FLINK-13637) Anchors not working in document(building.md, common.md, queryable_state.md)

Hequn Cheng created FLINK-13637: --- Summary: Anchors not working in document(building.md, common.md, queryable_state.md) Key: FLINK-13637 URL: https://issues.apache.org/jira/browse/FLINK-13637 Project:

[jira] [Closed] (FLINK-13446) Row count sliding window outputs incorrectly in blink planner

[ https://issues.apache.org/jira/browse/FLINK-13446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-13446. --- Resolution: Not A Problem > Row count sliding window outputs incorrectly in blink planner >

[jira] [Commented] (FLINK-13446) Row count sliding window outputs incorrectly in blink planner

[ https://issues.apache.org/jira/browse/FLINK-13446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897206#comment-16897206 ] Hequn Cheng commented on FLINK-13446: - [~twalthr] Thanks a lot for your suggestions. Great that we

[jira] [Commented] (FLINK-13446) Row count sliding window outputs incorrectly in blink planner

[ https://issues.apache.org/jira/browse/FLINK-13446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16895982#comment-16895982 ] Hequn Cheng commented on FLINK-13446: - Hi [~jark] I'm hesitating on the two options. It seems both

[jira] [Commented] (FLINK-13446) Row count sliding window outputs incorrectly in blink planner

[ https://issues.apache.org/jira/browse/FLINK-13446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16894373#comment-16894373 ] Hequn Cheng commented on FLINK-13446: - Thank you. I will open the PR soon. Would be great if you can

[jira] [Created] (FLINK-13446) Row count sliding window outputs incorrectly in blink planner

Hequn Cheng created FLINK-13446: --- Summary: Row count sliding window outputs incorrectly in blink planner Key: FLINK-13446 URL: https://issues.apache.org/jira/browse/FLINK-13446 Project: Flink

[jira] [Commented] (FLINK-12249) Type equivalence check fails for Window Aggregates

[ https://issues.apache.org/jira/browse/FLINK-12249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891524#comment-16891524 ] Hequn Cheng commented on FLINK-12249: - [~sunjincheng121] Good suggestion! I have created FLINK-13392

[jira] [Created] (FLINK-13392) WindowAggregate inherited from Aggregate incorrectly

Hequn Cheng created FLINK-13392: --- Summary: WindowAggregate inherited from Aggregate incorrectly Key: FLINK-13392 URL: https://issues.apache.org/jira/browse/FLINK-13392 Project: Flink Issue

[jira] [Commented] (FLINK-12249) Type equivalence check fails for Window Aggregates

[ https://issues.apache.org/jira/browse/FLINK-12249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16888670#comment-16888670 ] Hequn Cheng commented on FLINK-12249: - Same with the comments from [~godfreyhe]. I have verified the

[jira] [Commented] (FLINK-12249) Type equivalence check fails for Window Aggregates

[ https://issues.apache.org/jira/browse/FLINK-12249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16887179#comment-16887179 ] Hequn Cheng commented on FLINK-12249: - Hi [~dawidwys], You are right. I think you have pointed out

[jira] [Comment Edited] (FLINK-12249) Type equivalence check fails for Window Aggregates

[ https://issues.apache.org/jira/browse/FLINK-12249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885902#comment-16885902 ] Hequn Cheng edited comment on FLINK-12249 at 7/17/19 8:44 AM: --

[jira] [Commented] (FLINK-12249) Type equivalence check fails for Window Aggregates

[ https://issues.apache.org/jira/browse/FLINK-12249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885902#comment-16885902 ] Hequn Cheng commented on FLINK-12249: - [~sunjincheng121] Thanks for your suggestions. I think you

[jira] [Created] (FLINK-13196) Fix Ambiguous column name exception bug for Table API

Hequn Cheng created FLINK-13196: --- Summary: Fix Ambiguous column name exception bug for Table API Key: FLINK-13196 URL: https://issues.apache.org/jira/browse/FLINK-13196 Project: Flink Issue

[jira] [Created] (FLINK-13087) Add group window Aggregate operator to Table API

Hequn Cheng created FLINK-13087: --- Summary: Add group window Aggregate operator to Table API Key: FLINK-13087 URL: https://issues.apache.org/jira/browse/FLINK-13087 Project: Flink Issue Type:

[jira] [Updated] (FLINK-13057) Correct comments in ListState class

[ https://issues.apache.org/jira/browse/FLINK-13057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-13057: Description: ListState can be a keyed state or an operator state, but the comment in ListState

[jira] [Created] (FLINK-13057) Correct comments in ListState class

Hequn Cheng created FLINK-13057: --- Summary: Correct comments in ListState class Key: FLINK-13057 URL: https://issues.apache.org/jira/browse/FLINK-13057 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-12846) Carry primary key and unique key information in TableSchema

[ https://issues.apache.org/jira/browse/FLINK-12846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16868170#comment-16868170 ] Hequn Cheng commented on FLINK-12846: - +1 for adding the key information! Primary key and unique key

[jira] [Commented] (FLINK-12906) Port OperationTreeBuilder to Java

[ https://issues.apache.org/jira/browse/FLINK-12906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16867684#comment-16867684 ] Hequn Cheng commented on FLINK-12906: - [~dawidwys] Sure, just take it. Thank you for your help. >

[jira] [Created] (FLINK-12906) Port OperationTreeBuilder to Java

Hequn Cheng created FLINK-12906: --- Summary: Port OperationTreeBuilder to Java Key: FLINK-12906 URL: https://issues.apache.org/jira/browse/FLINK-12906 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-12533) Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type

[ https://issues.apache.org/jira/browse/FLINK-12533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-12533. --- Resolution: Duplicate > Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type >

[jira] [Commented] (FLINK-12533) Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type

[ https://issues.apache.org/jira/browse/FLINK-12533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16865470#comment-16865470 ] Hequn Cheng commented on FLINK-12533: - Close this jira. It will be solved in 

[jira] [Updated] (FLINK-12797) Remove duplicate tests in GroupWindowTableAggregateValidationTest

[ https://issues.apache.org/jira/browse/FLINK-12797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-12797: Environment: (was: Some tests in \{{GroupWindowTableAggregateValidationTest}} are duplicate

[jira] [Updated] (FLINK-12797) Remove duplicate tests in GroupWindowTableAggregateValidationTest

[ https://issues.apache.org/jira/browse/FLINK-12797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-12797: Description: Some tests in {{GroupWindowTableAggregateValidationTest}} are duplicate with tests

[jira] [Created] (FLINK-12797) Remove duplicate tests in GroupWindowTableAggregateValidationTest

Hequn Cheng created FLINK-12797: --- Summary: Remove duplicate tests in GroupWindowTableAggregateValidationTest Key: FLINK-12797 URL: https://issues.apache.org/jira/browse/FLINK-12797 Project: Flink

[jira] [Assigned] (FLINK-12794) Support ACC mode for non-window streaming FlatAggregate on Table API

[ https://issues.apache.org/jira/browse/FLINK-12794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-12794: --- Assignee: Hequn Cheng > Support ACC mode for non-window streaming FlatAggregate on Table

[jira] [Created] (FLINK-12789) Fix java docs in UserDefinedAggregateFunction

Hequn Cheng created FLINK-12789: --- Summary: Fix java docs in UserDefinedAggregateFunction Key: FLINK-12789 URL: https://issues.apache.org/jira/browse/FLINK-12789 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-12779) Avoid field conflicts when generate field names for non-composite Typeinformation

Hequn Cheng created FLINK-12779: --- Summary: Avoid field conflicts when generate field names for non-composite Typeinformation Key: FLINK-12779 URL: https://issues.apache.org/jira/browse/FLINK-12779

[jira] [Created] (FLINK-12778) Fix deriveTableAggRowType bug for non-composite types

Hequn Cheng created FLINK-12778: --- Summary: Fix deriveTableAggRowType bug for non-composite types Key: FLINK-12778 URL: https://issues.apache.org/jira/browse/FLINK-12778 Project: Flink Issue

[jira] [Commented] (FLINK-12737) Loosen Table class dependencies

[ https://issues.apache.org/jira/browse/FLINK-12737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16857204#comment-16857204 ] Hequn Cheng commented on FLINK-12737: - Hi [~dawidwys], +1 for this! As for the `insertInto`, what's

[jira] [Updated] (FLINK-12401) Support incremental emit under AccRetract mode for non-window streaming FlatAggregate on Table API

[ https://issues.apache.org/jira/browse/FLINK-12401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-12401: Summary: Support incremental emit under AccRetract mode for non-window streaming FlatAggregate on

[jira] [Commented] (FLINK-12401) Support incremental emit for non-window streaming FlatAggregate on Table API

[ https://issues.apache.org/jira/browse/FLINK-12401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846681#comment-16846681 ] Hequn Cheng commented on FLINK-12401: - [~jark] Hi, incremental emit under AccRetract mode has been

[jira] [Commented] (FLINK-12401) Support incremental emit for non-window streaming FlatAggregate on Table API

[ https://issues.apache.org/jira/browse/FLINK-12401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845700#comment-16845700 ] Hequn Cheng commented on FLINK-12401: - Hi [~sunjincheng121] [~jark], I'm going to support

[jira] [Created] (FLINK-12562) Improve code in ExpandColumnFunctionsRule

Hequn Cheng created FLINK-12562: --- Summary: Improve code in ExpandColumnFunctionsRule Key: FLINK-12562 URL: https://issues.apache.org/jira/browse/FLINK-12562 Project: Flink Issue Type:

[jira] [Created] (FLINK-12533) Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type

Hequn Cheng created FLINK-12533: --- Summary: Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type Key: FLINK-12533 URL: https://issues.apache.org/jira/browse/FLINK-12533 Project: Flink

[jira] [Commented] (FLINK-11214) Support non mergable aggregates for group windows on batch table

[ https://issues.apache.org/jira/browse/FLINK-11214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838211#comment-16838211 ] Hequn Cheng commented on FLINK-11214: - [~dian.fu] Hi, great job! Thanks for reporting this problem

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

[ https://issues.apache.org/jira/browse/FLINK-11052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-11052: --- Assignee: Hequn Cheng (was: Dian Fu) > Add Bounded(Group Window) FlatAggregate operator

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

[ https://issues.apache.org/jira/browse/FLINK-11052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837124#comment-16837124 ] Hequn Cheng commented on FLINK-11052: - Thank you very much! > Add Bounded(Group Window)

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

[ https://issues.apache.org/jira/browse/FLINK-11052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837114#comment-16837114 ] Hequn Cheng commented on FLINK-11052: - Hi [~dian.fu], are you still working on this issue? I have

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

[ https://issues.apache.org/jira/browse/FLINK-10979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-10979. --- Resolution: Fixed > Add support for group keys in Unbounded Aggregate/FlatAggregate operator >

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

[ https://issues.apache.org/jira/browse/FLINK-10979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16835283#comment-16835283 ] Hequn Cheng commented on FLINK-10979: - Will be implemented directly by flatAggregate/aggregate. >

[jira] [Commented] (FLINK-12348) Use TableConfig in api module to replace TableConfig in blink-planner module.

[ https://issues.apache.org/jira/browse/FLINK-12348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833507#comment-16833507 ] Hequn Cheng commented on FLINK-12348: - Hi [~jark], thanks for the detailed description and

[jira] [Commented] (FLINK-12402) Make validation error message for CallExpression more user friendly

[ https://issues.apache.org/jira/browse/FLINK-12402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833280#comment-16833280 ] Hequn Cheng commented on FLINK-12402: - [~sunjincheng121] thank you for your suggestions. I will open

[jira] [Created] (FLINK-12402) Make validation error message for CallExpression more user friendly

Hequn Cheng created FLINK-12402: --- Summary: Make validation error message for CallExpression more user friendly Key: FLINK-12402 URL: https://issues.apache.org/jira/browse/FLINK-12402 Project: Flink

[jira] [Commented] (FLINK-12401) Support incremental emit for non-window streaming FlatAggregate on Table API

[ https://issues.apache.org/jira/browse/FLINK-12401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833223#comment-16833223 ] Hequn Cheng commented on FLINK-12401: - [~jark] Hi, great that you are also interested in this. This

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

[ https://issues.apache.org/jira/browse/FLINK-10976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-10976: --- Assignee: Hequn Cheng > Add Aggregate operator to Table API >

[jira] [Created] (FLINK-12401) Support incremental emit for non-window streaming FlatAggregate on Table API

Hequn Cheng created FLINK-12401: --- Summary: Support incremental emit for non-window streaming FlatAggregate on Table API Key: FLINK-12401 URL: https://issues.apache.org/jira/browse/FLINK-12401 Project:

[jira] [Created] (FLINK-12357) Remove useless code in TableConfig

Hequn Cheng created FLINK-12357: --- Summary: Remove useless code in TableConfig Key: FLINK-12357 URL: https://issues.apache.org/jira/browse/FLINK-12357 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-12298) Make column functions accept custom Range class rather than Expression

[ https://issues.apache.org/jira/browse/FLINK-12298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16824929#comment-16824929 ] Hequn Cheng commented on FLINK-12298: - [~dawidwys] Hi, I think it's good to make our API type safe.

[jira] [Updated] (FLINK-12271) Display input field name list when throw Cannot resolve field exception

[ https://issues.apache.org/jira/browse/FLINK-12271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-12271: Issue Type: Improvement (was: Bug) > Display input field name list when throw Cannot resolve

[jira] [Created] (FLINK-12271) Display input field name list when throw Cannot resolve field exception

Hequn Cheng created FLINK-12271: --- Summary: Display input field name list when throw Cannot resolve field exception Key: FLINK-12271 URL: https://issues.apache.org/jira/browse/FLINK-12271 Project: Flink

[jira] [Commented] (FLINK-12249) Type equivalence check fails for Window Aggregates

[ https://issues.apache.org/jira/browse/FLINK-12249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16820797#comment-16820797 ] Hequn Cheng commented on FLINK-12249: - [~dawidwys] Thank you for providing the valuable information

[jira] [Assigned] (FLINK-12249) Type equivalence check fails for Window Aggregates

[ https://issues.apache.org/jira/browse/FLINK-12249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-12249: --- Assignee: Hequn Cheng > Type equivalence check fails for Window Aggregates >

[jira] [Created] (FLINK-12217) OperationTreeBuilder.map() should perform ExpressionResolver.resolve()

Hequn Cheng created FLINK-12217: --- Summary: OperationTreeBuilder.map() should perform ExpressionResolver.resolve() Key: FLINK-12217 URL: https://issues.apache.org/jira/browse/FLINK-12217 Project: Flink

[jira] [Comment Edited] (FLINK-12204) Improve JDBCOutputFormat ClassCastException

[ https://issues.apache.org/jira/browse/FLINK-12204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16818919#comment-16818919 ] Hequn Cheng edited comment on FLINK-12204 at 4/16/19 11:57 AM: --- [~fhueske]

[jira] [Commented] (FLINK-12204) Improve JDBCOutputFormat ClassCastException

[ https://issues.apache.org/jira/browse/FLINK-12204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16818919#comment-16818919 ] Hequn Cheng commented on FLINK-12204: - [~fhueske] Sure, Thanks for the reminder. The merged PR looks

[jira] [Comment Edited] (FLINK-12204) Improve JDBCOutputFormat ClassCastException

[ https://issues.apache.org/jira/browse/FLINK-12204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16818512#comment-16818512 ] Hequn Cheng edited comment on FLINK-12204 at 4/16/19 2:24 AM: -- [~fan_li_ya]

[jira] [Commented] (FLINK-12204) Improve JDBCOutputFormat ClassCastException

[ https://issues.apache.org/jira/browse/FLINK-12204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16818512#comment-16818512 ] Hequn Cheng commented on FLINK-12204: - [~fan_li_ya] Glad that you are also interested in this. I

[jira] [Assigned] (FLINK-12204) Improve JDBCOutputFormat ClassCastException

[ https://issues.apache.org/jira/browse/FLINK-12204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-12204: --- Assignee: Hequn Cheng > Improve JDBCOutputFormat ClassCastException >

[jira] [Updated] (FLINK-12182) AggregateProjectMergeRule can not handle LogicalWindowAggregate

[ https://issues.apache.org/jira/browse/FLINK-12182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-12182: Description: Currently, we add the AggregateProjectMergeRule.INSTANCE in logical rule sets and

[jira] [Created] (FLINK-12182) AggregateProjectMergeRule can not handle LogicalWindowAggregate

Hequn Cheng created FLINK-12182: --- Summary: AggregateProjectMergeRule can not handle LogicalWindowAggregate Key: FLINK-12182 URL: https://issues.apache.org/jira/browse/FLINK-12182 Project: Flink

[jira] [Created] (FLINK-12174) Introduce FlinkAggregateExtractProjectRule and remove extractFieldReferences

Hequn Cheng created FLINK-12174: --- Summary: Introduce FlinkAggregateExtractProjectRule and remove extractFieldReferences Key: FLINK-12174 URL: https://issues.apache.org/jira/browse/FLINK-12174 Project:

[jira] [Commented] (FLINK-10049) Unify the processing logic for NULL arguments in SQL built-in functions

[ https://issues.apache.org/jira/browse/FLINK-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814703#comment-16814703 ] Hequn Cheng commented on FLINK-10049: - Yes, I meant to unify the logic for the two problems I

[jira] [Commented] (FLINK-10049) Unify the processing logic for NULL arguments in SQL built-in functions

[ https://issues.apache.org/jira/browse/FLINK-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812935#comment-16812935 ] Hequn Cheng commented on FLINK-10049: - [~xccui] Thanks for opening the issue. Good catch and +1 to

[jira] [Commented] (FLINK-12105) TUMBLE INTERVAL value errors out for 100 or more value

[ https://issues.apache.org/jira/browse/FLINK-12105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16809550#comment-16809550 ] Hequn Cheng commented on FLINK-12105: - [~vmehra] Hi, thanks for bringing up the discussion. As the

[jira] [Assigned] (FLINK-12029) Add Column selections

[ https://issues.apache.org/jira/browse/FLINK-12029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-12029: --- Assignee: Hequn Cheng > Add Column selections > - > >

[jira] [Updated] (FLINK-12029) Add Column selections

[ https://issues.apache.org/jira/browse/FLINK-12029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-12029: Description: In this Jira will add column operators/operations as follows: Fine-grained column

[jira] [Commented] (FLINK-9477) Support SQL 2016 JSON functions in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16801808#comment-16801808 ] Hequn Cheng commented on FLINK-9477: +1 to have a little design document and split methods into

[jira] [Created] (FLINK-12016) Change package name in blink modules to avoid class conflict

Hequn Cheng created FLINK-12016: --- Summary: Change package name in blink modules to avoid class conflict Key: FLINK-12016 URL: https://issues.apache.org/jira/browse/FLINK-12016 Project: Flink

[jira] [Commented] (FLINK-11971) Fix `Command: start_kubernetes_if_not_ruunning failed` error

[ https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16797275#comment-16797275 ] Hequn Cheng commented on FLINK-11971: - [~sunjincheng121] Thanks for looking into the problem and

[jira] [Assigned] (FLINK-11971) Fix `Command: start_kubernetes_if_not_ruunning failed` error

[ https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-11971: --- Assignee: Hequn Cheng > Fix `Command: start_kubernetes_if_not_ruunning failed` error >

[jira] [Assigned] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-11972: --- Assignee: (was: Hequn Cheng) > The classpath is missing the

[jira] [Assigned] (FLINK-11972) Fix `Command: start_kubernetes_if_not_ruunning failed` error

[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-11972: --- Assignee: Hequn Cheng > Fix `Command: start_kubernetes_if_not_ruunning failed` error >

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