[jira] [Commented] (FLINK-12852) Deadlock occurs when requiring exclusive buffer for RemoteInputChannel

[ https://issues.apache.org/jira/browse/FLINK-12852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16877524#comment-16877524 ] Guowei Ma commented on FLINK-12852: --- In long run there may be another way to avoid the

[GitHub] [flink] flinkbot commented on issue #8961: [FLINK-13073][table-blink-runtime]BinaryRow in Blink runtime has wrong FIRST_BYTE_ZERO mask

flinkbot commented on issue #8961: [FLINK-13073][table-blink-runtime]BinaryRow in Blink runtime has wrong FIRST_BYTE_ZERO mask URL: https://github.com/apache/flink/pull/8961#issuecomment-507962159 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

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

JingsongLi commented on a change in 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#discussion_r299797109 ## File path: flink-table/flink-table-planner-blink/src/main/sca

[jira] [Updated] (FLINK-13073) BinaryRow in Blink runtime has wrong FIRST_BYTE_ZERO mask

[ https://issues.apache.org/jira/browse/FLINK-13073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13073: --- Labels: pull-request-available (was: ) > BinaryRow in Blink runtime has wrong FIRST_BYTE_ZE

[GitHub] [flink] AjaxXu opened a new pull request #8961: [FLINK-13073][table-blink-runtime]BinaryRow in Blink runtime has wrong FIRST_BYTE_ZERO mask

AjaxXu opened a new pull request #8961: [FLINK-13073][table-blink-runtime]BinaryRow in Blink runtime has wrong FIRST_BYTE_ZERO mask URL: https://github.com/apache/flink/pull/8961 ## What is the purpose of the change *(For example: This pull request makes task deployment go t

[jira] [Created] (FLINK-13073) BinaryRow in Blink runtime has wrong FIRST_BYTE_ZERO mask

Louis Xu created FLINK-13073: Summary: BinaryRow in Blink runtime has wrong FIRST_BYTE_ZERO mask Key: FLINK-13073 URL: https://issues.apache.org/jira/browse/FLINK-13073 Project: Flink Issue Type:

[GitHub] [flink] KurtYoung commented on a change in pull request #8959: [FLINK-13070][table-planner-blink] Remove TableImpl and use api.internal.TableImpl in blink

KurtYoung commented on a change in 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#discussion_r299795262 ## File path: flink-table/flink-table-planner-blink/src/main/scal

[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_r299794529 ## File path: docs/ops/state/checkpoints.zh.md ## @@ -26,69 +26,49 @@ under the License.

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

R-CodeBoy 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_r299791955 ## File path: docs/ops/state/checkpoints.zh.md ## @@ -26,69 +26,49 @@ under the License.

[GitHub] [flink] zhijiangW commented on a change in pull request #8948: [FLINK-12889] Set FatalExitExceptionHandler for StreamTask#asyncOperationsThreadPool

zhijiangW commented on a change in pull request #8948: [FLINK-12889] Set FatalExitExceptionHandler for StreamTask#asyncOperationsThreadPool URL: https://github.com/apache/flink/pull/8948#discussion_r299789957 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/concur

[GitHub] [flink] zhijiangW commented on a change in pull request #8948: [FLINK-12889] Set FatalExitExceptionHandler for StreamTask#asyncOperationsThreadPool

zhijiangW commented on a change in pull request #8948: [FLINK-12889] Set FatalExitExceptionHandler for StreamTask#asyncOperationsThreadPool URL: https://github.com/apache/flink/pull/8948#discussion_r299789891 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streami

[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&focusedCommentId=16877512#comment-16877512 ] vinoyang commented on FLINK-13032: -- Sounds reasonable, WDYT? [~aljoscha] > Allow Acces

[jira] [Closed] (FLINK-13049) Port planner expressions to blink-planner from flink-planner

[ https://issues.apache.org/jira/browse/FLINK-13049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-13049. -- Resolution: Fixed Fix Version/s: 1.9.0 merged in 1.9.0: 886b01d8b21ed378cbffa6d01217f960eb30877

[GitHub] [flink] KurtYoung closed pull request #8942: [FLINK-13049][table-planner-blink] Port planner expressions to blink-planner from flink-planner

KurtYoung closed pull request #8942: [FLINK-13049][table-planner-blink] Port planner expressions to blink-planner from flink-planner URL: https://github.com/apache/flink/pull/8942 This is an automated message from the Apache

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

klion26 commented on issue #8954: [FLINK-13065][doc] Corrected example snippet using KeySelector URL: https://github.com/apache/flink/pull/8954#issuecomment-507951159 thanks for the contribution, LGTM This is an automated mes

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

R-CodeBoy 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_r299787675 ## File path: docs/ops/state/checkpoints.zh.md ## @@ -26,69 +26,49 @@ under the License.

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

[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&focusedCommentId=16877507#comment-16877507 ] jasine chen commented on FLINK-13032: - [~yanghua] yes, it's helpful in our scene, we

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

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

[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，不过看上去好像 flink

[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: flink-runtime/src/main/java/org/apache/flink

[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: flink-runtime/src/main/java/org/apache/flink

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

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

[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: flink-runtime/src/main/java/org/apache/flink

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

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

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

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

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

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

[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: Sub-task

[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: Sub-tas

[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: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/pla

[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: flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/C

[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: flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/T

[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: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/ope

[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: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api

[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: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/ope

[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&focusedCommentId=16877445#comment-16877445 ] yelun edited comment on FLINK-12833 at 7/3/19 3:09 AM: --- Hi，[~jark]

[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&focusedCommentId=16877445#comment-16877445 ] yelun commented on FLINK-12833: --- Hi，[~jark]，do you know what this isuus means? thanks > A

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

[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: flink-table/flink-table-common/src/test/java/org/apache/flink/table

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

[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: flink-runtime/src/test/java/org/apache/fli

[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: flink-runtime/src/test/java/org/apache/flink/

[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: docs/_includes/generated/blob_server_configur

[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: flink-runtime/src/test/java/org/apache/flink

[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: flink-runtime/src/test/java/org/apache/fli

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

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

[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: flink-runtime/src/main/java/org/apache/flink

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

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

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

[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: flink-runtime/src/main/java/org/apache/flink/runtime/executiongr

[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: flink-runtime/src/main/java/org/apache/flink/runtime/executiongr

[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&focusedCommentId=16877431#comment-16877431 ] yelun commented on FLINK-12833: --- [~fhueske] hi,could you explain the "Klaviyo" in details?

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

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

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

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

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

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

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

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

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

[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&focusedCommentId=16877415#comment-16877415 ] Congxian Qiu(klion26) commented on FLINK-11638: --- [~guanghui] I'm not worki

[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&focusedCommentId=16877413#comment-16877413 ] yelun commented on FLINK-11638: --- [~klion26] hi,do you still working on this issue? > Tran

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

[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 Catalog.get_table_fa

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

  1   2   3   4   5   >