[GitHub] [flink] wangyang0918 commented on issue #10971: [FLINK-15791][kubernetes] Use explicit I/O Executor for asynchronous operations in Fabric8FlinkKubeClient

wangyang0918 commented on issue #10971: [FLINK-15791][kubernetes] Use explicit I/O Executor for asynchronous operations in Fabric8FlinkKubeClient URL: https://github.com/apache/flink/pull/10971#issuecomment-581287651 Hi @tillrohrmann. Thanks for your comments. I have added an

[GitHub] [flink] flinkbot edited a comment on issue #10971: [FLINK-15791][kubernetes] Use explicit I/O Executor for asynchronous operations in Fabric8FlinkKubeClient

flinkbot edited a comment on issue #10971: [FLINK-15791][kubernetes] Use explicit I/O Executor for asynchronous operations in Fabric8FlinkKubeClient URL: https://github.com/apache/flink/pull/10971#issuecomment-580116900 ## CI report: * f769194571216372e83fdff8d9898fd693079498

[GitHub] [flink] wangyang0918 removed a comment on issue #10971: [FLINK-15791][kubernetes] Use explicit I/O Executor for asynchronous operations in Fabric8FlinkKubeClient

wangyang0918 removed a comment on issue #10971: [FLINK-15791][kubernetes] Use explicit I/O Executor for asynchronous operations in Fabric8FlinkKubeClient URL: https://github.com/apache/flink/pull/10971#issuecomment-580606278 @flinkbot run travis

[jira] [Assigned] (FLINK-15844) Removal of JobWithJars.buildUserCodeClassLoader method without Configuration breaks backwards compatibility

