[GitHub] [flink] Mrart commented on a change in pull request #10510: [FLINK-15176][container] Add '--job-classname' to flink-container 'jo…

Mrart commented on a change in pull request #10510: [FLINK-15176][container] Add '--job-classname' to flink-container 'jo… URL: https://github.com/apache/flink/pull/10510#discussion_r368212686 ## File path: flink-container/kubernetes/job-cluster-job.yaml.template ## @@

[GitHub] [flink] Mrart commented on a change in pull request #10510: [FLINK-15176][container] Add '--job-classname' to flink-container 'jo…

Mrart commented on a change in pull request #10510: [FLINK-15176][container] Add '--job-classname' to flink-container 'jo… URL: https://github.com/apache/flink/pull/10510#discussion_r368212620 ## File path: flink-container/kubernetes/job-cluster-job.yaml.template ## @@

[GitHub] [flink] Mrart commented on a change in pull request #10510: [FLINK-15176][container] Add '--job-classname' to flink-container 'jo…

Mrart commented on a change in pull request #10510: [FLINK-15176][container] Add '--job-classname' to flink-container 'jo… URL: https://github.com/apache/flink/pull/10510#discussion_r368212620 ## File path: flink-container/kubernetes/job-cluster-job.yaml.template ## @@

[GitHub] [flink] flinkbot edited a comment on issue #10785: [FLINK-15375][core] Improve MemorySize to print / parse with better readability.

flinkbot edited a comment on issue #10785: [FLINK-15375][core] Improve MemorySize to print / parse with better readability. URL: https://github.com/apache/flink/pull/10785#issuecomment-571482425 ## CI report: * bfb11ff827395ce52de3c19567ec5fb60334e4d5 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10893: [FLINK-15637][state backends] Make RocksDB the default store for timers when using RocksDBStateBackend

flinkbot edited a comment on issue #10893: [FLINK-15637][state backends] Make RocksDB the default store for timers when using RocksDBStateBackend URL: https://github.com/apache/flink/pull/10893#issuecomment-575859797 ## CI report: * 2a07b12e4f943499075f42960fc84dd445df6f3c

[GitHub] [flink] flinkbot edited a comment on issue #10893: [FLINK-15637][state backends] Make RocksDB the default store for timers when using RocksDBStateBackend

flinkbot edited a comment on issue #10893: [FLINK-15637][state backends] Make RocksDB the default store for timers when using RocksDBStateBackend URL: https://github.com/apache/flink/pull/10893#issuecomment-575859797 ## CI report: * 2a07b12e4f943499075f42960fc84dd445df6f3c

[GitHub] [flink] flinkbot edited a comment on issue #10785: [FLINK-15375][core] Improve MemorySize to print / parse with better readability.

flinkbot edited a comment on issue #10785: [FLINK-15375][core] Improve MemorySize to print / parse with better readability. URL: https://github.com/apache/flink/pull/10785#issuecomment-571482425 ## CI report: * bfb11ff827395ce52de3c19567ec5fb60334e4d5 Travis:

[GitHub] [flink] flinkbot commented on issue #10893: [FLINK-15637][state backends] Make RocksDB the default store for timers when using RocksDBStateBackend

flinkbot commented on issue #10893: [FLINK-15637][state backends] Make RocksDB the default store for timers when using RocksDBStateBackend URL: https://github.com/apache/flink/pull/10893#issuecomment-575859797 ## CI report: * 2a07b12e4f943499075f42960fc84dd445df6f3c UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #10785: [FLINK-15375][core] Improve MemorySize to print / parse with better readability.

flinkbot edited a comment on issue #10785: [FLINK-15375][core] Improve MemorySize to print / parse with better readability. URL: https://github.com/apache/flink/pull/10785#issuecomment-571482425 ## CI report: * bfb11ff827395ce52de3c19567ec5fb60334e4d5 Travis:

[jira] [Commented] (FLINK-15638) releasing/create_release_branch.sh does not set version in flink-python/pyflink/version.py

