[jira] [Updated] (FLINK-8739) Optimize runtime support for distinct filter

[ https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-8739: -- Labels: pull-request-available (was: ) > Optimize runtime support for distinct filter >

[GitHub] dianfu opened a new pull request #7286: [FLINK-8739] [table] Optimize DISTINCE aggregates to use the same distinct accumulator if possible

dianfu opened a new pull request #7286: [FLINK-8739] [table] Optimize DISTINCE aggregates to use the same distinct accumulator if possible URL: https://github.com/apache/flink/pull/7286 ## What is the purpose of the change *This pull request optimizes the DISTINCT aggregates such as

[jira] [Commented] (FLINK-8739) Optimize runtime support for distinct filter

[ https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718569#comment-16718569 ] ASF GitHub Bot commented on FLINK-8739: --- dianfu opened a new pull request #7286: [FLINK-8739]

[jira] [Closed] (FLINK-8838) Add Support for UNNEST a MultiSet type field

[ https://issues.apache.org/jira/browse/FLINK-8838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln.lee closed FLINK-8838. -- > Add Support for UNNEST a MultiSet type field > > >

[jira] [Created] (FLINK-11138) RocksDB's wal seems to be useless in rocksdb-state-backend that reduce the disk's overhead

cailiuyang created FLINK-11138: -- Summary: RocksDB's wal seems to be useless in rocksdb-state-backend that reduce the disk's overhead Key: FLINK-11138 URL: https://issues.apache.org/jira/browse/FLINK-11138

[jira] [Closed] (FLINK-5511) Add support for outer joins with local predicates

[ https://issues.apache.org/jira/browse/FLINK-5511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln.lee closed FLINK-5511. -- > Add support for outer joins with local predicates > - >

[jira] [Created] (FLINK-11137) Unexpected RegistrationTimeoutException of TaskExecutor

Biao Liu created FLINK-11137: Summary: Unexpected RegistrationTimeoutException of TaskExecutor Key: FLINK-11137 URL: https://issues.apache.org/jira/browse/FLINK-11137 Project: Flink Issue Type:

[jira] [Commented] (FLINK-11081) Support binding port range for REST server

[ https://issues.apache.org/jira/browse/FLINK-11081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718562#comment-16718562 ] ASF GitHub Bot commented on FLINK-11081: yanghua commented on a change in pull request #7263:

[GitHub] yanghua commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server

yanghua commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server URL: https://github.com/apache/flink/pull/7263#discussion_r240905696 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java

[GitHub] TisonKun opened a new pull request #7285: [hotfix] [resource manager] Remove legacy(unused) class ResourceManag…

TisonKun opened a new pull request #7285: [hotfix] [resource manager] Remove legacy(unused) class ResourceManag… URL: https://github.com/apache/flink/pull/7285 …erServices ## What is the purpose of the change We introduced `ResourceManagerService` in

[jira] [Commented] (FLINK-11081) Support binding port range for REST server

[ https://issues.apache.org/jira/browse/FLINK-11081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718528#comment-16718528 ] ASF GitHub Bot commented on FLINK-11081: walterddr commented on a change in pull request #7263:

[GitHub] walterddr commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server

walterddr commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server URL: https://github.com/apache/flink/pull/7263#discussion_r240900279 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java

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

[ https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718513#comment-16718513 ] sunjincheng commented on FLINK-11067: - We list the two ways users use BatchTableEnvironment, as

[jira] [Commented] (FLINK-11107) [state] Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured

[ https://issues.apache.org/jira/browse/FLINK-11107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718512#comment-16718512 ] ASF GitHub Bot commented on FLINK-11107: Myasuka edited a comment on issue #7281:

[GitHub] Myasuka edited a comment on issue #7281: [FLINK-11107][state] Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured

Myasuka edited a comment on issue #7281: [FLINK-11107][state] Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured URL: https://github.com/apache/flink/pull/7281#issuecomment-446297350 @StephanEwen , since you have left annotations below:

[jira] [Commented] (FLINK-11107) [state] Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured

[ https://issues.apache.org/jira/browse/FLINK-11107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718511#comment-16718511 ] ASF GitHub Bot commented on FLINK-11107: Myasuka commented on issue #7281: [FLINK-11107][state]

[GitHub] Myasuka commented on issue #7281: [FLINK-11107][state] Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured

Myasuka commented on issue #7281: [FLINK-11107][state] Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured URL: https://github.com/apache/flink/pull/7281#issuecomment-446478434 BTW, If we do not create UUID directories for memory

[jira] [Assigned] (FLINK-4810) Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-4810: --- Assignee: vinoyang > Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful >

[GitHub] ramkrish86 commented on issue #3334: FLINK-4810 Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints

ramkrish86 commented on issue #3334: FLINK-4810 Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints URL: https://github.com/apache/flink/pull/3334#issuecomment-446471220 Closing the PR as per request.

[jira] [Commented] (FLINK-4810) Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718490#comment-16718490 ] ASF GitHub Bot commented on FLINK-4810: --- ramkrish86 commented on issue #3334: FLINK-4810 Checkpoint

[GitHub] ramkrish86 closed pull request #3334: FLINK-4810 Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints

ramkrish86 closed pull request #3334: FLINK-4810 Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints URL: https://github.com/apache/flink/pull/3334 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed

[jira] [Commented] (FLINK-4810) Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718491#comment-16718491 ] ASF GitHub Bot commented on FLINK-4810: --- ramkrish86 closed pull request #3334: FLINK-4810

[GitHub] lamber-ken removed a comment on issue #7279: [hotfix] add hadoop user name to yarn logs command

lamber-ken removed a comment on issue #7279: [hotfix] add hadoop user name to yarn logs command URL: https://github.com/apache/flink/pull/7279#issuecomment-446261251 hi, @zentol, cc :) This is an automated message from the

[jira] [Commented] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

[ https://issues.apache.org/jira/browse/FLINK-11048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718478#comment-16718478 ] ASF GitHub Bot commented on FLINK-11048: tweise commented on a change in pull request #7249:

[GitHub] tweise commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

tweise commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r240885619 ## File path:

[jira] [Commented] (FLINK-11081) Support binding port range for REST server

[ https://issues.apache.org/jira/browse/FLINK-11081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718466#comment-16718466 ] ASF GitHub Bot commented on FLINK-11081: yanghua commented on issue #7263: [FLINK-11081] Support

[jira] [Commented] (FLINK-11081) Support binding port range for REST server

[ https://issues.apache.org/jira/browse/FLINK-11081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718467#comment-16718467 ] ASF GitHub Bot commented on FLINK-11081: yanghua edited a comment on issue #7263: [FLINK-11081]

[GitHub] yanghua edited a comment on issue #7263: [FLINK-11081] Support binding port range for REST server

yanghua edited a comment on issue #7263: [FLINK-11081] Support binding port range for REST server URL: https://github.com/apache/flink/pull/7263#issuecomment-446460550 `ConfigOption.PORT` ? I can not find it. I guess what you want to express is `RestOptions.PORT`. I think that it

[GitHub] yanghua commented on issue #7263: [FLINK-11081] Support binding port range for REST server

yanghua commented on issue #7263: [FLINK-11081] Support binding port range for REST server URL: https://github.com/apache/flink/pull/7263#issuecomment-446460550 `ConfigOption.PORT` ? I can not find it. I guess what you want to express is `RestOptions.PORT`. I think that it can't be

[jira] [Commented] (FLINK-11081) Support binding port range for REST server

[ https://issues.apache.org/jira/browse/FLINK-11081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718464#comment-16718464 ] ASF GitHub Bot commented on FLINK-11081: yanghua commented on a change in pull request #7263:

[jira] [Commented] (FLINK-11081) Support binding port range for REST server

[ https://issues.apache.org/jira/browse/FLINK-11081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718463#comment-16718463 ] ASF GitHub Bot commented on FLINK-11081: yanghua commented on a change in pull request #7263:

[jira] [Commented] (FLINK-11081) Support binding port range for REST server

[ https://issues.apache.org/jira/browse/FLINK-11081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718462#comment-16718462 ] ASF GitHub Bot commented on FLINK-11081: yanghua commented on a change in pull request #7263:

[GitHub] yanghua commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server

yanghua commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server URL: https://github.com/apache/flink/pull/7263#discussion_r240880017 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java

[GitHub] yanghua commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server

yanghua commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server URL: https://github.com/apache/flink/pull/7263#discussion_r240880017 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java

[GitHub] yanghua commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server

yanghua commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server URL: https://github.com/apache/flink/pull/7263#discussion_r240880004 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java

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

[ https://issues.apache.org/jira/browse/FLINK-10976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718447#comment-16718447 ] ASF GitHub Bot commented on FLINK-10976: hequn8128 commented on a change in pull request #7235:

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718457#comment-16718457 ] ASF GitHub Bot commented on FLINK-11010: walterddr commented on issue #7180: [FLINK-11010]

[GitHub] walterddr commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

walterddr commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-446457485 > @walterddr could you please check the timezone problem when dealing with eventtime? > it

[jira] [Commented] (FLINK-11081) Support binding port range for REST server

[ https://issues.apache.org/jira/browse/FLINK-11081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718456#comment-16718456 ] ASF GitHub Bot commented on FLINK-11081: walterddr commented on a change in pull request #7263:

[jira] [Commented] (FLINK-11081) Support binding port range for REST server

[ https://issues.apache.org/jira/browse/FLINK-11081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718455#comment-16718455 ] ASF GitHub Bot commented on FLINK-11081: walterddr commented on a change in pull request #7263:

[GitHub] walterddr commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server

walterddr commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server URL: https://github.com/apache/flink/pull/7263#discussion_r240877872 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java

[GitHub] walterddr commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server

walterddr commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server URL: https://github.com/apache/flink/pull/7263#discussion_r240877630 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java

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

[ https://issues.apache.org/jira/browse/FLINK-10976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718450#comment-16718450 ] ASF GitHub Bot commented on FLINK-10976: hequn8128 commented on a change in pull request #7235:

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

[ https://issues.apache.org/jira/browse/FLINK-10976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718446#comment-16718446 ] ASF GitHub Bot commented on FLINK-10976: hequn8128 commented on a change in pull request #7235:

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

[ https://issues.apache.org/jira/browse/FLINK-10976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718453#comment-16718453 ] ASF GitHub Bot commented on FLINK-10976: hequn8128 commented on a change in pull request #7235:

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

[ https://issues.apache.org/jira/browse/FLINK-10976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718452#comment-16718452 ] ASF GitHub Bot commented on FLINK-10976: hequn8128 commented on a change in pull request #7235:

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

[ https://issues.apache.org/jira/browse/FLINK-10976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718449#comment-16718449 ] ASF GitHub Bot commented on FLINK-10976: hequn8128 commented on a change in pull request #7235:

[GitHub] hequn8128 commented on a change in pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API

hequn8128 commented on a change in pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API URL: https://github.com/apache/flink/pull/7235#discussion_r240877547 ## File path: docs/dev/table/tableApi.md ## @@ -1682,6 +1682,36 @@ The `OverWindow`

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

[ https://issues.apache.org/jira/browse/FLINK-10976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718451#comment-16718451 ] ASF GitHub Bot commented on FLINK-10976: hequn8128 commented on a change in pull request #7235:

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

[ https://issues.apache.org/jira/browse/FLINK-10976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718448#comment-16718448 ] ASF GitHub Bot commented on FLINK-10976: hequn8128 commented on a change in pull request #7235:

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

[ https://issues.apache.org/jira/browse/FLINK-10976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718445#comment-16718445 ] ASF GitHub Bot commented on FLINK-10976: hequn8128 commented on a change in pull request #7235:

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

[ https://issues.apache.org/jira/browse/FLINK-10976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718454#comment-16718454 ] ASF GitHub Bot commented on FLINK-10976: hequn8128 commented on a change in pull request #7235:

[GitHub] hequn8128 commented on a change in pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API

hequn8128 commented on a change in pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API URL: https://github.com/apache/flink/pull/7235#discussion_r240877583 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala

[GitHub] hequn8128 commented on a change in pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API

hequn8128 commented on a change in pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API URL: https://github.com/apache/flink/pull/7235#discussion_r240877602 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala

[GitHub] hequn8128 commented on a change in pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API

hequn8128 commented on a change in pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API URL: https://github.com/apache/flink/pull/7235#discussion_r240877626 ## File path:

[GitHub] hequn8128 commented on a change in pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API

hequn8128 commented on a change in pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API URL: https://github.com/apache/flink/pull/7235#discussion_r240877612 ## File path:

[GitHub] hequn8128 commented on a change in pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API

hequn8128 commented on a change in pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API URL: https://github.com/apache/flink/pull/7235#discussion_r240877554 ## File path: docs/dev/table/tableApi.md ## @@ -1682,6 +1682,36 @@ The `OverWindow`

[GitHub] hequn8128 commented on a change in pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API

hequn8128 commented on a change in pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API URL: https://github.com/apache/flink/pull/7235#discussion_r240877558 ## File path: docs/dev/table/tableApi.md ## @@ -1682,6 +1682,36 @@ The `OverWindow`

[GitHub] hequn8128 commented on a change in pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API

hequn8128 commented on a change in pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API URL: https://github.com/apache/flink/pull/7235#discussion_r240877547 ## File path: docs/dev/table/tableApi.md ## @@ -1682,6 +1682,36 @@ The `OverWindow`

[GitHub] hequn8128 commented on a change in pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API

hequn8128 commented on a change in pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API URL: https://github.com/apache/flink/pull/7235#discussion_r240877569 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala

[GitHub] hequn8128 commented on a change in pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API

hequn8128 commented on a change in pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API URL: https://github.com/apache/flink/pull/7235#discussion_r240877640 ## File path:

[GitHub] samsai edited a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

samsai edited a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-446445016 @walterddr could you please check the timezone problem when dealing with eventtime? it

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718434#comment-16718434 ] ASF GitHub Bot commented on FLINK-11010: samsai edited a comment on issue #7180: [FLINK-11010]

[jira] [Commented] (FLINK-11136) Fix the logical of merge for DISTINCT aggregates

[ https://issues.apache.org/jira/browse/FLINK-11136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718430#comment-16718430 ] ASF GitHub Bot commented on FLINK-11136: dianfu opened a new pull request #7284: [FLINK-11136]

[jira] [Updated] (FLINK-11136) Fix the logical of merge for DISTINCT aggregates

[ https://issues.apache.org/jira/browse/FLINK-11136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11136: --- Labels: pull-request-available (was: ) > Fix the logical of merge for DISTINCT aggregates

[jira] [Comment Edited] (FLINK-11037) Introduce another greedy mechanism for distributing floating buffers

[ https://issues.apache.org/jira/browse/FLINK-11037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718422#comment-16718422 ] zhijiang edited comment on FLINK-11037 at 12/12/18 3:38 AM: [~StephanEwen]，

[GitHub] dianfu opened a new pull request #7284: [FLINK-11136] [table] Fix the merge logic of DISTINCT aggregates

dianfu opened a new pull request #7284: [FLINK-11136] [table] Fix the merge logic of DISTINCT aggregates URL: https://github.com/apache/flink/pull/7284 ## What is the purpose of the change *This pull request fix the merge logic of DISTINCT aggregates.* ## Brief change log

[jira] [Created] (FLINK-11136) Fix the logical of merge for DISTINCT aggregates

Dian Fu created FLINK-11136: --- Summary: Fix the logical of merge for DISTINCT aggregates Key: FLINK-11136 URL: https://issues.apache.org/jira/browse/FLINK-11136 Project: Flink Issue Type: Test

[jira] [Commented] (FLINK-10817) Upgrade presto dependency to support path-style access

[ https://issues.apache.org/jira/browse/FLINK-10817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718425#comment-16718425 ] ASF GitHub Bot commented on FLINK-10817: adamlamar commented on issue #7058: [FLINK-10817]

[GitHub] adamlamar commented on issue #7058: [FLINK-10817] Upgrade presto dependency to support path-style access

adamlamar commented on issue #7058: [FLINK-10817] Upgrade presto dependency to support path-style access URL: https://github.com/apache/flink/pull/7058#issuecomment-446449939 @zentol @aljoscha With FLINK-10987 merged, is this ready for another review?

[jira] [Commented] (FLINK-11037) Introduce another greedy mechanism for distributing floating buffers

[ https://issues.apache.org/jira/browse/FLINK-11037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718422#comment-16718422 ] zhijiang commented on FLINK-11037: -- [~StephanEwen]， thanks for giving above proposals in point. :) *

[jira] [Created] (FLINK-11135) Reduce priority of the deprecated Hadoop specific Flink conf options

Paul Lin created FLINK-11135: Summary: Reduce priority of the deprecated Hadoop specific Flink conf options Key: FLINK-11135 URL: https://issues.apache.org/jira/browse/FLINK-11135 Project: Flink

[GitHub] KarmaGYZ opened a new pull request #7283: [hotfix][docs] Fix the mismatch generic type in hadoop compatibility doc

KarmaGYZ opened a new pull request #7283: [hotfix][docs] Fix the mismatch generic type in hadoop compatibility doc URL: https://github.com/apache/flink/pull/7283 ## What is the purpose of the change This pr fix the mismatch generic type in hadoop compatibility doc. ## Brief

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718417#comment-16718417 ] ASF GitHub Bot commented on FLINK-11010: samsai commented on issue #7180: [FLINK-11010] [TABLE]

[GitHub] samsai commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

samsai commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-446445016 @walterddr could you please check the timezone problem when dealing with eventtime? it seems

[jira] [Created] (FLINK-11134) Invalid REST API request should not log the full exception in Flink logs

Mark Cho created FLINK-11134: Summary: Invalid REST API request should not log the full exception in Flink logs Key: FLINK-11134 URL: https://issues.apache.org/jira/browse/FLINK-11134 Project: Flink

[GitHub] KarmaGYZ opened a new pull request #7282: [hotfix][docs] imporve docs of batch overview

KarmaGYZ opened a new pull request #7282: [hotfix][docs] imporve docs of batch overview URL: https://github.com/apache/flink/pull/7282 ## What is the purpose of the change This pr is to improve the docs of Batch Overview, make the sample code of partitionCustom more readable.

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

[ https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718401#comment-16718401 ] Dian Fu commented on FLINK-11067: - Hi [~twalthr], Thanks a lot for the solution. Agree with you that we

[jira] [Created] (FLINK-11133) FsCheckpointStorage is unaware about S3 entropy when creating directories

Mark Cho created FLINK-11133: Summary: FsCheckpointStorage is unaware about S3 entropy when creating directories Key: FLINK-11133 URL: https://issues.apache.org/jira/browse/FLINK-11133 Project: Flink

[jira] [Commented] (FLINK-10461) Speed up download file procedure when restore

[ https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718365#comment-16718365 ] ASF GitHub Bot commented on FLINK-10461: klion26 commented on issue #6777: [FLINK-10461] [State

[jira] [Commented] (FLINK-11081) Support binding port range for REST server

[ https://issues.apache.org/jira/browse/FLINK-11081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718372#comment-16718372 ] ASF GitHub Bot commented on FLINK-11081: yanghua commented on issue #7263: [FLINK-11081] Support

[GitHub] yanghua commented on issue #7263: [FLINK-11081] Support binding port range for REST server

yanghua commented on issue #7263: [FLINK-11081] Support binding port range for REST server URL: https://github.com/apache/flink/pull/7263#issuecomment-446434964 hi @walterddr Thank you for your review. I responded to them and I think some suggestions make sense. In addition, rest.port

[jira] [Commented] (FLINK-11081) Support binding port range for REST server

[ https://issues.apache.org/jira/browse/FLINK-11081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718363#comment-16718363 ] ASF GitHub Bot commented on FLINK-11081: yanghua commented on a change in pull request #7263:

[jira] [Commented] (FLINK-11081) Support binding port range for REST server

[ https://issues.apache.org/jira/browse/FLINK-11081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718361#comment-16718361 ] ASF GitHub Bot commented on FLINK-11081: yanghua commented on a change in pull request #7263:

[GitHub] klion26 commented on issue #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

klion26 commented on issue #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#issuecomment-446434187 @azagrebin Thank you for your explanation. As your explanation, I will - first move

[GitHub] yanghua commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server

yanghua commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server URL: https://github.com/apache/flink/pull/7263#discussion_r240860279 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java

[GitHub] yanghua commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server

yanghua commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server URL: https://github.com/apache/flink/pull/7263#discussion_r240860330 ## File path:

[jira] [Commented] (FLINK-11081) Support binding port range for REST server

[ https://issues.apache.org/jira/browse/FLINK-11081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718357#comment-16718357 ] ASF GitHub Bot commented on FLINK-11081: yanghua commented on a change in pull request #7263:

[GitHub] yanghua commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server

yanghua commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server URL: https://github.com/apache/flink/pull/7263#discussion_r240859949 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java

[jira] [Commented] (FLINK-11083) CRowSerializerConfigSnapshot is not instantiable

[ https://issues.apache.org/jira/browse/FLINK-11083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718356#comment-16718356 ] ASF GitHub Bot commented on FLINK-11083: kisimple commented on issue #7267: [FLINK-11083][Table]

[GitHub] kisimple commented on issue #7267: [FLINK-11083][Table] CRowSerializerConfigSnapshot is not instantiable

kisimple commented on issue #7267: [FLINK-11083][Table] CRowSerializerConfigSnapshot is not instantiable URL: https://github.com/apache/flink/pull/7267#issuecomment-446432902 cc @pnowojski @dawidwys This is an automated

[jira] [Assigned] (FLINK-11130) Migrate flink-table runtime triggers class

[ https://issues.apache.org/jira/browse/FLINK-11130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shenlei reassigned FLINK-11130: --- Assignee: shenlei > Migrate flink-table runtime triggers class >

[jira] [Commented] (FLINK-11081) Support binding port range for REST server

[ https://issues.apache.org/jira/browse/FLINK-11081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718350#comment-16718350 ] ASF GitHub Bot commented on FLINK-11081: yanghua commented on a change in pull request #7263:

[GitHub] yanghua commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server

yanghua commented on a change in pull request #7263: [FLINK-11081] Support binding port range for REST server URL: https://github.com/apache/flink/pull/7263#discussion_r240857598 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java

[jira] [Commented] (FLINK-10566) Flink Planning is exponential in the number of stages

[ https://issues.apache.org/jira/browse/FLINK-10566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718339#comment-16718339 ] ASF GitHub Bot commented on FLINK-10566: fhueske commented on a change in pull request #7276:

[GitHub] fhueske commented on a change in pull request #7276: [FLINK-10566] Fix exponential planning time of large programs

fhueske commented on a change in pull request #7276: [FLINK-10566] Fix exponential planning time of large programs URL: https://github.com/apache/flink/pull/7276#discussion_r240855219 ## File path: flink-tests/src/test/java/org/apache/flink/test/planning/LargePlanTest.java

[GitHub] fhueske commented on a change in pull request #7276: [FLINK-10566] Fix exponential planning time of large programs

fhueske commented on a change in pull request #7276: [FLINK-10566] Fix exponential planning time of large programs URL: https://github.com/apache/flink/pull/7276#discussion_r240855467 ## File path: flink-tests/src/test/java/org/apache/flink/test/planning/LargePlanTest.java

[jira] [Commented] (FLINK-10566) Flink Planning is exponential in the number of stages

[ https://issues.apache.org/jira/browse/FLINK-10566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718338#comment-16718338 ] ASF GitHub Bot commented on FLINK-10566: fhueske commented on a change in pull request #7276:

[jira] [Commented] (FLINK-10566) Flink Planning is exponential in the number of stages

[ https://issues.apache.org/jira/browse/FLINK-10566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718336#comment-16718336 ] ASF GitHub Bot commented on FLINK-10566: fhueske commented on a change in pull request #7276:

[GitHub] fhueske commented on a change in pull request #7276: [FLINK-10566] Fix exponential planning time of large programs

fhueske commented on a change in pull request #7276: [FLINK-10566] Fix exponential planning time of large programs URL: https://github.com/apache/flink/pull/7276#discussion_r240855139 ## File path: flink-tests/src/test/java/org/apache/flink/test/planning/LargePlanTest.java

  1   2   3   4   >