[ https://issues.apache.org/jira/browse/FLINK-15844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-15844: Assignee: Ismaël Mejía > Removal of JobWithJars.buildUserCodeClassLoader method

[jira] [Closed] (FLINK-15844) Removal of JobWithJars.buildUserCodeClassLoader method without Configuration breaks backwards compatibility

[ https://issues.apache.org/jira/browse/FLINK-15844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-15844. Fix Version/s: 1.9.3 Resolution: Fixed release-1.9:

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

[ https://issues.apache.org/jira/browse/FLINK-15795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028808#comment-17028808 ] Yang Wang commented on FLINK-15795: --- Just like what we have describe in the

[GitHub] [flink] flinkbot commented on issue #10996: [FLINK-15862][kafka] Remove deprecated KafkaPartitioner

flinkbot commented on issue #10996: [FLINK-15862][kafka] Remove deprecated KafkaPartitioner URL: https://github.com/apache/flink/pull/10996#issuecomment-581335917 ## CI report: * 9b80910202ebb87d7c0b27b397ea847f3f6aeca6 UNKNOWN Bot commands The @flinkbot bot

[GitHub] [flink] flinkbot edited a comment on issue #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt

flinkbot edited a comment on issue #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt URL: https://github.com/apache/flink/pull/10995#issuecomment-581294934 ## CI report: * 65debfebc1bad89160a6375b9c78ea8eb063 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10971: [FLINK-15791][kubernetes] Use explicit I/O Executor for asynchronous operations in Fabric8FlinkKubeClient

flinkbot edited a comment on issue #10971: [FLINK-15791][kubernetes] Use explicit I/O Executor for asynchronous operations in Fabric8FlinkKubeClient URL: https://github.com/apache/flink/pull/10971#issuecomment-580116900 ## CI report: * f769194571216372e83fdff8d9898fd693079498

[jira] [Updated] (FLINK-15068) Disable RocksDB's local LOG by default

[ https://issues.apache.org/jira/browse/FLINK-15068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15068: - Release Note: Logging in RocksDB (e.g., logging related to flush, compaction, memtable creation, etc.)

[jira] [Updated] (FLINK-13034) Improve the performance when checking whether mapstate is empty for RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-13034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-13034: - Release Note: We have added a new method MapState#isEmpty() which enables users to check whether a map

[GitHub] [flink] flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler

flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler URL: https://github.com/apache/flink/pull/10858#issuecomment-574561465 ## CI report: * cf716ecc2f23aa89683be8096f16725b1f1f8d26 Travis:

[jira] [Issue Comment Deleted] (FLINK-15752) Backpressure stats sometimes broken in WebUI

[ https://issues.apache.org/jira/browse/FLINK-15752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-15752: --- Comment: was deleted (was: [~NicoK] could you show the result from the rest API?) > Backpressure stats

[GitHub] [flink] flinkbot commented on issue #10996: [FLINK-15862][kafka] Remove deprecated KafkaPartitioner

flinkbot commented on issue #10996: [FLINK-15862][kafka] Remove deprecated KafkaPartitioner URL: https://github.com/apache/flink/pull/10996#issuecomment-581322036 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] aljoscha merged pull request #10991: [FLINK-15844][client] Expose JobWithJars.buildUserCodeClassLoader without Configuration to fix backwards compatibility

aljoscha merged pull request #10991: [FLINK-15844][client] Expose JobWithJars.buildUserCodeClassLoader without Configuration to fix backwards compatibility URL: https://github.com/apache/flink/pull/10991 This is an

[GitHub] [flink] flinkbot edited a comment on issue #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt

flinkbot edited a comment on issue #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt URL: https://github.com/apache/flink/pull/10995#issuecomment-581294934 ## CI report: * 65debfebc1bad89160a6375b9c78ea8eb063 Travis:

[GitHub] [flink] sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#discussion_r373999581 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job

flinkbot edited a comment on issue #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job URL: https://github.com/apache/flink/pull/10904#issuecomment-576004529 ## CI report: * dbfc485ecea3aec8bc0054ca8bacb310b417c5dc Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt

flinkbot edited a comment on issue #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt URL: https://github.com/apache/flink/pull/10995#issuecomment-581294934 ## CI report: * 65debfebc1bad89160a6375b9c78ea8eb063 Travis:

[GitHub] [flink] GJL commented on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler

GJL commented on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler URL: https://github.com/apache/flink/pull/10858#issuecomment-581379587 I will take a look. This

[GitHub] [flink] GJL commented on issue #10997: [FLINK-15743][docs] Extend Flink 1.10 release notes

GJL commented on issue #10997: [FLINK-15743][docs] Extend Flink 1.10 release notes URL: https://github.com/apache/flink/pull/10997#issuecomment-581389721 cc: @Myasuka @zentol @alpinegizmo This is an automated message from

[GitHub] [flink] GJL opened a new pull request #10997: [FLINK-15743][docs] Extend Flink 1.10 release notes

GJL opened a new pull request #10997: [FLINK-15743][docs] Extend Flink 1.10 release notes URL: https://github.com/apache/flink/pull/10997 *[FLINK-15743][docs] Extend Flink 1.10 release notes* This is an automated message

[jira] [Created] (FLINK-15861) Change TableEnvironmentImpl to StreamTableaEnvironmentImpl in python blink batch mode

Huang Xingbo created FLINK-15861: Summary: Change TableEnvironmentImpl to StreamTableaEnvironmentImpl in python blink batch mode Key: FLINK-15861 URL: https://issues.apache.org/jira/browse/FLINK-15861

[jira] [Commented] (FLINK-15844) Removal of JobWithJars.buildUserCodeClassLoader method without Configuration breaks backwards compatibility

[ https://issues.apache.org/jira/browse/FLINK-15844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028794#comment-17028794 ] Aljoscha Krettek commented on FLINK-15844: -- Is this a problem because Beam uses that class or

[GitHub] [flink] sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#discussion_r373989896 ## File path:

[jira] [Commented] (FLINK-15844) Removal of JobWithJars.buildUserCodeClassLoader method without Configuration breaks backwards compatibility

[ https://issues.apache.org/jira/browse/FLINK-15844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028800#comment-17028800 ] Ismaël Mejía commented on FLINK-15844: -- It is a problem because Beam uses this. I was not aware

[GitHub] [flink] wangyang0918 edited a comment on issue #10971: [FLINK-15791][kubernetes] Use explicit I/O Executor for asynchronous operations in Fabric8FlinkKubeClient

wangyang0918 edited a comment on issue #10971: [FLINK-15791][kubernetes] Use explicit I/O Executor for asynchronous operations in Fabric8FlinkKubeClient URL: https://github.com/apache/flink/pull/10971#issuecomment-581287651 Hi @tillrohrmann. Thanks for your comments. I have added an

[GitHub] [flink] aljoscha commented on issue #10891: [FLINK-15561][Security][hotfix] Add Delegation Token checker in YarnClusterDescriptor

aljoscha commented on issue #10891: [FLINK-15561][Security][hotfix] Add Delegation Token checker in YarnClusterDescriptor URL: https://github.com/apache/flink/pull/10891#issuecomment-581346296 This should fix the original issue outlined in

[jira] [Assigned] (FLINK-15836) Throw fatal exception when the watcher in Fabric8FlinkKubeClient is closed

[ https://issues.apache.org/jira/browse/FLINK-15836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-15836: - Assignee: Yang Wang > Throw fatal exception when the watcher in Fabric8FlinkKubeClient

[jira] [Commented] (FLINK-15836) Throw fatal exception when the watcher in Fabric8FlinkKubeClient is closed

[ https://issues.apache.org/jira/browse/FLINK-15836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028850#comment-17028850 ] Till Rohrmann commented on FLINK-15836: --- This sounds like a good improvement/hardening. Do you

[GitHub] [flink] flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler

flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler URL: https://github.com/apache/flink/pull/10858#issuecomment-574561465 ## CI report: * cf716ecc2f23aa89683be8096f16725b1f1f8d26 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10996: [FLINK-15862][kafka] Remove deprecated KafkaPartitioner

flinkbot edited a comment on issue #10996: [FLINK-15862][kafka] Remove deprecated KafkaPartitioner URL: https://github.com/apache/flink/pull/10996#issuecomment-581335917 ## CI report: * 9b80910202ebb87d7c0b27b397ea847f3f6aeca6 Travis:

[GitHub] [flink] aljoscha commented on issue #10996: [FLINK-15862][kafka] Remove deprecated KafkaPartitioner

aljoscha commented on issue #10996: [FLINK-15862][kafka] Remove deprecated KafkaPartitioner URL: https://github.com/apache/flink/pull/10996#issuecomment-581350492 Yes, please, I like code removal. Let's see if Travis is good but then I think this is good to merge.

[jira] [Updated] (FLINK-15837) flink-kubernetes module does not have correct NOTICE file

[ https://issues.apache.org/jira/browse/FLINK-15837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-15837: -- Fix Version/s: (was: 1.10.0) 1.10.1 1.11.0 >

[jira] [Resolved] (FLINK-15837) flink-kubernetes module does not have correct NOTICE file

[ https://issues.apache.org/jira/browse/FLINK-15837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-15837. --- Resolution: Fixed Fixed via master: 36a0e4ca86fa08b6bc495edcc2addf836d7a9090 1.10.0:

[GitHub] [flink] flinkbot edited a comment on issue #10996: [FLINK-15862][kafka] Remove deprecated KafkaPartitioner

flinkbot edited a comment on issue #10996: [FLINK-15862][kafka] Remove deprecated KafkaPartitioner URL: https://github.com/apache/flink/pull/10996#issuecomment-581335917 ## CI report: * 9b80910202ebb87d7c0b27b397ea847f3f6aeca6 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt

flinkbot edited a comment on issue #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt URL: https://github.com/apache/flink/pull/10995#issuecomment-581294934 ## CI report: * 65debfebc1bad89160a6375b9c78ea8eb063 Travis:

[jira] [Updated] (FLINK-15837) flink-kubernetes module does not have correct NOTICE file

[ https://issues.apache.org/jira/browse/FLINK-15837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-15837: -- Fix Version/s: (was: 1.10.1) 1.10.0 > flink-kubernetes module does not have correct

[jira] [Commented] (FLINK-15864) Upgrade jackson-databind dependency to 2.10.1 for security reasons

[ https://issues.apache.org/jira/browse/FLINK-15864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028881#comment-17028881 ] Till Rohrmann commented on FLINK-15864: --- [~fly_in_gis] is there are particular reason why the

[jira] [Created] (FLINK-15864) Upgrade jackson-databind dependency to 2.10.1 for security reasons

Till Rohrmann created FLINK-15864: - Summary: Upgrade jackson-databind dependency to 2.10.1 for security reasons Key: FLINK-15864 URL: https://issues.apache.org/jira/browse/FLINK-15864 Project: Flink

[jira] [Reopened] (FLINK-15743) Add Flink 1.10 release notes to documentation

[ https://issues.apache.org/jira/browse/FLINK-15743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reopened FLINK-15743: -- > Add Flink 1.10 release notes to documentation > - > >

[GitHub] [flink] flinkbot edited a comment on issue #10915: [FLINK-15706][table-planner-blink] LastValueAggFunctionWithOrderTest compilation error due to incompatible types

flinkbot edited a comment on issue #10915: [FLINK-15706][table-planner-blink] LastValueAggFunctionWithOrderTest compilation error due to incompatible types URL: https://github.com/apache/flink/pull/10915#issuecomment-576657964 ## CI report: *

[jira] [Updated] (FLINK-15851) JDK 8 and 11 CI build pipeline for Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-15851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-15851: Description: If we choose to use Travis, setting this up should be fairly

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

[ https://issues.apache.org/jira/browse/FLINK-15790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028774#comment-17028774 ] Yang Wang commented on FLINK-15790: --- [~trohrmann] If you agree with making all the interfaces of

[jira] [Updated] (FLINK-14460) Active Kubernetes integration phase 2 - Advanced Features

[ https://issues.apache.org/jira/browse/FLINK-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-14460: -- Fix Version/s: 1.11.0 > Active Kubernetes integration phase 2 - Advanced Features >

[GitHub] [flink] sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#discussion_r373987871 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10910: [FLINK-15702][SQL]Make sqlClient classloader aligned with other components

flinkbot edited a comment on issue #10910: [FLINK-15702][SQL]Make sqlClient classloader aligned with other components URL: https://github.com/apache/flink/pull/10910#issuecomment-576505209 ## CI report: * 8333b02c2d8e703f9b3ef25dae0e1f6d2c43e2aa Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job

flinkbot edited a comment on issue #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job URL: https://github.com/apache/flink/pull/10904#issuecomment-576004529 ## CI report: * dbfc485ecea3aec8bc0054ca8bacb310b417c5dc Travis:

[GitHub] [flink] zentol commented on a change in pull request #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt

zentol commented on a change in pull request #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt URL: https://github.com/apache/flink/pull/10995#discussion_r374016678 ## File path: flink-ml-parent/flink-ml-lib/pom.xml ## @@ -57,4 +57,30 @@ under the

[GitHub] [flink] KarmaGYZ edited a comment on issue #10746: [FLINK-15417] Remove the docker volume or mount when starting Mesos e…

KarmaGYZ edited a comment on issue #10746: [FLINK-15417] Remove the docker volume or mount when starting Mesos e… URL: https://github.com/apache/flink/pull/10746#issuecomment-581315998 @GJL Thanks for your comments. That's really helpful. I've updated the PR and test it on Ubuntu 18

[jira] [Closed] (FLINK-15830) Migrate docker-flink/docker-flink to apache/flink-docker

[ https://issues.apache.org/jira/browse/FLINK-15830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-15830. --- Resolution: Fixed apache/flink and docker-flink/docker-flink now have the same histories up to 

[jira] [Updated] (FLINK-15836) Throw fatal exception when the watcher in Fabric8FlinkKubeClient is closed

[ https://issues.apache.org/jira/browse/FLINK-15836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15836: --- Component/s: Deployment / Kubernetes > Throw fatal exception when the watcher in

[GitHub] [flink] tillrohrmann commented on issue #10986: [FLINK-15837] Add proper NOTICE file to flink-kubernetes

tillrohrmann commented on issue #10986: [FLINK-15837] Add proper NOTICE file to flink-kubernetes URL: https://github.com/apache/flink/pull/10986#issuecomment-581354295 Thanks for the review @zentol. Merging this PR now. Good question. I don't know why the `jackson-databind`

[GitHub] [flink] tillrohrmann closed pull request #10986: [FLINK-15837] Add proper NOTICE file to flink-kubernetes

tillrohrmann closed pull request #10986: [FLINK-15837] Add proper NOTICE file to flink-kubernetes URL: https://github.com/apache/flink/pull/10986 This is an automated message from the Apache Git Service. To respond to the

[jira] [Assigned] (FLINK-15817) Kubernetes Resource leak while deployment exception happens

[ https://issues.apache.org/jira/browse/FLINK-15817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-15817: - Assignee: Canbin Zheng > Kubernetes Resource leak while deployment exception happens >

[jira] [Updated] (FLINK-15863) Fix docs stating that savepoints are relocatable

[ https://issues.apache.org/jira/browse/FLINK-15863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-15863: - Labels: usability (was: ) > Fix docs stating that savepoints are relocatable >

[GitHub] [flink] StephanEwen commented on a change in pull request #10987: [FLINK-14495][docs] (EXTENDED) Add documentation for memory control of RocksDB state backend

StephanEwen commented on a change in pull request #10987: [FLINK-14495][docs] (EXTENDED) Add documentation for memory control of RocksDB state backend URL: https://github.com/apache/flink/pull/10987#discussion_r374066513 ## File path: docs/ops/state/state_backends.md ##

[GitHub] [flink] flinkbot commented on issue #10997: [FLINK-15743][docs] Extend Flink 1.10 release notes

flinkbot commented on issue #10997: [FLINK-15743][docs] Extend Flink 1.10 release notes URL: https://github.com/apache/flink/pull/10997#issuecomment-581390455 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] 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_r373963373 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10910: [FLINK-15702][SQL]Make sqlClient classloader aligned with other components

flinkbot edited a comment on issue #10910: [FLINK-15702][SQL]Make sqlClient classloader aligned with other components URL: https://github.com/apache/flink/pull/10910#issuecomment-576505209 ## CI report: * 8333b02c2d8e703f9b3ef25dae0e1f6d2c43e2aa Travis:

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

[ https://issues.apache.org/jira/browse/FLINK-15790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-15790: - Assignee: Yang Wang > Make FlinkKubeClient and its implementations asynchronous >

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

[ https://issues.apache.org/jira/browse/FLINK-15790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028857#comment-17028857 ] Till Rohrmann commented on FLINK-15790: --- Sure go ahead. I've assigned you. > Make FlinkKubeClient

[GitHub] [flink] flinkbot edited a comment on issue #10971: [FLINK-15791][kubernetes] Use explicit I/O Executor for asynchronous operations in Fabric8FlinkKubeClient

flinkbot edited a comment on issue #10971: [FLINK-15791][kubernetes] Use explicit I/O Executor for asynchronous operations in Fabric8FlinkKubeClient URL: https://github.com/apache/flink/pull/10971#issuecomment-580116900 ## CI report: * f769194571216372e83fdff8d9898fd693079498

[GitHub] [flink] aljoscha commented on issue #10891: [FLINK-15561][Security][hotfix] Add Delegation Token checker in YarnClusterDescriptor

aljoscha commented on issue #10891: [FLINK-15561][Security][hotfix] Add Delegation Token checker in YarnClusterDescriptor URL: https://github.com/apache/flink/pull/10891#issuecomment-581349701 I think the fix is good, we just have to agree on where the code should be. We could think

[jira] [Created] (FLINK-15863) Fix docs stating that savepoints are relocatable

Nico Kruber created FLINK-15863: --- Summary: Fix docs stating that savepoints are relocatable Key: FLINK-15863 URL: https://issues.apache.org/jira/browse/FLINK-15863 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-15841) TimeWindow.intersects return true for consecutive windows

[ https://issues.apache.org/jira/browse/FLINK-15841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-15841: Assignee: Jörn Kottmann > TimeWindow.intersects return true for consecutive

[jira] [Updated] (FLINK-15858) Unable to use HiveCatalog and kafka together

[ https://issues.apache.org/jira/browse/FLINK-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15858: --- Component/s: Table SQL / Ecosystem > Unable to use HiveCatalog and kafka together >

[jira] [Updated] (FLINK-15838) Dangling CountDownLatch.await(timeout)

[ https://issues.apache.org/jira/browse/FLINK-15838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15838: --- Component/s: Tests > Dangling CountDownLatch.await(timeout) >

[jira] [Commented] (FLINK-15841) TimeWindow.intersects return true for consecutive windows

[ https://issues.apache.org/jira/browse/FLINK-15841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028867#comment-17028867 ] Aljoscha Krettek commented on FLINK-15841: -- Did you try and do the change and check if all the

[jira] [Updated] (FLINK-15679) Improve Flink's ID system

[ https://issues.apache.org/jira/browse/FLINK-15679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15679: --- Component/s: Runtime / Coordination > Improve Flink's ID system > -

[GitHub] [flink] wuchong merged pull request #10989: [FLINK-15840][table-planner-blink] ClassCastException is thrown when use tEnv.from for temp/catalog table

wuchong merged pull request #10989: [FLINK-15840][table-planner-blink] ClassCastException is thrown when use tEnv.from for temp/catalog table URL: https://github.com/apache/flink/pull/10989 This is an automated message from

[GitHub] [flink] sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#discussion_r374044595 ## File path:

[jira] [Updated] (FLINK-14926) Make sure no resource leak of RocksObject

[ https://issues.apache.org/jira/browse/FLINK-14926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-14926: - Release Note: Interfaces OptionsFactory and ConfigurableOptionsFactory have been deprecated in favor of

[jira] [Created] (FLINK-15859) Unify identifiers in the interface methods of CatalogManager

Dawid Wysakowicz created FLINK-15859: Summary: Unify identifiers in the interface methods of CatalogManager Key: FLINK-15859 URL: https://issues.apache.org/jira/browse/FLINK-15859 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_r373962137 ## File path:

[GitHub] [flink-statefun] tzulitai opened a new pull request #10: [FLINK-15851] [build] Add .travis.yml for Travis CI setup

tzulitai opened a new pull request #10: [FLINK-15851] [build] Add .travis.yml for Travis CI setup URL: https://github.com/apache/flink-statefun/pull/10 Alternative approach to #9 where Stateful Functions continue to use Travis for the time being. This could make more sense

[GitHub] [flink] flinkbot edited a comment on issue #10971: [FLINK-15791][kubernetes] Use explicit I/O Executor for asynchronous operations in Fabric8FlinkKubeClient

flinkbot edited a comment on issue #10971: [FLINK-15791][kubernetes] Use explicit I/O Executor for asynchronous operations in Fabric8FlinkKubeClient URL: https://github.com/apache/flink/pull/10971#issuecomment-580116900 ## CI report: * f769194571216372e83fdff8d9898fd693079498

[jira] [Commented] (FLINK-15752) Backpressure stats sometimes broken in WebUI

[ https://issues.apache.org/jira/browse/FLINK-15752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028771#comment-17028771 ] lining commented on FLINK-15752: [~NicoK], could you show the result from rest API? > Backpressure

[GitHub] [flink] godfreyhe commented on issue #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job

godfreyhe commented on issue #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job URL: https://github.com/apache/flink/pull/10904#issuecomment-581303612 cc @docete @twalthr This is an automated message

[jira] [Commented] (FLINK-15861) Change TableEnvironmentImpl to StreamTableaEnvironmentImpl in python blink batch mode

[ https://issues.apache.org/jira/browse/FLINK-15861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028861#comment-17028861 ] Aljoscha Krettek commented on FLINK-15861: -- [~twalthr] is currently reworking user function

[GitHub] [flink] flinkbot edited a comment on issue #10971: [FLINK-15791][kubernetes] Use explicit I/O Executor for asynchronous operations in Fabric8FlinkKubeClient

flinkbot edited a comment on issue #10971: [FLINK-15791][kubernetes] Use explicit I/O Executor for asynchronous operations in Fabric8FlinkKubeClient URL: https://github.com/apache/flink/pull/10971#issuecomment-580116900 ## CI report: * f769194571216372e83fdff8d9898fd693079498

[GitHub] [flink] flinkbot edited a comment on issue #10996: [FLINK-15862][kafka] Remove deprecated KafkaPartitioner

flinkbot edited a comment on issue #10996: [FLINK-15862][kafka] Remove deprecated KafkaPartitioner URL: https://github.com/apache/flink/pull/10996#issuecomment-581335917 ## CI report: * 9b80910202ebb87d7c0b27b397ea847f3f6aeca6 Travis:

[jira] [Created] (FLINK-15860) Store temporary functions as CatalogFunctions in FunctionCatalog

Dawid Wysakowicz created FLINK-15860: Summary: Store temporary functions as CatalogFunctions in FunctionCatalog Key: FLINK-15860 URL: https://issues.apache.org/jira/browse/FLINK-15860 Project:

[jira] [Commented] (FLINK-15752) Backpressure stats sometimes broken in WebUI

[ https://issues.apache.org/jira/browse/FLINK-15752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028760#comment-17028760 ] lining commented on FLINK-15752: [~NicoK] could you show the result from the rest API? > Backpressure

[GitHub] [flink] flinkbot edited a comment on issue #10910: [FLINK-15702][SQL]Make sqlClient classloader aligned with other components

flinkbot edited a comment on issue #10910: [FLINK-15702][SQL]Make sqlClient classloader aligned with other components URL: https://github.com/apache/flink/pull/10910#issuecomment-576505209 ## CI report: * 8333b02c2d8e703f9b3ef25dae0e1f6d2c43e2aa Travis:

[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=17028782#comment-17028782 ] Kostas Kloudas commented on FLINK-15852: Yes this seems to be problematic and it may have also

[jira] [Created] (FLINK-15862) Remove deprecated class KafkaPartitioner and all its usages

Dawid Wysakowicz created FLINK-15862: Summary: Remove deprecated class KafkaPartitioner and all its usages Key: FLINK-15862 URL: https://issues.apache.org/jira/browse/FLINK-15862 Project: Flink

[jira] [Commented] (FLINK-15422) Expose Jvm Metaspace、Compressed Class Space、Eden Space、Survivor Space、Old Gen metric

[ https://issues.apache.org/jira/browse/FLINK-15422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028790#comment-17028790 ] lining commented on FLINK-15422: We could get these information from

[GitHub] [flink] flinkbot edited a comment on issue #8952: [FLINK-10868][flink-yarn] Add failure rater for resource manager

flinkbot edited a comment on issue #8952: [FLINK-10868][flink-yarn] Add failure rater for resource manager URL: https://github.com/apache/flink/pull/8952#issuecomment-513724324 ## CI report: * d5fa0c8c2c46bafaf2e62a02743378a1e5399b35 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt

flinkbot edited a comment on issue #10995: [FLINK-15847][ml] Include flink-ml-api and flink-ml-lib in opt URL: https://github.com/apache/flink/pull/10995#issuecomment-581294934 ## CI report: * 65debfebc1bad89160a6375b9c78ea8eb063 Travis:

[GitHub] [flink] KarmaGYZ commented on issue #10746: [FLINK-15417] Remove the docker volume or mount when starting Mesos e…

KarmaGYZ commented on issue #10746: [FLINK-15417] Remove the docker volume or mount when starting Mesos e… URL: https://github.com/apache/flink/pull/10746#issuecomment-581315998 Thanks for your comments. That's really helpful. I've updated the PR and test it on Ubuntu 18 and MacOS. It

[GitHub] [flink] zhuzhurk commented on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler

zhuzhurk commented on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler URL: https://github.com/apache/flink/pull/10858#issuecomment-581325616 @tillrohrmann This PR just enables the batch test case for the new scheduler. I think

[GitHub] [flink] flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler

flinkbot edited a comment on issue #10858: [FLINK-15582][tests] Enable batch scheduling tests for both LegacyScheduler and DefaultScheduler URL: https://github.com/apache/flink/pull/10858#issuecomment-574561465 ## CI report: * cf716ecc2f23aa89683be8096f16725b1f1f8d26 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10746: [FLINK-15417] Remove the docker volume or mount when starting Mesos e…

flinkbot edited a comment on issue #10746: [FLINK-15417] Remove the docker volume or mount when starting Mesos e… URL: https://github.com/apache/flink/pull/10746#issuecomment-570173870 ## CI report: * 964b4874eaa647c908289dd841b660bc966fdb61 Travis:

[jira] [Comment Edited] (FLINK-15847) Include flink-ml-api and flink-ml-lib in opt

[ https://issues.apache.org/jira/browse/FLINK-15847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028843#comment-17028843 ] Till Rohrmann edited comment on FLINK-15847 at 2/3/20 10:25 AM: We could

[jira] [Commented] (FLINK-15847) Include flink-ml-api and flink-ml-lib in opt

[ https://issues.apache.org/jira/browse/FLINK-15847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028843#comment-17028843 ] Till Rohrmann commented on FLINK-15847: --- We could also list he {{flink-ml-*}} jars as optional

[GitHub] [flink-docker] uce merged pull request #1: Migrate from docker-flink/docker-flink

uce merged pull request #1: Migrate from docker-flink/docker-flink URL: https://github.com/apache/flink-docker/pull/1 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink-docker] uce merged pull request #1: Migrate from docker-flink/docker-flink

uce merged pull request #1: Migrate from docker-flink/docker-flink URL: https://github.com/apache/flink-docker/pull/1 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] aljoscha commented on a change in pull request #10891: [FLINK-15561][Security][hotfix] Add Delegation Token checker in YarnClusterDescriptor

aljoscha commented on a change in pull request #10891: [FLINK-15561][Security][hotfix] Add Delegation Token checker in YarnClusterDescriptor URL: https://github.com/apache/flink/pull/10891#discussion_r374031205 ## File path:

[GitHub] [flink] aljoscha commented on a change in pull request #10891: [FLINK-15561][Security][hotfix] Add Delegation Token checker in YarnClusterDescriptor

aljoscha commented on a change in pull request #10891: [FLINK-15561][Security][hotfix] Add Delegation Token checker in YarnClusterDescriptor URL: https://github.com/apache/flink/pull/10891#discussion_r374031205 ## File path:

  1   2   3   4   5   6   >