[jira] [Updated] (FLINK-10848) Flink's Yarn ResourceManager can allocate too many excess containers

[ https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10848: --- Labels: pull-request-available (was: ) > Flink's Yarn ResourceManager can allocate too

[GitHub] suez1224 opened a new pull request #7078: [FLINK-10848][YARN] properly remove YARN ContainerRequest upon container allocation success

suez1224 opened a new pull request #7078: [FLINK-10848][YARN] properly remove YARN ContainerRequest upon container allocation success URL: https://github.com/apache/flink/pull/7078 ## What is the purpose of the change Properly remove YARN ContainerRequest upon container allocation

[jira] [Commented] (FLINK-10848) Flink's Yarn ResourceManager can allocate too many excess containers

[ https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16682768#comment-16682768 ] ASF GitHub Bot commented on FLINK-10848: suez1224 opened a new pull request #7078:

[jira] [Created] (FLINK-10848) Flink's Yarn ResourceManager can allocate too many excess containers

Shuyi Chen created FLINK-10848: -- Summary: Flink's Yarn ResourceManager can allocate too many excess containers Key: FLINK-10848 URL: https://issues.apache.org/jira/browse/FLINK-10848 Project: Flink

[jira] [Commented] (FLINK-7001) Improve performance of Sliding Time Window with pane optimization

[ https://issues.apache.org/jira/browse/FLINK-7001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16682733#comment-16682733 ] Rong Rong commented on FLINK-7001: -- Thanks for the inspiration from [~pgrulich] and [~aljoscha]. I have

[jira] [Closed] (FLINK-10789) Some new serializer snapshots added after 1.6 are not implementing the new TypeSerializerSnapshot interface

[ https://issues.apache.org/jira/browse/FLINK-10789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-10789. --- Resolution: Fixed Fix Version/s: 1.7.0 Merged. 1.8.0:

[jira] [Commented] (FLINK-10789) Some new serializer snapshots added after 1.6 are not implementing the new TypeSerializerSnapshot interface

[ https://issues.apache.org/jira/browse/FLINK-10789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16682735#comment-16682735 ] ASF GitHub Bot commented on FLINK-10789: asfgit closed pull request #7028: [FLINK-10789] New

[GitHub] asfgit closed pull request #7028: [FLINK-10789] New serializer snapshots after 1.6 should implement TypeSerializerSnapshot

asfgit closed pull request #7028: [FLINK-10789] New serializer snapshots after 1.6 should implement TypeSerializerSnapshot URL: https://github.com/apache/flink/pull/7028 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for

[jira] [Commented] (FLINK-10624) Extend SQL client end-to-end to test new KafkaTableSink

[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16682717#comment-16682717 ] ASF GitHub Bot commented on FLINK-10624: yanghua opened a new pull request #6927: [FLINK-10624]

[GitHub] yanghua opened a new pull request #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink

yanghua opened a new pull request #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink URL: https://github.com/apache/flink/pull/6927 ## What is the purpose of the change *This pull request extends SQL client end-to-end to test new KafkaTableSink* ##

[jira] [Commented] (FLINK-10624) Extend SQL client end-to-end to test new KafkaTableSink

[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16682716#comment-16682716 ] ASF GitHub Bot commented on FLINK-10624: yanghua closed pull request #6927: [FLINK-10624] Extend

[GitHub] yanghua closed pull request #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink

yanghua closed pull request #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink URL: https://github.com/apache/flink/pull/6927 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[jira] [Commented] (FLINK-10753) Propagate and log snapshotting exceptions

[ https://issues.apache.org/jira/browse/FLINK-10753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16682647#comment-16682647 ] ASF GitHub Bot commented on FLINK-10753: tillrohrmann commented on a change in pull request

[jira] [Commented] (FLINK-10753) Propagate and log snapshotting exceptions

[ https://issues.apache.org/jira/browse/FLINK-10753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16682648#comment-16682648 ] ASF GitHub Bot commented on FLINK-10753: tillrohrmann commented on a change in pull request

[jira] [Commented] (FLINK-10753) Propagate and log snapshotting exceptions

[ https://issues.apache.org/jira/browse/FLINK-10753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16682646#comment-16682646 ] ASF GitHub Bot commented on FLINK-10753: tillrohrmann commented on a change in pull request

[GitHub] tillrohrmann commented on a change in pull request #7064: [FLINK-10753] Improve propagation and logging of snapshot exceptions

tillrohrmann commented on a change in pull request #7064: [FLINK-10753] Improve propagation and logging of snapshot exceptions URL: https://github.com/apache/flink/pull/7064#discussion_r232468561 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7064: [FLINK-10753] Improve propagation and logging of snapshot exceptions

tillrohrmann commented on a change in pull request #7064: [FLINK-10753] Improve propagation and logging of snapshot exceptions URL: https://github.com/apache/flink/pull/7064#discussion_r232468420 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7064: [FLINK-10753] Improve propagation and logging of snapshot exceptions

tillrohrmann commented on a change in pull request #7064: [FLINK-10753] Improve propagation and logging of snapshot exceptions URL: https://github.com/apache/flink/pull/7064#discussion_r232468462 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7072: [FLINK-10821] Fix resume from externalized checkpoints E2E Test

tillrohrmann commented on a change in pull request #7072: [FLINK-10821] Fix resume from externalized checkpoints E2E Test URL: https://github.com/apache/flink/pull/7072#discussion_r232468084 ## File path: flink-end-to-end-tests/test-scripts/test_resume_externalized_checkpoints.sh

[jira] [Commented] (FLINK-10821) Resuming Externalized Checkpoint E2E test does not resume from Externalized Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-10821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16682637#comment-16682637 ] ASF GitHub Bot commented on FLINK-10821: tillrohrmann commented on a change in pull request

[jira] [Commented] (FLINK-10827) Add test for duplicate() to SerializerTestBase

[ https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16682632#comment-16682632 ] ASF GitHub Bot commented on FLINK-10827: tillrohrmann commented on a change in pull request

[jira] [Commented] (FLINK-10827) Add test for duplicate() to SerializerTestBase

[ https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16682633#comment-16682633 ] ASF GitHub Bot commented on FLINK-10827: tillrohrmann commented on a change in pull request

[jira] [Commented] (FLINK-10827) Add test for duplicate() to SerializerTestBase

[ https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16682631#comment-16682631 ] ASF GitHub Bot commented on FLINK-10827: tillrohrmann commented on a change in pull request

[GitHub] tillrohrmann commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase

tillrohrmann commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase URL: https://github.com/apache/flink/pull/7061#discussion_r232467673 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase

tillrohrmann commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase URL: https://github.com/apache/flink/pull/7061#discussion_r232467694 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase

tillrohrmann commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase URL: https://github.com/apache/flink/pull/7061#discussion_r232467908 ## File path:

[jira] [Commented] (FLINK-9523) Add Kafka examples for Flink Table/SQL API

[ https://issues.apache.org/jira/browse/FLINK-9523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16682269#comment-16682269 ] ASF GitHub Bot commented on FLINK-9523: --- SokolovMS commented on issue #6672: [FLINK-9523] [table]

[GitHub] SokolovMS commented on issue #6672: [FLINK-9523] [table] Add Kafka examples for Flink Table/SQL API

SokolovMS commented on issue #6672: [FLINK-9523] [table] Add Kafka examples for Flink Table/SQL API URL: https://github.com/apache/flink/pull/6672#issuecomment-437567213 @twalthr Could you please take a look again on that PR? Thank you