[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

[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

[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

[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=17025657#comment-17025657 ] Chesnay Schepler commented on FLINK-13369: -- [~arobe...@fuze.com] Can you provide us with a

[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

[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

[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

[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=17025619#comment-17025619 ] Canbin Zheng commented on FLINK-15662: -- [~trohrmann] It is a subtask of FLINK-14460 now. > Make

[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=17025615#comment-17025615 ] Canbin Zheng commented on FLINK-15667: -- [~yangwang166] WDYT > Hadoop Configurations Mount Support

[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=17025577#comment-17025577 ] Canbin Zheng commented on FLINK-15799: -- Seems a duplica of

[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

[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

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

[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

[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

[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=17025554#comment-17025554 ] Hequn Cheng commented on FLINK-14251: - Also fixed in 1.9.2 via

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

[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

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

[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

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

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

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

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

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

[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=17025437#comment-17025437 ] Stephan Ewen edited comment on FLINK-15703 at 1/28/20 8:55 PM: --- Is this

[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=17025437#comment-17025437 ] Stephan Ewen commented on FLINK-15703: -- Is this meant for the new Source API Kafka Source? I am

[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=17025435#comment-17025435 ] Andrew Roberts edited comment on FLINK-13369 at 1/28/20 8:53 PM: - I'm

[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=17025435#comment-17025435 ] Andrew Roberts commented on FLINK-13369: I'm still seeing this behavior in Flink 1.9.1 >

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

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

[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

[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

[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

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

[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=17025334#comment-17025334 ] Gary Yao commented on FLINK-15504: -- There are some examples here

[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=17025334#comment-17025334 ] Gary Yao edited comment on FLINK-15504 at 1/28/20 5:51 PM: --- There are some

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

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

[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=17025298#comment-17025298 ] Till Rohrmann commented on FLINK-15787: --- I think this sounds like a very good improvement Flink

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

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

[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=17025274#comment-17025274 ] Till Rohrmann commented on FLINK-15788: --- fyi [~yangwang166] > Various Kubernetes integration

[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

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

[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

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

[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

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

[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

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

[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

[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

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

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

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

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

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

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

[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

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

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

[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

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

[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

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

[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

[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

[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

[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

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

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

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

[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=17025175#comment-17025175 ] Timo Walther commented on FLINK-15775: -- This issue came up a couple of times in the past. 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 -

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

[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

[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

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

[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

  1   2   >