[GitHub] [flink] Aitozi commented on issue #8455: [FLINK-12284][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

Aitozi commented on issue #8455: [FLINK-12284][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#issuecomment-507949361 Ping @pnowojski

[GitHub] [flink] klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese

klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese URL: https://github.com/apache/flink/pull/8943#discussion_r299785151 ## File path: docs/ops/state/checkpoints.zh.md ## @@ -26,69 +26,49 @@ under the License.

[GitHub] [flink] klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese

klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese URL: https://github.com/apache/flink/pull/8943#discussion_r299784600 ## File path: docs/ops/state/checkpoints.zh.md ## @@ -26,69 +26,49 @@ under the License.

[GitHub] [flink] klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese

klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese URL: https://github.com/apache/flink/pull/8943#discussion_r299785107 ## File path: docs/ops/state/checkpoints.zh.md ## @@ -26,69 +26,49 @@ under the License.

[GitHub] [flink] klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese

klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese URL: https://github.com/apache/flink/pull/8943#discussion_r299785643 ## File path: docs/ops/state/checkpoints.zh.md ## @@ -26,69 +26,49 @@ under the License.

[GitHub] [flink] klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese

klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese URL: https://github.com/apache/flink/pull/8943#discussion_r299783577 ## File path: docs/ops/state/checkpoints.zh.md ## @@ -26,69 +26,49 @@ under the License.

[GitHub] [flink] klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese

klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese URL: https://github.com/apache/flink/pull/8943#discussion_r299784378 ## File path: docs/ops/state/checkpoints.zh.md ## @@ -26,69 +26,49 @@ under the License.

[GitHub] [flink] klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese

klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese URL: https://github.com/apache/flink/pull/8943#discussion_r299784434 ## File path: docs/ops/state/checkpoints.zh.md ## @@ -26,69 +26,49 @@ under the License.

[GitHub] [flink] klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese

klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese URL: https://github.com/apache/flink/pull/8943#discussion_r299785669 ## File path: docs/ops/state/checkpoints.zh.md ## @@ -26,69 +26,49 @@ under the License.

[GitHub] [flink] klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese

klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese URL: https://github.com/apache/flink/pull/8943#discussion_r299784986 ## File path: docs/ops/state/checkpoints.zh.md ## @@ -26,69 +26,49 @@ under the License.

[GitHub] [flink] klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese

klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese URL: https://github.com/apache/flink/pull/8943#discussion_r299783489 ## File path: docs/ops/state/checkpoints.zh.md ## @@ -26,69 +26,49 @@ under the License.

[GitHub] [flink] klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese

klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese URL: https://github.com/apache/flink/pull/8943#discussion_r299783547 ## File path: docs/ops/state/checkpoints.zh.md ## @@ -26,69 +26,49 @@ under the License.

[GitHub] [flink] klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese

klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese URL: https://github.com/apache/flink/pull/8943#discussion_r299785407 ## File path: docs/ops/state/checkpoints.zh.md ## @@ -26,69 +26,49 @@ under the License.

[GitHub] [flink] klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese

klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese URL: https://github.com/apache/flink/pull/8943#discussion_r299785612 ## File path: docs/ops/state/checkpoints.zh.md ## @@ -26,69 +26,49 @@ under the License.

[GitHub] [flink] klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese

klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese URL: https://github.com/apache/flink/pull/8943#discussion_r299784530 ## File path: docs/ops/state/checkpoints.zh.md ## @@ -26,69 +26,49 @@ under the License.

[GitHub] [flink] klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese

klion26 commented on a change in pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese URL: https://github.com/apache/flink/pull/8943#discussion_r299786000 ## File path: docs/ops/state/checkpoints.zh.md ## @@ -26,69 +26,49 @@ under the License.

[jira] [Commented] (FLINK-13032) Allow Access to Per-Window State in mergeable window ProcessWindowFunction

