[GitHub] [flink] faaronzheng removed a comment on issue #10299: [FLINK-14560] [runtime] The value of taskmanager.memory.size in flink…

faaronzheng removed a comment on issue #10299: [FLINK-14560] [runtime] The value of taskmanager.memory.size in flink… URL: https://github.com/apache/flink/pull/10299#issuecomment-559917269 > ## CI report: > *

[GitHub] [flink] flinkbot edited a comment on issue #10299: [FLINK-14560] [runtime] The value of taskmanager.memory.size in flink…

flinkbot edited a comment on issue #10299: [FLINK-14560] [runtime] The value of taskmanager.memory.size in flink… URL: https://github.com/apache/flink/pull/10299#issuecomment-557882742 ## CI report: * f7802aefa43e285597bfba62592e05d0cb2f074f : CANCELED

[GitHub] [flink] faaronzheng removed a comment on issue #10299: [FLINK-14560] [runtime] The value of taskmanager.memory.size in flink…

faaronzheng removed a comment on issue #10299: [FLINK-14560] [runtime] The value of taskmanager.memory.size in flink… URL: https://github.com/apache/flink/pull/10299#issuecomment-559909732 > * @flinkbot run travis @flinkbot run travis

[GitHub] [flink] faaronzheng commented on issue #10299: [FLINK-14560] [runtime] The value of taskmanager.memory.size in flink…

faaronzheng commented on issue #10299: [FLINK-14560] [runtime] The value of taskmanager.memory.size in flink… URL: https://github.com/apache/flink/pull/10299#issuecomment-559917269 > ## CI report: > *

[GitHub] [flink] flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#issuecomment-545881191 ## CI report: * 802ebf37e3d932169f9826b40df483bb5e9ac064 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

flinkbot edited a comment on issue #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#issuecomment-544813931 ## CI report: * 6f90b457e56a0a8cb45d63c1b05b47d2e38030a1 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#issuecomment-553881527 ## CI report: * e3ac83fe02a7583159184772ff4b4341fa65f827 : FAILURE

[jira] [Commented] (FLINK-14991) Export `FLINK_HOME` environment variable to all the entrypoint

