[GitHub] bowenli86 commented on issue #7643: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

bowenli86 commented on issue #7643: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/7643#issuecomment-462653964 Just took another look and found this PR needs to adapt to the new flink-table structure given that flink

[GitHub] bowenli86 removed a comment on issue #7643: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

bowenli86 removed a comment on issue #7643: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/7643#issuecomment-461575592 LGTM +1 This is an automated m

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

becketqin 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_r255822550 ## File path: flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/stre

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

becketqin 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_r255776176 ## File path: flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/str

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

becketqin 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_r255816157 ## File path: flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/stre

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

becketqin 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_r255815625 ## File path: flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/stre

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

becketqin 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_r255813728 ## File path: flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/stre

[GitHub] zhijiangW commented on issue #7549: [FLINK-11403][network] Remove ResultPartitionConsumableNotifier from ResultPartition

zhijiangW commented on issue #7549: [FLINK-11403][network] Remove ResultPartitionConsumableNotifier from ResultPartition URL: https://github.com/apache/flink/pull/7549#issuecomment-462638845 @azagrebin , thanks for your reviews! I think your suggestion makes sense and is worth trying

[GitHub] zhijiangW commented on issue #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor

zhijiangW commented on issue #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor URL: https://github.com/apache/flink/pull/7631#issuecomment-462637123 @azagrebin , thanks for your reviews! :) I was also confused a bit by the points you ment

[GitHub] zhijiangW commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor

zhijiangW commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor URL: https://github.com/apache/flink/pull/7631#discussion_r255819481 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] zhijiangW commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor

zhijiangW commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor URL: https://github.com/apache/flink/pull/7631#discussion_r255818212 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[jira] [Updated] (FLINK-11558) Translate "Ecosystem" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11558: --- Labels: pull-request-available (was: ) > Translate "Ecosystem" page into Chinese >

[GitHub] zhijiangW commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor

zhijiangW commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor URL: https://github.com/apache/flink/pull/7631#discussion_r255814019 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] sunjincheng121 commented on issue #5923: [FLINK-9253][network] make the maximum floating buffers count channel-type independent

sunjincheng121 commented on issue #5923: [FLINK-9253][network] make the maximum floating buffers count channel-type independent URL: https://github.com/apache/flink/pull/5923#issuecomment-462629185 Hi, @NicoK are you still following this PR? Recently, @rmetzger and I are planning the re

[GitHub] zhijiangW commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor

zhijiangW commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor URL: https://github.com/apache/flink/pull/7631#discussion_r255814019 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[jira] [Updated] (FLINK-11581) Add Chinese document contribution guideline