[ https://issues.apache.org/jira/browse/FLINK-13032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877507#comment-16877507 ] jasine chen commented on FLINK-13032: - [~yanghua] yes, it's helpful in our scene, we use session

[jira] [Created] (FLINK-13072) RocksDBStateBachend is not thread safe and data loss silently

lynn1.zhang created FLINK-13072: --- Summary: RocksDBStateBachend is not thread safe and data loss silently Key: FLINK-13072 URL: https://issues.apache.org/jira/browse/FLINK-13072 Project: Flink

[GitHub] [flink] stevenzwu opened a new pull request #8665: [FLINK-12781] [Runtime/REST] include the whole stack trace in response payload

stevenzwu opened a new pull request #8665: [FLINK-12781] [Runtime/REST] include the whole stack trace in response payload URL: https://github.com/apache/flink/pull/8665 This is an automated message from the Apache

[GitHub] [flink] stevenzwu closed pull request #8665: [FLINK-12781] [Runtime/REST] include the whole stack trace in response payload

stevenzwu closed pull request #8665: [FLINK-12781] [Runtime/REST] include the whole stack trace in response payload URL: https://github.com/apache/flink/pull/8665 This is an automated message from the Apache Git Service. To

[GitHub] [flink] Garlandal closed pull request #8960: fix: ignore infinite metrics value

Garlandal closed pull request #8960: fix: ignore infinite metrics value URL: https://github.com/apache/flink/pull/8960 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] Garlandal opened a new pull request #8960: fix: ignore infinite metrics value

Garlandal opened a new pull request #8960: fix: ignore infinite metrics value URL: https://github.com/apache/flink/pull/8960 influxdb 不支持 inf 类型的数据，flink 的 metrics 会产生挺多这样的数据，直接上的话 taskManager 会一直抛异常。 目前已经有 issue 提到了这个事情，https://issues.apache.org/jira/browse/FLINK-12147，不过看上去好像

[GitHub] [flink] zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy…

zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy… URL: https://github.com/apache/flink/pull/8912#discussion_r299768508 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy…

zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy… URL: https://github.com/apache/flink/pull/8912#discussion_r299771028 ## File path:

[jira] [Created] (FLINK-13071) QueryOperationConverter in Blink planner support add kinds of QueryOperations.

Jing Zhang created FLINK-13071: -- Summary: QueryOperationConverter in Blink planner support add kinds of QueryOperations. Key: FLINK-13071 URL: https://issues.apache.org/jira/browse/FLINK-13071 Project:

[GitHub] [flink] zhuzhurk commented on issue #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy…

zhuzhurk commented on issue #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy… URL: https://github.com/apache/flink/pull/8912#issuecomment-507927294 Forced pushing after rebased onto master.

[GitHub] [flink] XuPingyong commented on issue #8951: [FLINK-13062] Set ScheduleMode based on boundedness of streaming Pipeline

XuPingyong commented on issue #8951: [FLINK-13062] Set ScheduleMode based on boundedness of streaming Pipeline URL: https://github.com/apache/flink/pull/8951#issuecomment-507926214 Thanks @aljoscha . I think boundedness of streaming Pipeline is not related to the streaming/batch

[GitHub] [flink] zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy…

zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy… URL: https://github.com/apache/flink/pull/8912#discussion_r299766343 ## File path:

[GitHub] [flink] flinkbot commented on issue #8959: [FLINK-13070][table-planner-blink] Remove TableImpl and use api.internal.TableImpl in blink

flinkbot commented on issue #8959: [FLINK-13070][table-planner-blink] Remove TableImpl and use api.internal.TableImpl in blink URL: https://github.com/apache/flink/pull/8959#issuecomment-507922656 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[jira] [Updated] (FLINK-13070) Remove TableImpl and use api.internal.TableImpl in blink

[ https://issues.apache.org/jira/browse/FLINK-13070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13070: --- Labels: pull-request-available (was: ) > Remove TableImpl and use api.internal.TableImpl

[GitHub] [flink] JingsongLi opened a new pull request #8959: [FLINK-13070][table-planner-blink] Remove TableImpl and use api.internal.TableImpl in blink

JingsongLi opened a new pull request #8959: [FLINK-13070][table-planner-blink] Remove TableImpl and use api.internal.TableImpl in blink URL: https://github.com/apache/flink/pull/8959 ## What is the purpose of the change Remove TableImpl and use api.internal.TableImpl in blink

[jira] [Created] (FLINK-13070) Remove TableImpl and use api.internal.TableImpl in blink

Jingsong Lee created FLINK-13070: Summary: Remove TableImpl and use api.internal.TableImpl in blink Key: FLINK-13070 URL: https://issues.apache.org/jira/browse/FLINK-13070 Project: Flink

[GitHub] [flink] flinkbot commented on issue #8958: [FLINK-13035] [Runtime / Task] make LocalStreamEnvironment launch act…

flinkbot commented on issue #8958: [FLINK-13035] [Runtime / Task] make LocalStreamEnvironment launch act… URL: https://github.com/apache/flink/pull/8958#issuecomment-507921864 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] spafka opened a new pull request #8958: [FLINK-13035] [Runtime / Task] make LocalStreamEnvironment launch act…

spafka opened a new pull request #8958: [FLINK-13035] [Runtime / Task] make LocalStreamEnvironment launch act… URL: https://github.com/apache/flink/pull/8958 …ually solts number. ## What is the purpose of the change *(For example: This pull request makes task

[jira] [Updated] (FLINK-13035) LocalStreamEnvironment shall launch actuall task solts

[ https://issues.apache.org/jira/browse/FLINK-13035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13035: --- Labels: pull-request-available (was: ) > LocalStreamEnvironment shall launch actuall task

[jira] [Created] (FLINK-13069) HiveTableSink should implement OverwritableTableSink

Rui Li created FLINK-13069: -- Summary: HiveTableSink should implement OverwritableTableSink Key: FLINK-13069 URL: https://issues.apache.org/jira/browse/FLINK-13069 Project: Flink Issue Type:

[jira] [Created] (FLINK-13068) HiveTableSink should implement PartitionableTableSink

Rui Li created FLINK-13068: -- Summary: HiveTableSink should implement PartitionableTableSink Key: FLINK-13068 URL: https://issues.apache.org/jira/browse/FLINK-13068 Project: Flink Issue Type:

[GitHub] [flink] danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r299761058 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r299760631 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r299760657 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r299760572 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r299760129 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r299760275 ## File path:

[jira] [Comment Edited] (FLINK-12833) Add Klaviyo to Chinese PoweredBy page

[ https://issues.apache.org/jira/browse/FLINK-12833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877445#comment-16877445 ] yelun edited comment on FLINK-12833 at 7/3/19 3:09 AM: --- Hi，[~jark]，do you know

[GitHub] [flink] klion26 commented on issue #8751: [FLINK-11937][StateBackend]Resolve small file problem in RocksDB incremental checkpoint

klion26 commented on issue #8751: [FLINK-11937][StateBackend]Resolve small file problem in RocksDB incremental checkpoint URL: https://github.com/apache/flink/pull/8751#issuecomment-507920049 @StephanEwen thanks for the comments, I'm trying to answer the questions below: - As a

[jira] [Commented] (FLINK-12833) Add Klaviyo to Chinese PoweredBy page

[ https://issues.apache.org/jira/browse/FLINK-12833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877445#comment-16877445 ] yelun commented on FLINK-12833: --- Hi，[~jark]，do you know what this isuus means? thanks > Add Klaviyo to

[GitHub] [flink] zjuwangg commented on a change in pull request #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog

zjuwangg commented on a change in pull request #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8636#discussion_r299760649 ## File path:

[GitHub] [flink] zhijiangW commented on issue #8455: [FLINK-12284][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

zhijiangW commented on issue #8455: [FLINK-12284][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#issuecomment-507919160 Thanks for the patience and addressing my comments @Aitozi ! I think you

[GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

zhijiangW commented on a change in pull request #8455: [FLINK-12284][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r299759623 ## File path:

[GitHub] [flink] Aitozi commented on a change in pull request #8455: [FLINK-12284][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

Aitozi commented on a change in pull request #8455: [FLINK-12284][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r299758981 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy…

zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy… URL: https://github.com/apache/flink/pull/8912#discussion_r299758806 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy…

zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy… URL: https://github.com/apache/flink/pull/8912#discussion_r299758797 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

zhijiangW commented on a change in pull request #8455: [FLINK-12284][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r299758674 ## File path:

[GitHub] [flink] guoweiM commented on issue #8951: [FLINK-13062] Set ScheduleMode based on boundedness of streaming Pipeline

guoweiM commented on issue #8951: [FLINK-13062] Set ScheduleMode based on boundedness of streaming Pipeline URL: https://github.com/apache/flink/pull/8951#issuecomment-507917477 Thanks @aljoscha . I think it is ok for BlinkPlanner to choose a proper schedule mode in 1.9. I have a

[jira] [Updated] (FLINK-13067) Fix broken links to contributing docs

[ https://issues.apache.org/jira/browse/FLINK-13067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-13067: - Fix Version/s: 1.9.0 > Fix broken links to contributing docs > - >

[jira] [Created] (FLINK-13067) Fix broken links to contributing docs

Yun Tang created FLINK-13067: Summary: Fix broken links to contributing docs Key: FLINK-13067 URL: https://issues.apache.org/jira/browse/FLINK-13067 Project: Flink Issue Type: Bug

[GitHub] [flink] zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy…

zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy… URL: https://github.com/apache/flink/pull/8912#discussion_r299756509 ## File path:

[GitHub] [flink] zhijiangW commented on issue #7197: [FLINK-12909][flink-runtime][network] continue trying to find a suitable spilling channel even in case of exceptions

zhijiangW commented on issue #7197: [FLINK-12909][flink-runtime][network] continue trying to find a suitable spilling channel even in case of exceptions URL: https://github.com/apache/flink/pull/7197#issuecomment-507915036 Thanks for the further reviews @NicoK ! Sorry for missing your

[GitHub] [flink] flinkbot commented on issue #8957: [hotfix][docs] fix broken links

flinkbot commented on issue #8957: [hotfix][docs] fix broken links URL: https://github.com/apache/flink/pull/8957#issuecomment-507914700 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this

[GitHub] [flink] sjwiesman commented on issue #8957: [hotfix][docs] fix broken links

sjwiesman commented on issue #8957: [hotfix][docs] fix broken links URL: https://github.com/apache/flink/pull/8957#issuecomment-507914461 cc @knaufk This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] sjwiesman opened a new pull request #8957: [hotfix][docs] fix broken links

sjwiesman opened a new pull request #8957: [hotfix][docs] fix broken links URL: https://github.com/apache/flink/pull/8957 ## What is the purpose of the change Update broken links in the documentation introduced by FLINK-12639

[GitHub] [flink] zhuzhurk commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler

zhuzhurk commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8922#discussion_r299754527 ## File path:

[jira] [Assigned] (FLINK-12833) Add Klaviyo to Chinese PoweredBy page

[ https://issues.apache.org/jira/browse/FLINK-12833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yelun reassigned FLINK-12833: - Assignee: yelun > Add Klaviyo to Chinese PoweredBy page > - > >

[GitHub] [flink] zhuzhurk commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler

zhuzhurk commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8922#discussion_r299754065 ## File path:

[jira] [Commented] (FLINK-12833) Add Klaviyo to Chinese PoweredBy page

[ https://issues.apache.org/jira/browse/FLINK-12833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877431#comment-16877431 ] yelun commented on FLINK-12833: --- [~fhueske] hi,could you explain the "Klaviyo" in details? and  I did not

[GitHub] [flink] Xpray commented on issue #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client

Xpray commented on issue #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client URL: https://github.com/apache/flink/pull/8756#issuecomment-507911734 @StephanEwen , Thanks for the review, I'll try to catch up with the lasted changes on shuffle

[jira] [Closed] (FLINK-12943) Translate "HDFS Connector" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-12943. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 1.9.0: 345ac8868b705b7c9be9bb70e6fb54d1d15baa9b >

[jira] [Closed] (FLINK-12944) Translate "Streaming File Sink" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-12944. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 1.9.0: 29a0e8e5e7d69b0450ac3865c25df0e5d75d758b >

[GitHub] [flink] asfgit closed pull request #8838: [FLINK-12946][docs]Translate Apache NiFi Connector page into Chinese

asfgit closed pull request #8838: [FLINK-12946][docs]Translate Apache NiFi Connector page into Chinese URL: https://github.com/apache/flink/pull/8838 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] asfgit closed pull request #8918: [FLINK-12944][docs]Translate Streaming File Sink page into Chinese

asfgit closed pull request #8918: [FLINK-12944][docs]Translate Streaming File Sink page into Chinese URL: https://github.com/apache/flink/pull/8918 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] asfgit closed pull request #8843: [FLINK-12945][docs] Translate RabbitMQ Connector page into Chinese

asfgit closed pull request #8843: [FLINK-12945][docs] Translate RabbitMQ Connector page into Chinese URL: https://github.com/apache/flink/pull/8843 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] asfgit closed pull request #8897: [FLINK-12943][docs]Translate HDFS Connector page into Chinese

asfgit closed pull request #8897: [FLINK-12943][docs]Translate HDFS Connector page into Chinese URL: https://github.com/apache/flink/pull/8897 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] asfgit closed pull request #8837: [FLINK-12938][docs]Translate "Streaming Connectors" page into Chinese

asfgit closed pull request #8837: [FLINK-12938][docs]Translate "Streaming Connectors" page into Chinese URL: https://github.com/apache/flink/pull/8837 This is an automated message from the Apache Git Service. To respond to

[jira] [Closed] (FLINK-12946) Translate "Apache NiFi Connector" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-12946. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 1.9.0: 5caed717570e14e0d45c49eccf409c3170034af1 >

[jira] [Closed] (FLINK-12938) Translate "Streaming Connectors" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-12938. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 1.9.0: bda485fc077453ff0a555c3f25e702bfd0a1f339 >

[jira] [Closed] (FLINK-12945) Translate "RabbitMQ Connector" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-12945. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 1.9.0: 6bf207166a5ca09c259d854989ccff18687745bc >

[GitHub] [flink] klion26 commented on issue #8895: [FLINK-12536][Runtime/Network]Make BufferOrEventSequence#getNext non blocking

klion26 commented on issue #8895: [FLINK-12536][Runtime/Network]Make BufferOrEventSequence#getNext non blocking URL: https://github.com/apache/flink/pull/8895#issuecomment-507907989 @StephanEwen thanks for the comments, I'll continue after the discussion has been solved.

[jira] [Commented] (FLINK-11638) Translate "Savepoints" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877415#comment-16877415 ] Congxian Qiu(klion26) commented on FLINK-11638: --- [~guanghui] I'm not working on it, but

[jira] [Commented] (FLINK-11638) Translate "Savepoints" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877413#comment-16877413 ] yelun commented on FLINK-11638: --- [~klion26] hi,do you still working on this issue? > Translate

[GitHub] [flink] dianfu commented on issue #8956: [FLINK-12991][python] Correct the implementation of Catalog.get_table_factory

dianfu commented on issue #8956: [FLINK-12991][python] Correct the implementation of Catalog.get_table_factory URL: https://github.com/apache/flink/pull/8956#issuecomment-507906136 @bowenli86 Could you help to take a look at if this change makes sense to you?

[GitHub] [flink] flinkbot commented on issue #8956: [FLINK-12991][python] Correct the implementation of Catalog.get_table_factory

flinkbot commented on issue #8956: [FLINK-12991][python] Correct the implementation of Catalog.get_table_factory URL: https://github.com/apache/flink/pull/8956#issuecomment-507905839 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] dianfu opened a new pull request #8956: [FLINK-12991][python] Correct the implementation of Catalog.get_table_factory

dianfu opened a new pull request #8956: [FLINK-12991][python] Correct the implementation of Catalog.get_table_factory URL: https://github.com/apache/flink/pull/8956 ## What is the purpose of the change *Currently the implementation of Catalog.get_table_factory returns a Java

[jira] [Updated] (FLINK-12991) Correct the implementation of Catalog.get_table_factory

[ https://issues.apache.org/jira/browse/FLINK-12991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12991: --- Labels: pull-request-available (was: ) > Correct the implementation of

[GitHub] [flink] TengHu commented on issue #8885: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

TengHu commented on issue #8885: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload. URL: https://github.com/apache/flink/pull/8885#issuecomment-507905048 @rmetzger @aljoscha Hey guys, Although there

[GitHub] [flink] asfgit closed pull request #8947: [hotfix][python] Remove the redundant 'python setup.py install' from tox.ini

asfgit closed pull request #8947: [hotfix][python] Remove the redundant 'python setup.py install' from tox.ini URL: https://github.com/apache/flink/pull/8947 This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on issue #8947: [hotfix][python] Remove the redundant 'python setup.py install' from tox.ini

flinkbot edited a comment on issue #8947: [hotfix][python] Remove the redundant 'python setup.py install' from tox.ini URL: https://github.com/apache/flink/pull/8947#issuecomment-507664999 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] flinkbot commented on issue #8955: [FLINK-13066][hive] append hive-site.xml to path of Hive conf dir

flinkbot commented on issue #8955: [FLINK-13066][hive] append hive-site.xml to path of Hive conf dir URL: https://github.com/apache/flink/pull/8955#issuecomment-507884466 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Updated] (FLINK-13066) append hive-site.xml to path defined in 'hive-conf-dir'

[ https://issues.apache.org/jira/browse/FLINK-13066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13066: --- Labels: pull-request-available (was: ) > append hive-site.xml to path defined in

[GitHub] [flink] bowenli86 opened a new pull request #8955: [FLINK-13066][hive] append hive-site.xml to path of Hive conf dir

bowenli86 opened a new pull request #8955: [FLINK-13066][hive] append hive-site.xml to path of Hive conf dir URL: https://github.com/apache/flink/pull/8955 ## What is the purpose of the change This PR fixes a bug that we previously only pass Hive conf dir to `HiveConf` but we

[jira] [Created] (FLINK-13066) append hive-site.xml to path defined in 'hive-conf-dir'

Bowen Li created FLINK-13066: Summary: append hive-site.xml to path defined in 'hive-conf-dir' Key: FLINK-13066 URL: https://issues.apache.org/jira/browse/FLINK-13066 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on issue #8954: [FLINK-13065][doc] Corrected example snippet using KeySelector

flinkbot commented on issue #8954: [FLINK-13065][doc] Corrected example snippet using KeySelector URL: https://github.com/apache/flink/pull/8954#issuecomment-507873435 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[jira] [Updated] (FLINK-13065) Document example snippet correction using KeySelector

[ https://issues.apache.org/jira/browse/FLINK-13065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13065: --- Labels: correction doc, example pull-request-available (was: correction doc, example) >

[GitHub] [flink] mans2singh opened a new pull request #8954: [FLINK-13065][doc] Corrected example snippet using KeySelector

mans2singh opened a new pull request #8954: [FLINK-13065][doc] Corrected example snippet using KeySelector URL: https://github.com/apache/flink/pull/8954 ## What is the purpose of the change * Corrected example snippet * ## Brief change log * Corrected usage

[jira] [Updated] (FLINK-13065) Document example snippet correction using KeySelector

[ https://issues.apache.org/jira/browse/FLINK-13065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mans Singh updated FLINK-13065: --- Description: The broadcast state 

[jira] [Created] (FLINK-13065) Document example snippet correction using KeySelector

Mans Singh created FLINK-13065: -- Summary: Document example snippet correction using KeySelector Key: FLINK-13065 URL: https://issues.apache.org/jira/browse/FLINK-13065 Project: Flink Issue

[GitHub] [flink] StephanEwen commented on a change in pull request #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client

StephanEwen commented on a change in pull request #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client URL: https://github.com/apache/flink/pull/8756#discussion_r299700273 ## File path:

[GitHub] [flink] StephanEwen commented on a change in pull request #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client

StephanEwen commented on a change in pull request #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client URL: https://github.com/apache/flink/pull/8756#discussion_r299699717 ## File path:

[GitHub] [flink] StephanEwen commented on a change in pull request #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client

StephanEwen commented on a change in pull request #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client URL: https://github.com/apache/flink/pull/8756#discussion_r299701049 ## File path:

[GitHub] [flink] StephanEwen commented on a change in pull request #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client

StephanEwen commented on a change in pull request #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client URL: https://github.com/apache/flink/pull/8756#discussion_r299701522 ## File path:

[GitHub] [flink] StephanEwen commented on a change in pull request #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client

StephanEwen commented on a change in pull request #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client URL: https://github.com/apache/flink/pull/8756#discussion_r299700721 ## File path:

  1   2   3   4   5   >