[ https://issues.apache.org/jira/browse/FLINK-14991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16985271#comment-16985271 ] Jeff Zhang commented on FLINK-14991: +1, but it would be better to reserve `FLINK_CONF_DIR`. That

[GitHub] [flink] flinkbot edited a comment on issue #10369: [FLINK-14893][flink-core]Try child classLoader when parent classLoader could not load in parentFirstPatterns

flinkbot edited a comment on issue #10369: [FLINK-14893][flink-core]Try child classLoader when parent classLoader could not load in parentFirstPatterns URL: https://github.com/apache/flink/pull/10369#issuecomment-559908998 ## CI report: * 39957f4f139cc7b2d133e592e6a95ed9add9492b

[GitHub] [flink] flinkbot edited a comment on issue #10299: [FLINK-14560] [runtime] The value of taskmanager.memory.size in flink…

flinkbot edited a comment on issue #10299: [FLINK-14560] [runtime] The value of taskmanager.memory.size in flink… URL: https://github.com/apache/flink/pull/10299#issuecomment-557882742 ## CI report: * f7802aefa43e285597bfba62592e05d0cb2f074f : CANCELED

[jira] [Comment Edited] (FLINK-14984) Remove old WebUI

[ https://issues.apache.org/jira/browse/FLINK-14984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16985263#comment-16985263 ] lamber-ken edited comment on FLINK-14984 at 11/30/19 5:18 AM: -- hi,

[jira] [Commented] (FLINK-14984) Remove old WebUI

[ https://issues.apache.org/jira/browse/FLINK-14984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16985263#comment-16985263 ] lamber-ken commented on FLINK-14984: hi, [~chesnay] I think I can do it. Could anyon assign it to

[GitHub] [flink] flinkbot edited a comment on issue #10161: [FLINK-13986][runtime] Clean up legacy code for FLIP-49.

flinkbot edited a comment on issue #10161: [FLINK-13986][runtime] Clean up legacy code for FLIP-49. URL: https://github.com/apache/flink/pull/10161#issuecomment-552882313 ## CI report: * 2c0501f41bea1da031777069dd46eb17c5ae8038 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-552307115 ## CI report: * 25f9e4b87846e5a736aa329c834f82962e1f50c4 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#issuecomment-545881191 ## CI report: * 802ebf37e3d932169f9826b40df483bb5e9ac064 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

flinkbot edited a comment on issue #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#issuecomment-544813931 ## CI report: * 6f90b457e56a0a8cb45d63c1b05b47d2e38030a1 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10299: [FLINK-14560] [runtime] The value of taskmanager.memory.size in flink…

flinkbot edited a comment on issue #10299: [FLINK-14560] [runtime] The value of taskmanager.memory.size in flink… URL: https://github.com/apache/flink/pull/10299#issuecomment-557882742 ## CI report: * f7802aefa43e285597bfba62592e05d0cb2f074f : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#issuecomment-553881527 ## CI report: * e3ac83fe02a7583159184772ff4b4341fa65f827 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#issuecomment-545881191 ## CI report: * 802ebf37e3d932169f9826b40df483bb5e9ac064 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

flinkbot edited a comment on issue #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#issuecomment-544813931 ## CI report: * 6f90b457e56a0a8cb45d63c1b05b47d2e38030a1 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10369: [FLINK-14893][flink-core]Try child classLoader when parent classLoader could not load in parentFirstPatterns

flinkbot edited a comment on issue #10369: [FLINK-14893][flink-core]Try child classLoader when parent classLoader could not load in parentFirstPatterns URL: https://github.com/apache/flink/pull/10369#issuecomment-559908998 ## CI report: * 39957f4f139cc7b2d133e592e6a95ed9add9492b

[GitHub] [flink] flinkbot edited a comment on issue #10299: [FLINK-14560] [runtime] The value of taskmanager.memory.size in flink…

flinkbot edited a comment on issue #10299: [FLINK-14560] [runtime] The value of taskmanager.memory.size in flink… URL: https://github.com/apache/flink/pull/10299#issuecomment-557882742 ## CI report: * f7802aefa43e285597bfba62592e05d0cb2f074f : PENDING

[GitHub] [flink] faaronzheng commented on issue #10299: [FLINK-14560] [runtime] The value of taskmanager.memory.size in flink…

faaronzheng commented on issue #10299: [FLINK-14560] [runtime] The value of taskmanager.memory.size in flink… URL: https://github.com/apache/flink/pull/10299#issuecomment-559909732 > * @flinkbot run travis @flinkbot run travis

[GitHub] [flink] faaronzheng removed a comment on issue #10299: [FLINK-14560] [runtime] The value of taskmanager.memory.size in flink…

faaronzheng removed a comment on issue #10299: [FLINK-14560] [runtime] The value of taskmanager.memory.size in flink… URL: https://github.com/apache/flink/pull/10299#issuecomment-559813698 > * @flinkbot run travis @flinkbot run travis

[GitHub] [flink] flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#issuecomment-553881527 ## CI report: * e3ac83fe02a7583159184772ff4b4341fa65f827 : FAILURE

[GitHub] [flink] flinkbot commented on issue #10369: [FLINK-14893][flink-core]Try child classLoader when parent classLoader could not load in parentFirstPatterns

flinkbot commented on issue #10369: [FLINK-14893][flink-core]Try child classLoader when parent classLoader could not load in parentFirstPatterns URL: https://github.com/apache/flink/pull/10369#issuecomment-559908998 ## CI report: * 39957f4f139cc7b2d133e592e6a95ed9add9492b :

[GitHub] [flink] wangyang0918 commented on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

wangyang0918 commented on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#issuecomment-559908500 @TisonKun @walterddr Thanks a lot for your review. I have added a fixup to address all your

[GitHub] [flink] wangyang0918 commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

wangyang0918 commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#discussion_r352263878 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

wangyang0918 commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#discussion_r352263872 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

wangyang0918 commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#discussion_r352263878 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

wangyang0918 commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#discussion_r352263870 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

wangyang0918 commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#discussion_r352263865 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java

[jira] [Assigned] (FLINK-14893) Using Child ClassLoader to load class when Parent ClassLoader couldn't load in ParentFirstPatterns

[ https://issues.apache.org/jira/browse/FLINK-14893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-14893: - Assignee: hailong wang > Using Child ClassLoader to load class when Parent ClassLoader

[GitHub] [flink] TisonKun commented on issue #10369: [FLINK-14893][flink-core]Try child classLoader when parent classLoader could not load in parentFirstPatterns

TisonKun commented on issue #10369: [FLINK-14893][flink-core]Try child classLoader when parent classLoader could not load in parentFirstPatterns URL: https://github.com/apache/flink/pull/10369#issuecomment-559907351 @wangxlong thanks for your contribution. Changes look good to me. It would

[GitHub] [flink] flinkbot commented on issue #10369: [FLINK-14893][flink-core]Try child classLoader when parent classLoader could not load in parentFirstPatterns

flinkbot commented on issue #10369: [FLINK-14893][flink-core]Try child classLoader when parent classLoader could not load in parentFirstPatterns URL: https://github.com/apache/flink/pull/10369#issuecomment-559907305 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Updated] (FLINK-14893) Using Child ClassLoader to load class when Parent ClassLoader couldn't load in ParentFirstPatterns

[ https://issues.apache.org/jira/browse/FLINK-14893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14893: --- Labels: pull-request-available (was: ) > Using Child ClassLoader to load class when

[GitHub] [flink] wangxlong opened a new pull request #10369: [FLINK-14893][flink-core]Try child classLoader when parent classLoader could not load in parentFirstPatterns

wangxlong opened a new pull request #10369: [FLINK-14893][flink-core]Try child classLoader when parent classLoader could not load in parentFirstPatterns URL: https://github.com/apache/flink/pull/10369 ## What is the purpose of the change Try child classLoader to load class when

[GitHub] [flink] caidezhi closed pull request #10365: [FLINK-14994] StreamTableEnvironment.connect throw exception when using "FileSystem" connector and "CSV" format

caidezhi closed pull request #10365: [FLINK-14994] StreamTableEnvironment.connect throw exception when using "FileSystem" connector and "CSV" format URL: https://github.com/apache/flink/pull/10365 This is an automated

[GitHub] [flink] flinkbot edited a comment on issue #10161: [FLINK-13986][runtime] Clean up legacy code for FLIP-49.

flinkbot edited a comment on issue #10161: [FLINK-13986][runtime] Clean up legacy code for FLIP-49. URL: https://github.com/apache/flink/pull/10161#issuecomment-552882313 ## CI report: * 2c0501f41bea1da031777069dd46eb17c5ae8038 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-552307115 ## CI report: * 25f9e4b87846e5a736aa329c834f82962e1f50c4 : FAILURE

[jira] [Commented] (FLINK-14947) Implement LocalExecutor as new Executor interface

[ https://issues.apache.org/jira/browse/FLINK-14947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16985232#comment-16985232 ] Zili Chen commented on FLINK-14947: --- Sorry for late response but I think you already got it in the

[jira] [Commented] (FLINK-14854) Add executeAsync() method to execution environments

[ https://issues.apache.org/jira/browse/FLINK-14854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16985231#comment-16985231 ] Zili Chen commented on FLINK-14854: --- I notice that for batch code path, it is easy we introduce a

[GitHub] [flink] TisonKun commented on issue #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors.

TisonKun commented on issue #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors. URL: https://github.com/apache/flink/pull/10346#issuecomment-559905389 OK make sense. Possibly we can remote `RemoteExecutor extends PlanExecutor` since it is no more in used. I think

[jira] [Commented] (FLINK-14893) Using Child ClassLoader to load class when Parent ClassLoader couldn't load in ParentFirstPatterns

[ https://issues.apache.org/jira/browse/FLINK-14893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16985230#comment-16985230 ] hailong wang commented on FLINK-14893: -- Hi, [~chesnay]. I am glad to work on this. Thanks you for

[GitHub] [flink] flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-552307115 ## CI report: * 25f9e4b87846e5a736aa329c834f82962e1f50c4 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10161: [FLINK-13986][runtime] Clean up legacy code for FLIP-49.

flinkbot edited a comment on issue #10161: [FLINK-13986][runtime] Clean up legacy code for FLIP-49. URL: https://github.com/apache/flink/pull/10161#issuecomment-552882313 ## CI report: * 2c0501f41bea1da031777069dd46eb17c5ae8038 : FAILURE

[GitHub] [flink] walterddr commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

walterddr commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#discussion_r352259924 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java

[GitHub] [flink] azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#discussion_r352216048 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#discussion_r352208420 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#discussion_r352207899 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#discussion_r352228685 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#discussion_r35143 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#discussion_r352199731 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#discussion_r352221149 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#discussion_r352208816 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#discussion_r352221737 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#discussion_r352229577 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#discussion_r352227509 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#discussion_r352200409 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#discussion_r352204987 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#discussion_r352228283 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

azagrebin commented on a change in pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#discussion_r352200275 ## File path:

[jira] [Closed] (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 ] Andrey Zagrebin closed FLINK-14976. --- Resolution: Fixed merged into master by 07b66b60dd8c72f5ecd98054fa322d768c774e74 merged

[GitHub] [flink] flinkbot edited a comment on issue #10368: [FLINK-14983][table-common] Add interfaces for input type inference

flinkbot edited a comment on issue #10368: [FLINK-14983][table-common] Add interfaces for input type inference URL: https://github.com/apache/flink/pull/10368#issuecomment-559849270 ## CI report: * a38c5d9c361f67d4922932f3634c2387288c1d6e : SUCCESS

[GitHub] [flink] twalthr commented on a change in pull request #10342: [FLINK-14967][table] Add a utility for creating data types via reflection

twalthr commented on a change in pull request #10342: [FLINK-14967][table] Add a utility for creating data types via reflection URL: https://github.com/apache/flink/pull/10342#discussion_r352221356 ## File path:

[GitHub] [flink] twalthr commented on a change in pull request #10342: [FLINK-14967][table] Add a utility for creating data types via reflection

twalthr commented on a change in pull request #10342: [FLINK-14967][table] Add a utility for creating data types via reflection URL: https://github.com/apache/flink/pull/10342#discussion_r352218595 ## File path:

[GitHub] [flink] azagrebin commented on issue #10339: [FLINK-14976][cassandra] Release semaphore on all Throwable's in send()

azagrebin commented on issue #10339: [FLINK-14976][cassandra] Release semaphore on all Throwable's in send() URL: https://github.com/apache/flink/pull/10339#issuecomment-559856230 merged into master by 07b66b60dd8c72f5ecd98054fa322d768c774e74

[GitHub] [flink] azagrebin merged pull request #10339: [FLINK-14976][cassandra] Release semaphore on all Throwable's in send()

azagrebin merged pull request #10339: [FLINK-14976][cassandra] Release semaphore on all Throwable's in send() URL: https://github.com/apache/flink/pull/10339 This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#issuecomment-545881191 ## CI report: * 802ebf37e3d932169f9826b40df483bb5e9ac064 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10368: [FLINK-14983][table-common] Add interfaces for input type inference

flinkbot edited a comment on issue #10368: [FLINK-14983][table-common] Add interfaces for input type inference URL: https://github.com/apache/flink/pull/10368#issuecomment-559849270 ## CI report: * a38c5d9c361f67d4922932f3634c2387288c1d6e : PENDING

[GitHub] [flink] TisonKun commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

TisonKun commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#discussion_r352214874 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

TisonKun commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#discussion_r352214528 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java

[GitHub] [flink] TisonKun commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

TisonKun commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#discussion_r352214594 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10114: [FLINK -14651][runtime] Enable DefaultScheduler

flinkbot edited a comment on issue #10114: [FLINK -14651][runtime] Enable DefaultScheduler URL: https://github.com/apache/flink/pull/10114#issuecomment-551014940 ## CI report: * c436371614d7db5dfc8c97e01a4594c3139715db : FAILURE

[GitHub] [flink] flinkbot commented on issue #10368: [FLINK-14983][table-common] Add interfaces for input type inference

flinkbot commented on issue #10368: [FLINK-14983][table-common] Add interfaces for input type inference URL: https://github.com/apache/flink/pull/10368#issuecomment-559849270 ## CI report: * a38c5d9c361f67d4922932f3634c2387288c1d6e : UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #10366: [1.8][FLINK-14995][kinesis][legal] Update NOTICE

flinkbot edited a comment on issue #10366: [1.8][FLINK-14995][kinesis][legal] Update NOTICE URL: https://github.com/apache/flink/pull/10366#issuecomment-559835705 ## CI report: * 5c57da1ec7e28742c3b53a7bbc5587c2abac4fa4 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10367: [1.9][FLINK-14995][kinesis][legal] Update NOTICE

flinkbot edited a comment on issue #10367: [1.9][FLINK-14995][kinesis][legal] Update NOTICE URL: https://github.com/apache/flink/pull/10367#issuecomment-559835744 ## CI report: * b0e8b316663349ba4d3a9d72643d2bdc75917ffb : SUCCESS

[jira] [Commented] (FLINK-14729) Multi-topics consuming from KafkaTableSource

[ https://issues.apache.org/jira/browse/FLINK-14729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16985127#comment-16985127 ] Rong Rong commented on FLINK-14729: --- Hi [~fangpengcheng95] [~50man] I think it would be nice if you

[GitHub] [flink] flinkbot edited a comment on issue #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors.

flinkbot edited a comment on issue #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors. URL: https://github.com/apache/flink/pull/10346#issuecomment-559445838 ## CI report: * 9d133e6ba91f6d688401f493cc39729b4b34feb6 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #10114: [FLINK -14651][runtime] Enable DefaultScheduler

flinkbot edited a comment on issue #10114: [FLINK -14651][runtime] Enable DefaultScheduler URL: https://github.com/apache/flink/pull/10114#issuecomment-551014940 ## CI report: * c436371614d7db5dfc8c97e01a4594c3139715db : FAILURE

[GitHub] [flink] flinkbot commented on issue #10368: [FLINK-14983][table-common] Add interfaces for input type inference

flinkbot commented on issue #10368: [FLINK-14983][table-common] Add interfaces for input type inference URL: https://github.com/apache/flink/pull/10368#issuecomment-559843992 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Closed] (FLINK-14974) Managed memory fractions should be rounded properly to not summed up to be more than 1.0

[ https://issues.apache.org/jira/browse/FLINK-14974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-14974. Resolution: Fixed master: daa2f9590a5db69ee57ebc1c5878799cd08bd2b5 > Managed memory

[jira] [Updated] (FLINK-14983) Add interfaces for input type inference

[ https://issues.apache.org/jira/browse/FLINK-14983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14983: --- Labels: pull-request-available (was: ) > Add interfaces for input type inference >

[GitHub] [flink] zentol merged pull request #10341: [FLINK-14974][runtime] Calculate managed memory fractions with BigDecimal and round down it properly

zentol merged pull request #10341: [FLINK-14974][runtime] Calculate managed memory fractions with BigDecimal and round down it properly URL: https://github.com/apache/flink/pull/10341 This is an automated message from the

[GitHub] [flink] twalthr opened a new pull request #10368: [FLINK-14983][table-common] Add interfaces for input type inference

twalthr opened a new pull request #10368: [FLINK-14983][table-common] Add interfaces for input type inference URL: https://github.com/apache/flink/pull/10368 ## What is the purpose of the change This adds a similar class as Calcite's `SqlOperandTypeInference` to Flink's type

[GitHub] [flink] flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#issuecomment-545881191 ## CI report: * 802ebf37e3d932169f9826b40df483bb5e9ac064 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10367: [1.9][FLINK-14995][kinesis][legal] Update NOTICE

flinkbot edited a comment on issue #10367: [1.9][FLINK-14995][kinesis][legal] Update NOTICE URL: https://github.com/apache/flink/pull/10367#issuecomment-559835744 ## CI report: * b0e8b316663349ba4d3a9d72643d2bdc75917ffb : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10366: [1.8][FLINK-14995][kinesis][legal] Update NOTICE

flinkbot edited a comment on issue #10366: [1.8][FLINK-14995][kinesis][legal] Update NOTICE URL: https://github.com/apache/flink/pull/10366#issuecomment-559835705 ## CI report: * 5c57da1ec7e28742c3b53a7bbc5587c2abac4fa4 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10363: [FLINK-14104][build] Upgrade to flink-shaded 9.0

flinkbot edited a comment on issue #10363: [FLINK-14104][build] Upgrade to flink-shaded 9.0 URL: https://github.com/apache/flink/pull/10363#issuecomment-559809874 ## CI report: * 29f293aede9db08019c380fec1da3f24d19c51d3 : SUCCESS

[GitHub] [flink] azagrebin edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

azagrebin edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-559841792 We should consider all current usages of deprecated

[GitHub] [flink] flinkbot edited a comment on issue #10339: [FLINK-14976][cassandra] Release semaphore on all Throwable's in send()

flinkbot edited a comment on issue #10339: [FLINK-14976][cassandra] Release semaphore on all Throwable's in send() URL: https://github.com/apache/flink/pull/10339#issuecomment-559115891 ## CI report: * 65f4f8552770a2e1fd05c604a5cc074f32487c74 : CANCELED

[GitHub] [flink] azagrebin edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

azagrebin edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-559841792 We should consider all current usages of deprecated

[GitHub] [flink] azagrebin commented on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

azagrebin commented on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-559841792 We should consider all current usage of deprecated `TaskManagerOptions.NUM_TASK_SLOTS` in

[jira] [Updated] (FLINK-14651) Set default value of config option jobmanager.scheduler to "ng"

[ https://issues.apache.org/jira/browse/FLINK-14651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-14651: - Priority: Critical (was: Major) > Set default value of config option jobmanager.scheduler to "ng" >

[jira] [Updated] (FLINK-14651) Set default value of config option jobmanager.scheduler to "ng"

[ https://issues.apache.org/jira/browse/FLINK-14651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-14651: - Parent: FLINK-10429 Issue Type: Sub-task (was: Bug) > Set default value of config option

[GitHub] [flink] flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#issuecomment-545881191 ## CI report: * 802ebf37e3d932169f9826b40df483bb5e9ac064 : SUCCESS

[GitHub] [flink] azagrebin commented on a change in pull request #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

azagrebin commented on a change in pull request #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#discussion_r351831109 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

azagrebin commented on a change in pull request #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#discussion_r352157448 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

azagrebin commented on a change in pull request #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#discussion_r351880023 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

azagrebin commented on a change in pull request #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#discussion_r351839963 ## File path:

  1   2   3   4   >