[GitHub] yanghua commented on issue #7571: [FLINK-10724] Refactor failure handling in check point coordinator

yanghua commented on issue #7571: [FLINK-10724] Refactor failure handling in check point coordinator URL: https://github.com/apache/flink/pull/7571#issuecomment-463938350 Hi @kl0u can you help review this PR? Or @tillrohrmann Can you recommend a committer to help review this PR?

[GitHub] yanghua commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator

yanghua commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator URL: https://github.com/apache/flink/pull/7571#discussion_r257126465 ## File path:

[GitHub] yanghua commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator

yanghua commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator URL: https://github.com/apache/flink/pull/7571#discussion_r257125937 ## File path:

[jira] [Commented] (FLINK-10819) The instability problem of CI, JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure test fail.

[ https://issues.apache.org/jira/browse/FLINK-10819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16769016#comment-16769016 ] Congxian Qiu commented on FLINK-10819: -- Another instance: 

[jira] [Updated] (FLINK-11618) [state] Refactor operator state repartition mechanism

[ https://issues.apache.org/jira/browse/FLINK-11618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11618: --- Labels: pull-request-available (was: ) > [state] Refactor operator state repartition

[GitHub] flinkbot commented on issue #7711: [FLINK-11618][state] Refactor operator state repartition mechanism

flinkbot commented on issue #7711: [FLINK-11618][state] Refactor operator state repartition mechanism URL: https://github.com/apache/flink/pull/7711#issuecomment-463928531 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] Myasuka opened a new pull request #7711: [FLINK-11618][state] Refactor operator state repartition mechanism

Myasuka opened a new pull request #7711: [FLINK-11618][state] Refactor operator state repartition mechanism URL: https://github.com/apache/flink/pull/7711 ## What is the purpose of the change There existed two problems during state assignment when parallelism not changed: 1. If

[jira] [Assigned] (FLINK-10937) Add scripts to create docker image for k8s

[ https://issues.apache.org/jira/browse/FLINK-10937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chunhui Shi reassigned FLINK-10937: --- Assignee: Chunhui Shi (was: JIN SUN) > Add scripts to create docker image for k8s >

[jira] [Assigned] (FLINK-10936) Implement Command line tools

[ https://issues.apache.org/jira/browse/FLINK-10936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chunhui Shi reassigned FLINK-10936: --- Assignee: Chunhui Shi (was: JIN SUN) > Implement Command line tools >

[jira] [Assigned] (FLINK-10935) Implement KubeClient with Faric8 Kubernetes clients

[ https://issues.apache.org/jira/browse/FLINK-10935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chunhui Shi reassigned FLINK-10935: --- Assignee: Chunhui Shi (was: JIN SUN) > Implement KubeClient with Faric8 Kubernetes

[jira] [Assigned] (FLINK-9495) Implement ResourceManager for Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-9495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chunhui Shi reassigned FLINK-9495: -- Assignee: Chunhui Shi (was: JIN SUN) > Implement ResourceManager for Kubernetes >

[jira] [Assigned] (FLINK-10934) Implement KubernetesJobClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-10934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chunhui Shi reassigned FLINK-10934: --- Assignee: Chunhui Shi (was: JIN SUN) > Implement KubernetesJobClusterEntrypoint >

[jira] [Assigned] (FLINK-10939) Add documents for Flink on native k8s

[ https://issues.apache.org/jira/browse/FLINK-10939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chunhui Shi reassigned FLINK-10939: --- Assignee: Chunhui Shi (was: JIN SUN) > Add documents for Flink on native k8s >

[jira] [Assigned] (FLINK-10938) Enable Flink on native k8s E2E Tests in Travis CI

[ https://issues.apache.org/jira/browse/FLINK-10938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chunhui Shi reassigned FLINK-10938: --- Assignee: Chunhui Shi (was: JIN SUN) > Enable Flink on native k8s E2E Tests in Travis CI

[jira] [Assigned] (FLINK-10968) Implement TaskManager Entrypoint

[ https://issues.apache.org/jira/browse/FLINK-10968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chunhui Shi reassigned FLINK-10968: --- Assignee: Chunhui Shi (was: JIN SUN) > Implement TaskManager Entrypoint >

[jira] [Assigned] (FLINK-10933) Implement KubernetesSessionClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-10933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chunhui Shi reassigned FLINK-10933: --- Assignee: Chunhui Shi (was: JIN SUN) > Implement KubernetesSessionClusterEntrypoint >

[GitHub] sunjincheng121 commented on a change in pull request #7664: [FLINK-11449][table] Uncouple the Expression class from RexNodes.

sunjincheng121 commented on a change in pull request #7664: [FLINK-11449][table] Uncouple the Expression class from RexNodes. URL: https://github.com/apache/flink/pull/7664#discussion_r255337933 ## File path:

[GitHub] sunjincheng121 commented on a change in pull request #7664: [FLINK-11449][table] Uncouple the Expression class from RexNodes.

sunjincheng121 commented on a change in pull request #7664: [FLINK-11449][table] Uncouple the Expression class from RexNodes. URL: https://github.com/apache/flink/pull/7664#discussion_r255365157 ## File path:

[jira] [Assigned] (FLINK-9955) Kubernetes ClusterDescriptor

[ https://issues.apache.org/jira/browse/FLINK-9955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chunhui Shi reassigned FLINK-9955: -- Assignee: Chunhui Shi (was: JIN SUN) > Kubernetes ClusterDescriptor >

[jira] [Assigned] (FLINK-9953) Active Kubernetes integration

[ https://issues.apache.org/jira/browse/FLINK-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chunhui Shi reassigned FLINK-9953: -- Assignee: Chunhui Shi (was: JIN SUN) > Active Kubernetes integration >

[jira] [Assigned] (FLINK-10932) Initial flink-kubernetes module with empty implementation

[ https://issues.apache.org/jira/browse/FLINK-10932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chunhui Shi reassigned FLINK-10932: --- Assignee: Chunhui Shi (was: JIN SUN) > Initial flink-kubernetes module with empty

[jira] [Created] (FLINK-11619) Make ScheduleMode configurable via user code or configuration file

yuqi created FLINK-11619: Summary: Make ScheduleMode configurable via user code or configuration file Key: FLINK-11619 URL: https://issues.apache.org/jira/browse/FLINK-11619 Project: Flink Issue

[jira] [Updated] (FLINK-11334) Migrate enum serializers to use new serialization compatibility abstractions

[ https://issues.apache.org/jira/browse/FLINK-11334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11334: --- Labels: pull-request-available (was: ) > Migrate enum serializers to use new serialization

[GitHub] flinkbot commented on issue #7710: [FLINK-11334][core] Migrate enum serializers to use new serialization compatibility abstractions

flinkbot commented on issue #7710: [FLINK-11334][core] Migrate enum serializers to use new serialization compatibility abstractions URL: https://github.com/apache/flink/pull/7710#issuecomment-463891813 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] klion26 opened a new pull request #7710: [FLINK-11334][core] Migrate enum serializers to use new serialization compatibility abstractions

klion26 opened a new pull request #7710: [FLINK-11334][core] Migrate enum serializers to use new serialization compatibility abstractions URL: https://github.com/apache/flink/pull/7710 ## What is the purpose of the change Migrate enum serializers to use new serialization

[GitHub] KurtYoung edited a comment on issue #7664: [FLINK-11449][table] Uncouple the Expression class from RexNodes.

KurtYoung edited a comment on issue #7664: [FLINK-11449][table] Uncouple the Expression class from RexNodes. URL: https://github.com/apache/flink/pull/7664#issuecomment-463553997 Thanks @sunjincheng121 for this great effort. I just quickly go through the changes, and have some design

[GitHub] carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code

carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code URL: https://github.com/apache/flink/pull/7674#discussion_r257088835 ## File path:

[GitHub] carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code

carp84 commented on a change in pull request #7674: [FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code URL: https://github.com/apache/flink/pull/7674#discussion_r257088134 ## File path:

[GitHub] tweise merged pull request #7672: [FLINK-11568][kinesis] Don't obscure important Kinesis exceptions

tweise merged pull request #7672: [FLINK-11568][kinesis] Don't obscure important Kinesis exceptions URL: https://github.com/apache/flink/pull/7672 This is an automated message from the Apache Git Service. To respond to the

[GitHub] flinkbot edited a comment on issue #7672: [FLINK-11568][kinesis] Don't obscure important Kinesis exceptions

flinkbot edited a comment on issue #7672: [FLINK-11568][kinesis] Don't obscure important Kinesis exceptions URL: https://github.com/apache/flink/pull/7672#issuecomment-461938418 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] tweise commented on issue #7672: [FLINK-11568][kinesis] Don't obscure important Kinesis exceptions

tweise commented on issue #7672: [FLINK-11568][kinesis] Don't obscure important Kinesis exceptions URL: https://github.com/apache/flink/pull/7672#issuecomment-463882250 @flinkbot approve all This is an automated message from

[GitHub] tweise commented on a change in pull request #7672: [FLINK-11568][kinesis] Don't obscure important Kinesis exceptions

tweise commented on a change in pull request #7672: [FLINK-11568][kinesis] Don't obscure important Kinesis exceptions URL: https://github.com/apache/flink/pull/7672#discussion_r257085977 ## File path:

[jira] [Assigned] (FLINK-11613) Translate the "Project Template for Scala" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Goong reassigned FLINK-11613: - Assignee: Tom Goong > Translate the "Project Template for Scala" page into Chinese >

[GitHub] wujinhu commented on issue #7599: [FLINK-11442] upgrade oss sdk version

wujinhu commented on issue #7599: [FLINK-11442] upgrade oss sdk version URL: https://github.com/apache/flink/pull/7599#issuecomment-463874242 Thanks @StefanRRichter This is an automated message from the Apache Git Service.

[jira] [Commented] (FLINK-11373) CliFrontend cuts off reason for error messages

[ https://issues.apache.org/jira/browse/FLINK-11373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768840#comment-16768840 ] leesf commented on FLINK-11373: --- [~AT-Fieldless], hi, thanks for your advise, but i am still working on

[jira] [Assigned] (FLINK-11613) Translate the "Project Template for Scala" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leesf reassigned FLINK-11613: - Assignee: (was: leesf) > Translate the "Project Template for Scala" page into Chinese >

[GitHub] glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#discussion_r257072070 ## File path:

[GitHub] glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#discussion_r257072024 ## File path:

[GitHub] glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#discussion_r257072051 ## File path:

[GitHub] tweise commented on a change in pull request #7706: [FLINK-11617] [kinesis connector] Kinesis Connector getRecords() failure logging is misleading

tweise commented on a change in pull request #7706: [FLINK-11617] [kinesis connector] Kinesis Connector getRecords() failure logging is misleading URL: https://github.com/apache/flink/pull/7706#discussion_r257053063 ## File path:

[GitHub] tweise commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

tweise commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#discussion_r257046152 ## File path:

[GitHub] tweise commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

tweise commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#discussion_r257047597 ## File path:

[GitHub] tweise commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

tweise commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#discussion_r257045352 ## File path:

[GitHub] glaksh100 commented on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

glaksh100 commented on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#issuecomment-463830228 @tweise @becketqin I updated the code to include a `FlinkConnectorRateLimiter` and also included a

[GitHub] glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#discussion_r257040349 ## File path:

[GitHub] glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#discussion_r257040325 ## File path:

[GitHub] Xeli commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

Xeli commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257039386 ## File path: flink-connectors/flink-connector-pubsub/pom.xml

[GitHub] Xeli commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

Xeli commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r257039169 ## File path: flink-examples/flink-examples-streaming/pom.xml

[GitHub] GJL commented on issue #7697: [FLINK-11578][tests] Port BackPressureStatsTrackerImplITCase to new code base

GJL commented on issue #7697: [FLINK-11578][tests] Port BackPressureStatsTrackerImplITCase to new code base URL: https://github.com/apache/flink/pull/7697#issuecomment-463793079 Thanks for the review... merging. This is an

[GitHub] GJL commented on a change in pull request #7697: [FLINK-11578][tests] Port BackPressureStatsTrackerImplITCase to new code base

GJL commented on a change in pull request #7697: [FLINK-11578][tests] Port BackPressureStatsTrackerImplITCase to new code base URL: https://github.com/apache/flink/pull/7697#discussion_r257008935 ## File path:

[jira] [Updated] (FLINK-11597) Remove legacy JobManagerActorTestUtils

[ https://issues.apache.org/jira/browse/FLINK-11597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-11597: - Description: Remove legacy JobManagerActorTestUtils > Remove legacy JobManagerActorTestUtils >

[GitHub] flinkbot commented on issue #7709: [FLINK-11577][tests] Replace StackTraceSampleCoordinatorITCase

flinkbot commented on issue #7709: [FLINK-11577][tests] Replace StackTraceSampleCoordinatorITCase URL: https://github.com/apache/flink/pull/7709#issuecomment-463787310 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] GJL opened a new pull request #7709: [FLINK-11577][tests] Replace StackTraceSampleCoordinatorITCase

GJL opened a new pull request #7709: [FLINK-11577][tests] Replace StackTraceSampleCoordinatorITCase URL: https://github.com/apache/flink/pull/7709 ## What is the purpose of the change *This removes the StackTraceSampleCoordinatorITCase test, and replaces it with

[jira] [Reopened] (FLINK-10457) Support SequenceFile for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-10457: -- > Support SequenceFile for StreamingFileSink > --

[jira] [Reopened] (FLINK-11487) Support for writing data to Apache Flume

[ https://issues.apache.org/jira/browse/FLINK-11487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-11487: -- > Support for writing data to Apache Flume > > >

[jira] [Updated] (FLINK-10457) Support SequenceFile for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10457: - Fix Version/s: 1.8.0 > Support SequenceFile for StreamingFileSink >

[jira] [Closed] (FLINK-11487) Support for writing data to Apache Flume

[ https://issues.apache.org/jira/browse/FLINK-11487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11487. Resolution: Invalid Release Note: (was: [FLINK-4446] Remove Flume connector (now

[jira] [Closed] (FLINK-10457) Support SequenceFile for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10457. Resolution: Fixed > Support SequenceFile for StreamingFileSink >

[jira] [Updated] (FLINK-11487) Support for writing data to Apache Flume

[ https://issues.apache.org/jira/browse/FLINK-11487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11487: - Fix Version/s: (was: 1.7.2) (was: 1.8.0) > Support for

[jira] [Updated] (FLINK-10910) Harden Kubernetes e2e test

[ https://issues.apache.org/jira/browse/FLINK-10910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10910: - Issue Type: Improvement (was: Bug) > Harden Kubernetes e2e test >

[jira] [Updated] (FLINK-11201) Document SBT dependency requirements when using MiniClusterResource

[ https://issues.apache.org/jira/browse/FLINK-11201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11201: - Summary: Document SBT dependency requirements when using MiniClusterResource (was:

[GitHub] tillrohrmann merged pull request #7701: [FLINK-11602] Remove legacy AkkaJobManagerRetriever

tillrohrmann merged pull request #7701: [FLINK-11602] Remove legacy AkkaJobManagerRetriever URL: https://github.com/apache/flink/pull/7701 This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Resolved] (FLINK-11602) Remove legacy AkkaJobManagerRetriever

[ https://issues.apache.org/jira/browse/FLINK-11602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-11602. --- Resolution: Fixed Fixed via

[jira] [Updated] (FLINK-10721) Kafka discovery-loop exceptions may be swallowed

[ https://issues.apache.org/jira/browse/FLINK-10721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10721: - Summary: Kafka discovery-loop exceptions may be swallowed (was: kafkaFetcher

[jira] [Closed] (FLINK-10807) KafkaConsumer still consume removed topic after changing topics list

[ https://issues.apache.org/jira/browse/FLINK-10807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-10807. Resolution: Duplicate > KafkaConsumer still consume removed topic after changing topics

[jira] [Updated] (FLINK-11618) [state] Refactor operator state repartition mechanism

[ https://issues.apache.org/jira/browse/FLINK-11618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-11618: - Description: Currently we have state assignment strategy of operator state below: * When parallelism

[jira] [Created] (FLINK-11618) [state] Refactor operator state repartition mechanism

Yun Tang created FLINK-11618: Summary: [state] Refactor operator state repartition mechanism Key: FLINK-11618 URL: https://issues.apache.org/jira/browse/FLINK-11618 Project: Flink Issue Type:

[GitHub] StefanRRichter commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

StefanRRichter commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256882174 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

StefanRRichter commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256881369 ## File path:

[GitHub] zentol commented on issue #7692: [FLINK-11121][license] Check and update licensing notes for Aliyun FS

zentol commented on issue #7692: [FLINK-11121][license] Check and update licensing notes for Aliyun FS URL: https://github.com/apache/flink/pull/7692#issuecomment-463667794 Needs a rebase now that #7599 was merged. This is

[GitHub] StefanRRichter commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

StefanRRichter commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256878807 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256852009 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256859785 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256864344 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256842090 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256859879 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256868137 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256851648 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256855501 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256855186 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256857264 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256852629 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256871460 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256867000 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256859426 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256863219 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256858255 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256863744 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256849683 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256851926 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256864748 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased)

tillrohrmann commented on a change in pull request #7662: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler (rebased) URL: https://github.com/apache/flink/pull/7662#discussion_r256860858 ## File path:

[GitHub] flinkbot commented on issue #7708: [WIP][FLINK-10569][tests] Clean up uses of Scheduler and Instance in valid tests(Batch 2)

flinkbot commented on issue #7708: [WIP][FLINK-10569][tests] Clean up uses of Scheduler and Instance in valid tests(Batch 2) URL: https://github.com/apache/flink/pull/7708#issuecomment-463659717 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] TisonKun opened a new pull request #7708: [FLINK-10569][tests] Clean up uses of Scheduler and Instance in valid tests(Batch 2)

TisonKun opened a new pull request #7708: [FLINK-10569][tests] Clean up uses of Scheduler and Instance in valid tests(Batch 2) URL: https://github.com/apache/flink/pull/7708 ## What is the purpose of the change 1. Remove `Instance` usage in ExecutionGraphDeploymentTest ##

[jira] [Commented] (FLINK-11373) CliFrontend cuts off reason for error messages

[ https://issues.apache.org/jira/browse/FLINK-11373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768320#comment-16768320 ] 金钟镛 commented on FLINK-11373: - Hello,is anyone still working on this issue?If not,do you mind assigning to

[jira] [Commented] (FLINK-11617) Kinesis Connector getRecords() failure logging is misleading

[ https://issues.apache.org/jira/browse/FLINK-11617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768330#comment-16768330 ] Jamie Grier commented on FLINK-11617: - Here's an example:   Stacktrace is:

[GitHub] StefanRRichter merged pull request #7599: [FLINK-11442] upgrade oss sdk version

StefanRRichter merged pull request #7599: [FLINK-11442] upgrade oss sdk version URL: https://github.com/apache/flink/pull/7599 This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Commented] (FLINK-11616) Flink official document has an error

[ https://issues.apache.org/jira/browse/FLINK-11616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768307#comment-16768307 ] Fabian Hueske commented on FLINK-11616: --- You would need to provide a pull request. Once it got

[jira] [Updated] (FLINK-10241) Reduce performance/stability impact of latency metrics

[ https://issues.apache.org/jira/browse/FLINK-10241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-10241: Fix Version/s: (was: 1.6.4) 1.6.5 > Reduce performance/stability impact of

[jira] [Updated] (FLINK-10954) Hardlink from files of previous local stored state might cross devices

[ https://issues.apache.org/jira/browse/FLINK-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-10954: Fix Version/s: (was: 1.6.4) 1.6.5 > Hardlink from files of previous local

  1   2   3   >