[GitHub] [flink] pnowojski merged pull request #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI

pnowojski merged pull request #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI URL: https://github.com/apache/flink/pull/10935 This is an automated message from the Apache Git Service. To respo

[GitHub] [flink] flinkbot commented on issue #10956: [FLINK-15646][client]Configurable K8s context support.

flinkbot commented on issue #10956: [FLINK-15646][client]Configurable K8s context support. URL: https://github.com/apache/flink/pull/10956#issuecomment-579636254 ## CI report: * b8552e9bdb85a747491fec61f7f74284bd4ebf53 UNKNOWN Bot commands The @flinkbot bot suppor

[jira] [Created] (FLINK-15800) Refactor download page to make hadoop less prominant

Chesnay Schepler created FLINK-15800: Summary: Refactor download page to make hadoop less prominant Key: FLINK-15800 URL: https://issues.apache.org/jira/browse/FLINK-15800 Project: Flink

[jira] [Updated] (FLINK-15646) Configurable K8s context support

[ https://issues.apache.org/jira/browse/FLINK-15646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15646: - Priority: Major (was: Minor) > Configurable K8s context support > -

[GitHub] [flink] flinkbot commented on issue #10956: [FLINK-15646][client]Configurable K8s context support.

flinkbot commented on issue #10956: [FLINK-15646][client]Configurable K8s context support. URL: https://github.com/apache/flink/pull/10956#issuecomment-579631002 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull r

[jira] [Commented] (FLINK-13369) Recursive closure cleaner ends up with stackOverflow in case of circular dependency

[ https://issues.apache.org/jira/browse/FLINK-13369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025657#comment-17025657 ] Chesnay Schepler commented on FLINK-13369: -- [~arobe...@fuze.com] Can you provid

[jira] [Updated] (FLINK-15646) Configurable K8s context support

[ https://issues.apache.org/jira/browse/FLINK-15646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15646: --- Labels: pull-request-available (was: ) > Configurable K8s context support > ---

[GitHub] [flink] zhengcanbin opened a new pull request #10956: [FLINK-15646][client]Configurable K8s context support.

zhengcanbin opened a new pull request #10956: [FLINK-15646][client]Configurable K8s context support. URL: https://github.com/apache/flink/pull/10956 ## What is the purpose of the change One would be forced to firstly use kubectl config use-context to switch to the desired context i

[jira] [Updated] (FLINK-15647) Support to set annotations for JM/TM Pods

[ https://issues.apache.org/jira/browse/FLINK-15647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15647: - Parent: FLINK-14460 Issue Type: Sub-task (was: New Feature) > Support to set annotation

[jira] [Updated] (FLINK-15652) Support for imagePullSecrets k8s option

[ https://issues.apache.org/jira/browse/FLINK-15652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15652: - Parent: FLINK-14460 Issue Type: Sub-task (was: New Feature) > Support for imagePullSecr

[jira] [Commented] (FLINK-15662) Make K8s client timeouts configurable

[ https://issues.apache.org/jira/browse/FLINK-15662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025619#comment-17025619 ] Canbin Zheng commented on FLINK-15662: -- [~trohrmann] It is a subtask of FLINK-14460

[jira] [Updated] (FLINK-15662) Make K8s client timeouts configurable

[ https://issues.apache.org/jira/browse/FLINK-15662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15662: - Parent: FLINK-14460 Issue Type: Sub-task (was: Improvement) > Make K8s client timeouts

[jira] [Commented] (FLINK-15667) Hadoop Configurations Mount Support

[ https://issues.apache.org/jira/browse/FLINK-15667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025615#comment-17025615 ] Canbin Zheng commented on FLINK-15667: -- [~yangwang166] WDYT > Hadoop Configuration

[jira] [Commented] (FLINK-15799) Support running kubernetes.sh against different context than the current context

[ https://issues.apache.org/jira/browse/FLINK-15799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025577#comment-17025577 ] Canbin Zheng commented on FLINK-15799: -- Seems a duplica of [FLINK-15646|https://is

[GitHub] [flink] link3280 edited a comment on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy

link3280 edited a comment on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy URL: https://github.com/apache/flink/pull/10113#issuecomment-579582816 @hequn8128 Thanks a lot for your work on the new release! But IIUC, I did have backported this PR to rele

[GitHub] [flink] link3280 edited a comment on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy

link3280 edited a comment on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy URL: https://github.com/apache/flink/pull/10113#issuecomment-579582816 @hequn8128 Thanks a lot for your work on the new release! But IIUC, I did have backported this PR to rele

[GitHub] [flink] flinkbot edited a comment on issue #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations

flinkbot edited a comment on issue #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations URL: https://github.com/apache/flink/pull/10378#issuecomment-560291002 ## CI report: * 5a9b8cc32f275d416e8358ee148ad4daff2626ba Travis: [FA

[GitHub] [flink] link3280 commented on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy

link3280 commented on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy URL: https://github.com/apache/flink/pull/10113#issuecomment-579582816 @hequn8128 Thanks a lot for your work on the new release! But IIUC, I did have backported this PR to release-1.9

[jira] [Updated] (FLINK-14976) Cassandra Connector leaks Semaphore on Throwable; hangs on close

[ https://issues.apache.org/jira/browse/FLINK-14976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14976: Fix Version/s: 1.8.3 1.10.0 1.9.2 > Cassandra Connector leak

[jira] [Commented] (FLINK-14251) Add FutureUtils#forward utility

[ https://issues.apache.org/jira/browse/FLINK-14251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025554#comment-17025554 ] Hequn Cheng commented on FLINK-14251: - Also fixed in 1.9.2 via 9fc56279abcf0e9a08321

[jira] [Updated] (FLINK-14251) Add FutureUtils#forward utility

[ https://issues.apache.org/jira/browse/FLINK-14251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14251: Fix Version/s: 1.9.2 > Add FutureUtils#forward utility > --- > >

[GitHub] [flink] flinkbot edited a comment on issue #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations

flinkbot edited a comment on issue #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations URL: https://github.com/apache/flink/pull/10378#issuecomment-560291002 ## CI report: * 5a9b8cc32f275d416e8358ee148ad4daff2626ba Travis: [FA

[jira] [Updated] (FLINK-13940) S3RecoverableWriter causes job to get stuck in recovery

[ https://issues.apache.org/jira/browse/FLINK-13940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-13940: Fix Version/s: 1.9.1 > S3RecoverableWriter causes job to get stuck in recovery > -

[jira] [Updated] (FLINK-13940) S3RecoverableWriter causes job to get stuck in recovery

[ https://issues.apache.org/jira/browse/FLINK-13940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-13940: Fix Version/s: (was: 1.9.2) > S3RecoverableWriter causes job to get stuck in recovery > --

[jira] [Updated] (FLINK-13749) Make Flink client respect classloading policy

[ https://issues.apache.org/jira/browse/FLINK-13749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-13749: Fix Version/s: (was: 1.9.2) (was: 1.8.3) > Make Flink client respect cl

[GitHub] [flink] Li-Aihua commented on issue #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations

Li-Aihua commented on issue #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations URL: https://github.com/apache/flink/pull/10378#issuecomment-579574996 @zentol thanks for your commens.i updated it,please review it again.thanks very much.

[GitHub] [flink] hequn8128 edited a comment on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy

hequn8128 edited a comment on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy URL: https://github.com/apache/flink/pull/10113#issuecomment-579574747 @link3280 I'm checking the release note of 1.9.2 and found that the fix has not been included in 1.9. It

[GitHub] [flink] hequn8128 commented on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy

hequn8128 commented on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy URL: https://github.com/apache/flink/pull/10113#issuecomment-579574747 @link3280 I'm checking the release note of 1.9.2 and found that the fix has not been included in 1.9, could you

[GitHub] [flink] Li-Aihua commented on a change in pull request #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations

Li-Aihua commented on a change in pull request #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations URL: https://github.com/apache/flink/pull/10378#discussion_r372172296 ## File path: flink-end-to-end-perf-tests/flink-basic-operat

[jira] [Updated] (FLINK-13747) Remove some TODOs in Hive connector

[ https://issues.apache.org/jira/browse/FLINK-13747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-13747: Fix Version/s: 1.9.2 > Remove some TODOs in Hive connector > --- >

[GitHub] [flink] flinkbot edited a comment on issue #10955: [hotfix] [docs] Typo in Time-windowed Joins doc

flinkbot edited a comment on issue #10955: [hotfix] [docs] Typo in Time-windowed Joins doc URL: https://github.com/apache/flink/pull/10955#issuecomment-579427151 ## CI report: * 02bbc58d944550d4a920cbc5f5db1d35d3a0cc91 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/build

[GitHub] [flink] flinkbot edited a comment on issue #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model

flinkbot edited a comment on issue #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model URL: https://github.com/apache/flink/pull/10435#issuecomment-562048103 ## CI report: * d07737bd54c586aa87204c6ac298309f432cc06c Travis: [FAILURE]

[GitHub] [flink] flinkbot edited a comment on issue #10955: [hotfix] [docs] Typo in Time-windowed Joins doc

flinkbot edited a comment on issue #10955: [hotfix] [docs] Typo in Time-windowed Joins doc URL: https://github.com/apache/flink/pull/10955#issuecomment-579427151 ## CI report: * 02bbc58d944550d4a920cbc5f5db1d35d3a0cc91 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/build

[GitHub] [flink] flinkbot edited a comment on issue #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model

flinkbot edited a comment on issue #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model URL: https://github.com/apache/flink/pull/10435#issuecomment-562048103 ## CI report: * d07737bd54c586aa87204c6ac298309f432cc06c Travis: [FAILURE]

[jira] [Comment Edited] (FLINK-15703) FlinkKafkaConsumer should enable partition discovery by default.

[ https://issues.apache.org/jira/browse/FLINK-15703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025437#comment-17025437 ] Stephan Ewen edited comment on FLINK-15703 at 1/28/20 8:55 PM: ---

[jira] [Commented] (FLINK-15703) FlinkKafkaConsumer should enable partition discovery by default.

[ https://issues.apache.org/jira/browse/FLINK-15703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025437#comment-17025437 ] Stephan Ewen commented on FLINK-15703: -- Is this meant for the new Source API Kafka

[jira] [Comment Edited] (FLINK-13369) Recursive closure cleaner ends up with stackOverflow in case of circular dependency

[ https://issues.apache.org/jira/browse/FLINK-13369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025435#comment-17025435 ] Andrew Roberts edited comment on FLINK-13369 at 1/28/20 8:53 PM: -

[jira] [Commented] (FLINK-13369) Recursive closure cleaner ends up with stackOverflow in case of circular dependency

[ https://issues.apache.org/jira/browse/FLINK-13369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025435#comment-17025435 ] Andrew Roberts commented on FLINK-13369: I'm still seeing this behavior in Flink

[GitHub] [flink] rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model

rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model URL: https://github.com/apache/flink/pull/10435#discussion_r372047776 ## File path: flink-streaming-java/src/main/java/org/apache/f

[GitHub] [flink] flinkbot edited a comment on issue #10955: [hotfix] [docs] Typo in Time-windowed Joins doc

flinkbot edited a comment on issue #10955: [hotfix] [docs] Typo in Time-windowed Joins doc URL: https://github.com/apache/flink/pull/10955#issuecomment-579427151 ## CI report: * 02bbc58d944550d4a920cbc5f5db1d35d3a0cc91 Travis: [PENDING](https://travis-ci.com/flink-ci/flink/build

[GitHub] [flink] flinkbot commented on issue #10955: [hotfix] [docs] Typo in Time-windowed Joins doc

flinkbot commented on issue #10955: [hotfix] [docs] Typo in Time-windowed Joins doc URL: https://github.com/apache/flink/pull/10955#issuecomment-579427151 ## CI report: * 02bbc58d944550d4a920cbc5f5db1d35d3a0cc91 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] alpinegizmo commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

alpinegizmo commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r372013058 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,377 @@ +--- +title: "Release No

[GitHub] [flink] flinkbot commented on issue #10955: [hotfix] [docs] Typo in Time-windowed Joins doc

flinkbot commented on issue #10955: [hotfix] [docs] Typo in Time-windowed Joins doc URL: https://github.com/apache/flink/pull/10955#issuecomment-579413723 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request.

[GitHub] [flink] benoitparis opened a new pull request #10955: [hotfix] [docs] Typo in Time-windowed Joins doc

benoitparis opened a new pull request #10955: [hotfix] [docs] Typo in Time-windowed Joins doc URL: https://github.com/apache/flink/pull/10955 This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] flinkbot edited a comment on issue #10498: [FLINK-14495][docs] Add documentation for memory control of RocksDB state backend

flinkbot edited a comment on issue #10498: [FLINK-14495][docs] Add documentation for memory control of RocksDB state backend URL: https://github.com/apache/flink/pull/10498#issuecomment-563242008 ## CI report: * dd347fe423313a8bb7c975e3f04ba626fe5dd1b2 Travis: [SUCCESS](https://

[jira] [Commented] (FLINK-15504) Flink suppresses stdout/stderr during JobGraph generation from JAR

[ https://issues.apache.org/jira/browse/FLINK-15504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025334#comment-17025334 ] Gary Yao commented on FLINK-15504: -- There are some examples here [https://ci.apache.or

[jira] [Comment Edited] (FLINK-15504) Flink suppresses stdout/stderr during JobGraph generation from JAR

[ https://issues.apache.org/jira/browse/FLINK-15504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025334#comment-17025334 ] Gary Yao edited comment on FLINK-15504 at 1/28/20 5:51 PM: --- Th

[GitHub] [flink] flinkbot edited a comment on issue #10498: [FLINK-14495][docs] Add documentation for memory control of RocksDB state backend

flinkbot edited a comment on issue #10498: [FLINK-14495][docs] Add documentation for memory control of RocksDB state backend URL: https://github.com/apache/flink/pull/10498#issuecomment-563242008 ## CI report: * dd347fe423313a8bb7c975e3f04ba626fe5dd1b2 Travis: [SUCCESS](https://

[GitHub] [flink] flinkbot edited a comment on issue #10498: [FLINK-14495][docs] Add documentation for memory control of RocksDB state backend

flinkbot edited a comment on issue #10498: [FLINK-14495][docs] Add documentation for memory control of RocksDB state backend URL: https://github.com/apache/flink/pull/10498#issuecomment-563242008 ## CI report: * dd347fe423313a8bb7c975e3f04ba626fe5dd1b2 Travis: [SUCCESS](https://

[jira] [Commented] (FLINK-15787) Upgrade REST API response to remove '-' from key names.

[ https://issues.apache.org/jira/browse/FLINK-15787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025298#comment-17025298 ] Till Rohrmann commented on FLINK-15787: --- I think this sounds like a very good impr

[GitHub] [flink] flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#issuecomment-577792274 ## CI report: * 91aa4fb6f751281910c9e470aa780fa7abe43aa1 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/

[GitHub] [flink] flinkbot edited a comment on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI

flinkbot edited a comment on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI URL: https://github.com/apache/flink/pull/10935#issuecomment-577747488 ## CI report: * d23cbb62a92aeacecabdad080c3d062dcaa7ddba Travis: [FAILURE](https://travis-ci.

[jira] [Closed] (FLINK-15780) Manual Smoke Test of Native Kubernetes Integration

[ https://issues.apache.org/jira/browse/FLINK-15780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-15780. - Fix Version/s: (was: 1.10.0) Resolution: Fixed I've done the manual smoke testing by

[jira] [Updated] (FLINK-15787) Upgrade REST API response to remove '-' from key names.

[ https://issues.apache.org/jira/browse/FLINK-15787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-15787: -- Fix Version/s: 1.11.0 > Upgrade REST API response to remove '-' from key names. >

[jira] [Commented] (FLINK-15788) Various Kubernetes integration improvements

[ https://issues.apache.org/jira/browse/FLINK-15788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025274#comment-17025274 ] Till Rohrmann commented on FLINK-15788: --- fyi [~yangwang166] > Various Kubernetes

[jira] [Created] (FLINK-15799) Support running kubernetes.sh against different context than the current context

Till Rohrmann created FLINK-15799: - Summary: Support running kubernetes.sh against different context than the current context Key: FLINK-15799 URL: https://issues.apache.org/jira/browse/FLINK-15799 Pr

[jira] [Created] (FLINK-15798) Running ./bin/kubernetes-session.sh -Dkubernetes.cluster-id= -Dexecution.attached=true fails with exception

Till Rohrmann created FLINK-15798: - Summary: Running ./bin/kubernetes-session.sh -Dkubernetes.cluster-id= -Dexecution.attached=true fails with exception Key: FLINK-15798 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-15797) Reduce logging noise of Fabric8FlinkKubeClient

Till Rohrmann created FLINK-15797: - Summary: Reduce logging noise of Fabric8FlinkKubeClient Key: FLINK-15797 URL: https://issues.apache.org/jira/browse/FLINK-15797 Project: Flink Issue Type:

[jira] [Created] (FLINK-15796) Extend Kubernetes documentation on how to use a custom image

Till Rohrmann created FLINK-15796: - Summary: Extend Kubernetes documentation on how to use a custom image Key: FLINK-15796 URL: https://issues.apache.org/jira/browse/FLINK-15796 Project: Flink

[jira] [Created] (FLINK-15795) KubernetesClusterDescriptor seems to report unreachable JobManager interface URL

Till Rohrmann created FLINK-15795: - Summary: KubernetesClusterDescriptor seems to report unreachable JobManager interface URL Key: FLINK-15795 URL: https://issues.apache.org/jira/browse/FLINK-15795 Pr

[GitHub] [flink] flinkbot edited a comment on issue #10498: [FLINK-14495][docs] Add documentation for memory control of RocksDB state backend

flinkbot edited a comment on issue #10498: [FLINK-14495][docs] Add documentation for memory control of RocksDB state backend URL: https://github.com/apache/flink/pull/10498#issuecomment-563242008 ## CI report: * dd347fe423313a8bb7c975e3f04ba626fe5dd1b2 Travis: [SUCCESS](https://

[jira] [Created] (FLINK-15794) Rethink default value of kubernetes.container.image

Till Rohrmann created FLINK-15794: - Summary: Rethink default value of kubernetes.container.image Key: FLINK-15794 URL: https://issues.apache.org/jira/browse/FLINK-15794 Project: Flink Issue T

[GitHub] [flink] flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#issuecomment-577792274 ## CI report: * 91aa4fb6f751281910c9e470aa780fa7abe43aa1 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/

[jira] [Created] (FLINK-15793) Move kubernetes-entry.sh out of FLINK_HOME/bin

Till Rohrmann created FLINK-15793: - Summary: Move kubernetes-entry.sh out of FLINK_HOME/bin Key: FLINK-15793 URL: https://issues.apache.org/jira/browse/FLINK-15793 Project: Flink Issue Type:

[jira] [Created] (FLINK-15792) Make Flink logs accessible via kubectl logs per default

Till Rohrmann created FLINK-15792: - Summary: Make Flink logs accessible via kubectl logs per default Key: FLINK-15792 URL: https://issues.apache.org/jira/browse/FLINK-15792 Project: Flink Iss

[jira] [Created] (FLINK-15791) Don't use ForkJoinPool#commonPool() for executing asynchronous operations in Fabric8FlinkKubeClient

Till Rohrmann created FLINK-15791: - Summary: Don't use ForkJoinPool#commonPool() for executing asynchronous operations in Fabric8FlinkKubeClient Key: FLINK-15791 URL: https://issues.apache.org/jira/browse/FLINK-15

[jira] [Created] (FLINK-15790) Make FlinkKubeClient and its implementations asynchronous

Till Rohrmann created FLINK-15790: - Summary: Make FlinkKubeClient and its implementations asynchronous Key: FLINK-15790 URL: https://issues.apache.org/jira/browse/FLINK-15790 Project: Flink I

[jira] [Created] (FLINK-15789) ActionWatcher.await should throw InterruptedException

Till Rohrmann created FLINK-15789: - Summary: ActionWatcher.await should throw InterruptedException Key: FLINK-15789 URL: https://issues.apache.org/jira/browse/FLINK-15789 Project: Flink Issue

[GitHub] [flink] dawidwys commented on a change in pull request #10942: [FLINK-15487][table] Allow registering FLIP-65 functions in TableEnvironment

dawidwys commented on a change in pull request #10942: [FLINK-15487][table] Allow registering FLIP-65 functions in TableEnvironment URL: https://github.com/apache/flink/pull/10942#discussion_r371791374 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/ta

[GitHub] [flink] dawidwys commented on a change in pull request #10942: [FLINK-15487][table] Allow registering FLIP-65 functions in TableEnvironment

dawidwys commented on a change in pull request #10942: [FLINK-15487][table] Allow registering FLIP-65 functions in TableEnvironment URL: https://github.com/apache/flink/pull/10942#discussion_r371781417 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/ta

[GitHub] [flink] dawidwys commented on a change in pull request #10942: [FLINK-15487][table] Allow registering FLIP-65 functions in TableEnvironment

dawidwys commented on a change in pull request #10942: [FLINK-15487][table] Allow registering FLIP-65 functions in TableEnvironment URL: https://github.com/apache/flink/pull/10942#discussion_r371863785 ## File path: flink-table/flink-table-api-java/src/test/java/org/apache/flink/ta

[GitHub] [flink] dawidwys commented on a change in pull request #10942: [FLINK-15487][table] Allow registering FLIP-65 functions in TableEnvironment

dawidwys commented on a change in pull request #10942: [FLINK-15487][table] Allow registering FLIP-65 functions in TableEnvironment URL: https://github.com/apache/flink/pull/10942#discussion_r371793891 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/ta

[GitHub] [flink] dawidwys commented on a change in pull request #10942: [FLINK-15487][table] Allow registering FLIP-65 functions in TableEnvironment

dawidwys commented on a change in pull request #10942: [FLINK-15487][table] Allow registering FLIP-65 functions in TableEnvironment URL: https://github.com/apache/flink/pull/10942#discussion_r371888078 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/ta

[GitHub] [flink] dawidwys commented on a change in pull request #10942: [FLINK-15487][table] Allow registering FLIP-65 functions in TableEnvironment

dawidwys commented on a change in pull request #10942: [FLINK-15487][table] Allow registering FLIP-65 functions in TableEnvironment URL: https://github.com/apache/flink/pull/10942#discussion_r371791193 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/ta

[jira] [Assigned] (FLINK-15758) Investigate potential out-of-memory problems due to managed unsafe memory allocation

[ https://issues.apache.org/jira/browse/FLINK-15758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-15758: --- Assignee: Andrey Zagrebin > Investigate potential out-of-memory problems due to man

[jira] [Created] (FLINK-15788) Various Kubernetes integration improvements

Till Rohrmann created FLINK-15788: - Summary: Various Kubernetes integration improvements Key: FLINK-15788 URL: https://issues.apache.org/jira/browse/FLINK-15788 Project: Flink Issue Type: Imp

[GitHub] [flink] flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#issuecomment-577792274 ## CI report: * 91aa4fb6f751281910c9e470aa780fa7abe43aa1 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/

[jira] [Assigned] (FLINK-15756) StateFun poms are inconsistent in their scala version usages

[ https://issues.apache.org/jira/browse/FLINK-15756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-15756: Assignee: Igal Shilman > StateFun poms are inconsistent in their scala version us

[GitHub] [flink] flinkbot edited a comment on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI

flinkbot edited a comment on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI URL: https://github.com/apache/flink/pull/10935#issuecomment-577747488 ## CI report: * d23cbb62a92aeacecabdad080c3d062dcaa7ddba Travis: [FAILURE](https://travis-ci.

[jira] [Assigned] (FLINK-15759) ridesharing-example-simulator does not compile on Java 11

[ https://issues.apache.org/jira/browse/FLINK-15759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-15759: Assignee: Igal Shilman > ridesharing-example-simulator does not compile on Java 1

[jira] [Updated] (FLINK-15759) ridesharing-example-simulator does not compile on Java 11

[ https://issues.apache.org/jira/browse/FLINK-15759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15759: --- Labels: pull-request-available (was: ) > ridesharing-example-simulator does not compile on

[GitHub] [flink-statefun] igalshilman opened a new pull request #3: [FLINK-15759][FLINK-15757][FLINK-15764] Adjust POM definitions

igalshilman opened a new pull request #3: [FLINK-15759][FLINK-15757][FLINK-15764] Adjust POM definitions URL: https://github.com/apache/flink-statefun/pull/3 This PR addresses multiple build related issues. 1) Removes Lombok so that stateful functions can be built with Java11 2) C

[GitHub] [flink] aljoscha commented on issue #10944: [FLINK-15739] Fix TypeSerializerUpgradeTestBase on Java 12

aljoscha commented on issue #10944: [FLINK-15739] Fix TypeSerializerUpgradeTestBase on Java 12 URL: https://github.com/apache/flink/pull/10944#issuecomment-579304985 As I said, I think it's doable. But even if it requires only one additional test module per serializer that's quite a lot of

[GitHub] [flink] kl0u closed pull request #7313: [FLINK-11116][fs-connector] Removed randomness from HDFS and Local fs writers.

kl0u closed pull request #7313: [FLINK-6][fs-connector] Removed randomness from HDFS and Local fs writers. URL: https://github.com/apache/flink/pull/7313 This is an automated message from the Apache Git Service. To respo

[jira] [Updated] (FLINK-15758) Investigate potential out-of-memory problems due to managed unsafe memory allocation

[ https://issues.apache.org/jira/browse/FLINK-15758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-15758: Description: After FLINK-13985, managed memory is allocated from UNSAFE, not as direct nio

[jira] [Updated] (FLINK-15758) Investigate potential out-of-memory problems due to managed unsafe memory allocation

[ https://issues.apache.org/jira/browse/FLINK-15758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-15758: Description: After FLINK-13985, managed memory is allocated from UNSAFE, not as direct nio

[GitHub] [flink] flinkbot edited a comment on issue #10954: [FLINK-15785][travis][e2e] Rework E2E test activations

flinkbot edited a comment on issue #10954: [FLINK-15785][travis][e2e] Rework E2E test activations URL: https://github.com/apache/flink/pull/10954#issuecomment-579242201 ## CI report: * 0a4cdba97fcfbb788402b890e6e958cb2949646b Travis: [FAILURE](https://travis-ci.com/flink-ci/flin

[GitHub] [flink] flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#issuecomment-577792274 ## CI report: * 91aa4fb6f751281910c9e470aa780fa7abe43aa1 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/

[GitHub] [flink] flinkbot edited a comment on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI

flinkbot edited a comment on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI URL: https://github.com/apache/flink/pull/10935#issuecomment-577747488 ## CI report: * d23cbb62a92aeacecabdad080c3d062dcaa7ddba Travis: [FAILURE](https://travis-ci.

[GitHub] [flink] pnowojski commented on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI

pnowojski commented on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI URL: https://github.com/apache/flink/pull/10935#issuecomment-579291876 Thank you all the reviews :) Will merge it with green travis.

[GitHub] [flink] vthinkxie commented on a change in pull request #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI

vthinkxie commented on a change in pull request #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI URL: https://github.com/apache/flink/pull/10935#discussion_r371857640 ## File path: flink-runtime-web/web-dashboard/src/app/interfaces/job-checkpoint.ts #

[jira] [Commented] (FLINK-15775) SourceFunctions are instantiated twice when pulled on from 2 Sinks

[ https://issues.apache.org/jira/browse/FLINK-15775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025175#comment-17025175 ] Timo Walther commented on FLINK-15775: -- This issue came up a couple of times in the

[jira] [Updated] (FLINK-15787) Upgrade REST API response to remove '-' from key names.

[ https://issues.apache.org/jira/browse/FLINK-15787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daryl Roberts updated FLINK-15787: -- Description: There are some REST API responses that include keys with hyphens in them.  This

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r371842311 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes - Fl

[GitHub] [flink] flinkbot edited a comment on issue #10954: [FLINK-15785][travis][e2e] Rework E2E test activations

flinkbot edited a comment on issue #10954: [FLINK-15785][travis][e2e] Rework E2E test activations URL: https://github.com/apache/flink/pull/10954#issuecomment-579242201 ## CI report: * 0a4cdba97fcfbb788402b890e6e958cb2949646b Travis: [FAILURE](https://travis-ci.com/flink-ci/flin

[GitHub] [flink] pnowojski commented on a change in pull request #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI

pnowojski commented on a change in pull request #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI URL: https://github.com/apache/flink/pull/10935#discussion_r371836089 ## File path: flink-runtime-web/web-dashboard/src/app/interfaces/job-checkpoint.ts #

[GitHub] [flink] pnowojski edited a comment on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI

pnowojski edited a comment on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI URL: https://github.com/apache/flink/pull/10935#issuecomment-579272380 I've addressed the comments. This is a

[GitHub] [flink] pnowojski commented on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI

pnowojski commented on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI URL: https://github.com/apache/flink/pull/10935#issuecomment-579272380 Thanks for pointing this out @vthinkxie. I've added a single line entry in the `src/app/interfaces/job-checkpo

[GitHub] [flink] pnowojski commented on a change in pull request #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI

pnowojski commented on a change in pull request #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI URL: https://github.com/apache/flink/pull/10935#discussion_r371832317 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/

[GitHub] [flink] zentol commented on issue #10944: [FLINK-15739] Fix TypeSerializerUpgradeTestBase on Java 12

zentol commented on issue #10944: [FLINK-15739] Fix TypeSerializerUpgradeTestBase on Java 12 URL: https://github.com/apache/flink/pull/10944#issuecomment-579261556 @igalshilman According to Aljoscha they don't have to be on the test classpath at the same time; you need one version to be on

  1   2   >