[GitHub] [flink] zhijiangW commented on a change in pull request #8320: [FLINK-12201][network][metrics] Introduce InputGateWithMetrics in Task to increment numBytesIn metric

zhijiangW commented on a change in pull request #8320: [FLINK-12201][network][metrics] Introduce InputGateWithMetrics in Task to increment numBytesIn metric URL: https://github.com/apache/flink/pull/8320#discussion_r281006940 ## File path: flink-runtime/src/main/java/org/apache/fl

[jira] [Comment Edited] (FLINK-12229) Implement Lazy Scheduling Strategy

[ https://issues.apache.org/jira/browse/FLINK-12229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833241#comment-16833241 ] ryantaocer edited comment on FLINK-12229 at 5/5/19 6:40 AM:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support

sunjincheng121 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support URL: https://github.com/apache/flink/pull/8267#discussion_r281006384 ## File path: flink-python/src/main/java/or

[jira] [Commented] (FLINK-12229) Implement Lazy Scheduling Strategy

[ https://issues.apache.org/jira/browse/FLINK-12229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833241#comment-16833241 ] ryantaocer commented on FLINK-12229: Maybe we could introduce a new scheduling trigg

[GitHub] [flink] zhijiangW commented on a change in pull request #8320: [FLINK-12201][network][metrics] Introduce InputGateWithMetrics in Task to increment numBytesIn metric

zhijiangW commented on a change in pull request #8320: [FLINK-12201][network][metrics] Introduce InputGateWithMetrics in Task to increment numBytesIn metric URL: https://github.com/apache/flink/pull/8320#discussion_r281006200 ## File path: flink-runtime/src/main/java/org/apache/fl

[GitHub] [flink] zjffdu commented on a change in pull request #8144: [FLINK-12159]. Enable YarnMiniCluster integration test under non-secure mode

zjffdu commented on a change in pull request #8144: [FLINK-12159]. Enable YarnMiniCluster integration test under non-secure mode URL: https://github.com/apache/flink/pull/8144#discussion_r281006208 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDesc

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r281002357 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] zhijiangW commented on a change in pull request #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure

zhijiangW commented on a change in pull request #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#discussion_r281005899 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io

[GitHub] [flink] zhijiangW commented on a change in pull request #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure

zhijiangW commented on a change in pull request #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#discussion_r281005734 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io

[GitHub] [flink] zhijiangW commented on a change in pull request #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure

zhijiangW commented on a change in pull request #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#discussion_r281005469 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io

[GitHub] [flink] sunjincheng121 commented on issue #8230: [FLINK-10977][table] Add streaming non-window FlatAggregate to Table API

sunjincheng121 commented on issue #8230: [FLINK-10977][table] Add streaming non-window FlatAggregate to Table API URL: https://github.com/apache/flink/pull/8230#issuecomment-489392533 Thanks for create the JIRA @hequn8128! +1 to merged. @flinkbot approve all -

[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&focusedCommentId=16833223#comment-16833223 ] Hequn Cheng commented on FLINK-12401: - [~jark] Hi, great that you are also intereste

[GitHub] [flink] hequn8128 commented on issue #8230: [FLINK-10977][table] Add streaming non-window FlatAggregate to Table API

hequn8128 commented on issue #8230: [FLINK-10977][table] Add streaming non-window FlatAggregate to Table API URL: https://github.com/apache/flink/pull/8230#issuecomment-489390597 @sunjincheng121 Thank you for the reminder. I have created another jira([FLINK-12401](https://issues.apache.or

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r281004053 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] zhijiangW edited a comment on issue #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure

zhijiangW edited a comment on issue #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#issuecomment-489389513 Thanks for your professional reviews and valuable suggestions @tillrohrmann . I t

[GitHub] [flink] zhijiangW edited a comment on issue #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure

zhijiangW edited a comment on issue #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#issuecomment-489389513 Thanks for your professional reviews and valuable suggestions @tillrohrmann . I t

[GitHub] [flink] zhijiangW commented on issue #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure

zhijiangW commented on issue #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#issuecomment-489389513 Thanks for your professional reviews and valuable suggestions @tillrohrmann . I think th

[GitHub] [flink] zhijiangW edited a comment on issue #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure

zhijiangW edited a comment on issue #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#issuecomment-489389513 Thanks for your professional reviews and valuable suggestions @tillrohrmann . I t

[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&focusedCommentId=16833212#comment-16833212 ] Jark Wu commented on FLINK-12348: - Hi [~twalthr], I find that the updates to TableConfig

[jira] [Updated] (FLINK-11820) SimpleStringSchema handle message record which value is null

[ https://issues.apache.org/jira/browse/FLINK-11820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-11820: -- Affects Version/s: 1.8.0 Fix Version/s: (was: 1.7.3) Issue Type: Bug (was: Improvement)

[GitHub] [flink] carp84 commented on issue #7987: [FLINK-11820][serialization] SimpleStringSchema handle message record which value is null

carp84 commented on issue #7987: [FLINK-11820][serialization] SimpleStringSchema handle message record which value is null URL: https://github.com/apache/flink/pull/7987#issuecomment-489388048 @aljoscha @tzulitai Mind take a look here? Thanks. --

[jira] [Resolved] (FLINK-12400) NullpointerException using SimpleStringSchema with Kafka

[ https://issues.apache.org/jira/browse/FLINK-12400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li resolved FLINK-12400. --- Resolution: Duplicate > NullpointerException using SimpleStringSchema with Kafka > -

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r281002555 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support

WeiZhong94 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support URL: https://github.com/apache/flink/pull/8267#discussion_r281002536 ## File path: flink-python/pyflink/table/table.p

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r281002374 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r281002364 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r281002357 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r281002317 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r281002177 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r281002120 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r281002108 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r281002116 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r281002114 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r281002106 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r281002110 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support

sunjincheng121 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support URL: https://github.com/apache/flink/pull/8267#discussion_r281002095 ## File path: flink-dist/src/main/flink-bin/

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r281001965 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r281001882 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r281001867 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strateg

[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 > -

[GitHub] [flink] flinkbot commented on issue #8343: [hotfix][runtime] Remove useless code in JSONGenerator

flinkbot commented on issue #8343: [hotfix][runtime] Remove useless code in JSONGenerator URL: https://github.com/apache/flink/pull/8343#issuecomment-489383552 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull req

[GitHub] [flink] JingsongLi commented on a change in pull request #8295: [FLINK-11974][runtime] Introduce StreamOperatorFactory

JingsongLi commented on a change in pull request #8295: [FLINK-11974][runtime] Introduce StreamOperatorFactory URL: https://github.com/apache/flink/pull/8295#discussion_r281001725 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/JSONGenerator.ja

[GitHub] [flink] JingsongLi opened a new pull request #8343: [hotfix][runtime] Remove useless code in JSONGenerator

JingsongLi opened a new pull request #8343: [hotfix][runtime] Remove useless code in JSONGenerator URL: https://github.com/apache/flink/pull/8343 ## What is the purpose of the change Remove useless code in JSONGenerator for https://github.com/apache/flink/pull/8295 ## Verifyi

[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 ] Dian Fu reassigned FLINK-10976: --- Assignee: (was: Dian Fu) > Add Aggregate operator to Table API > --

[GitHub] [flink] dianfu closed pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API

dianfu closed pull request #7235: [FLINK-10976] [table] Add support for aggregate to table API URL: https://github.com/apache/flink/pull/7235 This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r281001575 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strateg

[GitHub] [flink] flinkbot commented on issue #8342: [FLINK-12360][chinese-translation]Translate Jobs and Scheduling Page …

flinkbot commented on issue #8342: [FLINK-12360][chinese-translation]Translate Jobs and Scheduling Page … URL: https://github.com/apache/flink/pull/8342#issuecomment-489383011 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

[jira] [Updated] (FLINK-12360) Translate "Jobs and Scheduling" Page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12360: --- Labels: pull-request-available (was: ) > Translate "Jobs and Scheduling" Page into Chinese

[GitHub] [flink] Armstrongya opened a new pull request #8342: [FLINK-12360][chinese-translation]Translate Jobs and Scheduling Page …

Armstrongya opened a new pull request #8342: [FLINK-12360][chinese-translation]Translate Jobs and Scheduling Page … URL: https://github.com/apache/flink/pull/8342 Translate the internal page "https://ci.apache.org/projects/flink/flink-docs-master/internals/job_scheduling.html"; to Chinese

[GitHub] [flink] zhuzhurk commented on a change in pull request #8233: [FLINK-12227] [runtime] introduce SchedulingStrategy interface

zhuzhurk commented on a change in pull request #8233: [FLINK-12227] [runtime] introduce SchedulingStrategy interface URL: https://github.com/apache/flink/pull/8233#discussion_r281001358 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/ExecutionVertexDepl

[GitHub] [flink] dianfu commented on issue #8311: [FLINK-10976][table] Add Aggregate operator to Table API

dianfu commented on issue #8311: [FLINK-10976][table] Add Aggregate operator to Table API URL: https://github.com/apache/flink/pull/8311#issuecomment-489382199 @hequn8128 Thanks a lot for the PR. LGTM overall with just a few comments. ---

[GitHub] [flink] dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API

dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API URL: https://github.com/apache/flink/pull/8311#discussion_r281000530 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/operations/Operation

[GitHub] [flink] dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API

dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API URL: https://github.com/apache/flink/pull/8311#discussion_r281000842 ## File path: docs/dev/table/tableApi.md ## @@ -1889,6 +1889,57 @@ tableEnv.registerFunction("f

[GitHub] [flink] dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API

dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API URL: https://github.com/apache/flink/pull/8311#discussion_r281001161 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/stream/table/val

[GitHub] [flink] dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API

dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API URL: https://github.com/apache/flink/pull/8311#discussion_r281000705 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/operations/Operation

[GitHub] [flink] dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API

dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API URL: https://github.com/apache/flink/pull/8311#discussion_r281000442 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/tableImpl.scala

[GitHub] [flink] dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API

dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API URL: https://github.com/apache/flink/pull/8311#discussion_r281000507 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/tableImpl.scala

[GitHub] [flink] dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API

dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API URL: https://github.com/apache/flink/pull/8311#discussion_r281000356 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Table.java

[GitHub] [flink] dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API

dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API URL: https://github.com/apache/flink/pull/8311#discussion_r281000946 ## File path: docs/dev/table/tableApi.md ## @@ -1957,6 +2008,52 @@ class MyFlatMapFunction exte

[GitHub] [flink] dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API

dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API URL: https://github.com/apache/flink/pull/8311#discussion_r281000689 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/operations/Operation

[GitHub] [flink] dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API

dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API URL: https://github.com/apache/flink/pull/8311#discussion_r281001183 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/stream/table/val

[GitHub] [flink] dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API

dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API URL: https://github.com/apache/flink/pull/8311#discussion_r281001232 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/stream/table/val

[GitHub] [flink] dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API

dianfu commented on a change in pull request #8311: [FLINK-10976][table] Add Aggregate operator to Table API URL: https://github.com/apache/flink/pull/8311#discussion_r281000677 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/operations/Operation

[GitHub] [flink] klion26 commented on a change in pull request #8319: [FLINK-11636] [docs-zh] Translate "State Schema Evolution" into Chinese

klion26 commented on a change in pull request #8319: [FLINK-11636] [docs-zh] Translate "State Schema Evolution" into Chinese URL: https://github.com/apache/flink/pull/8319#discussion_r281000916 ## File path: docs/dev/stream/state/schema_evolution.zh.md ## @@ -26,11 +26,11

[GitHub] [flink] klion26 commented on a change in pull request #8319: [FLINK-11636] [docs-zh] Translate "State Schema Evolution" into Chinese

klion26 commented on a change in pull request #8319: [FLINK-11636] [docs-zh] Translate "State Schema Evolution" into Chinese URL: https://github.com/apache/flink/pull/8319#discussion_r281000985 ## File path: docs/dev/stream/state/schema_evolution.zh.md ## @@ -80,19 +80,19

[GitHub] [flink] Leeviiii commented on a change in pull request #8319: [FLINK-11636] [docs-zh] Translate "State Schema Evolution" into Chinese

Leev commented on a change in pull request #8319: [FLINK-11636] [docs-zh] Translate "State Schema Evolution" into Chinese URL: https://github.com/apache/flink/pull/8319#discussion_r281000793 ## File path: docs/dev/stream/state/schema_evolution.zh.md ## @@ -48,62 +47,52

[jira] [Comment Edited] (FLINK-12400) NullpointerException using SimpleStringSchema with Kafka

[ https://issues.apache.org/jira/browse/FLINK-12400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833187#comment-16833187 ] Congxian Qiu(klion26) edited comment on FLINK-12400 at 5/5/19 1:52 AM: ---

[jira] [Commented] (FLINK-12400) NullpointerException using SimpleStringSchema with Kafka

[ https://issues.apache.org/jira/browse/FLINK-12400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833187#comment-16833187 ] Congxian Qiu(klion26) commented on FLINK-12400: --- [~PierreZ] thanks for fil

[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&focusedCommentId=16833186#comment-16833186 ] Jark Wu commented on FLINK-12401: - Incremental value is ACC? Is this issue going to supp

[GitHub] [flink] Leeviiii commented on a change in pull request #8319: [FLINK-11636] [docs-zh] Translate "State Schema Evolution" into Chinese

Leev commented on a change in pull request #8319: [FLINK-11636] [docs-zh] Translate "State Schema Evolution" into Chinese URL: https://github.com/apache/flink/pull/8319#discussion_r281000414 ## File path: docs/dev/stream/state/schema_evolution.zh.md ## @@ -25,17 +25,16

[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: F

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support

sunjincheng121 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support URL: https://github.com/apache/flink/pull/8267#discussion_r281000307 ## File path: tools/verify_scala_suffixes.sh

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support

sunjincheng121 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support URL: https://github.com/apache/flink/pull/8267#discussion_r281000283 ## File path: flink-python/pyflink/table/tab

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support

sunjincheng121 commented on a change in pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support URL: https://github.com/apache/flink/pull/8267#discussion_r281000156 ## File path: flink-python/pyflink/find_flin

[GitHub] [flink] sunjincheng121 commented on issue #8230: [FLINK-10977][table] Add streaming non-window FlatAggregate to Table API

sunjincheng121 commented on issue #8230: [FLINK-10977][table] Add streaming non-window FlatAggregate to Table API URL: https://github.com/apache/flink/pull/8230#issuecomment-489378092 Thanks for your update! Then changes look good to me now! And one more thing is in current PR wit

[jira] [Commented] (FLINK-9679) Implement ConfluentRegistryAvroSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-9679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833108#comment-16833108 ] Bowen Li commented on FLINK-9679: - Hi [~dawidwys], what do you think of the relationship

[jira] [Commented] (FLINK-12399) FilterableTableSource does not use filters on job run

[ https://issues.apache.org/jira/browse/FLINK-12399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833107#comment-16833107 ] Rong Rong commented on FLINK-12399: --- Hi [~josh.bradt]. I think I found the root cause

[jira] [Assigned] (FLINK-12399) FilterableTableSource does not use filters on job run

[ https://issues.apache.org/jira/browse/FLINK-12399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-12399: - Assignee: Rong Rong > FilterableTableSource does not use filters on job run > -

[jira] [Comment Edited] (FLINK-11909) Provide default failure/timeout/backoff handling strategy for AsyncIO functions

[ https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831421#comment-16831421 ] Rong Rong edited comment on FLINK-11909 at 5/4/19 3:28 PM: --- I

[jira] [Assigned] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-12351: --- Assignee: Jark Wu > AsyncWaitOperator should deep copy StreamElement when object reuse is enabled >

[GitHub] [flink] wuchong commented on issue #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime

wuchong commented on issue #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime URL: https://github.com/apache/flink/pull/8302#issuecomment-489331877 Hi @KurtYoung , I have addressed the review comments. 1. add unit tests for all join runners

[GitHub] [flink] klion26 commented on a change in pull request #8300: [FLINK-11638][docs-zh] Translate Savepoints page into Chinese

klion26 commented on a change in pull request #8300: [FLINK-11638][docs-zh] Translate Savepoints page into Chinese URL: https://github.com/apache/flink/pull/8300#discussion_r280980371 ## File path: docs/ops/state/savepoints.zh.md ## @@ -25,32 +25,22 @@ under the License.

[GitHub] [flink] klion26 commented on a change in pull request #8300: [FLINK-11638][docs-zh] Translate Savepoints page into Chinese

klion26 commented on a change in pull request #8300: [FLINK-11638][docs-zh] Translate Savepoints page into Chinese URL: https://github.com/apache/flink/pull/8300#discussion_r280980514 ## File path: docs/ops/state/savepoints.zh.md ## @@ -78,160 +68,158 @@ source-id | Stat

[GitHub] [flink] klion26 commented on a change in pull request #8300: [FLINK-11638][docs-zh] Translate Savepoints page into Chinese

klion26 commented on a change in pull request #8300: [FLINK-11638][docs-zh] Translate Savepoints page into Chinese URL: https://github.com/apache/flink/pull/8300#discussion_r280980459 ## File path: docs/ops/state/savepoints.zh.md ## @@ -78,160 +68,158 @@ source-id | Stat

[GitHub] [flink] klion26 commented on a change in pull request #8300: [FLINK-11638][docs-zh] Translate Savepoints page into Chinese

klion26 commented on a change in pull request #8300: [FLINK-11638][docs-zh] Translate Savepoints page into Chinese URL: https://github.com/apache/flink/pull/8300#discussion_r280980436 ## File path: docs/ops/state/savepoints.zh.md ## @@ -78,160 +68,158 @@ source-id | Stat

[GitHub] [flink] klion26 commented on a change in pull request #8300: [FLINK-11638][docs-zh] Translate Savepoints page into Chinese

klion26 commented on a change in pull request #8300: [FLINK-11638][docs-zh] Translate Savepoints page into Chinese URL: https://github.com/apache/flink/pull/8300#discussion_r280980604 ## File path: docs/ops/state/savepoints.zh.md ## @@ -78,160 +68,158 @@ source-id | Stat

[GitHub] [flink] klion26 commented on a change in pull request #8300: [FLINK-11638][docs-zh] Translate Savepoints page into Chinese

klion26 commented on a change in pull request #8300: [FLINK-11638][docs-zh] Translate Savepoints page into Chinese URL: https://github.com/apache/flink/pull/8300#discussion_r280980635 ## File path: docs/ops/state/savepoints.zh.md ## @@ -78,160 +68,158 @@ source-id | Stat

[GitHub] [flink] klion26 commented on a change in pull request #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese

klion26 commented on a change in pull request #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese URL: https://github.com/apache/flink/pull/8341#discussion_r280980168 ## File path: docs/dev/stream/state/state.zh.md ## @@ -22,122 +22,87 @@ specific lan

[GitHub] [flink] klion26 commented on a change in pull request #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese

klion26 commented on a change in pull request #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese URL: https://github.com/apache/flink/pull/8341#discussion_r280980039 ## File path: docs/dev/stream/state/state.zh.md ## @@ -22,122 +22,87 @@ specific lan

[GitHub] [flink] klion26 commented on a change in pull request #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese

klion26 commented on a change in pull request #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese URL: https://github.com/apache/flink/pull/8341#discussion_r280979940 ## File path: docs/dev/stream/state/state.zh.md ## @@ -22,122 +22,87 @@ specific lan

[GitHub] [flink] klion26 commented on a change in pull request #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese

klion26 commented on a change in pull request #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese URL: https://github.com/apache/flink/pull/8341#discussion_r280979906 ## File path: docs/dev/stream/state/state.zh.md ## @@ -22,122 +22,87 @@ specific lan

[GitHub] [flink] klion26 commented on a change in pull request #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese

klion26 commented on a change in pull request #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese URL: https://github.com/apache/flink/pull/8341#discussion_r280980096 ## File path: docs/dev/stream/state/state.zh.md ## @@ -22,122 +22,87 @@ specific lan

[GitHub] [flink] klion26 commented on a change in pull request #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese

klion26 commented on a change in pull request #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese URL: https://github.com/apache/flink/pull/8341#discussion_r280979970 ## File path: docs/dev/stream/state/state.zh.md ## @@ -22,122 +22,87 @@ specific lan

[GitHub] [flink] klion26 commented on a change in pull request #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese

klion26 commented on a change in pull request #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese URL: https://github.com/apache/flink/pull/8341#discussion_r280980068 ## File path: docs/dev/stream/state/state.zh.md ## @@ -22,122 +22,87 @@ specific lan

[GitHub] [flink] klion26 commented on a change in pull request #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese

klion26 commented on a change in pull request #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese URL: https://github.com/apache/flink/pull/8341#discussion_r280979872 ## File path: docs/dev/stream/state/state.zh.md ## @@ -22,122 +22,87 @@ specific lan

[jira] [Created] (FLINK-12400) NullpointerException using SimpleStringSchema with Kafka

Pierre Zemb created FLINK-12400: --- Summary: NullpointerException using SimpleStringSchema with Kafka Key: FLINK-12400 URL: https://issues.apache.org/jira/browse/FLINK-12400 Project: Flink Issue

[GitHub] [flink] PierreZ commented on a change in pull request #8272: [FLINK-12274] Fix documentation to enable Queryable State

PierreZ commented on a change in pull request #8272: [FLINK-12274] Fix documentation to enable Queryable State URL: https://github.com/apache/flink/pull/8272#discussion_r280978158 ## File path: docs/dev/stream/state/queryable_state.md ## @@ -69,10 +69,12 @@ response back t

[jira] [Commented] (FLINK-12392) FlinkRelMetadataQuery does not compile with Scala 2.12

[ https://issues.apache.org/jira/browse/FLINK-12392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833022#comment-16833022 ] Jark Wu commented on FLINK-12392: - cc [~godfreyhe] > FlinkRelMetadataQuery does not com

[GitHub] [flink] klion26 commented on issue #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese

klion26 commented on issue #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese URL: https://github.com/apache/flink/pull/8341#issuecomment-489305163 This page contains many pieces of information, so I'll recheck the translation again, and any reviews are welcome. @

[jira] [Updated] (FLINK-11633) Translate "Working with State" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11633: --- Labels: pull-request-available (was: ) > Translate "Working with State" into Chinese >

  1   2   >