[GitHub] [flink] flinkbot commented on issue #8616: [FLINK-12718][hive] allow users to specify hive-site.xml location to configure hive metastore client in HiveCatalog

flinkbot commented on issue #8616: [FLINK-12718][hive] allow users to specify hive-site.xml location to configure hive metastore client in HiveCatalog URL: https://github.com/apache/flink/pull/8616#issuecomment-498774282 Thanks a lot for your contribution to the Apache Flink project. I'm

[GitHub] [flink] bowenli86 commented on issue #8522: [FLINK-12572][hive]Implement HiveInputFormat to read Hive tables

bowenli86 commented on issue #8522: [FLINK-12572][hive]Implement HiveInputFormat to read Hive tables URL: https://github.com/apache/flink/pull/8522#issuecomment-498774160 BTW, please add correct commit message in the future, e.g. the first commit's msg should be

[GitHub] [flink] flinkbot commented on issue #8617: [FLINK-12619][StateBackend]Support TERMINATE/SUSPEND Job with Checkpoint

flinkbot commented on issue #8617: [FLINK-12619][StateBackend]Support TERMINATE/SUSPEND Job with Checkpoint URL: https://github.com/apache/flink/pull/8617#issuecomment-498774272 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-12619) Support TERMINATE/SUSPEND Job with Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-12619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12619: --- Labels: pull-request-available (was: ) > Support TERMINATE/SUSPEND Job with Checkpoint >

[jira] [Updated] (FLINK-12718) allow users to specify hive-site.xml location to configure hive metastore client in HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12718: --- Labels: pull-request-available (was: ) > allow users to specify hive-site.xml location to

[GitHub] [flink] klion26 opened a new pull request #8617: [FLINK-12619][StateBackend]Support TERMINATE/SUSPEND Job with Checkpoint

klion26 opened a new pull request #8617: [FLINK-12619][StateBackend]Support TERMINATE/SUSPEND Job with Checkpoint URL: https://github.com/apache/flink/pull/8617 ## What is the purpose of the change Inspired by the idea of

[GitHub] [flink] bowenli86 commented on issue #8616: [FLINK-12718][hive] allow users to specify hive-site.xml location to configure hive metastore client in HiveCatalog

bowenli86 commented on issue #8616: [FLINK-12718][hive] allow users to specify hive-site.xml location to configure hive metastore client in HiveCatalog URL: https://github.com/apache/flink/pull/8616#issuecomment-498773580 cc @xuefuz @lirui-apache @zjuwangg

[GitHub] [flink] bowenli86 opened a new pull request #8616: [FLINK-12718][hive] allow users to specify hive-site.xml location to configure hive metastore client in HiveCatalog

bowenli86 opened a new pull request #8616: [FLINK-12718][hive] allow users to specify hive-site.xml location to configure hive metastore client in HiveCatalog URL: https://github.com/apache/flink/pull/8616 ## What is the purpose of the change This PR enables users to specify the

[GitHub] [flink] bowenli86 opened a new pull request #8589: [FLINK-12677][hive][sql-client] Add descriptor, validator, and factory for HiveCatalog

bowenli86 opened a new pull request #8589: [FLINK-12677][hive][sql-client] Add descriptor, validator, and factory for HiveCatalog URL: https://github.com/apache/flink/pull/8589 ## What is the purpose of the change This PR adds descriptor, validator, and factory for HiveCatalog, and

[GitHub] [flink] bowenli86 closed pull request #8589: [FLINK-12677][hive][sql-client] Add descriptor, validator, and factory for HiveCatalog

bowenli86 closed pull request #8589: [FLINK-12677][hive][sql-client] Add descriptor, validator, and factory for HiveCatalog URL: https://github.com/apache/flink/pull/8589 This is an automated message from the Apache Git

[GitHub] [flink] bowenli86 commented on issue #8522: [FLINK-12572][hive]Implement HiveInputFormat to read Hive tables

bowenli86 commented on issue #8522: [FLINK-12572][hive]Implement HiveInputFormat to read Hive tables URL: https://github.com/apache/flink/pull/8522#issuecomment-498763208 LGTM, merging This is an automated message from the

[GitHub] [flink] bowenli86 commented on issue #8610: [FLINK-12715][hive] Hive-1.2.1 build is broken

bowenli86 commented on issue #8610: [FLINK-12715][hive] Hive-1.2.1 build is broken URL: https://github.com/apache/flink/pull/8610#issuecomment-498762147 I wonder that, since`moveToTrash()` is mainly a util, should we move it to a separate util shim class like `HiveUtilShim`? The current

[GitHub] [flink] xuefuz commented on issue #8610: [FLINK-12715][hive] Hive-1.2.1 build is broken

xuefuz commented on issue #8610: [FLINK-12715][hive] Hive-1.2.1 build is broken URL: https://github.com/apache/flink/pull/8610#issuecomment-498761727 LGTM This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] Aitozi commented on issue #8280: [FLINK-12297]Harden ClosureCleaner to handle the wrapped function

Aitozi commented on issue #8280: [FLINK-12297]Harden ClosureCleaner to handle the wrapped function URL: https://github.com/apache/flink/pull/8280#issuecomment-498759646 I think it over again, it can be removed directly. And after this the clean method should not be directly used, it's