[ https://issues.apache.org/jira/browse/FLINK-15638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018475#comment-17018475 ] Hequn Cheng commented on FLINK-15638: - Fixed in 1.10.0 via 1416b0f9dac37c11c4a17c60a15747b25c6b8e3e

[jira] [Closed] (FLINK-15638) releasing/create_release_branch.sh does not set version in flink-python/pyflink/version.py

[ https://issues.apache.org/jira/browse/FLINK-15638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-15638. --- Resolution: Fixed > releasing/create_release_branch.sh does not set version in >

[GitHub] [flink] flinkbot commented on issue #10893: [FLINK-15637][state backends] Make RocksDB the default store for timers when using RocksDBStateBackend

flinkbot commented on issue #10893: [FLINK-15637][state backends] Make RocksDB the default store for timers when using RocksDBStateBackend URL: https://github.com/apache/flink/pull/10893#issuecomment-575858109 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Updated] (FLINK-15637) For RocksDBStateBackend, make RocksDB the default store for timers

[ https://issues.apache.org/jira/browse/FLINK-15637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15637: --- Labels: pull-request-available (was: ) > For RocksDBStateBackend, make RocksDB the default

[GitHub] [flink] klion26 opened a new pull request #10893: [FLINK-15637][state backends] Make RocksDB the default store for timers when using RocksDBStateBackend

klion26 opened a new pull request #10893: [FLINK-15637][state backends] Make RocksDB the default store for timers when using RocksDBStateBackend URL: https://github.com/apache/flink/pull/10893 ## What is the purpose of the change Make RocksDB the default store for timers when using

[GitHub] [flink] flinkbot commented on issue #10892: [FLINK-15638][release][python] Change version of pyflink to the release version when creating release branch

flinkbot commented on issue #10892: [FLINK-15638][release][python] Change version of pyflink to the release version when creating release branch URL: https://github.com/apache/flink/pull/10892#issuecomment-575857387 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] hequn8128 merged pull request #10892: [FLINK-15638][release][python] Change version of pyflink to the release version when creating release branch

hequn8128 merged pull request #10892: [FLINK-15638][release][python] Change version of pyflink to the release version when creating release branch URL: https://github.com/apache/flink/pull/10892 This is an automated message

[jira] [Updated] (FLINK-15638) releasing/create_release_branch.sh does not set version in flink-python/pyflink/version.py

[ https://issues.apache.org/jira/browse/FLINK-15638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15638: --- Labels: pull-request-available (was: ) > releasing/create_release_branch.sh does not set

[GitHub] [flink] hequn8128 opened a new pull request #10892: [FLINK-15638][release][python] Change version of pyflink to the release version when creating release branch

hequn8128 opened a new pull request #10892: [FLINK-15638][release][python] Change version of pyflink to the release version when creating release branch URL: https://github.com/apache/flink/pull/10892 ## What is the purpose of the change This pull request sets the version in

[GitHub] [flink] flinkbot edited a comment on issue #10785: [FLINK-15375][core] Improve MemorySize to print / parse with better readability.

flinkbot edited a comment on issue #10785: [FLINK-15375][core] Improve MemorySize to print / parse with better readability. URL: https://github.com/apache/flink/pull/10785#issuecomment-571482425 ## CI report: * bfb11ff827395ce52de3c19567ec5fb60334e4d5 Travis:

[GitHub] [flink] xintongsong commented on issue #10785: [FLINK-15375][core] Improve MemorySize to print / parse with better readability.

xintongsong commented on issue #10785: [FLINK-15375][core] Improve MemorySize to print / parse with better readability. URL: https://github.com/apache/flink/pull/10785#issuecomment-575856631 @tillrohrmann, thanks for the review. I've addressed your comments.

[GitHub] [flink] xintongsong commented on a change in pull request #10785: [FLINK-15375][core] Improve MemorySize to print / parse with better readability.

xintongsong commented on a change in pull request #10785: [FLINK-15375][core] Improve MemorySize to print / parse with better readability. URL: https://github.com/apache/flink/pull/10785#discussion_r368198923 ## File path:

[jira] [Comment Edited] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018462#comment-17018462 ] Victor Wong edited comment on FLINK-15447 at 1/18/20 1:41 AM: -- [~rongr]

[jira] [Comment Edited] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018462#comment-17018462 ] Victor Wong edited comment on FLINK-15447 at 1/18/20 1:40 AM: -- [~rongr]

[jira] [Comment Edited] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018462#comment-17018462 ] Victor Wong edited comment on FLINK-15447 at 1/18/20 1:40 AM: -- [~rongr]

[jira] [Commented] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018462#comment-17018462 ] Victor Wong commented on FLINK-15447: - [~rongr] Thanks for your reply! _Could you elaborate what

[jira] [Closed] (FLINK-15616) Move boot error messages from python-udf-boot.log to taskmanager's log file

[ https://issues.apache.org/jira/browse/FLINK-15616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-15616. --- Resolution: Resolved > Move boot error messages from python-udf-boot.log to taskmanager's log file

[jira] [Updated] (FLINK-15616) Move boot error messages from python-udf-boot.log to taskmanager's log file

[ https://issues.apache.org/jira/browse/FLINK-15616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-15616: Fix Version/s: 1.11.0 > Move boot error messages from python-udf-boot.log to taskmanager's log

[jira] [Commented] (FLINK-15616) Move boot error messages from python-udf-boot.log to taskmanager's log file

[ https://issues.apache.org/jira/browse/FLINK-15616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018454#comment-17018454 ] Hequn Cheng commented on FLINK-15616: - Resolved in 1.11.0 via

[GitHub] [flink] hequn8128 closed pull request #10870: [FLINK-15616][python] Move boot error messages from python-udf-boot.log to taskmanager's log file

hequn8128 closed pull request #10870: [FLINK-15616][python] Move boot error messages from python-udf-boot.log to taskmanager's log file URL: https://github.com/apache/flink/pull/10870 This is an automated message from the

[GitHub] [flink] curcur commented on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

curcur commented on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#issuecomment-575845406 Thanks for reviewing and merging! @zentol

[GitHub] [flink] curcur commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

curcur commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#discussion_r368188645 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options

flinkbot edited a comment on issue #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options URL: https://github.com/apache/flink/pull/10748#issuecomment-570221103 ## CI report: * 38514c02c79ab0ddb7e80bb483b6034a40d4e199 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options

flinkbot edited a comment on issue #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options URL: https://github.com/apache/flink/pull/10748#issuecomment-570221103 ## CI report: * 38514c02c79ab0ddb7e80bb483b6034a40d4e199 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options

flinkbot edited a comment on issue #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options URL: https://github.com/apache/flink/pull/10748#issuecomment-570221103 ## CI report: * 38514c02c79ab0ddb7e80bb483b6034a40d4e199 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options

flinkbot edited a comment on issue #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options URL: https://github.com/apache/flink/pull/10748#issuecomment-570221103 ## CI report: * 38514c02c79ab0ddb7e80bb483b6034a40d4e199 Travis:

[jira] [Assigned] (FLINK-15638) releasing/create_release_branch.sh does not set version in flink-python/pyflink/version.py

[ https://issues.apache.org/jira/browse/FLINK-15638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-15638: --- Assignee: Hequn Cheng (was: sunjincheng) > releasing/create_release_branch.sh does not

[jira] [Assigned] (FLINK-15638) releasing/create_release_branch.sh does not set version in flink-python/pyflink/version.py

[ https://issues.apache.org/jira/browse/FLINK-15638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-15638: --- Assignee: sunjincheng > releasing/create_release_branch.sh does not set version in >

[jira] [Closed] (FLINK-14703) Port the Kafka SQL related tests.

[ https://issues.apache.org/jira/browse/FLINK-14703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-14703. Fix Version/s: 1.11.0 Resolution: Fixed master:

[GitHub] [flink] zentol commented on issue #10236: [FLINK-14703][e2e] Port the Kafka SQL related tests.

zentol commented on issue #10236: [FLINK-14703][e2e] Port the Kafka SQL related tests. URL: https://github.com/apache/flink/pull/10236#issuecomment-575799902 @openinx Quick update for you: I polished the PR a bit, and reverted the addition of the FileSystemResource. In hindsight it was a

[GitHub] [flink] zentol merged pull request #10236: [FLINK-14703][e2e] Port the Kafka SQL related tests.

zentol merged pull request #10236: [FLINK-14703][e2e] Port the Kafka SQL related tests. URL: https://github.com/apache/flink/pull/10236 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on issue #10236: [FLINK-14703][e2e] Port the Kafka SQL related tests.

flinkbot edited a comment on issue #10236: [FLINK-14703][e2e] Port the Kafka SQL related tests. URL: https://github.com/apache/flink/pull/10236#issuecomment-554979302 ## CI report: * 271d1809c4fa83e7b7655e941e632f6c6d7318ec Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options

flinkbot edited a comment on issue #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options URL: https://github.com/apache/flink/pull/10748#issuecomment-570221103 ## CI report: * 38514c02c79ab0ddb7e80bb483b6034a40d4e199 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10236: [FLINK-14703][e2e] Port the Kafka SQL related tests.

flinkbot edited a comment on issue #10236: [FLINK-14703][e2e] Port the Kafka SQL related tests. URL: https://github.com/apache/flink/pull/10236#issuecomment-554979302 ## CI report: * 271d1809c4fa83e7b7655e941e632f6c6d7318ec Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options

flinkbot edited a comment on issue #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options URL: https://github.com/apache/flink/pull/10748#issuecomment-570221103 ## CI report: * 38514c02c79ab0ddb7e80bb483b6034a40d4e199 Travis:

[jira] [Commented] (FLINK-5763) Make savepoints self-contained and relocatable

[ https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018243#comment-17018243 ] Stephan Ewen commented on FLINK-5763: - We should make this non breaking, with SavepointV3. > Make

[GitHub] [flink] flinkbot edited a comment on issue #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options

flinkbot edited a comment on issue #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options URL: https://github.com/apache/flink/pull/10748#issuecomment-570221103 ## CI report: * 38514c02c79ab0ddb7e80bb483b6034a40d4e199 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10891: [FLINK-15561][Security][hotfix] Add Delegation Token checker in YarnClusterDescriptor

flinkbot edited a comment on issue #10891: [FLINK-15561][Security][hotfix] Add Delegation Token checker in YarnClusterDescriptor URL: https://github.com/apache/flink/pull/10891#issuecomment-575711809 ## CI report: * 6de7e8f4a6b893f0c4e731efa68ee78d144e6a4b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10890: [FLINK-15198][Deployment / Mesos] remove mesos.resourcemanager.tasks.mem

flinkbot edited a comment on issue #10890: [FLINK-15198][Deployment / Mesos] remove mesos.resourcemanager.tasks.mem URL: https://github.com/apache/flink/pull/10890#issuecomment-575711704 ## CI report: * 42db346a226bf559c202c38affea6e9eef97dafe Travis:

[GitHub] [flink] bowenli86 commented on a change in pull request #10879: [FLINK-15595][table] Remove CoreMudule in ModuleManager

bowenli86 commented on a change in pull request #10879: [FLINK-15595][table] Remove CoreMudule in ModuleManager URL: https://github.com/apache/flink/pull/10879#discussion_r368074550 ## File path: docs/dev/table/functions/index.md ## @@ -84,11 +84,13 @@ The resolution

[GitHub] [flink] bowenli86 commented on a change in pull request #10879: [FLINK-15595][table] Remove CoreMudule in ModuleManager

bowenli86 commented on a change in pull request #10879: [FLINK-15595][table] Remove CoreMudule in ModuleManager URL: https://github.com/apache/flink/pull/10879#discussion_r368074550 ## File path: docs/dev/table/functions/index.md ## @@ -84,11 +84,13 @@ The resolution

[GitHub] [flink] bowenli86 commented on issue #10879: [FLINK-15595][table] Remove CoreMudule in ModuleManager

bowenli86 commented on issue #10879: [FLINK-15595][table] Remove CoreMudule in ModuleManager URL: https://github.com/apache/flink/pull/10879#issuecomment-575742781 @twalthr @dawidwys can you also take a look and share your thoughts?

[GitHub] [flink] bowenli86 commented on a change in pull request #10879: [FLINK-15595][table] Remove CoreMudule in ModuleManager

bowenli86 commented on a change in pull request #10879: [FLINK-15595][table] Remove CoreMudule in ModuleManager URL: https://github.com/apache/flink/pull/10879#discussion_r368076119 ## File path: docs/dev/table/modules.md ## @@ -101,8 +93,6 @@ The following types are

[GitHub] [flink] flinkbot edited a comment on issue #10236: [FLINK-14703][e2e] Port the Kafka SQL related tests.

flinkbot edited a comment on issue #10236: [FLINK-14703][e2e] Port the Kafka SQL related tests. URL: https://github.com/apache/flink/pull/10236#issuecomment-554979302 ## CI report: * 271d1809c4fa83e7b7655e941e632f6c6d7318ec Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options

flinkbot edited a comment on issue #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options URL: https://github.com/apache/flink/pull/10748#issuecomment-570221103 ## CI report: * 38514c02c79ab0ddb7e80bb483b6034a40d4e199 Travis:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r368064219 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r368065079 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r368068307 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r368067378 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r368071764 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r368059634 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r368070093 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r368061316 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10889: [Flink-15355][plugins]Enable s3 plugins under Java 11.

flinkbot edited a comment on issue #10889: [Flink-15355][plugins]Enable s3 plugins under Java 11. URL: https://github.com/apache/flink/pull/10889#issuecomment-575697892 ## CI report: * b352d9bce1e32923a1b3da9ab9b835d5aa6dd613 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10890: [FLINK-15198][Deployment / Mesos] remove mesos.resourcemanager.tasks.mem

flinkbot edited a comment on issue #10890: [FLINK-15198][Deployment / Mesos] remove mesos.resourcemanager.tasks.mem URL: https://github.com/apache/flink/pull/10890#issuecomment-575711704 ## CI report: * 42db346a226bf559c202c38affea6e9eef97dafe Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10891: [FLINK-15561][Security][hotfix] Add Delegation Token checker in YarnClusterDescriptor

flinkbot edited a comment on issue #10891: [FLINK-15561][Security][hotfix] Add Delegation Token checker in YarnClusterDescriptor URL: https://github.com/apache/flink/pull/10891#issuecomment-575711809 ## CI report: * 6de7e8f4a6b893f0c4e731efa68ee78d144e6a4b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10850: [FLINK-15519][configuration] Preserve logs from BashJavaUtils and make them part of TM logs

flinkbot edited a comment on issue #10850: [FLINK-15519][configuration] Preserve logs from BashJavaUtils and make them part of TM logs URL: https://github.com/apache/flink/pull/10850#issuecomment-574076308 ## CI report: * f902fd5c6cc693bac289427094b53d9e4274 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10836: [FLINK-11589][Security] Support security module and context discovery via ServiceLoader

flinkbot edited a comment on issue #10836: [FLINK-11589][Security] Support security module and context discovery via ServiceLoader URL: https://github.com/apache/flink/pull/10836#issuecomment-573438212 ## CI report: * 0e53d682360fe30462917c820c9aa866caa957b5 Travis:

[jira] [Commented] (FLINK-15644) Add support for SQL query validation

[ https://issues.apache.org/jira/browse/FLINK-15644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018217#comment-17018217 ] Zhenqiu Huang commented on FLINK-15644: --- It is a very useful feature. Looking forward to it. >

[GitHub] [flink] flinkbot edited a comment on issue #10236: [FLINK-14703][e2e] Port the Kafka SQL related tests.

flinkbot edited a comment on issue #10236: [FLINK-14703][e2e] Port the Kafka SQL related tests. URL: https://github.com/apache/flink/pull/10236#issuecomment-554979302 ## CI report: * 271d1809c4fa83e7b7655e941e632f6c6d7318ec Travis:

[jira] [Commented] (FLINK-15611) KafkaITCase.testOneToOneSources fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-15611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018210#comment-17018210 ] Gary Yao commented on FLINK-15611: -- Can we rule out that this isn't similar to FLINK-15490? >

[jira] [Updated] (FLINK-15623) Buildling flink-python with maven profile docs-and-source fails

[ https://issues.apache.org/jira/browse/FLINK-15623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15623: - Priority: Major (was: Critical) > Buildling flink-python with maven profile docs-and-source fails >

[jira] [Commented] (FLINK-15623) Buildling flink-python with maven profile docs-and-source fails

[ https://issues.apache.org/jira/browse/FLINK-15623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018205#comment-17018205 ] Gary Yao commented on FLINK-15623: -- We can downgrade the priority. > Buildling flink-python with maven

[jira] [Updated] (FLINK-15623) Buildling flink-python with maven profile docs-and-source fails

[ https://issues.apache.org/jira/browse/FLINK-15623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15623: - Priority: Critical (was: Blocker) > Buildling flink-python with maven profile docs-and-source fails >

[GitHub] [flink] flinkbot edited a comment on issue #10891: [FLINK-15561][Security][hotfix] Add Delegation Token checker in YarnClusterDescriptor

flinkbot edited a comment on issue #10891: [FLINK-15561][Security][hotfix] Add Delegation Token checker in YarnClusterDescriptor URL: https://github.com/apache/flink/pull/10891#issuecomment-575711809 ## CI report: * 6de7e8f4a6b893f0c4e731efa68ee78d144e6a4b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10890: [FLINK-15198][Deployment / Mesos] remove mesos.resourcemanager.tasks.mem

flinkbot edited a comment on issue #10890: [FLINK-15198][Deployment / Mesos] remove mesos.resourcemanager.tasks.mem URL: https://github.com/apache/flink/pull/10890#issuecomment-575711704 ## CI report: * 42db346a226bf559c202c38affea6e9eef97dafe Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10836: [FLINK-11589][Security] Support security module and context discovery via ServiceLoader

flinkbot edited a comment on issue #10836: [FLINK-11589][Security] Support security module and context discovery via ServiceLoader URL: https://github.com/apache/flink/pull/10836#issuecomment-573438212 ## CI report: * 0e53d682360fe30462917c820c9aa866caa957b5 Travis:

[jira] [Created] (FLINK-15644) Add support for SQL query validation

Fabian Hueske created FLINK-15644: - Summary: Add support for SQL query validation Key: FLINK-15644 URL: https://issues.apache.org/jira/browse/FLINK-15644 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018197#comment-17018197 ] Till Rohrmann commented on FLINK-12122: --- I think it could help in this situation. What I am a bit

[jira] [Updated] (FLINK-15419) Validate SQL syntax not need to depend on connector jar

[ https://issues.apache.org/jira/browse/FLINK-15419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-15419: -- Summary: Validate SQL syntax not need to depend on connector jar (was: Add support for SQL

[jira] [Updated] (FLINK-15419) Add support for SQL query validation

[ https://issues.apache.org/jira/browse/FLINK-15419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-15419: -- Summary: Add support for SQL query validation (was: Validate SQL syntax not need to depend

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

flinkbot commented on issue #10891: [FLINK-15561][Security][hotfix] Add Delegation Token checker in YarnClusterDescriptor URL: https://github.com/apache/flink/pull/10891#issuecomment-575711809 ## CI report: * 6de7e8f4a6b893f0c4e731efa68ee78d144e6a4b UNKNOWN Bot

[GitHub] [flink] flinkbot commented on issue #10890: [FLINK-15198][Deployment / Mesos] remove mesos.resourcemanager.tasks.mem

flinkbot commented on issue #10890: [FLINK-15198][Deployment / Mesos] remove mesos.resourcemanager.tasks.mem URL: https://github.com/apache/flink/pull/10890#issuecomment-575711704 ## CI report: * 42db346a226bf559c202c38affea6e9eef97dafe UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #10889: [Flink-15355][plugins]Enable s3 plugins under Java 11.

flinkbot edited a comment on issue #10889: [Flink-15355][plugins]Enable s3 plugins under Java 11. URL: https://github.com/apache/flink/pull/10889#issuecomment-575697892 ## CI report: * b352d9bce1e32923a1b3da9ab9b835d5aa6dd613 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10850: [FLINK-15519][configuration] Preserve logs from BashJavaUtils and make them part of TM logs

flinkbot edited a comment on issue #10850: [FLINK-15519][configuration] Preserve logs from BashJavaUtils and make them part of TM logs URL: https://github.com/apache/flink/pull/10850#issuecomment-574076308 ## CI report: * f902fd5c6cc693bac289427094b53d9e4274 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10836: [FLINK-11589][Security] Support security module and context discovery via ServiceLoader

flinkbot edited a comment on issue #10836: [FLINK-11589][Security] Support security module and context discovery via ServiceLoader URL: https://github.com/apache/flink/pull/10836#issuecomment-573438212 ## CI report: * 0e53d682360fe30462917c820c9aa866caa957b5 Travis:

[jira] [Assigned] (FLINK-15601) Remove useless constant field NUM_STOP_CALL_TRIES in Execution

[ https://issues.apache.org/jira/browse/FLINK-15601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-15601: - Assignee: vinoyang > Remove useless constant field NUM_STOP_CALL_TRIES in Execution >

[jira] [Commented] (FLINK-15601) Remove useless constant field NUM_STOP_CALL_TRIES in Execution

[ https://issues.apache.org/jira/browse/FLINK-15601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018179#comment-17018179 ] Till Rohrmann commented on FLINK-15601: --- Sure, go ahead [~yanghua]. > Remove useless constant

[jira] [Commented] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018177#comment-17018177 ] Rong Rong commented on FLINK-15447: --- as far as I can tell, {{java.io.tmpdir}} is controlled by

[jira] [Commented] (FLINK-12362) Remove legacy container number config option for Flink on yarn

[ https://issues.apache.org/jira/browse/FLINK-12362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018173#comment-17018173 ] Till Rohrmann commented on FLINK-12362: --- At the moment there is no way to configure a fixed number

[jira] [Commented] (FLINK-15198) Remove deprecated mesos.resourcemanager.tasks.mem in 1.11

[ https://issues.apache.org/jira/browse/FLINK-15198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018171#comment-17018171 ] ptmagic commented on FLINK-15198: - [~azagrebin] Please take a look at this pr 

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

flinkbot commented on issue #10891: [FLINK-15561][Security][hotfix] Add Delegation Token checker in YarnClusterDescriptor URL: https://github.com/apache/flink/pull/10891#issuecomment-575699403 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-15561) Improve Kerberos delegation token login

[ https://issues.apache.org/jira/browse/FLINK-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15561: --- Labels: pull-request-available usability (was: usability) > Improve Kerberos delegation

[GitHub] [flink] flinkbot commented on issue #10890: [FLINK-15198][Deployment / Mesos] remove mesos.resourcemanager.tasks.mem

flinkbot commented on issue #10890: [FLINK-15198][Deployment / Mesos] remove mesos.resourcemanager.tasks.mem URL: https://github.com/apache/flink/pull/10890#issuecomment-575698484 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] walterddr opened a new pull request #10891: [FLINK-15561][Security][hotfix] Add Delegation Token checker in YarnClusterDescriptor

walterddr opened a new pull request #10891: [FLINK-15561][Security][hotfix] Add Delegation Token checker in YarnClusterDescriptor URL: https://github.com/apache/flink/pull/10891 …ker.

[GitHub] [flink] tillrohrmann commented on a change in pull request #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options

tillrohrmann commented on a change in pull request #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options URL: https://github.com/apache/flink/pull/10748#discussion_r36892 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10887: [FLINK-15150][tests] Prevent job from reaching terminal state

flinkbot edited a comment on issue #10887: [FLINK-15150][tests] Prevent job from reaching terminal state URL: https://github.com/apache/flink/pull/10887#issuecomment-575653696 ## CI report: * 7f91b3855bca5e7e2d2d9abf196cca861e122312 Travis:

[GitHub] [flink] flinkbot commented on issue #10889: [Flink-15355][plugins]Enable s3 plugins under Java 11.

flinkbot commented on issue #10889: [Flink-15355][plugins]Enable s3 plugins under Java 11. URL: https://github.com/apache/flink/pull/10889#issuecomment-575697892 ## CI report: * b352d9bce1e32923a1b3da9ab9b835d5aa6dd613 UNKNOWN Bot commands The @flinkbot bot

[GitHub] [flink] PengTaoWW opened a new pull request #10890: [FLINK-15198][Deployment / Mesos] remove mesos.resourcemanager.tasks.mem

PengTaoWW opened a new pull request #10890: [FLINK-15198][Deployment / Mesos] remove mesos.resourcemanager.tasks.mem URL: https://github.com/apache/flink/pull/10890 fix https://issues.apache.org/jira/projects/FLINK/issues/FLINK-15198 ## What is the purpose of the change

[GitHub] [flink] flinkbot edited a comment on issue #10850: [FLINK-15519][configuration] Preserve logs from BashJavaUtils and make them part of TM logs

flinkbot edited a comment on issue #10850: [FLINK-15519][configuration] Preserve logs from BashJavaUtils and make them part of TM logs URL: https://github.com/apache/flink/pull/10850#issuecomment-574076308 ## CI report: * f902fd5c6cc693bac289427094b53d9e4274 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10836: [FLINK-11589][Security] Support security module and context discovery via ServiceLoader

flinkbot edited a comment on issue #10836: [FLINK-11589][Security] Support security module and context discovery via ServiceLoader URL: https://github.com/apache/flink/pull/10836#issuecomment-573438212 ## CI report: * 0e53d682360fe30462917c820c9aa866caa957b5 Travis:

  1   2   3   4   >