[jira] [Created] (FLINK-12108) Simplify splitting expressions into projections, aggregations & windowProperties

Dawid Wysakowicz created FLINK-12108: Summary: Simplify splitting expressions into projections, aggregations & windowProperties Key: FLINK-12108 URL: https://issues.apache.org/jira/browse/FLINK-12108

[GitHub] [flink] JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102#discussion_r272038501 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apac

[GitHub] [flink] JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102#discussion_r272038501 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apac

[jira] [Comment Edited] (FLINK-3273) Remove Scala dependency from flink-streaming-java

[ https://issues.apache.org/jira/browse/FLINK-3273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16809565#comment-16809565 ] Dawid Wysakowicz edited comment on FLINK-3273 at 4/4/19 6:54 AM: --

[jira] [Commented] (FLINK-3273) Remove Scala dependency from flink-streaming-java

[ https://issues.apache.org/jira/browse/FLINK-3273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16809565#comment-16809565 ] Dawid Wysakowicz commented on FLINK-3273: - [~fan_li_ya] "Adding a Scala suffix" m

[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&focusedCommentId=16809561#comment-16809561 ] Dawid Wysakowicz commented on FLINK-12105: -- I think the design doc for upcoming

[GitHub] [flink] JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102#discussion_r272036049 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apac

[GitHub] [flink] JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102#discussion_r272035934 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apac

[GitHub] [flink] JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102#discussion_r272036049 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apac

[GitHub] [flink] JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102#discussion_r272034292 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apac

[GitHub] [flink] JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102#discussion_r272033859 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apac

[GitHub] [flink] JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102#discussion_r272033041 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apac

[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&focusedCommentId=16809550#comment-16809550 ] Hequn Cheng commented on FLINK-12105: - [~vmehra] Hi, thanks for bringing up the disc

[GitHub] [flink] dawidwys commented on a change in pull request #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces

dawidwys commented on a change in pull request #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces URL: https://github.com/apache/flink/pull/8050#discussion_r272031691 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvir

[GitHub] [flink] JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102#discussion_r272031198 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apac

[GitHub] [flink] zhijiangW commented on issue #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment

zhijiangW commented on issue #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8090#issuecomment-479745830 @azagrebin , thanks for review again. :) I submitted the commit for rebasing master and addressing the above co

[GitHub] [flink] zhijiangW commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment

zhijiangW commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8090#discussion_r272013899 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/NetworkEn

[jira] [Commented] (FLINK-3273) Remove Scala dependency from flink-streaming-java

[ https://issues.apache.org/jira/browse/FLINK-3273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16809495#comment-16809495 ] Liya Fan commented on FLINK-3273: - Hi [~mxm], would you please help explain what you mean

[jira] [Commented] (FLINK-12102) FlinkILoopTest fails on Java 9

[ https://issues.apache.org/jira/browse/FLINK-12102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16809493#comment-16809493 ] Liya Fan commented on FLINK-12102: -- Does Java 11 also have this problem? > FlinkILoopT

[GitHub] [flink] zhijiangW commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment

zhijiangW commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8090#discussion_r272012531 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskMana

[jira] [Commented] (FLINK-10725) Support for Java 11 (LTS)

[ https://issues.apache.org/jira/browse/FLINK-10725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16809487#comment-16809487 ] Liya Fan commented on FLINK-10725: -- Is anyone looking at this issue? > Support for Jav

[GitHub] [flink] zhijiangW commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment

zhijiangW commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8090#discussion_r272008282 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ConfigurationPar

[GitHub] [flink] JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102#discussion_r272008044 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk

[jira] [Updated] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10195: --- Labels: pull-request-available (was: ) > RabbitMQ Source With Checkpointing Doesn't Backpre

[GitHub] [flink] flinkbot commented on issue #8111: [FLINK-10195] [RabbitMQ] - RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

flinkbot commented on issue #8111: [FLINK-10195] [RabbitMQ] - RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly URL: https://github.com/apache/flink/pull/8111#issuecomment-479738490 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help th

[GitHub] [flink] ljurukov opened a new pull request #8111: [FLINK-10195] [RabbitMQ] - RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

ljurukov opened a new pull request #8111: [FLINK-10195] [RabbitMQ] - RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly URL: https://github.com/apache/flink/pull/8111 ## What Does This Change Currently RabbitMQ Connection doesn't backpressure when setting no limit to una

[GitHub] [flink] JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

JingsongLi commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102#discussion_r272007149 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apac

[GitHub] [flink] zhijiangW commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment

zhijiangW commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8090#discussion_r272006302 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/NetworkEn

[GitHub] [flink] KurtYoung commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

KurtYoung commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102#discussion_r272005278 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apach

[GitHub] [flink] KurtYoung commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

KurtYoung commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102#discussion_r272003227 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apach

[GitHub] [flink] KurtYoung commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

KurtYoung commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102#discussion_r272003199 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apach

[GitHub] [flink] KurtYoung commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

KurtYoung commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102#discussion_r272006270 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apach

[GitHub] [flink] KurtYoung commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

KurtYoung commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102#discussion_r272003306 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apach

[GitHub] [flink] KurtYoung commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

KurtYoung commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102#discussion_r272005225 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apach

[GitHub] [flink] KurtYoung commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

KurtYoung commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102#discussion_r272003166 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apach

[GitHub] [flink] KurtYoung commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

KurtYoung commented on a change in pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102#discussion_r272001917 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/

[GitHub] [flink] zhijiangW commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment

zhijiangW commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8090#discussion_r272005759 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/NetworkEn

[GitHub] [flink] hequn8128 commented on a change in pull request #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces

hequn8128 commented on a change in pull request #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces URL: https://github.com/apache/flink/pull/8050#discussion_r271807543 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvi

[jira] [Assigned] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luka Jurukovski reassigned FLINK-10195: --- Assignee: Luka Jurukovski > RabbitMQ Source With Checkpointing Doesn't Backpressure

[GitHub] [flink] JingsongLi commented on a change in pull request #8099: [FLINK-12081][table-planner-blink] Introduce aggregation operator code generator to blink batch

JingsongLi commented on a change in pull request #8099: [FLINK-12081][table-planner-blink] Introduce aggregation operator code generator to blink batch URL: https://github.com/apache/flink/pull/8099#discussion_r272003098 ## File path: flink-table/flink-table-planner-blink/src/main

[GitHub] [flink] flinkbot edited a comment on issue #7835: [FLINK-11750][network] Replace IntermediateResultPartitionID with ResultPartitionID in ResultPartitionDeploymentDescriptor

flinkbot edited a comment on issue #7835: [FLINK-11750][network] Replace IntermediateResultPartitionID with ResultPartitionID in ResultPartitionDeploymentDescriptor URL: https://github.com/apache/flink/pull/7835#issuecomment-467344372 Thanks a lot for your contribution to the Apache Flink

[GitHub] [flink] zhijiangW commented on issue #7835: [FLINK-11750][network] Replace IntermediateResultPartitionID with ResultPartitionID in ResultPartitionDeploymentDescriptor

zhijiangW commented on issue #7835: [FLINK-11750][network] Replace IntermediateResultPartitionID with ResultPartitionID in ResultPartitionDeploymentDescriptor URL: https://github.com/apache/flink/pull/7835#issuecomment-479730951 cc @azagrebin -

[GitHub] [flink] hequn8128 edited a comment on issue #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces

hequn8128 edited a comment on issue #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces URL: https://github.com/apache/flink/pull/8050#issuecomment-479572670 @dawidwys Thanks a lot for your review. I think you have given a lot of good suggestions! 1. As for the usel

[GitHub] [flink] KurtYoung commented on a change in pull request #8099: [FLINK-12081][table-planner-blink] Introduce aggregation operator code generator to blink batch

KurtYoung commented on a change in pull request #8099: [FLINK-12081][table-planner-blink] Introduce aggregation operator code generator to blink batch URL: https://github.com/apache/flink/pull/8099#discussion_r272000909 ## File path: flink-table/flink-table-planner-blink/src/main/

[GitHub] [flink] KurtYoung commented on a change in pull request #8099: [FLINK-12081][table-planner-blink] Introduce aggregation operator code generator to blink batch

KurtYoung commented on a change in pull request #8099: [FLINK-12081][table-planner-blink] Introduce aggregation operator code generator to blink batch URL: https://github.com/apache/flink/pull/8099#discussion_r272000967 ## File path: flink-table/flink-table-planner-blink/src/main/

[GitHub] [flink] KurtYoung commented on a change in pull request #8099: [FLINK-12081][table-planner-blink] Introduce aggregation operator code generator to blink batch

KurtYoung commented on a change in pull request #8099: [FLINK-12081][table-planner-blink] Introduce aggregation operator code generator to blink batch URL: https://github.com/apache/flink/pull/8099#discussion_r272001068 ## File path: flink-table/flink-table-planner-blink/src/main/

[GitHub] [flink] KurtYoung commented on a change in pull request #8099: [FLINK-12081][table-planner-blink] Introduce aggregation operator code generator to blink batch

KurtYoung commented on a change in pull request #8099: [FLINK-12081][table-planner-blink] Introduce aggregation operator code generator to blink batch URL: https://github.com/apache/flink/pull/8099#discussion_r272000977 ## File path: flink-table/flink-table-planner-blink/src/main/

[GitHub] [flink] KurtYoung commented on a change in pull request #8099: [FLINK-12081][table-planner-blink] Introduce aggregation operator code generator to blink batch

KurtYoung commented on a change in pull request #8099: [FLINK-12081][table-planner-blink] Introduce aggregation operator code generator to blink batch URL: https://github.com/apache/flink/pull/8099#discussion_r272000862 ## File path: flink-table/flink-table-planner-blink/src/main/

[GitHub] [flink] KurtYoung commented on a change in pull request #8099: [FLINK-12081][table-planner-blink] Introduce aggregation operator code generator to blink batch

KurtYoung commented on a change in pull request #8099: [FLINK-12081][table-planner-blink] Introduce aggregation operator code generator to blink batch URL: https://github.com/apache/flink/pull/8099#discussion_r272001002 ## File path: flink-table/flink-table-planner-blink/src/main/

[GitHub] [flink] KurtYoung commented on a change in pull request #8099: [FLINK-12081][table-planner-blink] Introduce aggregation operator code generator to blink batch

KurtYoung commented on a change in pull request #8099: [FLINK-12081][table-planner-blink] Introduce aggregation operator code generator to blink batch URL: https://github.com/apache/flink/pull/8099#discussion_r272000515 ## File path: flink-table/flink-table-planner-blink/src/main/

[jira] [Assigned] (FLINK-12070) Make blocking result partitions consumable multiple times

[ https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] BoWang reassigned FLINK-12070: -- Assignee: BoWang > Make blocking result partitions consumable multiple times > --

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r271996542 ## File path: flink-table/flink-table-common/src/test/java/org/apache/flin

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r271991771 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flin

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r271996701 ## File path: flink-table/flink-table-common/src/test/java/org/apache/flin

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r271990155 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flin

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r271999138 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flin

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r271991218 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flin

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r271995584 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flin

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r271993087 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flin

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r271990956 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flin

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r271990551 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flin

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r271997186 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flin

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r271996645 ## File path: flink-table/flink-table-common/src/test/java/org/apache/flin

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r271990685 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flin

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r271994232 ## File path: flink-table/flink-table-common/src/test/java/org/apache/flin

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r271991296 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flin

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r271995866 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flin

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r271988554 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flin

[jira] [Created] (FLINK-12107) Use Proxy For DataDog Validation

Luka Jurukovski created FLINK-12107: --- Summary: Use Proxy For DataDog Validation Key: FLINK-12107 URL: https://issues.apache.org/jira/browse/FLINK-12107 Project: Flink Issue Type: Improvemen

[GitHub] [flink] KurtYoung commented on a change in pull request #8110: [FLINK-12098] [table-planner-blink] Add support for generating optimized logical plan for simple group aggregate on stream

KurtYoung commented on a change in pull request #8110: [FLINK-12098] [table-planner-blink] Add support for generating optimized logical plan for simple group aggregate on stream URL: https://github.com/apache/flink/pull/8110#discussion_r271998434 ## File path: flink-table/flink-ta

[GitHub] [flink] KurtYoung commented on a change in pull request #8110: [FLINK-12098] [table-planner-blink] Add support for generating optimized logical plan for simple group aggregate on stream

KurtYoung commented on a change in pull request #8110: [FLINK-12098] [table-planner-blink] Add support for generating optimized logical plan for simple group aggregate on stream URL: https://github.com/apache/flink/pull/8110#discussion_r271998411 ## File path: flink-table/flink-ta

[GitHub] [flink] KurtYoung commented on a change in pull request #8110: [FLINK-12098] [table-planner-blink] Add support for generating optimized logical plan for simple group aggregate on stream

KurtYoung commented on a change in pull request #8110: [FLINK-12098] [table-planner-blink] Add support for generating optimized logical plan for simple group aggregate on stream URL: https://github.com/apache/flink/pull/8110#discussion_r271997758 ## File path: flink-table/flink-ta

[GitHub] [flink] KurtYoung commented on a change in pull request #8110: [FLINK-12098] [table-planner-blink] Add support for generating optimized logical plan for simple group aggregate on stream

KurtYoung commented on a change in pull request #8110: [FLINK-12098] [table-planner-blink] Add support for generating optimized logical plan for simple group aggregate on stream URL: https://github.com/apache/flink/pull/8110#discussion_r271998426 ## File path: flink-table/flink-ta

[GitHub] [flink] KurtYoung commented on a change in pull request #8110: [FLINK-12098] [table-planner-blink] Add support for generating optimized logical plan for simple group aggregate on stream

KurtYoung commented on a change in pull request #8110: [FLINK-12098] [table-planner-blink] Add support for generating optimized logical plan for simple group aggregate on stream URL: https://github.com/apache/flink/pull/8110#discussion_r271997795 ## File path: flink-table/flink-ta

[jira] [Comment Edited] (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&focusedCommentId=16809428#comment-16809428 ] leesf edited comment on FLINK-12105 at 4/4/19 1:54 AM: --- [~vmehra]，

[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&focusedCommentId=16809428#comment-16809428 ] leesf commented on FLINK-12105: --- [~vmehra]，hi. The issue could be more appropriate to be f

[jira] [Commented] (FLINK-12106) Jobmanager is killing FINISHED taskmanger containers, causing exception in still running Taskmanagers an

[ https://issues.apache.org/jira/browse/FLINK-12106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16809421#comment-16809421 ] Guowei Ma commented on FLINK-12106: --- AFAIK, the community is working on it.  [FLINK-1

[GitHub] [flink] leesf commented on issue #8079: [FLINK-12054][Tests] HBaseConnectorITCase fails on Java 9

leesf commented on issue #8079: [FLINK-12054][Tests] HBaseConnectorITCase fails on Java 9 URL: https://github.com/apache/flink/pull/8079#issuecomment-479713439 @zentol hi, Chesnay. Sorry to bother you, could you please tell me the reason you closed this PR. ---

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

sunjincheng121 commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r271987200 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flin

[jira] [Created] (FLINK-12106) Jobmanager is killing FINISHED taskmanger containers, causing exception in still running Taskmanagers an

John created FLINK-12106: Summary: Jobmanager is killing FINISHED taskmanger containers, causing exception in still running Taskmanagers an Key: FLINK-12106 URL: https://issues.apache.org/jira/browse/FLINK-12106

[jira] [Commented] (FLINK-12104) Flink Kafka fails with Incompatible KafkaProducer version / NoSuchFieldException sequenceNumbers

[ https://issues.apache.org/jira/browse/FLINK-12104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16809220#comment-16809220 ] Tim commented on FLINK-12104: - I am sure I am, not intentionally - but due to other libs in

[GitHub] [flink] xuefuz commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

xuefuz commented on a change in pull request #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#discussion_r271887584 ## File path: flink-table/flink-table-common/src/test/java/org/apache/flink/table/

[GitHub] [flink] aloyszhang edited a comment on issue #8075: [FLINK-12043][core] Process unreadble NPE without any hint

aloyszhang edited a comment on issue #8075: [FLINK-12043][core] Process unreadble NPE without any hint URL: https://github.com/apache/flink/pull/8075#issuecomment-479601262 I agree with "Even without them, when you get an NPE you can already infer that one of the incoming elements was like

[jira] [Commented] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16809002#comment-16809002 ] Shuyi Chen commented on FLINK-11912: Hi [~aitozi], the current approach does the fol

[GitHub] [flink] aloyszhang commented on issue #8075: [FLINK-12043][core] Process unreadble NPE without any hint

aloyszhang commented on issue #8075: [FLINK-12043][core] Process unreadble NPE without any hint URL: https://github.com/apache/flink/pull/8075#issuecomment-479601262 I agree with "Even without them, when you get an NPE you can already infer that one of the incoming elements was likely null

[jira] [Commented] (FLINK-12104) Flink Kafka fails with Incompatible KafkaProducer version / NoSuchFieldException sequenceNumbers

[ https://issues.apache.org/jira/browse/FLINK-12104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16808986#comment-16808986 ] Elias Levy commented on FLINK-12104: The {{flink-connector-kafka-0.11}} depends on t

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

Vinod Mehra created FLINK-12105: --- Summary: TUMBLE INTERVAL value errors out for 100 or more value Key: FLINK-12105 URL: https://issues.apache.org/jira/browse/FLINK-12105 Project: Flink Issue Ty

[jira] [Updated] (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:all-tabpanel ] Vinod Mehra updated FLINK-12105: Description: I ran into this while experimenting with different values at Lyft eng. However it is

[GitHub] [flink] hequn8128 edited a comment on issue #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces

hequn8128 edited a comment on issue #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces URL: https://github.com/apache/flink/pull/8050#issuecomment-479572670 @dawidwys Thanks a lot for your review. I think you have given a lot of good suggestions! 1. As for the usel

[jira] [Created] (FLINK-12104) Flink Kafka fails with Incompatible KafkaProducer version / NoSuchFieldException sequenceNumbers

Tim created FLINK-12104: --- Summary: Flink Kafka fails with Incompatible KafkaProducer version / NoSuchFieldException sequenceNumbers Key: FLINK-12104 URL: https://issues.apache.org/jira/browse/FLINK-12104 Projec

[GitHub] [flink] hequn8128 edited a comment on issue #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces

hequn8128 edited a comment on issue #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces URL: https://github.com/apache/flink/pull/8050#issuecomment-479573907 > Hi @hequn8128 Would you mind rebasing this commit on current master? Sure :-) I will do it ASAP while add

[GitHub] [flink] hequn8128 commented on issue #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces

hequn8128 commented on issue #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces URL: https://github.com/apache/flink/pull/8050#issuecomment-479573907 > Hi @hequn8128 Would you mind rebasing this commit on current master? Sure :-) I will do it ASAP while addressing

[GitHub] [flink] hequn8128 commented on issue #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces

hequn8128 commented on issue #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces URL: https://github.com/apache/flink/pull/8050#issuecomment-479572670 @dawidwys Thanks a lot for your review. I think you have given a lot of good suggestions! 1. As for the useless API

[jira] [Created] (FLINK-12103) Extend builtin operator metrics with user defined scope and variables

Ben Marini created FLINK-12103: -- Summary: Extend builtin operator metrics with user defined scope and variables Key: FLINK-12103 URL: https://issues.apache.org/jira/browse/FLINK-12103 Project: Flink

[GitHub] [flink] azagrebin commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment

azagrebin commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8090#discussion_r271823199 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskMana

[GitHub] [flink] azagrebin commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment

azagrebin commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8090#discussion_r271834864 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskManag

[GitHub] [flink] azagrebin commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment

azagrebin commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8090#discussion_r271829700 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/NetworkEn

[GitHub] [flink] azagrebin commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment

azagrebin commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8090#discussion_r271453248 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NetworkEnv

[GitHub] [flink] azagrebin commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment

azagrebin commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8090#discussion_r271457542 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/NetworkEn

[GitHub] [flink] azagrebin commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment

azagrebin commented on a change in pull request #8090: [FLINK-12067][network] Refactor the constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8090#discussion_r271833815 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/NetworkB

  1   2   3   >