[GitHub] [flink] Aitozi commented on issue #8280: [FLINK-12297]Harden ClosureCleaner to handle the wrapped function

Aitozi commented on issue #8280: [FLINK-12297]Harden ClosureCleaner to handle the wrapped function URL: https://github.com/apache/flink/pull/8280#issuecomment-498756627 I know your mean, and can we remove all the scattered `clean()` used in functions like `connector`, `Pattern`. Because

[jira] [Created] (FLINK-12732) Add savepoint reader for consuming partitioned operator state

Seth Wiesman created FLINK-12732: Summary: Add savepoint reader for consuming partitioned operator state Key: FLINK-12732 URL: https://issues.apache.org/jira/browse/FLINK-12732 Project: Flink

[GitHub] [flink] azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290387680 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290385492 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290385179 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290383005 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290360264 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java ##

[GitHub] [flink] azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290358896 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java ##

[GitHub] [flink] azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290356202 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290354332 ## File path:

[GitHub] [flink] NicoK commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary

NicoK commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary URL: https://github.com/apache/flink/pull/8607#discussion_r290353193 ## File path: docs/concepts/glossary.md ## @@ -0,0 +1,140 @@ +--- +title: Glossary

[GitHub] [flink] NicoK commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary

NicoK commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary URL: https://github.com/apache/flink/pull/8607#discussion_r290352357 ## File path: docs/concepts/glossary.md ## @@ -0,0 +1,158 @@ +--- +title: Glossary

[GitHub] [flink] zhijiangW edited a comment on issue #8529: [FLINK-12603][network] Remove getOwningTaskName method from InputGate

zhijiangW edited a comment on issue #8529: [FLINK-12603][network] Remove getOwningTaskName method from InputGate URL: https://github.com/apache/flink/pull/8529#issuecomment-498711393 @tillrohrmann I have addressed the last comment and the travis issue is caused by another merged PR which

[GitHub] [flink] zhijiangW commented on issue #8529: [FLINK-12603][network] Remove getOwningTaskName method from InputGate

zhijiangW commented on issue #8529: [FLINK-12603][network] Remove getOwningTaskName method from InputGate URL: https://github.com/apache/flink/pull/8529#issuecomment-498711393 @tillrohrmann I have addressed the last comment and the travis issue is caused by another PR merged which is also

[GitHub] [flink] GJL commented on issue #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator

GJL commented on issue #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator URL: https://github.com/apache/flink/pull/8486#issuecomment-498709422 Thanks for your contribution to Apache Flink, @shuai-xu! I have left some comments that we should address prior to merging.

[GitHub] [flink] GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator

GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator URL: https://github.com/apache/flink/pull/8486#discussion_r290340620 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator

GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator URL: https://github.com/apache/flink/pull/8486#discussion_r289804535 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator

GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator URL: https://github.com/apache/flink/pull/8486#discussion_r289802837 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator

GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator URL: https://github.com/apache/flink/pull/8486#discussion_r290330381 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator

GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator URL: https://github.com/apache/flink/pull/8486#discussion_r289808534 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator

GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator URL: https://github.com/apache/flink/pull/8486#discussion_r290331180 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator

GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator URL: https://github.com/apache/flink/pull/8486#discussion_r290163711 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator

GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator URL: https://github.com/apache/flink/pull/8486#discussion_r289773084 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator

GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator URL: https://github.com/apache/flink/pull/8486#discussion_r290192255 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator

GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator URL: https://github.com/apache/flink/pull/8486#discussion_r290328242 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator

GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator URL: https://github.com/apache/flink/pull/8486#discussion_r290166547 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator

GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator URL: https://github.com/apache/flink/pull/8486#discussion_r290340620 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator

GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator URL: https://github.com/apache/flink/pull/8486#discussion_r289801892 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator

GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator URL: https://github.com/apache/flink/pull/8486#discussion_r290326821 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator

GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator URL: https://github.com/apache/flink/pull/8486#discussion_r290322371 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator

GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator URL: https://github.com/apache/flink/pull/8486#discussion_r290330863 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator

GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator URL: https://github.com/apache/flink/pull/8486#discussion_r290329493 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator

GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator URL: https://github.com/apache/flink/pull/8486#discussion_r290309691 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator

GJL commented on a change in pull request #8486: [FLINK-12372] [runtime] implement ExecutionSlotAllocator URL: https://github.com/apache/flink/pull/8486#discussion_r289803788 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8529: [FLINK-12603][network] Remove getOwningTaskName method from InputGate

tillrohrmann commented on a change in pull request #8529: [FLINK-12603][network] Remove getOwningTaskName method from InputGate URL: https://github.com/apache/flink/pull/8529#discussion_r290330027 ## File path:

[jira] [Closed] (FLINK-12684) User defined configuration for per job clusters

