[jira] [Commented] (FLINK-11261) BlobServer moves file with open OutputStream

[ https://issues.apache.org/jira/browse/FLINK-11261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16787627#comment-16787627 ] vinoyang commented on FLINK-11261: -- Hi [~Zentol] what do you think of this changing？ {c

[jira] [Issue Comment Deleted] (FLINK-10884) Flink on yarn TM container will be killed by nodemanager because of the exceeded physical memory.

[ https://issues.apache.org/jira/browse/FLINK-10884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chunpinghe updated FLINK-10884: --- Comment: was deleted (was: what's your solution? yarn will check the physical memory used by contai

[jira] [Commented] (FLINK-11860) Remove all the usage of deprecated unit-provided memory options in docs and scripts

[ https://issues.apache.org/jira/browse/FLINK-11860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16787629#comment-16787629 ] Yun Tang commented on FLINK-11860: -- This issue is inspired by user mail https://lists

[GitHub] [flink] JingsongLi commented on a change in pull request #7913: [FLINK-11837][table-runtime-blink] Improve internal data format

JingsongLi commented on a change in pull request #7913: [FLINK-11837][table-runtime-blink] Improve internal data format URL: https://github.com/apache/flink/pull/7913#discussion_r263688467 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data

[GitHub] [flink] JingsongLi commented on a change in pull request #7941: [FLINK-11858][table-runtime-blink] Introduce block compression to batch table runtime

JingsongLi commented on a change in pull request #7941: [FLINK-11858][table-runtime-blink] Introduce block compression to batch table runtime URL: https://github.com/apache/flink/pull/7941#discussion_r263676627 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/

[GitHub] [flink] JingsongLi commented on a change in pull request #7941: [FLINK-11858][table-runtime-blink] Introduce block compression to batch table runtime

JingsongLi commented on a change in pull request #7941: [FLINK-11858][table-runtime-blink] Introduce block compression to batch table runtime URL: https://github.com/apache/flink/pull/7941#discussion_r263687636 ## File path: flink-table/flink-table-runtime-blink/src/test/java/org/

[GitHub] [flink] JingsongLi commented on a change in pull request #7941: [FLINK-11858][table-runtime-blink] Introduce block compression to batch table runtime

JingsongLi commented on a change in pull request #7941: [FLINK-11858][table-runtime-blink] Introduce block compression to batch table runtime URL: https://github.com/apache/flink/pull/7941#discussion_r263676219 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/

[GitHub] [flink] KurtYoung commented on a change in pull request #7913: [FLINK-11837][table-runtime-blink] Improve internal data format

KurtYoung commented on a change in pull request #7913: [FLINK-11837][table-runtime-blink] Improve internal data format URL: https://github.com/apache/flink/pull/7913#discussion_r263687900 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataf

[GitHub] [flink] JingsongLi commented on a change in pull request #7941: [FLINK-11858][table-runtime-blink] Introduce block compression to batch table runtime

JingsongLi commented on a change in pull request #7941: [FLINK-11858][table-runtime-blink] Introduce block compression to batch table runtime URL: https://github.com/apache/flink/pull/7941#discussion_r263675547 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/

[GitHub] [flink] KurtYoung commented on a change in pull request #7913: [FLINK-11837][table-runtime-blink] Improve internal data format

KurtYoung commented on a change in pull request #7913: [FLINK-11837][table-runtime-blink] Improve internal data format URL: https://github.com/apache/flink/pull/7913#discussion_r263687825 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataf

[GitHub] [flink] QiLuo-BD commented on issue #7938: [FLINK-10941] Keep slots which contain unconsumed result partitions (on top of #7186)

QiLuo-BD commented on issue #7938: [FLINK-10941] Keep slots which contain unconsumed result partitions (on top of #7186) URL: https://github.com/apache/flink/pull/7938#issuecomment-470832337 LGTM This is an automated message

[jira] [Assigned] (FLINK-11860) Remove all the usage of deprecated unit-provided memory options in docs and scripts

[ https://issues.apache.org/jira/browse/FLINK-11860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-11860: Assignee: Yun Tang > Remove all the usage of deprecated unit-provided memory options in docs and

[jira] [Created] (FLINK-11860) Remove all the usage of deprecated unit-provided memory options in docs and scripts

Yun Tang created FLINK-11860: Summary: Remove all the usage of deprecated unit-provided memory options in docs and scripts Key: FLINK-11860 URL: https://issues.apache.org/jira/browse/FLINK-11860 Project:

[GitHub] [flink] KurtYoung commented on issue #7941: [FLINK-11858][table-runtime-blink] Introduce block compression to batch table runtime

KurtYoung commented on issue #7941: [FLINK-11858][table-runtime-blink] Introduce block compression to batch table runtime URL: https://github.com/apache/flink/pull/7941#issuecomment-470829598 cc @JingsongLi This is an automa

[GitHub] [flink] klion26 edited a comment on issue #7921: [FLINK-11825][StateBackends] Resolve name class of StateTTL TimeCharacteristic class

klion26 edited a comment on issue #7921: [FLINK-11825][StateBackends] Resolve name class of StateTTL TimeCharacteristic class URL: https://github.com/apache/flink/pull/7921#issuecomment-470779712 @azagrebin thank you for your review, I've updated the code, PTAL when you have time. I did no

[jira] [Created] (FLINK-11859) Improve SpanningRecordSerializer performance by serializing record length to serialization buffer directly

Yingjie Cao created FLINK-11859: --- Summary: Improve SpanningRecordSerializer performance by serializing record length to serialization buffer directly Key: FLINK-11859 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Updated] (FLINK-11696) [checkpoint] Avoid to send mkdir requests to DFS from task side

[ https://issues.apache.org/jira/browse/FLINK-11696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11696: --- Labels: pull-request-available (was: ) > [checkpoint] Avoid to send mkdir requests to DFS f

[GitHub] [flink] Myasuka opened a new pull request #7942: [FLINK-11696][checkpoint] Avoid to send mkdir requests to DFS from task side

Myasuka opened a new pull request #7942: [FLINK-11696][checkpoint] Avoid to send mkdir requests to DFS from task side URL: https://github.com/apache/flink/pull/7942 ## What is the purpose of the change Previously, not only checkpoint coordinator but also tasks would always send those `m

[GitHub] [flink] flinkbot commented on issue #7942: [FLINK-11696][checkpoint] Avoid to send mkdir requests to DFS from task side

flinkbot commented on issue #7942: [FLINK-11696][checkpoint] Avoid to send mkdir requests to DFS from task side URL: https://github.com/apache/flink/pull/7942#issuecomment-470819951 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community t

[jira] [Updated] (FLINK-11858) Introduce block compressor/decompressor for batch table runtime

[ https://issues.apache.org/jira/browse/FLINK-11858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11858: --- Labels: pull-request-available (was: ) > Introduce block compressor/decompressor for batch

[GitHub] [flink] flinkbot commented on issue #7941: [FLINK-11858][table-runtime-blink] Introduce block compression to batch table runtime

flinkbot commented on issue #7941: [FLINK-11858][table-runtime-blink] Introduce block compression to batch table runtime URL: https://github.com/apache/flink/pull/7941#issuecomment-470816714 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the commu

[GitHub] [flink] KurtYoung opened a new pull request #7941: [FLINK-11858][table-runtime-blink] Introduce block compression to batch table runtime

KurtYoung opened a new pull request #7941: [FLINK-11858][table-runtime-blink] Introduce block compression to batch table runtime URL: https://github.com/apache/flink/pull/7941 ## What is the purpose of the change Introduce BlockCompressor and BlockDecompressor to batch ta

[GitHub] [flink] flinkbot commented on issue #7940: [hotfix][docs] fix error in functions example

flinkbot commented on issue #7940: [hotfix][docs] fix error in functions example URL: https://github.com/apache/flink/pull/7940#issuecomment-470805294 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We

[GitHub] [flink] leesf opened a new pull request #7940: [hotfix][docs] fix error in functions example

leesf opened a new pull request #7940: [hotfix][docs] fix error in functions example URL: https://github.com/apache/flink/pull/7940 fix error in functions example. This is an automated message from the Apache Git Service. T

[GitHub] [flink] wuchong commented on a change in pull request #7913: [FLINK-11837][table-runtime-blink] Improve internal data format

wuchong commented on a change in pull request #7913: [FLINK-11837][table-runtime-blink] Improve internal data format URL: https://github.com/apache/flink/pull/7913#discussion_r263663630 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/typeuti

[GitHub] [flink] wuchong commented on a change in pull request #7913: [FLINK-11837][table-runtime-blink] Improve internal data format

wuchong commented on a change in pull request #7913: [FLINK-11837][table-runtime-blink] Improve internal data format URL: https://github.com/apache/flink/pull/7913#discussion_r263663580 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/typeuti

[jira] [Created] (FLINK-11858) Introduce block compressor/decompressor for batch table runtime

Kurt Young created FLINK-11858: -- Summary: Introduce block compressor/decompressor for batch table runtime Key: FLINK-11858 URL: https://issues.apache.org/jira/browse/FLINK-11858 Project: Flink

[jira] [Created] (FLINK-11857) Introduce BinaryExternalSorter to batch table runtime

Jingsong Lee created FLINK-11857: Summary: Introduce BinaryExternalSorter to batch table runtime Key: FLINK-11857 URL: https://issues.apache.org/jira/browse/FLINK-11857 Project: Flink Issue T

[GitHub] [flink] TisonKun edited a comment on issue #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint

TisonKun edited a comment on issue #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint URL: https://github.com/apache/flink/pull/7927#issuecomment-470792906 travis failed on ``` 02:03:48.550 [ERROR] Failures: 02:03:48.550 [ERROR] YARNHighAvailabi

[GitHub] [flink] TisonKun commented on issue #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint

TisonKun commented on issue #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint URL: https://github.com/apache/flink/pull/7927#issuecomment-470792906 travis failed on ``` 02:03:48.550 [ERROR] Failures: 02:03:48.550 [ERROR] YARNHighAvailabilityITC

[GitHub] [flink] JingsongLi commented on a change in pull request #7931: [FLINK-11854] [table-planner-blink] Introduce batch physical nodes

JingsongLi commented on a change in pull request #7931: [FLINK-11854] [table-planner-blink] Introduce batch physical nodes URL: https://github.com/apache/flink/pull/7931#discussion_r263655776 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/d

[GitHub] [flink] JingsongLi commented on a change in pull request #7931: [FLINK-11854] [table-planner-blink] Introduce batch physical nodes

JingsongLi commented on a change in pull request #7931: [FLINK-11854] [table-planner-blink] Introduce batch physical nodes URL: https://github.com/apache/flink/pull/7931#discussion_r263655861 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/d

[GitHub] [flink] JingsongLi commented on a change in pull request #7931: [FLINK-11854] [table-planner-blink] Introduce batch physical nodes

JingsongLi commented on a change in pull request #7931: [FLINK-11854] [table-planner-blink] Introduce batch physical nodes URL: https://github.com/apache/flink/pull/7931#discussion_r263655776 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/d

[jira] [Created] (FLINK-11856) Introduce BinaryHashTable and LongHashTable to batch table runtime

Kurt Young created FLINK-11856: -- Summary: Introduce BinaryHashTable and LongHashTable to batch table runtime Key: FLINK-11856 URL: https://issues.apache.org/jira/browse/FLINK-11856 Project: Flink

[GitHub] [flink] wuchong commented on issue #7923: [FLINK-11703][table-planner-blink] Introduce TableEnvironments and support registerDataStream and sqlQuery

wuchong commented on issue #7923: [FLINK-11703][table-planner-blink] Introduce TableEnvironments and support registerDataStream and sqlQuery URL: https://github.com/apache/flink/pull/7923#issuecomment-470792029 Commits squashed and re-titled. --

[GitHub] [flink] JingsongLi commented on issue #7913: [FLINK-11837][table-runtime-blink] Improve internal data format

JingsongLi commented on issue #7913: [FLINK-11837][table-runtime-blink] Improve internal data format URL: https://github.com/apache/flink/pull/7913#issuecomment-470791761 @KurtYoung Thanks for your suggestion, I have fixed it. ---

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

zhijiangW commented on issue #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions URL: https://github.com/apache/flink/pull/7186#issuecomment-470780791 Agree with @azagrebin 's suggestions for checking partition registered/released status in current `NetworkEnvironme

[GitHub] [flink] klion26 commented on a change in pull request #7895: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials

klion26 commented on a change in pull request #7895: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials URL: https://github.com/apache/flink/pull/7895#discussion_r263646747 ## File path: flink-yarn/src/test/java/org/apache/flink/yarn/UtilsTest.java

[GitHub] [flink] klion26 commented on issue #7921: [FLINK-11825][StateBackends] Resolve name class of StateTTL TimeCharacteristic class

klion26 commented on issue #7921: [FLINK-11825][StateBackends] Resolve name class of StateTTL TimeCharacteristic class URL: https://github.com/apache/flink/pull/7921#issuecomment-470779712 @azagrebin thank you for your review, I've updated the code, PTAL when you have time. hi @rmet

[GitHub] [flink] KurtYoung commented on a change in pull request #7931: [FLINK-11854] [table-planner-blink] Introduce batch physical nodes

KurtYoung commented on a change in pull request #7931: [FLINK-11854] [table-planner-blink] Introduce batch physical nodes URL: https://github.com/apache/flink/pull/7931#discussion_r263639880 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/da

[GitHub] [flink] KurtYoung commented on a change in pull request #7931: [FLINK-11854] [table-planner-blink] Introduce batch physical nodes

KurtYoung commented on a change in pull request #7931: [FLINK-11854] [table-planner-blink] Introduce batch physical nodes URL: https://github.com/apache/flink/pull/7931#discussion_r263641774 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/p

[GitHub] [flink] JingsongLi commented on issue #7913: [FLINK-11837][table-runtime-blink] Improve internal data format

JingsongLi commented on issue #7913: [FLINK-11837][table-runtime-blink] Improve internal data format URL: https://github.com/apache/flink/pull/7913#issuecomment-470774081 > BTW, `NestedRow` has not been covered by any test case Yes, I will add test for NestedRow, JoinedRow, BoxedWrap

[jira] [Assigned] (FLINK-11852) Improve Processing function example

[ https://issues.apache.org/jira/browse/FLINK-11852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11852: Assignee: TANG Wen-hui > Improve Processing function example > --

[jira] [Commented] (FLINK-11819) Additional attribute for order by not support by flink sql, but told supported in doc

[ https://issues.apache.org/jira/browse/FLINK-11819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16787428#comment-16787428 ] Hequn Cheng commented on FLINK-11819: - [~hustclf] Thanks for bringing up the discuss

[jira] [Updated] (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 ] ASF GitHub Bot updated FLINK-10935: --- Labels: pull-request-available (was: ) > Implement KubeClient with Faric8 Kubernetes client

[GitHub] [flink] chunhui-shi commented on issue #7939: [FLINK-10935][ResourceManager] Implement KubeClient with Fabric8 Kubenetes clients

chunhui-shi commented on issue #7939: [FLINK-10935][ResourceManager] Implement KubeClient with Fabric8 Kubenetes clients URL: https://github.com/apache/flink/pull/7939#issuecomment-470764389 This is the second pull request coming after #7844. ---

[GitHub] [flink] chunhui-shi opened a new pull request #7939: [FLINK-10935][ResourceManager] Implement KubeClient with Fabric8 Kubenetes clients

chunhui-shi opened a new pull request #7939: [FLINK-10935][ResourceManager] Implement KubeClient with Fabric8 Kubenetes clients URL: https://github.com/apache/flink/pull/7939 ##What is the purpose of the change As part of native kubernetes integration. Introduce client wrapper to access

[GitHub] [flink] flinkbot commented on issue #7939: [FLINK-10935][ResourceManager] Implement KubeClient with Fabric8 Kubenetes clients

flinkbot commented on issue #7939: [FLINK-10935][ResourceManager] Implement KubeClient with Fabric8 Kubenetes clients URL: https://github.com/apache/flink/pull/7939#issuecomment-470764365 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the communit

[jira] [Commented] (FLINK-9685) Flink should support hostname-substitution for security.kerberos.login.principal

[ https://issues.apache.org/jira/browse/FLINK-9685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16787326#comment-16787326 ] Rong Rong commented on FLINK-9685: -- Hi. I was wondering whether I fully understood the r

[jira] [Updated] (FLINK-11848) Delete outdated kafka topics caused UNKNOWN_TOPIC_EXCEPTIION

[ https://issues.apache.org/jira/browse/FLINK-11848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-11848: --- Description: Recently we are doing some streaming jobs with apache flink. There are multiple

[jira] [Closed] (FLINK-11851) ClusterEntrypoint provides wrong executor to HaServices

[ https://issues.apache.org/jira/browse/FLINK-11851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-11851. - Resolution: Fixed Fixed via master: 3c7ed148cf39fa81a18832f7774365d78c3af08c 1.8.0: b7d85c871952

[GitHub] [flink] asfgit merged pull request #7926: [BP-1.7][FLINK-11851] Introduce dedicated io executor for ClusterEntrypoint and MiniCluster

asfgit merged pull request #7926: [BP-1.7][FLINK-11851] Introduce dedicated io executor for ClusterEntrypoint and MiniCluster URL: https://github.com/apache/flink/pull/7926 This is an automated message from the Apache Git Se

[jira] [Resolved] (FLINK-11846) Duplicate job submission delete HA files

[ https://issues.apache.org/jira/browse/FLINK-11846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-11846. --- Resolution: Fixed Fix Version/s: (was: 1.8.0) Fixed via master: f2b0e494e6089ccda

[jira] [Resolved] (FLINK-11850) ZooKeeperHaServicesTest#testSimpleCloseAndCleanupAllData fails on Travis

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

[GitHub] [flink] asfgit merged pull request #7925: [BP-1.8][FLINK-11851] Introduce dedicated io executor for ClusterEntrypoint and MiniCluster

asfgit merged pull request #7925: [BP-1.8][FLINK-11851] Introduce dedicated io executor for ClusterEntrypoint and MiniCluster URL: https://github.com/apache/flink/pull/7925 This is an automated message from the Apache Git Se

[GitHub] [flink] asfgit merged pull request #7919: [BP-1.8][FLINK-11846] Don't delete HA job files in case of duplicate job submission

asfgit merged pull request #7919: [BP-1.8][FLINK-11846] Don't delete HA job files in case of duplicate job submission URL: https://github.com/apache/flink/pull/7919 This is an automated message from the Apache Git Service. T

[GitHub] [flink] asfgit merged pull request #7929: [BP-1.8][FLINK-11850][zk] Tolerate concurrent child deletions when deleting owned zNode

asfgit merged pull request #7929: [BP-1.8][FLINK-11850][zk] Tolerate concurrent child deletions when deleting owned zNode URL: https://github.com/apache/flink/pull/7929 This is an automated message from the Apache Git Servic

[GitHub] [flink] asfgit merged pull request #7924: [FLINK-11851] Introduce dedicated io executor for ClusterEntrypoint and MiniCluster

asfgit merged pull request #7924: [FLINK-11851] Introduce dedicated io executor for ClusterEntrypoint and MiniCluster URL: https://github.com/apache/flink/pull/7924 This is an automated message from the Apache Git Service. T

[GitHub] [flink] asfgit merged pull request #7928: [FLINK-11850][zk] Tolerate concurrent child deletions when deleting owned zNode

asfgit merged pull request #7928: [FLINK-11850][zk] Tolerate concurrent child deletions when deleting owned zNode URL: https://github.com/apache/flink/pull/7928 This is an automated message from the Apache Git Service. To re

[GitHub] [flink] asfgit merged pull request #7918: [FLINK-11846] Don't delete HA job files in case of duplicate job submission

asfgit merged pull request #7918: [FLINK-11846] Don't delete HA job files in case of duplicate job submission URL: https://github.com/apache/flink/pull/7918 This is an automated message from the Apache Git Service. To respon

[GitHub] [flink] pnowojski commented on a change in pull request #7713: [FLINK-10995][network] Copy intermediate serialization results only once for broadcast mode

pnowojski commented on a change in pull request #7713: [FLINK-10995][network] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#discussion_r263563494 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] [flink] walterddr commented on a change in pull request #7860: [FLINK-9685] Adding support hostname-substitution for security.kerberos login.principal

walterddr commented on a change in pull request #7860: [FLINK-9685] Adding support hostname-substitution for security.kerberos login.principal URL: https://github.com/apache/flink/pull/7860#discussion_r263552559 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/sec

[GitHub] [flink] walterddr commented on a change in pull request #7860: [FLINK-9685] Adding support hostname-substitution for security.kerberos login.principal

walterddr commented on a change in pull request #7860: [FLINK-9685] Adding support hostname-substitution for security.kerberos login.principal URL: https://github.com/apache/flink/pull/7860#discussion_r263553448 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/sec

[jira] [Commented] (FLINK-11798) Incorrect Kubernetes Documentation

[ https://issues.apache.org/jira/browse/FLINK-11798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16787142#comment-16787142 ] Alex commented on FLINK-11798: -- [~pritesh-patel], unfortunately the docker entry point for

[GitHub] [flink] walterddr commented on a change in pull request #7895: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials

walterddr commented on a change in pull request #7895: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials URL: https://github.com/apache/flink/pull/7895#discussion_r263529807 ## File path: flink-yarn/src/test/java/org/apache/flink/yarn/UtilsTest.java ##

[GitHub] [flink] walterddr commented on a change in pull request #7895: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials

walterddr commented on a change in pull request #7895: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials URL: https://github.com/apache/flink/pull/7895#discussion_r263529807 ## File path: flink-yarn/src/test/java/org/apache/flink/yarn/UtilsTest.java ##

[GitHub] [flink] walterddr commented on a change in pull request #7895: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials

walterddr commented on a change in pull request #7895: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials URL: https://github.com/apache/flink/pull/7895#discussion_r263528664 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java ##

[GitHub] [flink] walterddr commented on a change in pull request #7895: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials

walterddr commented on a change in pull request #7895: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials URL: https://github.com/apache/flink/pull/7895#discussion_r263529202 ## File path: flink-yarn/src/test/java/org/apache/flink/yarn/UtilsTest.java ##

[GitHub] [flink] tillrohrmann commented on issue #7928: [FLINK-11850][zk] Tolerate concurrent child deletions when deleting owned zNode

tillrohrmann commented on issue #7928: [FLINK-11850][zk] Tolerate concurrent child deletions when deleting owned zNode URL: https://github.com/apache/flink/pull/7928#issuecomment-470638988 Thanks for the review @TisonKun and @zentol. Addressing Chesnay's last comment and then merging this

[GitHub] [flink] tillrohrmann commented on a change in pull request #7928: [FLINK-11850][zk] Tolerate concurrent child deletions when deleting owned zNode

tillrohrmann commented on a change in pull request #7928: [FLINK-11850][zk] Tolerate concurrent child deletions when deleting owned zNode URL: https://github.com/apache/flink/pull/7928#discussion_r263508836 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavai

[GitHub] [flink] tillrohrmann commented on issue #7924: [FLINK-11851] Introduce dedicated io executor for ClusterEntrypoint and MiniCluster

tillrohrmann commented on issue #7924: [FLINK-11851] Introduce dedicated io executor for ClusterEntrypoint and MiniCluster URL: https://github.com/apache/flink/pull/7924#issuecomment-470637680 Thanks for the review @StefanRRichter and @jgrier. Merging this PR. -

[GitHub] [flink] tillrohrmann commented on issue #7935: [FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall

tillrohrmann commented on issue #7935: [FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall URL: https://github.com/apache/flink/pull/7935#issuecomment-470634979 Thanks for the review @zentol. I think you are right that we should also fix the `RevokeLeadershipCall`

[GitHub] [flink] connord-stripe commented on issue #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API …

connord-stripe commented on issue #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API … URL: https://github.com/apache/flink/pull/7168#issuecomment-470629861 Neat. Thanks! This is an automated message

[GitHub] [flink] azagrebin commented on issue #7938: [FLINK-10941] Keep slots which contain unconsumed result partitions (on top of #7186)

azagrebin commented on issue #7938: [FLINK-10941] Keep slots which contain unconsumed result partitions (on top of #7186) URL: https://github.com/apache/flink/pull/7938#issuecomment-470629769 cc @QiLuo-BD @zhijiangW @pnowojski --

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

azagrebin commented on issue #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions URL: https://github.com/apache/flink/pull/7186#issuecomment-470629679 I agree with @zhijiangW. We discussed it also with @pnowojski, we might not merge it into 1.8.0 right away b

[GitHub] [flink] azagrebin commented on issue #7938: [FLINK-10941] Keep slots which contain unconsumed result partitions (on top of #7186)

azagrebin commented on issue #7938: [FLINK-10941] Keep slots which contain unconsumed result partitions (on top of #7186) URL: https://github.com/apache/flink/pull/7938#issuecomment-470629074 @flinkbot attention @pnowojski T

[GitHub] [flink] flinkbot commented on issue #7938: [FLINK-10941] Keep slots which contain unconsumed result partitions (on top of #7186)

flinkbot commented on issue #7938: [FLINK-10941] Keep slots which contain unconsumed result partitions (on top of #7186) URL: https://github.com/apache/flink/pull/7938#issuecomment-470628733 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the commu

[GitHub] [flink] azagrebin opened a new pull request #7938: [FLINK-10941] Keep slots which contain unconsumed result partitions (on top of #7186)

azagrebin opened a new pull request #7938: [FLINK-10941] Keep slots which contain unconsumed result partitions (on top of #7186) URL: https://github.com/apache/flink/pull/7938 ## What is the purpose of the change More changes based on #7186. ## Brief change log The task

[GitHub] [flink] azagrebin commented on issue #7921: [FLINK-11825][StateBackends] Resolve name class of StateTTL TimeCharacteristic class

azagrebin commented on issue #7921: [FLINK-11825][StateBackends] Resolve name class of StateTTL TimeCharacteristic class URL: https://github.com/apache/flink/pull/7921#issuecomment-470619215 @flinkbot approve all This is an a

[GitHub] [flink] tillrohrmann commented on a change in pull request #7935: [FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall

tillrohrmann commented on a change in pull request #7935: [FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall URL: https://github.com/apache/flink/pull/7935#discussion_r263487660 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/highavaila

[GitHub] [flink] tillrohrmann commented on a change in pull request #7935: [FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall

tillrohrmann commented on a change in pull request #7935: [FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall URL: https://github.com/apache/flink/pull/7935#discussion_r263483901 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavaila

[GitHub] [flink] tillrohrmann commented on a change in pull request #7935: [FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall

tillrohrmann commented on a change in pull request #7935: [FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall URL: https://github.com/apache/flink/pull/7935#discussion_r263482371 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/highavaila

[GitHub] [flink] tillrohrmann commented on issue #7918: [FLINK-11846] Don't delete HA job files in case of duplicate job submission

tillrohrmann commented on issue #7918: [FLINK-11846] Don't delete HA job files in case of duplicate job submission URL: https://github.com/apache/flink/pull/7918#issuecomment-470611600 Thanks for the review @TisonKun and @StefanRRichter. Merging this PR. ---

[GitHub] [flink] zentol commented on a change in pull request #7935: [FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall

zentol commented on a change in pull request #7935: [FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall URL: https://github.com/apache/flink/pull/7935#discussion_r263465103 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/highavailability

[GitHub] [flink] zentol commented on a change in pull request #7935: [FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall

zentol commented on a change in pull request #7935: [FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall URL: https://github.com/apache/flink/pull/7935#discussion_r263479048 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability

[GitHub] [flink] flinkbot commented on issue #7937: [BP-1.7][FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall

flinkbot commented on issue #7937: [BP-1.7][FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall URL: https://github.com/apache/flink/pull/7937#issuecomment-470601948 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the commu

[GitHub] [flink] tillrohrmann opened a new pull request #7937: [BP-1.7][FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall

tillrohrmann opened a new pull request #7937: [BP-1.7][FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall URL: https://github.com/apache/flink/pull/7937 Backport of #7935 to `release-1.7`. This is an

[GitHub] [flink] flinkbot commented on issue #7936: [BP-1.8][FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall

flinkbot commented on issue #7936: [BP-1.8][FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall URL: https://github.com/apache/flink/pull/7936#issuecomment-470601303 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the commu

[GitHub] [flink] tillrohrmann opened a new pull request #7936: [BP-1.8][FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall

tillrohrmann opened a new pull request #7936: [BP-1.8][FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall URL: https://github.com/apache/flink/pull/7936 Backport of #7935 to `release-1.8`. This is an

[GitHub] [flink] flinkbot commented on issue #7935: [FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall

flinkbot commented on issue #7935: [FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall URL: https://github.com/apache/flink/pull/7935#issuecomment-470597573 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Updated] (FLINK-11855) Race condition in EmbeddedLeaderService

[ https://issues.apache.org/jira/browse/FLINK-11855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11855: --- Labels: pull-request-available (was: ) > Race condition in EmbeddedLeaderService >

[GitHub] [flink] tillrohrmann opened a new pull request #7935: [FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall

tillrohrmann opened a new pull request #7935: [FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall URL: https://github.com/apache/flink/pull/7935 ## What is the purpose of the change Fix the race condition between executing EmbeddedLeaderService#GrantLeaders

[GitHub] [flink] zentol commented on a change in pull request #7928: [FLINK-11850][zk] Tolerate concurrent child deletions when deleting owned zNode

zentol commented on a change in pull request #7928: [FLINK-11850][zk] Tolerate concurrent child deletions when deleting owned zNode URL: https://github.com/apache/flink/pull/7928#discussion_r263450942 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailabili

[jira] [Assigned] (FLINK-11798) Incorrect Kubernetes Documentation

[ https://issues.apache.org/jira/browse/FLINK-11798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex reassigned FLINK-11798: Assignee: Alex > Incorrect Kubernetes Documentation > -- > >

[GitHub] [flink] desiam commented on issue #7861: [FLINK-11747] [ Connectors / ElasticSearch] Expose RestHighLevelClient to allow for custom sniffing

desiam commented on issue #7861: [FLINK-11747] [ Connectors / ElasticSearch] Expose RestHighLevelClient to allow for custom sniffing URL: https://github.com/apache/flink/pull/7861#issuecomment-470579574 @tzulitai If it's difficult to expose the RestHighLevelClient, we may look into creatin

[jira] [Updated] (FLINK-11855) Race condition in EmbeddedLeaderService

[ https://issues.apache.org/jira/browse/FLINK-11855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11855: -- Priority: Major (was: Critical) > Race condition in EmbeddedLeaderService > -

[jira] [Created] (FLINK-11855) Race condition in EmbeddedLeaderService

Till Rohrmann created FLINK-11855: - Summary: Race condition in EmbeddedLeaderService Key: FLINK-11855 URL: https://issues.apache.org/jira/browse/FLINK-11855 Project: Flink Issue Type: Bug

[GitHub] [flink] azagrebin commented on a change in pull request #7921: [FLINK-11825][StateBackends] Resolve name class of StateTTL TimeCharacteristic class

azagrebin commented on a change in pull request #7921: [FLINK-11825][StateBackends] Resolve name class of StateTTL TimeCharacteristic class URL: https://github.com/apache/flink/pull/7921#discussion_r263432284 ## File path: flink-core/src/main/java/org/apache/flink/api/common/state

[GitHub] [flink] azagrebin commented on a change in pull request #7921: [FLINK-11825][StateBackends] Resolve name class of StateTTL TimeCharacteristic class

azagrebin commented on a change in pull request #7921: [FLINK-11825][StateBackends] Resolve name class of StateTTL TimeCharacteristic class URL: https://github.com/apache/flink/pull/7921#discussion_r263434298 ## File path: flink-core/src/main/java/org/apache/flink/api/common/state

[GitHub] [flink] azagrebin commented on a change in pull request #7921: [FLINK-11825][StateBackends] Resolve name class of StateTTL TimeCharacteristic class

azagrebin commented on a change in pull request #7921: [FLINK-11825][StateBackends] Resolve name class of StateTTL TimeCharacteristic class URL: https://github.com/apache/flink/pull/7921#discussion_r263432469 ## File path: flink-core/src/main/java/org/apache/flink/api/common/state

  1   2   3   >