[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

[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: *

[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:

[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:

[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

[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

[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

[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).

[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

[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:

[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:

[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:

[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`

[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:

[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:

[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

[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:

[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

[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:

[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

[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

[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

[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:

[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=17063064#comment-17063064 ] Victor Wong commented on FLINK-15447: - Currently, we can solve this issue through "env.java.opts:

[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:

[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:

[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

[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

[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:

[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:

[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:

[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:

[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:

[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=17063042#comment-17063042 ] likang commented on FLINK-16482: Thank you very much > Flink Job throw CloseException when call the

[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

[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:

[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

[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

[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

[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:

[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:

[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:

[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:

[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

[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

[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

[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

[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=17063034#comment-17063034 ] Hequn Cheng commented on FLINK-16650: - Resolved in 1.11.0 via

[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

[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=17063025#comment-17063025 ] Zili Chen edited comment on FLINK-16637 at 3/20/20, 1:31 AM: - [~gjy] after

[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:

[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=17063025#comment-17063025 ] Zili Chen commented on FLINK-16637: --- [~gjy] after "cancel" command received by the {{JobMaster}}, it

[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

[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=17063021#comment-17063021 ] Canbin Zheng commented on FLINK-15852: -- Thanks for the fixup [~kkl0u]! > Job is submitted to the

[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:

[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 *

[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:

[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:

[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:

[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:

[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:

[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:

[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_r395375423 ## File path:

[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 *

[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_r395348055 ## File path:

[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_r395368073 ## File path:

[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 *

[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_r395366353 ## File path:

[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_r395365114 ## File path:

[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_r395365114 ## File path:

[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_r395365114 ## File path:

[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_r395360427 ## File path:

[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 *

[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_r395348055 ## File path:

[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 *

[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_r395348055 ## File path:

[jira] [Closed] (FLINK-10424) Inconsistency between JsonSchemaConveerter and FlinkTypeFactory

[ https://issues.apache.org/jira/browse/FLINK-10424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dominik Wosiński closed FLINK-10424. Resolution: Fixed > Inconsistency between JsonSchemaConveerter and FlinkTypeFactory >

[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 *

[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_r395337241 ## File path:

[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_r395335333 ## File path:

  1   2   3   4   5   6   >