[ https://issues.apache.org/jira/browse/FLINK-12684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Moorhead closed FLINK-12684. Resolution: Information Provided > User defined configuration for per job clusters >

[jira] [Commented] (FLINK-12684) User defined configuration for per job clusters

[ https://issues.apache.org/jira/browse/FLINK-12684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855763#comment-16855763 ] Richard Moorhead commented on FLINK-12684: -- Thanks [~zhuzh]! > User defined configuration for

[jira] [Resolved] (FLINK-11403) Introduce ResultPartitionWithConsumableNotifier in task for notifying consumable result partition

[ https://issues.apache.org/jira/browse/FLINK-11403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-11403. --- Resolution: Done Fix Version/s: 1.9.0 Merged via

[GitHub] [flink] tillrohrmann closed pull request #7549: [FLINK-11403][network] Introduce ResultPartitionWithConsumableNotifier in task for notifying consumable result partition

tillrohrmann closed pull request #7549: [FLINK-11403][network] Introduce ResultPartitionWithConsumableNotifier in task for notifying consumable result partition URL: https://github.com/apache/flink/pull/7549 This is an

[GitHub] [flink] tillrohrmann commented on issue #7549: [FLINK-11403][network] Introduce ResultPartitionWithConsumableNotifier in task for notifying consumable result partition

tillrohrmann commented on issue #7549: [FLINK-11403][network] Introduce ResultPartitionWithConsumableNotifier in task for notifying consumable result partition URL: https://github.com/apache/flink/pull/7549#issuecomment-498696989 Makes sense. Thanks a lot @zhijiangW. Travis gave green

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290318982 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290325010 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290301970 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NetworkEnvironment.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290303793 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290307596 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290324483 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290303436 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290308989 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290310263 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleDescriptor.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290316943 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ShuffleMaster.java ##

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290306695 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290306120 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290319430 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290314401 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ProducerDescriptor.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290278205 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290288340 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290296329 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290286956 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290290722 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290301693 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NetworkEnvironment.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290290106 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290300192 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/PartitionInfo.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290289035 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290300766 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/PartitionInfo.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290282381 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290275962 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290286480 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290278446 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290284123 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290297974 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290283546 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

tillrohrmann commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r290278967 ## File path:

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

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

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

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

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

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

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

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

[GitHub] [flink] knaufk commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary

knaufk commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary URL: https://github.com/apache/flink/pull/8607#discussion_r290307750 ## File path: docs/concepts/glossary.md ## @@ -0,0 +1,158 @@ +--- +title: Glossary

[GitHub] [flink] knaufk commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary

knaufk commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary URL: https://github.com/apache/flink/pull/8607#discussion_r290307750 ## File path: docs/concepts/glossary.md ## @@ -0,0 +1,158 @@ +--- +title: Glossary

[GitHub] [flink] knaufk commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary

knaufk commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary URL: https://github.com/apache/flink/pull/8607#discussion_r290304299 ## File path: docs/concepts/glossary.md ## @@ -0,0 +1,140 @@ +--- +title: Glossary

[GitHub] [flink] NicoK commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary

NicoK commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary URL: https://github.com/apache/flink/pull/8607#discussion_r290301874 ## File path: docs/concepts/glossary.md ## @@ -0,0 +1,158 @@ +--- +title: Glossary

[GitHub] [flink] sjwiesman commented on issue #8615: [FLINK-12729][state-processor-api] Add state reader for consuming non-partitioned operator state

sjwiesman commented on issue #8615: [FLINK-12729][state-processor-api] Add state reader for consuming non-partitioned operator state URL: https://github.com/apache/flink/pull/8615#issuecomment-498676786 @flinkbot attention @tzulitai

[GitHub] [flink] flinkbot commented on issue #8615: [FLINK-12729][state-processor-api] Add state reader for consuming non-partitioned operator state

flinkbot commented on issue #8615: [FLINK-12729][state-processor-api] Add state reader for consuming non-partitioned operator state URL: https://github.com/apache/flink/pull/8615#issuecomment-498676123 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[jira] [Closed] (FLINK-11604) Extend the necessary methods in ResultPartitionWriter interface

[ https://issues.apache.org/jira/browse/FLINK-11604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang closed FLINK-11604. Resolution: Duplicate Already done in FLINK-12570 > Extend the necessary methods in

[GitHub] [flink] zhijiangW closed pull request #7704: [FLINK-11604][network] Extend the necessary methods in ResultPartitionWriter interface

zhijiangW closed pull request #7704: [FLINK-11604][network] Extend the necessary methods in ResultPartitionWriter interface URL: https://github.com/apache/flink/pull/7704 This is an automated message from the Apache Git

[GitHub] [flink] zhijiangW commented on issue #7704: [FLINK-11604][network] Extend the necessary methods in ResultPartitionWriter interface

zhijiangW commented on issue #7704: [FLINK-11604][network] Extend the necessary methods in ResultPartitionWriter interface URL: https://github.com/apache/flink/pull/7704#issuecomment-498675714 Close this PR because it was solved in #8494

[jira] [Commented] (FLINK-6755) Allow triggering Checkpoints through command line client

[ https://issues.apache.org/jira/browse/FLINK-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855707#comment-16855707 ] Aljoscha Krettek commented on FLINK-6755: - I agree with [~yanghua] that these two issues are

<    1   2   3   4   5   >