[GitHub] [flink] flinkbot edited a comment on issue #11447: [FLINK-16646][orc] Flink read orc file throw a NullPointerException after re-open

flinkbot edited a comment on issue #11447: [FLINK-16646][orc] Flink read orc file throw a NullPointerException after re-open URL: https://github.com/apache/flink/pull/11447#issuecomment-601013584 ## CI report: * ea0f4e7583ae24884363201c86814d12af42bc24 Travis: [PENDING](https://

[jira] [Commented] (FLINK-16675) TableEnvironmentITCase. testClearOperation fails on travis nightly build

[ https://issues.apache.org/jira/browse/FLINK-16675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17062330#comment-17062330 ] Yu Li commented on FLINK-16675: --- >From the commit history, this should be a regression of

[GitHub] [flink] flinkbot edited a comment on issue #11439: [FLINK-16650][python] Support LocalZonedTimestampType for Python UDF in blink planner

flinkbot edited a comment on issue #11439: [FLINK-16650][python] Support LocalZonedTimestampType for Python UDF in blink planner URL: https://github.com/apache/flink/pull/11439#issuecomment-600585411 ## CI report: * 49d8110c15aa07463bf535459eb5fd657603ac10 UNKNOWN * a6a131a49a

[GitHub] [flink] flinkbot edited a comment on issue #11439: [FLINK-16650][python] Support LocalZonedTimestampType for Python UDF in blink planner

flinkbot edited a comment on issue #11439: [FLINK-16650][python] Support LocalZonedTimestampType for Python UDF in blink planner URL: https://github.com/apache/flink/pull/11439#issuecomment-600585411 ## CI report: * 49d8110c15aa07463bf535459eb5fd657603ac10 UNKNOWN * a6a131a49a

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17062344#comment-17062344 ] Sivaprasanna Sethuraman commented on FLINK-10114: - Thanks [~kkl0u] I'll

[jira] [Commented] (FLINK-15639) Support to set toleration for jobmanager and taskmanger

[ https://issues.apache.org/jira/browse/FLINK-15639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17062348#comment-17062348 ] Canbin Zheng commented on FLINK-15639: -- [~fly_in_gis] Thanks for the explanation! S

[GitHub] [flink] flinkbot edited a comment on issue #11439: [FLINK-16650][python] Support LocalZonedTimestampType for Python UDF in blink planner

flinkbot edited a comment on issue #11439: [FLINK-16650][python] Support LocalZonedTimestampType for Python UDF in blink planner URL: https://github.com/apache/flink/pull/11439#issuecomment-600585411 ## CI report: * 49d8110c15aa07463bf535459eb5fd657603ac10 UNKNOWN * a6a131a49a

[jira] [Assigned] (FLINK-16597) tryCleanupOnError should happen before close

[ https://issues.apache.org/jira/browse/FLINK-16597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-16597: - Assignee: Jiayi Liao > tryCleanupOnError should happen before close > -

[jira] [Commented] (FLINK-16597) tryCleanupOnError should happen before close

[ https://issues.apache.org/jira/browse/FLINK-16597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17062354#comment-17062354 ] Roman Khachatryan commented on FLINK-16597: --- [~wind_ljy] :)  Thanks! > tryCl

[jira] [Updated] (FLINK-16666) Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table

[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-1: --- Labels: pull-request-available (was: ) > Support new Python dependency configuration option

[GitHub] [flink] WeiZhong94 opened a new pull request #11448: [FLINK-16666][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table.

WeiZhong94 opened a new pull request #11448: [FLINK-1][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table. URL: https://github.com/apache/flink/pull/11448 ## What is the purpose of the change *This pull request

[GitHub] [flink] flinkbot commented on issue #11448: [FLINK-16666][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table.

flinkbot commented on issue #11448: [FLINK-1][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table. URL: https://github.com/apache/flink/pull/11448#issuecomment-601040060 Thanks a lot for your contribution to the Apache

[GitHub] [flink] flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#issuecomment-596050968 ## CI report: * 1e95f02cc2803e695eb28597de8f7344362826fd UNKNOWN * f38af5e48e36464e94a14cb7b10e7fc74008

[GitHub] [flink] flinkbot commented on issue #11448: [FLINK-16666][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table.

flinkbot commented on issue #11448: [FLINK-1][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table. URL: https://github.com/apache/flink/pull/11448#issuecomment-601042255 ## CI report: * d595c9fddd3ac097d6861e

[GitHub] [flink] xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components

xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components URL: https://github.com/apache/flink/pull/11445#discussion_r394816211 ## File path: flink-runtime/src/main/java/org/apache/fli

[GitHub] [flink] xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components

xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components URL: https://github.com/apache/flink/pull/11445#discussion_r394809166 ## File path: flink-runtime/src/main/java/org/apache/fli

[GitHub] [flink] xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components

xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components URL: https://github.com/apache/flink/pull/11445#discussion_r394816955 ## File path: flink-runtime/src/main/java/org/apache/fli

[GitHub] [flink] xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components

xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components URL: https://github.com/apache/flink/pull/11445#discussion_r394807903 ## File path: flink-runtime/src/main/java/org/apache/fli

[GitHub] [flink] xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components

xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components URL: https://github.com/apache/flink/pull/11445#discussion_r394808377 ## File path: flink-runtime/src/main/java/org/apache/fli

[GitHub] [flink] xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components

xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components URL: https://github.com/apache/flink/pull/11445#discussion_r394799524 ## File path: flink-core/src/main/java/org/apache/flink/

[GitHub] [flink] xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components

xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components URL: https://github.com/apache/flink/pull/11445#discussion_r394808461 ## File path: flink-runtime/src/main/java/org/apache/fli

[GitHub] [flink] xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components

xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components URL: https://github.com/apache/flink/pull/11445#discussion_r394803377 ## File path: flink-core/src/main/java/org/apache/flink/

[GitHub] [flink] xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components

xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components URL: https://github.com/apache/flink/pull/11445#discussion_r394807326 ## File path: flink-runtime/src/main/java/org/apache/fli

[GitHub] [flink] xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components

xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components URL: https://github.com/apache/flink/pull/11445#discussion_r394777251 ## File path: flink-core/src/main/java/org/apache/flink/

[GitHub] [flink] xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components

xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components URL: https://github.com/apache/flink/pull/11445#discussion_r394777277 ## File path: flink-core/src/main/java/org/apache/flink/

[GitHub] [flink] xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components

xintongsong commented on a change in pull request #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components URL: https://github.com/apache/flink/pull/11445#discussion_r394808543 ## File path: flink-runtime/src/main/java/org/apache/fli

[GitHub] [flink] pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r394831873 ## File path: flink-streaming-java/src/main/java/org/

[GitHub] [flink] pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r394375674 ## File path: flink-streaming-java/src/test/java/org/

[GitHub] [flink] pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r394369655 ## File path: flink-streaming-java/src/main/java/org/

[GitHub] [flink] pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r394823900 ## File path: flink-streaming-java/src/main/java/org/

[GitHub] [flink] pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r394828846 ## File path: flink-streaming-java/src/main/java/org/

[GitHub] [flink] pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r394829936 ## File path: flink-streaming-java/src/main/java/org/

[GitHub] [flink] pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r394843938 ## File path: flink-streaming-java/src/main/java/org/

[GitHub] [flink] pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r394405466 ## File path: flink-streaming-java/src/main/java/org/

[GitHub] [flink] pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r394850101 ## File path: flink-streaming-java/src/main/java/org/

[GitHub] [flink] pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r394828951 ## File path: flink-streaming-java/src/main/java/org/

[GitHub] [flink] pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r394843638 ## File path: flink-streaming-java/src/main/java/org/

[GitHub] [flink] pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r394370772 ## File path: flink-streaming-java/src/main/java/org/

[GitHub] [flink] pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r394373171 ## File path: flink-streaming-java/src/test/java/org/

[GitHub] [flink] pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r394848872 ## File path: flink-streaming-java/src/main/java/org/

[GitHub] [flink] pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r394374886 ## File path: flink-streaming-java/src/test/java/org/

[GitHub] [flink] pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

pnowojski commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r394369655 ## File path: flink-streaming-java/src/main/java/org/

[GitHub] [flink] flinkbot edited a comment on issue #11439: [FLINK-16650][python] Support LocalZonedTimestampType for Python UDF in blink planner

flinkbot edited a comment on issue #11439: [FLINK-16650][python] Support LocalZonedTimestampType for Python UDF in blink planner URL: https://github.com/apache/flink/pull/11439#issuecomment-600585411 ## CI report: * 49d8110c15aa07463bf535459eb5fd657603ac10 UNKNOWN * b7fb7300c3

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11448: [FLINK-16666][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table.

flinkbot edited a comment on issue #11448: [FLINK-1][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table. URL: https://github.com/apache/flink/pull/11448#issuecomment-601042255 ## CI report: * d595c9fddd3ac09

[jira] [Assigned] (FLINK-16602) Rework the Service design for Kubernetes deployment

[ https://issues.apache.org/jira/browse/FLINK-16602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-16602: - Assignee: zhengcanbin > Rework the Service design for Kubernetes deployment > -

[jira] [Assigned] (FLINK-16602) Rework the Service design for Kubernetes deployment

[ https://issues.apache.org/jira/browse/FLINK-16602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-16602: - Assignee: Canbin Zheng (was: zhengcanbin) > Rework the Service design for Kubernetes deploymen

[jira] [Created] (FLINK-16676) test_pipeline_from_invalid_json failed on Azure

Piotr Nowojski created FLINK-16676: -- Summary: test_pipeline_from_invalid_json failed on Azure Key: FLINK-16676 URL: https://issues.apache.org/jira/browse/FLINK-16676 Project: Flink Issue Typ

[GitHub] [flink] xintongsong commented on a change in pull request #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

xintongsong commented on a change in pull request #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#discussion_r394860629 ## File path: flink-kubernetes/src/mai

[GitHub] [flink] xintongsong commented on a change in pull request #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

xintongsong commented on a change in pull request #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#discussion_r394860402 ## File path: flink-runtime/src/main/j

[jira] [Updated] (FLINK-16676) test_pipeline_from_invalid_json is failing Azure

[ https://issues.apache.org/jira/browse/FLINK-16676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16676: --- Affects Version/s: (was: 1.10.0) 1.11.0 Description: Se

[jira] [Updated] (FLINK-16676) test_pipeline_from_invalid_json is failing Azure

[ https://issues.apache.org/jira/browse/FLINK-16676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16676: --- Fix Version/s: 1.11.0 > test_pipeline_from_invalid_json is failing Azure > -

[jira] [Updated] (FLINK-16676) test_pipeline_from_invalid_json is failing Azure

[ https://issues.apache.org/jira/browse/FLINK-16676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16676: --- Labels: test-stability (was: ) > test_pipeline_from_invalid_json is failing Azure > ---

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

flinkbot edited a comment on issue #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#issuecomment-598702521 ## CI report: * c1facefebee52a1ac84f188f46b114deae0aad89 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11447: [FLINK-16646][orc] Flink read orc file throw a NullPointerException after re-open

flinkbot edited a comment on issue #11447: [FLINK-16646][orc] Flink read orc file throw a NullPointerException after re-open URL: https://github.com/apache/flink/pull/11447#issuecomment-601013584 ## CI report: * ea0f4e7583ae24884363201c86814d12af42bc24 Travis: [FAILURE](https://

[GitHub] [flink] TisonKun commented on a change in pull request #11415: [FLINK-15667][k8s] Support to mount custom Hadoop configurations

TisonKun commented on a change in pull request #11415: [FLINK-15667][k8s] Support to mount custom Hadoop configurations URL: https://github.com/apache/flink/pull/11415#discussion_r394864583 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/factory/

[GitHub] [flink] xintongsong commented on a change in pull request #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

xintongsong commented on a change in pull request #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#discussion_r394865352 ## File path: flink-kubernetes/src/mai

[GitHub] [flink] tillrohrmann commented on a change in pull request #11189: [FLINK-16236][yarn][hotfix] fix Yarn secure test not loading correct context factory

tillrohrmann commented on a change in pull request #11189: [FLINK-16236][yarn][hotfix] fix Yarn secure test not loading correct context factory URL: https://github.com/apache/flink/pull/11189#discussion_r394867702 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/

[GitHub] [flink] tillrohrmann commented on a change in pull request #11189: [FLINK-16236][yarn][hotfix] fix Yarn secure test not loading correct context factory

tillrohrmann commented on a change in pull request #11189: [FLINK-16236][yarn][hotfix] fix Yarn secure test not loading correct context factory URL: https://github.com/apache/flink/pull/11189#discussion_r394865266 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/

[GitHub] [flink] tillrohrmann commented on a change in pull request #11189: [FLINK-16236][yarn][hotfix] fix Yarn secure test not loading correct context factory

tillrohrmann commented on a change in pull request #11189: [FLINK-16236][yarn][hotfix] fix Yarn secure test not loading correct context factory URL: https://github.com/apache/flink/pull/11189#discussion_r394866598 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/

[GitHub] [flink] xintongsong commented on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

xintongsong commented on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#issuecomment-601058005 Thanks for the review, @wangyang0918. Regarding your conce

[GitHub] [flink] tillrohrmann commented on a change in pull request #11189: [FLINK-16236][yarn][hotfix] fix Yarn secure test not loading correct context factory

tillrohrmann commented on a change in pull request #11189: [FLINK-16236][yarn][hotfix] fix Yarn secure test not loading correct context factory URL: https://github.com/apache/flink/pull/11189#discussion_r394865508 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/

[GitHub] [flink] rkhachatryan commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

rkhachatryan commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r394869466 ## File path: flink-streaming-java/src/main/java/o

[GitHub] [flink] twalthr commented on issue #11153: [FLINK-15958][table-common] Introduce unresolved data types in API

twalthr commented on issue #11153: [FLINK-15958][table-common] Introduce unresolved data types in API URL: https://github.com/apache/flink/pull/11153#issuecomment-601062112 Thanks for the review @dawidwys. Merging... This is

[jira] [Assigned] (FLINK-16676) test_pipeline_from_invalid_json is failing Azure

[ https://issues.apache.org/jira/browse/FLINK-16676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-16676: --- Assignee: Hequn Cheng > test_pipeline_from_invalid_json is failing Azure >

[jira] [Commented] (FLINK-16676) test_pipeline_from_invalid_json is failing Azure

[ https://issues.apache.org/jira/browse/FLINK-16676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17062381#comment-17062381 ] Hequn Cheng commented on FLINK-16676: - Looking into the problem now. > test_pipelin

[GitHub] [flink] xintongsong commented on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

xintongsong commented on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#issuecomment-601065318 @wangyang0918 I've addressed your comments, except for those I

[GitHub] [flink] rkhachatryan commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

rkhachatryan commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r394877955 ## File path: flink-streaming-java/src/main/java/o

[GitHub] [flink] lirui-apache opened a new pull request #11449: [FLINK-16675][test] Fix TableEnvironmentITCase.testClearOperation fai…

lirui-apache opened a new pull request #11449: [FLINK-16675][test] Fix TableEnvironmentITCase.testClearOperation fai… URL: https://github.com/apache/flink/pull/11449 …lure ## What is the purpose of the change Fix TableEnvironmentITCase.testClearOperation test failure

[jira] [Updated] (FLINK-16675) TableEnvironmentITCase. testClearOperation fails on travis nightly build

[ https://issues.apache.org/jira/browse/FLINK-16675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16675: --- Labels: pull-request-available (was: ) > TableEnvironmentITCase. testClearOperation fails o

[GitHub] [flink] nielsbasjes commented on issue #11316: [FLINK-16432] Fix dependencies in Hive Connector build

nielsbasjes commented on issue #11316: [FLINK-16432] Fix dependencies in Hive Connector build URL: https://github.com/apache/flink/pull/11316#issuecomment-601068347 @JingsongLi Yes, this seems to work also. I like your solution better so I've updated my pull request. -

[GitHub] [flink] nielsbasjes commented on issue #11316: [FLINK-16432] Fix dependencies in Hive Connector build

nielsbasjes commented on issue #11316: [FLINK-16432] Fix dependencies in Hive Connector build URL: https://github.com/apache/flink/pull/11316#issuecomment-601068841 @flinkbot run travis @flinkbot run azure This is an aut

[GitHub] [flink] rkhachatryan commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

rkhachatryan commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r394881417 ## File path: flink-streaming-java/src/main/java/o

[GitHub] [flink] flinkbot commented on issue #11449: [FLINK-16675][test] Fix TableEnvironmentITCase.testClearOperation fai…

flinkbot commented on issue #11449: [FLINK-16675][test] Fix TableEnvironmentITCase.testClearOperation fai… URL: https://github.com/apache/flink/pull/11449#issuecomment-601068784 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to re

[GitHub] [flink] GJL closed pull request #11433: [FLINK-15953][web] fix restarting status in web

GJL closed pull request #11433: [FLINK-15953][web] fix restarting status in web URL: https://github.com/apache/flink/pull/11433 This is an automated message from the Apache Git Service. To respond to the message, please log o

[GitHub] [flink] hequn8128 opened a new pull request #11450: [FLINK-16676][python][test] Fix ValidationPipelineTest.test_pipeline_from_invalid_json failure on Azure

hequn8128 opened a new pull request #11450: [FLINK-16676][python][test] Fix ValidationPipelineTest.test_pipeline_from_invalid_json failure on Azure URL: https://github.com/apache/flink/pull/11450 Do not review now. Add some log to see the detailed error message. --

[jira] [Assigned] (FLINK-15765) Contributing section in README should point to contribution guide

[ https://issues.apache.org/jira/browse/FLINK-15765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marta Paes Moreira reassigned FLINK-15765: -- Assignee: Marta Paes Moreira > Contributing section in README should point to

[jira] [Updated] (FLINK-16676) test_pipeline_from_invalid_json is failing Azure

[ https://issues.apache.org/jira/browse/FLINK-16676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16676: --- Labels: pull-request-available test-stability (was: test-stability) > test_pipeline_from_in

[jira] [Commented] (FLINK-16675) TableEnvironmentITCase. testClearOperation fails on travis nightly build

[ https://issues.apache.org/jira/browse/FLINK-16675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17062384#comment-17062384 ] Rui Li commented on FLINK-16675: I can't reproduce the failure by running this specific

[jira] [Commented] (FLINK-15765) Contributing section in README should point to contribution guide

[ https://issues.apache.org/jira/browse/FLINK-15765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17062385#comment-17062385 ] Marta Paes Moreira commented on FLINK-15765: Wasn't aware that there was an

[jira] [Comment Edited] (FLINK-15765) Contributing section in README should point to contribution guide

[ https://issues.apache.org/jira/browse/FLINK-15765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17062385#comment-17062385 ] Marta Paes Moreira edited comment on FLINK-15765 at 3/19/20, 9:17 AM:

[GitHub] [flink] flinkbot edited a comment on issue #11316: [FLINK-16432] Fix dependencies in Hive Connector build

flinkbot edited a comment on issue #11316: [FLINK-16432] Fix dependencies in Hive Connector build URL: https://github.com/apache/flink/pull/11316#issuecomment-595136134 ## CI report: * 0e09cc2806e813a52f53f58b9ec4228465639668 Travis: [PENDING](https://travis-ci.com/flink-ci/flin

[GitHub] [flink] flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#issuecomment-595267888 ## CI report: * edd2f98c2a607655aef8823024753fcceb

[GitHub] [flink] flinkbot commented on issue #11450: [FLINK-16676][python][test] Fix ValidationPipelineTest.test_pipeline_from_invalid_json failure on Azure

flinkbot commented on issue #11450: [FLINK-16676][python][test] Fix ValidationPipelineTest.test_pipeline_from_invalid_json failure on Azure URL: https://github.com/apache/flink/pull/11450#issuecomment-601072517 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkb

[GitHub] [flink] flinkbot edited a comment on issue #11439: [FLINK-16650][python] Support LocalZonedTimestampType for Python UDF in blink planner

flinkbot edited a comment on issue #11439: [FLINK-16650][python] Support LocalZonedTimestampType for Python UDF in blink planner URL: https://github.com/apache/flink/pull/11439#issuecomment-600585411 ## CI report: * 49d8110c15aa07463bf535459eb5fd657603ac10 UNKNOWN * b7fb7300c3

[GitHub] [flink] flinkbot edited a comment on issue #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

flinkbot edited a comment on issue #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#issuecomment-598702521 ## CI report: * af0a9aaf0e21579c2de2715535d166142aa4d2fe Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11448: [FLINK-16666][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table.

flinkbot edited a comment on issue #11448: [FLINK-1][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table. URL: https://github.com/apache/flink/pull/11448#issuecomment-601042255 ## CI report: * d595c9fddd3ac09

[GitHub] [flink] flinkbot commented on issue #11449: [FLINK-16675][test] Fix TableEnvironmentITCase.testClearOperation fai…

flinkbot commented on issue #11449: [FLINK-16675][test] Fix TableEnvironmentITCase.testClearOperation fai… URL: https://github.com/apache/flink/pull/11449#issuecomment-601073144 ## CI report: * e5220f8ed130af97eade2977cac9f2f14eeb8c29 UNKNOWN Bot commands The @fli

[jira] [Closed] (FLINK-15953) Job Status is hard to read for some Statuses

[ https://issues.apache.org/jira/browse/FLINK-15953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-15953. Resolution: Fixed 1.10: 742d420dbe41c387515f8f87cee79e0073f78da3 master: 64abbdd6f274333fbdc3d6a51b2876c31

[jira] [Comment Edited] (FLINK-15640) Support to set label and node selector

[ https://issues.apache.org/jira/browse/FLINK-15640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060029#comment-17060029 ] Yang Wang edited comment on FLINK-15640 at 3/19/20, 9:20 AM: -

[GitHub] [flink] JingsongLi merged pull request #11447: [FLINK-16646][orc] Flink read orc file throw a NullPointerException after re-open

JingsongLi merged pull request #11447: [FLINK-16646][orc] Flink read orc file throw a NullPointerException after re-open URL: https://github.com/apache/flink/pull/11447 This is an automated message from the Apache Git Servic

[jira] [Resolved] (FLINK-16646) flink read orc file throw a NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-16646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee resolved FLINK-16646. -- Resolution: Fixed release-1.10: d2213bfa81d9b77c6ff1361c31314e606b042c4a master: 1276507fa688

[jira] [Created] (FLINK-16677) Make Stateful Functions more prominent in the Flink website.

Marta Paes Moreira created FLINK-16677: -- Summary: Make Stateful Functions more prominent in the Flink website. Key: FLINK-16677 URL: https://issues.apache.org/jira/browse/FLINK-16677 Project: Fli

[jira] [Updated] (FLINK-16677) Make Stateful Functions more prominent in the Flink website.

[ https://issues.apache.org/jira/browse/FLINK-16677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marta Paes Moreira updated FLINK-16677: --- Description: As discussed in the @dev Mailing List [1], we'd like to give Stateful F

[GitHub] [flink] flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

flinkbot edited a comment on issue #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#issuecomment-595267888 ## CI report: * edd2f98c2a607655aef8823024753fcceb

[GitHub] [flink] flinkbot edited a comment on issue #11449: [FLINK-16675][test] Fix TableEnvironmentITCase.testClearOperation fai…

flinkbot edited a comment on issue #11449: [FLINK-16675][test] Fix TableEnvironmentITCase.testClearOperation fai… URL: https://github.com/apache/flink/pull/11449#issuecomment-601073144 ## CI report: * e5220f8ed130af97eade2977cac9f2f14eeb8c29 Travis: [PENDING](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #11448: [FLINK-16666][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table.

flinkbot edited a comment on issue #11448: [FLINK-1][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table. URL: https://github.com/apache/flink/pull/11448#issuecomment-601042255 ## CI report: * d595c9fddd3ac09

  1   2   3   4   5   6   >