[GitHub] Tom-Goong commented on a change in pull request #7820: [FLINK-11742][Metrics]Push metrics to Pushgateway without "instance"

Tom-Goong commented on a change in pull request #7820: [FLINK-11742][Metrics]Push metrics to Pushgateway without "instance" URL: https://github.com/apache/flink/pull/7820#discussion_r261851802 ## File path:

[jira] [Updated] (FLINK-11742) Push metrics to Pushgateway without "instance"

[ https://issues.apache.org/jira/browse/FLINK-11742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Goong updated FLINK-11742: -- Description: According to the official article,

[jira] [Commented] (FLINK-11742) Push metrics to Pushgateway without "instance"

[ https://issues.apache.org/jira/browse/FLINK-11742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782592#comment-16782592 ] Tom Goong commented on FLINK-11742: --- I need to monitor some conditions of different taskmanagers. But

[GitHub] Tom-Goong commented on a change in pull request #7820: [FLINK-11742][Metrics]Push metrics to Pushgateway without "instance"

Tom-Goong commented on a change in pull request #7820: [FLINK-11742][Metrics]Push metrics to Pushgateway without "instance" URL: https://github.com/apache/flink/pull/7820#discussion_r261851648 ## File path:

[jira] [Updated] (FLINK-11526) Support Chinese Website for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-11526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11526: --- Labels: pull-request-available (was: ) > Support Chinese Website for Apache Flink >

[jira] [Updated] (FLINK-11797) Implement empty unit tests in CheckpointCoordinatorMasterHooksTest

[ https://issues.apache.org/jira/browse/FLINK-11797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-11797: -- Description: Current, there are some empty tests(no implementation) such as

[jira] [Updated] (FLINK-11797) Implement empty unit tests in CheckpointCoordinatorMasterHooksTest

[ https://issues.apache.org/jira/browse/FLINK-11797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-11797: -- Summary: Implement empty unit tests in CheckpointCoordinatorMasterHooksTest

[jira] [Updated] (FLINK-11797) Implementation empty unit tests in CheckpointCoordinatorMasterHooksTest

[ https://issues.apache.org/jira/browse/FLINK-11797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-11797: -- Description: Current, there are some empty tests(no implementation) such as

[jira] [Updated] (FLINK-11797) Implementation empty unit tests in CheckpointCoordinatorMasterHooksTest

[ https://issues.apache.org/jira/browse/FLINK-11797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-11797: -- Affects Version/s: 1.8.0 > Implementation empty unit tests in

[jira] [Created] (FLINK-11797) Implementation empty unit tests in CheckpointCoordinatorMasterHooksTest

Congxian Qiu(klion26) created FLINK-11797: - Summary: Implementation empty unit tests in CheckpointCoordinatorMasterHooksTest Key: FLINK-11797 URL: https://issues.apache.org/jira/browse/FLINK-11797

[GitHub] HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r261848167 ## File path:

[GitHub] flinkbot commented on issue #7882: [typo] Inaccurate info on Avro splitting support

flinkbot commented on issue #7882: [typo] Inaccurate info on Avro splitting support URL: https://github.com/apache/flink/pull/7882#issuecomment-468973315 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request.

[GitHub] a10y opened a new pull request #7882: [typo] Outdated comment

a10y opened a new pull request #7882: [typo] Outdated comment URL: https://github.com/apache/flink/pull/7882 Fixes outdated comment in FileInputFormat. Flink has supported block-splitting Avro since https://github.com/apache/flink/pull/387.

[GitHub] a10y commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

a10y commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r261846737 ## File path:

[GitHub] flinkbot edited a comment on issue #7865: [FLINK-9650] [formats] add support for protobuf objects

flinkbot edited a comment on issue #7865: [FLINK-9650] [formats] add support for protobuf objects URL: https://github.com/apache/flink/pull/7865#issuecomment-468415774 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-11796) Remove Snapshotable interface

[ https://issues.apache.org/jira/browse/FLINK-11796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-11796: -- Component/s: Runtime / State Backends > Remove Snapshotable interface > - > >

[GitHub] azagrebin commented on issue #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions

azagrebin commented on issue #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions URL: https://github.com/apache/flink/pull/7186#issuecomment-468950331 @zhijiangW thanks for explanation, `PartitionRequestQueue.channelInactive` and `handleException` should be

[jira] [Created] (FLINK-11796) Remove Snapshotable interface

Yu Li created FLINK-11796: - Summary: Remove Snapshotable interface Key: FLINK-11796 URL: https://issues.apache.org/jira/browse/FLINK-11796 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-11455) Support evictor operations on slicing and merging operators

[ https://issues.apache.org/jira/browse/FLINK-11455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11455: -- Issue Type: Improvement (was: Sub-task) Parent: (was: FLINK-11276) > Support evictor

[jira] [Closed] (FLINK-11456) Improve window operator with sliding window assigners

[ https://issues.apache.org/jira/browse/FLINK-11456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong closed FLINK-11456. - Resolution: Invalid > Improve window operator with sliding window assigners >

[jira] [Updated] (FLINK-11456) Improve window operator with sliding window assigners

[ https://issues.apache.org/jira/browse/FLINK-11456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11456: -- Issue Type: Improvement (was: Sub-task) Parent: (was: FLINK-11276) > Improve window

[jira] [Closed] (FLINK-11455) Support evictor operations on slicing and merging operators

[ https://issues.apache.org/jira/browse/FLINK-11455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong closed FLINK-11455. - Resolution: Invalid > Support evictor operations on slicing and merging operators >

[GitHub] flinkbot edited a comment on issue #7678: [FLINK-11453][DataStream] Support SliceStream with forwardable pane info using slice assigner, operator and stream

flinkbot edited a comment on issue #7678: [FLINK-11453][DataStream] Support SliceStream with forwardable pane info using slice assigner, operator and stream URL: https://github.com/apache/flink/pull/7678#issuecomment-462519667 Thanks a lot for your contribution to the Apache Flink project.

[jira] [Updated] (FLINK-11454) Support MergedStream operation

[ https://issues.apache.org/jira/browse/FLINK-11454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11454: -- Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-11276) > Support

[jira] [Updated] (FLINK-11453) Support SliceStream with forwardable pane info

[ https://issues.apache.org/jira/browse/FLINK-11453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11453: -- Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-11276) > Support SliceStream

[jira] [Commented] (FLINK-11453) Support SliceStream with forwardable pane info

[ https://issues.apache.org/jira/browse/FLINK-11453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782461#comment-16782461 ] Rong Rong commented on FLINK-11453: --- Per the discussion of the community, we will move the slicing API

[jira] [Closed] (FLINK-11453) Support SliceStream with forwardable pane info

[ https://issues.apache.org/jira/browse/FLINK-11453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong closed FLINK-11453. - Resolution: Invalid > Support SliceStream with forwardable pane info >

[GitHub] walterddr closed pull request #7678: [FLINK-11453][DataStream] Support SliceStream with forwardable pane info using slice assigner, operator and stream

walterddr closed pull request #7678: [FLINK-11453][DataStream] Support SliceStream with forwardable pane info using slice assigner, operator and stream URL: https://github.com/apache/flink/pull/7678 This is an automated

[jira] [Updated] (FLINK-11276) Slicing Window Optimization

[ https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11276: -- Description: This is the umbrella ticket for the improvement discussion in:

[jira] [Updated] (FLINK-11276) Slicing Window Optimization

[ https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11276: -- Description: This is the umbrella ticket for the improvement discussion in:

[jira] [Updated] (FLINK-11276) Slicing Window Optimization

[ https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11276: -- Description: This is the umbrella ticket for the improvement discussion in:

[jira] [Updated] (FLINK-11795) Introduce DataStream nodes and converter rules for batch and stream

[ https://issues.apache.org/jira/browse/FLINK-11795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11795: --- Labels: pull-request-available (was: ) > Introduce DataStream nodes and converter rules

[GitHub] godfreyhe opened a new pull request #7881: [FLINK-11795][table-runtime-blink] Introduce DataStream nodes and converter rules for batch and stream

godfreyhe opened a new pull request #7881: [FLINK-11795][table-runtime-blink] Introduce DataStream nodes and converter rules for batch and stream URL: https://github.com/apache/flink/pull/7881 ## What is the purpose of the change *Introduce DataStream nodes and converter rules

[GitHub] flinkbot commented on issue #7881: [FLINK-11795][table-runtime-blink] Introduce DataStream nodes and converter rules for batch and stream

flinkbot commented on issue #7881: [FLINK-11795][table-runtime-blink] Introduce DataStream nodes and converter rules for batch and stream URL: https://github.com/apache/flink/pull/7881#issuecomment-468915070 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Updated] (FLINK-11795) Introduce DataStream nodes and rules for batch and stream

[ https://issues.apache.org/jira/browse/FLINK-11795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-11795: --- Description: 1. adds DataStreamTable 2. adds DataStream nodes for batch and stream 3. adds convert

[jira] [Updated] (FLINK-11795) Introduce DataStream nodes and converter rules for batch and stream

[ https://issues.apache.org/jira/browse/FLINK-11795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-11795: --- Summary: Introduce DataStream nodes and converter rules for batch and stream (was: Introduce

[jira] [Created] (FLINK-11795) Introduce DataStream nodes and rules for batch and stream

godfrey he created FLINK-11795: -- Summary: Introduce DataStream nodes and rules for batch and stream Key: FLINK-11795 URL: https://issues.apache.org/jira/browse/FLINK-11795 Project: Flink Issue

[jira] [Updated] (FLINK-11790) Introduce FlinkRelNode interface and FlinkConventions

[ https://issues.apache.org/jira/browse/FLINK-11790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-11790: --- Summary: Introduce FlinkRelNode interface and FlinkConventions (was: Introduce basic Flink RelNode

[GitHub] leesf commented on issue #7862: [FLINK-11779] CLI ignores -m parameter if high-availability is ZOOKEEPER

leesf commented on issue #7862: [FLINK-11779] CLI ignores -m parameter if high-availability is ZOOKEEPER URL: https://github.com/apache/flink/pull/7862#issuecomment-468911168 @zentol thanks for your advice. I will start making -m tabke precedence.

[GitHub] leesf edited a comment on issue #7862: [FLINK-11779] CLI ignores -m parameter if high-availability is ZOOKEEPER

leesf edited a comment on issue #7862: [FLINK-11779] CLI ignores -m parameter if high-availability is ZOOKEEPER URL: https://github.com/apache/flink/pull/7862#issuecomment-468911168 @zentol thanks for your advice. I will start making -m take precedence.