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

wangyang0918 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_r395431678 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/deco

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

wangyang0918 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_r394988645 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/deco

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

wangyang0918 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_r395460432 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/fact

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

wangyang0918 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_r395430296 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/deco

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

wangyang0918 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_r395432805 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/para

[GitHub] [flink] tzulitai commented on issue #8344: [FLINK-12141] [API/Type Serialization System] Allow @TypeInfo annotation on POJO field declarations

tzulitai commented on issue #8344: [FLINK-12141] [API/Type Serialization System] Allow @TypeInfo annotation on POJO field declarations URL: https://github.com/apache/flink/pull/8344#issuecomment-601559882 @flinkbot approve consensus -

[GitHub] [flink] flinkbot edited a comment on issue #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager

flinkbot edited a comment on issue #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager URL: https://github.com/apache/flink/pull/11250#issuecomment-592336212 ## CI report: * e474761e49927bb30bac6a297e992dc2ec98e01a UNKNOWN * 306b1e6622445245bdc59517d23

[jira] [Commented] (FLINK-16345) Computed column can not refer time attribute column

[ https://issues.apache.org/jira/browse/FLINK-16345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063124#comment-17063124 ] Jark Wu commented on FLINK-16345: - After an offline discussion with [~danny0405], we rea

[GitHub] [flink] GJL commented on a change in pull request #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager

GJL commented on a change in pull request #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager URL: https://github.com/apache/flink/pull/11250#discussion_r395459799 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/taskmanager/A

[jira] [Resolved] (FLINK-16220) JsonRowSerializationSchema throws cast exception : NullNode cannot be cast to ArrayNode

[ https://issues.apache.org/jira/browse/FLINK-16220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-16220. - Resolution: Fixed Fixed in - master (1.11.0): 0619a5b3e000855f00d11e71ae2f1b9deef05c98 - 1.10.1: 4cde

[GitHub] [flink] wuchong merged pull request #11180: [FLINK-16220][json] Fix JsonRowSerializationSchema cast exception due…

wuchong merged pull request #11180: [FLINK-16220][json] Fix JsonRowSerializationSchema cast exception due… URL: https://github.com/apache/flink/pull/11180 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] zhengcanbin commented on issue #10973: [FLINK-15647][kubernetes] Support to set annotations for JM/TM Pods.

zhengcanbin commented on issue #10973: [FLINK-15647][kubernetes] Support to set annotations for JM/TM Pods. URL: https://github.com/apache/flink/pull/10973#issuecomment-601556745 > Thanks for creating this PR @zhengcanbin. The changes look good to me. > > Please rebase the PR onto th

[GitHub] [flink-statefun] tzulitai opened a new pull request #64: [FLINK-16124] YAML-ized Kinesis ingress / egresses

tzulitai opened a new pull request #64: [FLINK-16124] YAML-ized Kinesis ingress / egresses URL: https://github.com/apache/flink-statefun/pull/64 This is a follow-up to #61, adding the YAML-ized Kinesis ingress / egresses. --- ### Usage - Ingress: ``` ingress:

[jira] [Commented] (FLINK-16688) Hive-connector should set SessionState for hive

[ https://issues.apache.org/jira/browse/FLINK-16688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063120#comment-17063120 ] Rui Li commented on FLINK-16688: The root cause is the same as FLINK-16618. {{SessionSta

[GitHub] [flink] zhengcanbin commented on issue #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils

zhengcanbin commented on issue #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils URL: https://github.com/apache/flink/pull/11458#issuecomment-601555893 @TisonKun Travis gives a green light, could you help take a look?

[GitHub] [flink] flinkbot edited a comment on issue #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager

flinkbot edited a comment on issue #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager URL: https://github.com/apache/flink/pull/11250#issuecomment-592336212 ## CI report: * e474761e49927bb30bac6a297e992dc2ec98e01a UNKNOWN * 306b1e6622445245bdc59517d23

[GitHub] [flink] zhengcanbin commented on issue #11456: [FLINK-16602][k8s] Rework the internal/external Service

zhengcanbin commented on issue #11456: [FLINK-16602][k8s] Rework the internal/external Service URL: https://github.com/apache/flink/pull/11456#issuecomment-601554248 @TisonKun Travis gives a green light, kindly expect to see your reply. -

[GitHub] [flink] flinkbot edited a comment on issue #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils

flinkbot edited a comment on issue #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils URL: https://github.com/apache/flink/pull/11458#issuecomment-601537757 ## CI report: * 61e13aca86d70d5279d9ed0e482a5797915b068c

[GitHub] [flink] flinkbot edited a comment on issue #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils

flinkbot edited a comment on issue #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils URL: https://github.com/apache/flink/pull/11458#issuecomment-601537757 ## CI report: * 61e13aca86d70d5279d9ed0e482a5797915b068c

[jira] [Created] (FLINK-16689) kafka connector as source get byte deserialize add support charsets

xiaodao created FLINK-16689: --- Summary: kafka connector as source get byte deserialize add support charsets Key: FLINK-16689 URL: https://issues.apache.org/jira/browse/FLINK-16689 Project: Flink Is

[GitHub] [flink] flinkbot edited a comment on issue #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils

flinkbot edited a comment on issue #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils URL: https://github.com/apache/flink/pull/11458#issuecomment-601537757 ## CI report: * 61e13aca86d70d5279d9ed0e482a5797915b068c

[GitHub] [flink] jinglining commented on a change in pull request #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager

jinglining commented on a change in pull request #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager URL: https://github.com/apache/flink/pull/11250#discussion_r395440082 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/taskma

[GitHub] [flink] jinglining commented on a change in pull request #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager

jinglining commented on a change in pull request #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager URL: https://github.com/apache/flink/pull/11250#discussion_r395440082 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/taskma

[GitHub] [flink] flinkbot commented on issue #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils

flinkbot commented on issue #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils URL: https://github.com/apache/flink/pull/11458#issuecomment-601537757 ## CI report: * 61e13aca86d70d5279d9ed0e482a5797915b068c UNKNOW

[GitHub] [flink] xintongsong commented on issue #11284: [FLINK-15911][runtime] Make Flink work with NAT.

xintongsong commented on issue #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#issuecomment-601536922 Thanks for the review @tillrohrmann. > A quick question for my understanding. In the e2e test we give every container an ext

[GitHub] [flink-playgrounds] garyfeng closed pull request #11: Pyflink

garyfeng closed pull request #11: Pyflink URL: https://github.com/apache/flink-playgrounds/pull/11 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[GitHub] [flink-playgrounds] garyfeng commented on issue #11: Pyflink

garyfeng commented on issue #11: Pyflink URL: https://github.com/apache/flink-playgrounds/pull/11#issuecomment-601535615 The PyLink branch fixed the missing flink-connector and flink-formats issues. other bugs remain (#3). T

[GitHub] [flink-playgrounds] garyfeng opened a new pull request #11: Pyflink

garyfeng opened a new pull request #11: Pyflink URL: https://github.com/apache/flink-playgrounds/pull/11 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r395435948 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java #

[jira] [Created] (FLINK-16688) Hive-connector should set SessionState for hive

Jingsong Lee created FLINK-16688: Summary: Hive-connector should set SessionState for hive Key: FLINK-16688 URL: https://issues.apache.org/jira/browse/FLINK-16688 Project: Flink Issue Type: B

[GitHub] [flink] xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r395435813 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterConfiguration.j

[GitHub] [flink] flinkbot edited a comment on issue #11457: [FLINK-14255][WIP][table] Introduce FileSystemStreamingSinkV2

flinkbot edited a comment on issue #11457: [FLINK-14255][WIP][table] Introduce FileSystemStreamingSinkV2 URL: https://github.com/apache/flink/pull/11457#issuecomment-601515074 ## CI report: * 2d43f0faeabc760120d3e0cbfc9632e42b2cfab6 Travis: [FAILURE](https://travis-ci.com/github

[GitHub] [flink] flinkbot commented on issue #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils

flinkbot commented on issue #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils URL: https://github.com/apache/flink/pull/11458#issuecomment-601534139 Thanks a lot for your contribution to the Apache Flink project. I'm the @

[jira] [Updated] (FLINK-16625) Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils

[ https://issues.apache.org/jira/browse/FLINK-16625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16625: --- Labels: pull-request-available (was: ) > Extract BootstrapTools#getEnvironmentVariables to

[GitHub] [flink] zhengcanbin opened a new pull request #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils

zhengcanbin opened a new pull request #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils URL: https://github.com/apache/flink/pull/11458 ## What is the purpose of the change `BootstrapTools#getEnvironmentVariables` ac

[GitHub] [flink] zhijiangW commented on a change in pull request #11453: [FLINK-13553][tests] Fix ByteBuf leak in KvStateServerHandlerTest

zhijiangW commented on a change in pull request #11453: [FLINK-13553][tests] Fix ByteBuf leak in KvStateServerHandlerTest URL: https://github.com/apache/flink/pull/11453#discussion_r395433462 ## File path: flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache

[GitHub] [flink] flinkbot edited a comment on issue #11457: [FLINK-14255][WIP][table] Introduce FileSystemStreamingSinkV2

flinkbot edited a comment on issue #11457: [FLINK-14255][WIP][table] Introduce FileSystemStreamingSinkV2 URL: https://github.com/apache/flink/pull/11457#issuecomment-601515074 ## CI report: * 2d43f0faeabc760120d3e0cbfc9632e42b2cfab6 Travis: [PENDING](https://travis-ci.com/github

[GitHub] [flink] jiasheng55 commented on issue #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir…

jiasheng55 commented on issue #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir… URL: https://github.com/apache/flink/pull/11322#issuecomment-601517139 @kl0u this PR removed the "targetDir" parameter from `YarnClusterDescriptor#uploadAndRegisterFiles` method and

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347#discussion_r395431078 ## File path: flink-runtime/src/main/java/org/apac

[GitHub] [flink] flinkbot commented on issue #11457: [FLINK-14255][WIP][table] Introduce FileSystemStreamingSinkV2

flinkbot commented on issue #11457: [FLINK-14255][WIP][table] Introduce FileSystemStreamingSinkV2 URL: https://github.com/apache/flink/pull/11457#issuecomment-601515074 ## CI report: * 2d43f0faeabc760120d3e0cbfc9632e42b2cfab6 UNKNOWN Bot commands The @flinkbot bot

[GitHub] [flink] flinkbot edited a comment on issue #11456: [FLINK-16602][k8s] Rework the internal/external Service

flinkbot edited a comment on issue #11456: [FLINK-16602][k8s] Rework the internal/external Service URL: https://github.com/apache/flink/pull/11456#issuecomment-601501414 ## CI report: * e4c3073a6fb379bacb4da0e299245a73ea2a97d4 Travis: [SUCCESS](https://travis-ci.com/github/flink

[jira] [Updated] (FLINK-16625) Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils

[ https://issues.apache.org/jira/browse/FLINK-16625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16625: - Summary: Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUti

[jira] [Updated] (FLINK-16625) Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils

[ https://issues.apache.org/jira/browse/FLINK-16625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16625: - Description: {{BootstrapTools#getEnvironmentVariables}} actually is a general utility to extrac

[GitHub] [flink] xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r395430171 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java ###

[jira] [Assigned] (FLINK-16625) Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtil

[ https://issues.apache.org/jira/browse/FLINK-16625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-16625: - Assignee: Canbin Zheng > Extract BootstrapTools#getEnvironmentVariables to a general utility in

[GitHub] [flink] jiasheng55 commented on a change in pull request #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir…

jiasheng55 commented on a change in pull request #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir… URL: https://github.com/apache/flink/pull/11322#discussion_r393478330 ## File path: flink-yarn/src/test/java/org/apache/flink/yarn/YarnFileStageTestS3ITCa

[GitHub] [flink] xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r395429730 ## File path: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java ##

[jira] [Commented] (FLINK-15447) To improve utilization of the `java.io.tmpdir` for YARN module

[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063064#comment-17063064 ] Victor Wong commented on FLINK-15447: - Currently, we can solve this issue through "e

[jira] [Closed] (FLINK-15447) To improve utilization of the `java.io.tmpdir` for YARN module

[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong closed FLINK-15447. --- Resolution: Not A Problem > To improve utilization of the `java.io.tmpdir` for YARN module > ---

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347#discussion_r395429422 ## File path: flink-runtime/src/main/java/org/apac

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347#discussion_r395429228 ## File path: flink-runtime/src/main/java/org/apac

[jira] [Assigned] (FLINK-16687) PyFlink Cannot determine simple type name "PythonScalarFunction$0"

[ https://issues.apache.org/jira/browse/FLINK-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-16687: --- Assignee: Huang Xingbo > PyFlink Cannot determine simple type name "PythonScalarFunction$0" > -

[GitHub] [flink] jiasheng55 closed pull request #11331: [FLINK-15447][yarn] Add config to define 'java.io.tmpdir' property of…

jiasheng55 closed pull request #11331: [FLINK-15447][yarn] Add config to define 'java.io.tmpdir' property of… URL: https://github.com/apache/flink/pull/11331 This is an automated message from the Apache Git Service. To respo

[GitHub] [flink] xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r395428193 ## File path: flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java ##

[GitHub] [flink] xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r395426701 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java

[GitHub] [flink] flinkbot commented on issue #11457: [FLINK-14255][WIP][table] Introduce FileSystemStreamingSinkV2

flinkbot commented on issue #11457: [FLINK-14255][WIP][table] Introduce FileSystemStreamingSinkV2 URL: https://github.com/apache/flink/pull/11457#issuecomment-601511488 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r395426615 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java

[GitHub] [flink] JingsongLi opened a new pull request #11457: [FLINK-14255][WIP][table] Introduce FileSystemStreamingSinkV2

JingsongLi opened a new pull request #11457: [FLINK-14255][WIP][table] Introduce FileSystemStreamingSinkV2 URL: https://github.com/apache/flink/pull/11457 ## What is the purpose of the change Build table streaming file sink based on DataStream StreamingFileSink. NOTE: Work in

[GitHub] [flink] xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r395425038 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java

[GitHub] [flink] flinkbot edited a comment on issue #11456: [FLINK-16602][k8s] Rework the internal/external Service

flinkbot edited a comment on issue #11456: [FLINK-16602][k8s] Rework the internal/external Service URL: https://github.com/apache/flink/pull/11456#issuecomment-601501414 ## CI report: * e4c3073a6fb379bacb4da0e299245a73ea2a97d4 Travis: [PENDING](https://travis-ci.com/github/flink

[GitHub] [flink] xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

xintongsong commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r395425038 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java

[GitHub] [flink] flinkbot edited a comment on issue #11415: [FLINK-15667][k8s] Support to mount custom Hadoop configurations

flinkbot edited a comment on issue #11415: [FLINK-15667][k8s] Support to mount custom Hadoop configurations URL: https://github.com/apache/flink/pull/11415#issuecomment-599458187 ## CI report: * abc66a0d2605b380ed890dd23e4ff19c9a65ed6a Travis: [FAILURE](https://travis-ci.com/git

[GitHub] [flink] liuzhixing1006 commented on issue #11391: [FLINK-16098] [chinese-translation, Documentation] Translate "Overview" page of "Hive Integration" into Chinese

liuzhixing1006 commented on issue #11391: [FLINK-16098] [chinese-translation, Documentation] Translate "Overview" page of "Hive Integration" into Chinese URL: https://github.com/apache/flink/pull/11391#issuecomment-601505120 Thank you @JingsongLi for bringing this problem to my attention,

[GitHub] [flink] flinkbot edited a comment on issue #11456: [FLINK-16602][k8s] Rework the internal/external Service

flinkbot edited a comment on issue #11456: [FLINK-16602][k8s] Rework the internal/external Service URL: https://github.com/apache/flink/pull/11456#issuecomment-601501414 ## CI report: * e4c3073a6fb379bacb4da0e299245a73ea2a97d4 Travis: [PENDING](https://travis-ci.com/github/flink

[GitHub] [flink] flinkbot edited a comment on issue #11415: [FLINK-15667][k8s] Support to mount custom Hadoop configurations

flinkbot edited a comment on issue #11415: [FLINK-15667][k8s] Support to mount custom Hadoop configurations URL: https://github.com/apache/flink/pull/11415#issuecomment-599458187 ## CI report: * 64eaf715bef2bfc9492ef197ecec62d3e067d18d Travis: [PENDING](https://travis-ci.com/git

[GitHub] [flink] jinglining commented on a change in pull request #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager

jinglining commented on a change in pull request #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager URL: https://github.com/apache/flink/pull/11250#discussion_r395418363 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/taskma

[jira] [Commented] (FLINK-16482) Flink Job throw CloseException when call the FlinkKafkaConsumer cancel function

[ https://issues.apache.org/jira/browse/FLINK-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063042#comment-17063042 ] likang commented on FLINK-16482: Thank you very much > Flink Job throw CloseException w

[GitHub] [flink] flinkbot commented on issue #11456: [FLINK-16602][k8s] Rework the internal/external Service

flinkbot commented on issue #11456: [FLINK-16602][k8s] Rework the internal/external Service URL: https://github.com/apache/flink/pull/11456#issuecomment-601501414 ## CI report: * e4c3073a6fb379bacb4da0e299245a73ea2a97d4 UNKNOWN Bot commands The @flinkbot bot suppo

[GitHub] [flink] flinkbot edited a comment on issue #11421: [FLINK-15962][network] Reduce the default chunk size to 4M in netty stack

flinkbot edited a comment on issue #11421: [FLINK-15962][network] Reduce the default chunk size to 4M in netty stack URL: https://github.com/apache/flink/pull/11421#issuecomment-599826019 ## CI report: * 394192b70d312009146b91bda454b5297ad3b036 Travis: [SUCCESS](https://travis-c

[GitHub] [flink] zhengcanbin commented on issue #11415: [FLINK-15667][k8s] Support to mount custom Hadoop configurations

zhengcanbin commented on issue #11415: [FLINK-15667][k8s] Support to mount custom Hadoop configurations URL: https://github.com/apache/flink/pull/11415#issuecomment-601500881 @flinkbot run travis This is an automated message

[GitHub] [flink] zhengcanbin commented on issue #11415: [FLINK-15667][k8s] Support to mount custom Hadoop configurations

zhengcanbin commented on issue #11415: [FLINK-15667][k8s] Support to mount custom Hadoop configurations URL: https://github.com/apache/flink/pull/11415#issuecomment-601500915 @flinkbot run azure This is an automated message f

[GitHub] [flink] flinkbot commented on issue #11456: [FLINK-16602][k8s] Rework the internal/external Service

flinkbot commented on issue #11456: [FLINK-16602][k8s] Rework the internal/external Service URL: https://github.com/apache/flink/pull/11456#issuecomment-601500094 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Updated] (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 ] ASF GitHub Bot updated FLINK-16602: --- Labels: pull-request-available (was: ) > Rework the Service design for Kubernetes deploymen

[jira] [Updated] (FLINK-16687) PyFlink Cannot determine simple type name "PythonScalarFunction$0"

[ https://issues.apache.org/jira/browse/FLINK-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16687: Priority: Major (was: Blocker) > PyFlink Cannot determine simple type name "PythonScalarFunction$0" > ---

[GitHub] [flink] zhengcanbin opened a new pull request #11456: [FLINK-16602][k8s] Rework the internal/external Service

zhengcanbin opened a new pull request #11456: [FLINK-16602][k8s] Rework the internal/external Service URL: https://github.com/apache/flink/pull/11456 ## What is the purpose of the change At the moment we usually create two Services for a Flink application, one is the internal Servic

[GitHub] [flink] JingsongLi commented on a change in pull request #11336: [FLINK-16471][jdbc] develop PostgresCatalog

JingsongLi commented on a change in pull request #11336: [FLINK-16471][jdbc] develop PostgresCatalog URL: https://github.com/apache/flink/pull/11336#discussion_r395413626 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/catalog/JDBCCatalog.j

[GitHub] [flink] flinkbot edited a comment on issue #11421: [FLINK-15962][network] Reduce the default chunk size to 4M in netty stack

flinkbot edited a comment on issue #11421: [FLINK-15962][network] Reduce the default chunk size to 4M in netty stack URL: https://github.com/apache/flink/pull/11421#issuecomment-599826019 ## CI report: * 394192b70d312009146b91bda454b5297ad3b036 Travis: [PENDING](https://travis-c

[GitHub] [flink] JingsongLi commented on a change in pull request #11336: [FLINK-16471][jdbc] develop PostgresCatalog

JingsongLi commented on a change in pull request #11336: [FLINK-16471][jdbc] develop PostgresCatalog URL: https://github.com/apache/flink/pull/11336#discussion_r395412510 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/catalog/JDBCCatalog.j

[jira] [Created] (FLINK-16687) PyFlink Cannot determine simple type name "PythonScalarFunction$0"

mayne wong created FLINK-16687: -- Summary: PyFlink Cannot determine simple type name "PythonScalarFunction$0" Key: FLINK-16687 URL: https://issues.apache.org/jira/browse/FLINK-16687 Project: Flink

[GitHub] [flink] JingsongLi commented on a change in pull request #11336: [FLINK-16471][jdbc] develop PostgresCatalog

JingsongLi commented on a change in pull request #11336: [FLINK-16471][jdbc] develop PostgresCatalog URL: https://github.com/apache/flink/pull/11336#discussion_r395412120 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/catalog/AbstractJDBCC

[GitHub] [flink] JingsongLi commented on issue #11391: [FLINK-16098] [chinese-translation, Documentation] Translate "Overview" page of "Hive Integration" into Chinese

JingsongLi commented on issue #11391: [FLINK-16098] [chinese-translation, Documentation] Translate "Overview" page of "Hive Integration" into Chinese URL: https://github.com/apache/flink/pull/11391#issuecomment-601496994 Hi @liuzhixing1006 , you can not use merge. You should use rebase only

[GitHub] [flink-statefun] sjwiesman commented on issue #62: [FLINK-16685] Add a k8s example for the Python SDK

sjwiesman commented on issue #62: [FLINK-16685] Add a k8s example for the Python SDK URL: https://github.com/apache/flink-statefun/pull/62#issuecomment-601494204 Maybe off topics but should we add k8s deployment docs? This i

[jira] [Updated] (FLINK-16557) Document YAML-ized Kafka egresses / ingresses in Stateful Functions documentation

[ https://issues.apache.org/jira/browse/FLINK-16557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16557: --- Labels: pull-request-available (was: ) > Document YAML-ized Kafka egresses / ingresses in S

[GitHub] [flink-statefun] sjwiesman opened a new pull request #63: [FLINK-16557][docs] Document YAML-ized Kafka egresses / ingresses in …

sjwiesman opened a new pull request #63: [FLINK-16557][docs] Document YAML-ized Kafka egresses / ingresses in … URL: https://github.com/apache/flink-statefun/pull/63 …Stateful Functions documentation This is an automated mess

[jira] [Closed] (FLINK-16650) Support LocalZonedTimestampType for Python UDF in blink planner

[ https://issues.apache.org/jira/browse/FLINK-16650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16650. --- Resolution: Resolved > Support LocalZonedTimestampType for Python UDF in blink planner > ---

[jira] [Commented] (FLINK-16650) Support LocalZonedTimestampType for Python UDF in blink planner

[ https://issues.apache.org/jira/browse/FLINK-16650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063034#comment-17063034 ] Hequn Cheng commented on FLINK-16650: - Resolved in 1.11.0 via 5ccb16724769becab0003e

[GitHub] [flink] hequn8128 merged pull request #11439: [FLINK-16650][python] Support LocalZonedTimestampType for Python UDF in blink planner

hequn8128 merged pull request #11439: [FLINK-16650][python] Support LocalZonedTimestampType for Python UDF in blink planner URL: https://github.com/apache/flink/pull/11439 This is an automated message from the Apache Git Ser

[jira] [Comment Edited] (FLINK-16637) Flink per job mode terminates before serving job cancellation result

[ https://issues.apache.org/jira/browse/FLINK-16637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063025#comment-17063025 ] Zili Chen edited comment on FLINK-16637 at 3/20/20, 1:31 AM: -

[GitHub] [flink] flinkbot edited a comment on issue #11421: [FLINK-15962][network] Reduce the default chunk size to 4M in netty stack

flinkbot edited a comment on issue #11421: [FLINK-15962][network] Reduce the default chunk size to 4M in netty stack URL: https://github.com/apache/flink/pull/11421#issuecomment-599826019 ## CI report: * dd9c079d6024bcae4216bdc3004660018e41f938 Travis: [FAILURE](https://travis-c

[jira] [Commented] (FLINK-16637) Flink per job mode terminates before serving job cancellation result

[ https://issues.apache.org/jira/browse/FLINK-16637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063025#comment-17063025 ] Zili Chen commented on FLINK-16637: --- [~gjy] after "cancel" command received by the {{J

[GitHub] [flink] dianfu commented on issue #11439: [FLINK-16650][python] Support LocalZonedTimestampType for Python UDF in blink planner

dianfu commented on issue #11439: [FLINK-16650][python] Support LocalZonedTimestampType for Python UDF in blink planner URL: https://github.com/apache/flink/pull/11439#issuecomment-601487959 The failed azure test is a known issue and has already been tracked in https://issues.apache.org/j

[jira] [Commented] (FLINK-15852) Job is submitted to the wrong session cluster

[ https://issues.apache.org/jira/browse/FLINK-15852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063021#comment-17063021 ] Canbin Zheng commented on FLINK-15852: -- Thanks for the fixup [~kkl0u]! > Job is su

[GitHub] [flink] flinkbot edited a comment on issue #11421: [FLINK-15962][network] Reduce the default chunk size to 4M in netty stack

flinkbot edited a comment on issue #11421: [FLINK-15962][network] Reduce the default chunk size to 4M in netty stack URL: https://github.com/apache/flink/pull/11421#issuecomment-599826019 ## CI report: * dd9c079d6024bcae4216bdc3004660018e41f938 Travis: [FAILURE](https://travis-c

[GitHub] [flink] liuzhixing1006 edited a comment on issue #11391: [FLINK-16098] [chinese-translation, Documentation] Translate "Overview" page of "Hive Integration" into Chinese

liuzhixing1006 edited a comment on issue #11391: [FLINK-16098] [chinese-translation, Documentation] Translate "Overview" page of "Hive Integration" into Chinese URL: https://github.com/apache/flink/pull/11391#issuecomment-601200160 @lirui-apache @JingsongLi Thanks for your advice, I have

[GitHub] [flink] flinkbot edited a comment on issue #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

flinkbot edited a comment on issue #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#issuecomment-590065588 ## CI report: * 738a6fd162d5ba99432438d224f3b4890961af56 UNKNOWN * 77f24b292a04fde34f

[GitHub] [flink] afedulov commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

afedulov commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r395376334 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/jav

[GitHub] [flink] afedulov commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

afedulov commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r395375550 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/jav

[GitHub] [flink] afedulov commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

afedulov commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r395376334 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/jav

[GitHub] [flink] afedulov commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

afedulov commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r395375550 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/jav

[GitHub] [flink] afedulov commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

afedulov commented on a change in pull request #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#discussion_r395375550 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/jav

  1   2   3   4   5   6   >