[ https://issues.apache.org/jira/browse/FLINK-11581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11581: --- Labels: pull-request-available (was: ) > Add Chinese document contribution guideline >

[jira] [Assigned] (FLINK-11581) Add Chinese document contribution guideline

[ https://issues.apache.org/jira/browse/FLINK-11581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Forward Xu reassigned FLINK-11581: -- Assignee: Forward Xu > Add Chinese document contribution guideline >

[jira] [Updated] (FLINK-11555) Translate "Contributing Code" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11555: --- Labels: pull-request-available (was: ) > Translate "Contributing Code" page into Chinese >

[jira] [Created] (FLINK-11581) Add Chinese document contribution guideline

Jark Wu created FLINK-11581: --- Summary: Add Chinese document contribution guideline Key: FLINK-11581 URL: https://issues.apache.org/jira/browse/FLINK-11581 Project: Flink Issue Type: Sub-task

[GitHub] liyafan82 opened a new pull request #7680: [FLINK-11421][Table API & SQL] Providing more compilation options for code-generated o…

liyafan82 opened a new pull request #7680: [FLINK-11421][Table API & SQL] Providing more compilation options for code-generated o… URL: https://github.com/apache/flink/pull/7680 …perators (changes for stream jobs) ## What is the purpose of the change This is to support JIRA [F

[GitHub] flinkbot commented on issue #7680: [FLINK-11421][Table API & SQL] Providing more compilation options for code-generated o…

flinkbot commented on issue #7680: [FLINK-11421][Table API & SQL] Providing more compilation options for code-generated o… URL: https://github.com/apache/flink/pull/7680#issuecomment-462593057 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the com

[jira] [Updated] (FLINK-11501) Add a ratelimiting feature to the FlinkKafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-11501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11501: --- Labels: pull-request-available (was: ) > Add a ratelimiting feature to the FlinkKafkaConsum

[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-462575544 Thanks @greghogan Would you pls help to merge this PR? It seems StefanRRichter is not available now. --

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

flinkbot commented on issue #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#issuecomment-462574731 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review yo

[GitHub] glaksh100 opened a new pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

glaksh100 opened a new pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679 ## What is the purpose of the change This pull request adds a ratelimiting feature to the Flink Kafka consumer. There are instances

[GitHub] HuangZhenQiu commented on a change in pull request #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers

HuangZhenQiu commented on a change in pull request #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers URL: https://github.com/apache/flink/pull/7356#discussion_r255752753 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceMan

[jira] [Updated] (FLINK-9816) Support Netty configuration to enable an openSSL-based SslEngine

[ https://issues.apache.org/jira/browse/FLINK-9816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9816: --- Issue Type: Sub-task (was: Improvement) Parent: FLINK-11579 > Support Netty configuration to

[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 ] ASF GitHub Bot updated FLINK-11453: --- Labels: pull-request-available (was: ) > Support SliceStream with forwardable pane info >

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

flinkbot commented on issue #7678: [FLINK-11453][DataStreamAPI] 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. I'm

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

walterddr opened a new pull request #7678: [FLINK-11453][DataStreamAPI] Support SliceStream with forwardable pane info using slice assigner, operator and stream URL: https://github.com/apache/flink/pull/7678 **(The sections below can be removed for hotfixes of typos)** -->

[jira] [Created] (FLINK-11580) Provide a dynamically-linked netty-tc

Nico Kruber created FLINK-11580: --- Summary: Provide a dynamically-linked netty-tc Key: FLINK-11580 URL: https://issues.apache.org/jira/browse/FLINK-11580 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11579) Support Netty SslEngine based on openSSL

Nico Kruber created FLINK-11579: --- Summary: Support Netty SslEngine based on openSSL Key: FLINK-11579 URL: https://issues.apache.org/jira/browse/FLINK-11579 Project: Flink Issue Type: Improvemen

[jira] [Updated] (FLINK-9816) Support Netty configuration to enable an openSSL-based SslEngine

[ https://issues.apache.org/jira/browse/FLINK-9816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9816: --- Summary: Support Netty configuration to enable an openSSL-based SslEngine (was: Support Netty SslEng

[jira] [Updated] (FLINK-9816) Support Netty configuration to enable an openSSL-based SslEngine

[ https://issues.apache.org/jira/browse/FLINK-9816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9816: --- Description: Since a while now, Netty does not only support the JDK's {{SSLEngine}} but also impleme

[GitHub] flinkbot edited a comment on issue #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor

flinkbot edited a comment on issue #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor URL: https://github.com/apache/flink/pull/7631#issuecomment-459738324 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I h

[GitHub] azagrebin commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor

azagrebin commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor URL: https://github.com/apache/flink/pull/7631#discussion_r255616682 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] azagrebin commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor

azagrebin commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor URL: https://github.com/apache/flink/pull/7631#discussion_r255629226 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] azagrebin commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor

azagrebin commented on a change in pull request #7631: [FLINK-11391][shuffle] Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor URL: https://github.com/apache/flink/pull/7631#discussion_r255611695 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[jira] [Resolved] (FLINK-10721) kafkaFetcher runFetchLoop throw exception will cause follow-up code not execute in FlinkKafkaConsumerBase run method

[ https://issues.apache.org/jira/browse/FLINK-10721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-10721. - Resolution: Fixed > kafkaFetcher runFetchLoop throw exception will cause follow-

[jira] [Commented] (FLINK-10721) kafkaFetcher runFetchLoop throw exception will cause follow-up code not execute in FlinkKafkaConsumerBase run method

[ https://issues.apache.org/jira/browse/FLINK-10721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16765226#comment-16765226 ] Tzu-Li (Gordon) Tai commented on FLINK-10721: - I think this is indirectly fi

[GitHub] asfgit closed pull request #7576: [FLINK-11046][elasticsearch] Fix ElasticSearch6Connector thread blocked when index failed with retry

asfgit closed pull request #7576: [FLINK-11046][elasticsearch] Fix ElasticSearch6Connector thread blocked when index failed with retry URL: https://github.com/apache/flink/pull/7576 This is an automated message from the Apac

[jira] [Closed] (FLINK-11046) ElasticSearch6Connector cause thread blocked when index failed with retry

[ https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-11046. --- Resolution: Fixed Merged. 1.8.0: 3aa92af9a68015f240c6dcc46313202e78ea5883 1.7.2: 2f

[GitHub] GJL commented on a change in pull request #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base

GJL commented on a change in pull request #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base URL: https://github.com/apache/flink/pull/7676#discussion_r255613841 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterTest.java #

[GitHub] GJL commented on a change in pull request #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base

GJL commented on a change in pull request #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base URL: https://github.com/apache/flink/pull/7676#discussion_r255593757 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java #

[GitHub] GJL commented on a change in pull request #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base

GJL commented on a change in pull request #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base URL: https://github.com/apache/flink/pull/7676#discussion_r255589778 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java #

[GitHub] GJL commented on a change in pull request #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base

GJL commented on a change in pull request #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base URL: https://github.com/apache/flink/pull/7676#discussion_r255600139 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/minicluster/TestingMiniCluster.

[GitHub] GJL commented on a change in pull request #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base

GJL commented on a change in pull request #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base URL: https://github.com/apache/flink/pull/7676#discussion_r255600846 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorITCase

[GitHub] GJL commented on a change in pull request #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base

GJL commented on a change in pull request #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base URL: https://github.com/apache/flink/pull/7676#discussion_r255591538 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java #

[GitHub] GJL commented on a change in pull request #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base

GJL commented on a change in pull request #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base URL: https://github.com/apache/flink/pull/7676#discussion_r255594841 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorITCase

[jira] [Assigned] (FLINK-11577) Check and port StackTraceSampleCoordinatorITCase to new code base if necessary

[ https://issues.apache.org/jira/browse/FLINK-11577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-11577: Assignee: (was: Gary Yao) > Check and port StackTraceSampleCoordinatorITCase to new code base

[GitHub] asfgit closed pull request #7637: [FLINK-11511] Remove legacy class JobAttachmentClientActor

asfgit closed pull request #7637: [FLINK-11511] Remove legacy class JobAttachmentClientActor URL: https://github.com/apache/flink/pull/7637 This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Closed] (FLINK-11511) Remove legacy class JobAttachmentClientActor

[ https://issues.apache.org/jira/browse/FLINK-11511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-11511. Resolution: Fixed Fixed via ef2edd09d32b988a5ac0209787d28e7a48b79ddb > Remove legacy class JobAttachmentC

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

rehevkor5 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_r255585813 ## File path: flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/stream

[GitHub] pnowojski commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer

pnowojski commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer URL: https://github.com/apache/flink/pull/7405#issuecomment-462391160 Thanks @EAlexRojas for the investigation. I am/was also in the process of discovering/fixing the same prob

[GitHub] flinkbot commented on issue #7677: [FLINK-11249][kafka] Add migration tests for FlinkKafkaProdcuer and FlinkKafkaProducer011

flinkbot commented on issue #7677: [FLINK-11249][kafka] Add migration tests for FlinkKafkaProdcuer and FlinkKafkaProducer011 URL: https://github.com/apache/flink/pull/7677#issuecomment-462389051 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the c

[GitHub] pnowojski opened a new pull request #7677: [FLINK-11249][kafka] Add migration tests for FlinkKafkaProdcuer and FlinkKafkaProducer011

pnowojski opened a new pull request #7677: [FLINK-11249][kafka] Add migration tests for FlinkKafkaProdcuer and FlinkKafkaProducer011 URL: https://github.com/apache/flink/pull/7677 This PR doesn't solve the problem of migrating from 0.11 to universal connector, it just adds regression tests

[GitHub] flinkbot edited a comment on issue #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base

flinkbot edited a comment on issue #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base URL: https://github.com/apache/flink/pull/7676#issuecomment-462382064 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to re

[GitHub] GJL commented on issue #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base

GJL commented on issue #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base URL: https://github.com/apache/flink/pull/7676#issuecomment-462387760 @flinkbot approve description @flinkbot approve consensus --

[GitHub] flinkbot commented on issue #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base

flinkbot commented on issue #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base URL: https://github.com/apache/flink/pull/7676#issuecomment-462382064 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review yo

[jira] [Updated] (FLINK-11364) Check and port TaskManagerFailsITCase to new code base if necessary

[ https://issues.apache.org/jira/browse/FLINK-11364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11364: --- Labels: pull-request-available (was: ) > Check and port TaskManagerFailsITCase to new code

[GitHub] tillrohrmann opened a new pull request #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base

tillrohrmann opened a new pull request #7676: [FLINK-11364][tests] Port TaskManagerFailsITCase to new code base URL: https://github.com/apache/flink/pull/7676 ## What is the purpose of the change Port `TaskManagerFailsITCase` to new code base. ## Brief change log - "det

[jira] [Updated] (FLINK-11578) Check and port BackPressureStatsTrackerImplITCase to new code base if necessary

[ https://issues.apache.org/jira/browse/FLINK-11578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-11578: - Description: Check and port {{BackPressureStatsTrackerImplITCase}} to new code base if necessary. (was:

[jira] [Created] (FLINK-11577) Check and port StackTraceSampleCoordinatorITCase to new code base if necessary

Gary Yao created FLINK-11577: Summary: Check and port StackTraceSampleCoordinatorITCase to new code base if necessary Key: FLINK-11577 URL: https://issues.apache.org/jira/browse/FLINK-11577 Project: Flink

[jira] [Created] (FLINK-11578) Check and port BackPressureStatsTrackerImplITCase to new code base if necessary

Gary Yao created FLINK-11578: Summary: Check and port BackPressureStatsTrackerImplITCase to new code base if necessary Key: FLINK-11578 URL: https://issues.apache.org/jira/browse/FLINK-11578 Project: Flin

[jira] [Updated] (FLINK-11577) Check and port StackTraceSampleCoordinatorITCase to new code base if necessary

[ https://issues.apache.org/jira/browse/FLINK-11577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-11577: - Description: Check and port {{StackTraceSampleCoordinatorITCase}} to new code base if necessary. (was:

[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_r255547663 ## File path: flink-end-to-end-tests/flink-datast

[jira] [Updated] (FLINK-11511) Remove legacy class JobAttachmentClientActor

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

[GitHub] flinkbot edited a comment on issue #7637: [FLINK-11511] Remove legacy class JobAttachmentClientActor

flinkbot edited a comment on issue #7637: [FLINK-11511] Remove legacy class JobAttachmentClientActor URL: https://github.com/apache/flink/pull/7637#issuecomment-459738301 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review yo

[GitHub] GJL commented on issue #7637: [FLINK-11511] Remove legacy class JobAttachmentClientActor

GJL commented on issue #7637: [FLINK-11511] Remove legacy class JobAttachmentClientActor URL: https://github.com/apache/flink/pull/7637#issuecomment-462359647 @flinkbot approve all This is an automated message from the Apache

[GitHub] GJL commented on issue #7637: [FLINK-11511] Remove legacy class JobAttachmentClientActor

GJL commented on issue #7637: [FLINK-11511] Remove legacy class JobAttachmentClientActor URL: https://github.com/apache/flink/pull/7637#issuecomment-462359456 LGTM, merging. This is an automated message from the Apache Git Se

[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_r255543476 ## File path: flink-runtime/src/main/java/org/apa

[jira] [Closed] (FLINK-11508) Remove invalid test AkkaJobManagerRetrieverTest

[ https://issues.apache.org/jira/browse/FLINK-11508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-11508. Resolution: Fixed > Remove invalid test AkkaJobManagerRetrieverTest >

[jira] [Updated] (FLINK-11508) Remove invalid test AkkaJobManagerRetrieverTest

[ https://issues.apache.org/jira/browse/FLINK-11508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-11508: - Description: Remove invalid test AkkaJobManagerRetrieverTest > Remove invalid test AkkaJobManagerRetriev

[jira] [Reopened] (FLINK-11508) Remove invalid test AkkaJobManagerRetrieverTest

[ https://issues.apache.org/jira/browse/FLINK-11508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reopened FLINK-11508: -- > Remove invalid test AkkaJobManagerRetrieverTest > --- > >

[jira] [Closed] (FLINK-11507) Remove invalid test JobClientActorTest

[ https://issues.apache.org/jira/browse/FLINK-11507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-11507. Resolution: Fixed Fixed via e6b5eda7359cd1fd2c58f5e33b844c4ea061294a > Remove invalid test JobClientActor

[GitHub] asfgit closed pull request #7633: [FLINK-11508] Remove invalid test AkkaJobManagerRetrieverTest

asfgit closed pull request #7633: [FLINK-11508] Remove invalid test AkkaJobManagerRetrieverTest URL: https://github.com/apache/flink/pull/7633 This is an automated message from the Apache Git Service. To respond to the messa

[GitHub] asfgit closed pull request #7635: [FLINK-11507] Remove invalid test JobClientActorTest

asfgit closed pull request #7635: [FLINK-11507] Remove invalid test JobClientActorTest URL: https://github.com/apache/flink/pull/7635 This is an automated message from the Apache Git Service. To respond to the message, plea

[jira] [Closed] (FLINK-11508) Remove invalid test AkkaJobManagerRetrieverTest

[ https://issues.apache.org/jira/browse/FLINK-11508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-11508. Resolution: Fixed Fixed via 6ae2ed40830bd3bf4c94b0038c373f25c5cdba7b > Remove invalid test AkkaJobManager

[jira] [Updated] (FLINK-10834) TableAPI flatten() calculated value error

[ https://issues.apache.org/jira/browse/FLINK-10834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10834: Fix Version/s: (was: 1.7.2) 1.7.3 > TableAPI flatten() calc

[jira] [Updated] (FLINK-11260) Bump Janino compiler dependency

[ https://issues.apache.org/jira/browse/FLINK-11260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11260: Fix Version/s: (was: 1.7.2) 1.7.3 > Bump Janino compiler de

[jira] [Updated] (FLINK-9228) log details about task fail/task manager is shutting down

[ https://issues.apache.org/jira/browse/FLINK-9228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9228: --- Fix Version/s: (was: 1.7.2) 1.7.3 > log details about task fai

[jira] [Updated] (FLINK-10875) Add `toTableWithTimestamp` method in `DataStreamConversions`

[ https://issues.apache.org/jira/browse/FLINK-10875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10875: Fix Version/s: (was: 1.7.2) 1.7.3 > Add `toTableWithTimesta

[jira] [Updated] (FLINK-11259) Bump Zookeeper dependency to 3.4.13

[ https://issues.apache.org/jira/browse/FLINK-11259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11259: Fix Version/s: (was: 1.7.2) 1.7.3 > Bump Zookeeper dependen

[jira] [Updated] (FLINK-11250) fix thread leaked when StreamTask switched from DEPLOYING to CANCELING

[ https://issues.apache.org/jira/browse/FLINK-11250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11250: Fix Version/s: (was: 1.7.2) 1.7.3 > fix thread leaked when

[jira] [Updated] (FLINK-11116) Overwrite outdated in-progress files in StreamingFileSink.

[ https://issues.apache.org/jira/browse/FLINK-6?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6: Fix Version/s: (was: 1.7.2) 1.7.3 > Overwrite outdated in-p

[jira] [Updated] (FLINK-11107) [state] Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured

[ https://issues.apache.org/jira/browse/FLINK-11107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11107: Fix Version/s: (was: 1.7.2) 1.7.3 > [state] Avoid memory st

[jira] [Updated] (FLINK-11061) Add travis profile that would run on each commit with scala 2.12

[ https://issues.apache.org/jira/browse/FLINK-11061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11061: Fix Version/s: (was: 1.7.2) 1.7.3 > Add travis profile that

[jira] [Updated] (FLINK-11055) Allow Queryable State to be transformed on the TaskManager before being returned to the client

[ https://issues.apache.org/jira/browse/FLINK-11055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11055: Fix Version/s: (was: 1.7.2) 1.7.3 > Allow Queryable State t

[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 ] Tzu-Li (Gordon) Tai updated FLINK-10954: Fix Version/s: (was: 1.7.2) 1.7.3 > Hardlink from files of

[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_r255512747 ## File path: flink-runtime/src/test/java/org/apa

[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_r255510916 ## File path: flink-runtime/src/test/java/org/apa

[GitHub] NicoK commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

NicoK commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer URL: https://github.com/apache/flink/pull/6705#discussion_r255508677 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/netwo

[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_r255505919 ## File path: flink-runtime/src/test/java/org/apa

[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_r255502651 ## File path: flink-runtime/src/test/java/org/apa

[GitHub] NicoK commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

NicoK commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer URL: https://github.com/apache/flink/pull/6705#discussion_r252367679 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/netwo

[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_r255498671 ## File path: flink-runtime/src/test/java/org/apa

[jira] [Assigned] (FLINK-11529) Support Chinese Documents for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-11529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-11529: --- Assignee: Jark Wu > Support Chinese Documents for Apache Flink > --

[jira] [Updated] (FLINK-4330) Consider removing min()/minBy()/max()/maxBy()/sum() utility methods from the DataStream API

[ https://issues.apache.org/jira/browse/FLINK-4330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valeria Vasylieva updated FLINK-4330: - Attachment: (was: 1.url) > Consider removing min()/minBy()/max()/maxBy()/sum() utilit

[jira] [Updated] (FLINK-4330) Consider removing min()/minBy()/max()/maxBy()/sum() utility methods from the DataStream API

[ https://issues.apache.org/jira/browse/FLINK-4330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valeria Vasylieva updated FLINK-4330: - Attachment: 1.url > Consider removing min()/minBy()/max()/maxBy()/sum() utility methods f

[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_r255495062 ## File path: flink-runtime/src/test/java/org/apa

  1   2   >