[GitHub] [flink] ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347#discussion_r392856449 ## File path:

[jira] [Updated] (FLINK-15640) Support to set label and node selector

[ https://issues.apache.org/jira/browse/FLINK-15640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-15640: -- Description: Navigate to [Kubernetes

[jira] [Updated] (FLINK-16547) Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH

[ https://issues.apache.org/jira/browse/FLINK-16547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-16547: --- Affects Version/s: 1.10.0 > Respect the config option of

[jira] [Commented] (FLINK-15641) Support to start init container

[ https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060035#comment-17060035 ] Yang Wang commented on FLINK-15641: --- [~ouyangwuli] What's going on with the init and sidecar container

[jira] [Assigned] (FLINK-16547) Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH

[ https://issues.apache.org/jira/browse/FLINK-16547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-16547: -- Assignee: Canbin Zheng (was: Kostas Kloudas) > Respect the config option of

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060054#comment-17060054 ] Stephan Ewen commented on FLINK-14807: -- Not sure I understand. What is the mechanism by which the

[GitHub] [flink] flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#issuecomment-596050968 ## CI report: * 1e95f02cc2803e695eb28597de8f7344362826fd UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

flinkbot edited a comment on issue #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347#issuecomment-596323413 ## CI report: * a04e4412520adcc0f51cb9ce2b53c8ea70798bcc Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir…

flinkbot edited a comment on issue #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir… URL: https://github.com/apache/flink/pull/11322#issuecomment-595233010 ## CI report: * 497c65724ea2499cd2a5b82a7ce4ffd2f8807502 Travis:

[GitHub] [flink] godfreyhe commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

godfreyhe commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#discussion_r392898854 ## File path:

[GitHub] [flink] rmetzger commented on issue #11406: [FLINK-16494][k8s] Switch to enum type for config option KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY

rmetzger commented on issue #11406: [FLINK-16494][k8s] Switch to enum type for config option KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY URL: https://github.com/apache/flink/pull/11406#issuecomment-599460062 Thanks a lot for pining me. @zentol it seems that the ci-bot is down. No

[GitHub] [flink] zhengcanbin commented on issue #11406: [FLINK-16494][k8s] Switch to enum type for config option KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY

zhengcanbin commented on issue #11406: [FLINK-16494][k8s] Switch to enum type for config option KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY URL: https://github.com/apache/flink/pull/11406#issuecomment-599459067 Hi, @rmetzger! It's quite strange that the **CI** is not timely

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060117#comment-17060117 ] Piotr Nowojski commented on FLINK-16142: I'm assigning [~azagrebin] as he is assigned to an

[jira] [Assigned] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-16142: -- Assignee: Andrey Zagrebin > Memory Leak causes Metaspace OOM error on repeated job

[jira] [Created] (FLINK-16615) Introduce data structures and utilities to calculate Job Manager memory components

Andrey Zagrebin created FLINK-16615: --- Summary: Introduce data structures and utilities to calculate Job Manager memory components Key: FLINK-16615 URL: https://issues.apache.org/jira/browse/FLINK-16615

[jira] [Commented] (FLINK-16227) Streaming bucketing end-to-end test / test_streaming_bucketing.sh unstable

[ https://issues.apache.org/jira/browse/FLINK-16227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060119#comment-17060119 ] Robert Metzger commented on FLINK-16227: According to this thread that I've started, we won't

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347#discussion_r392859883 ## File path:

[jira] [Assigned] (FLINK-16547) Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH

[ https://issues.apache.org/jira/browse/FLINK-16547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-16547: -- Assignee: Kostas Kloudas > Respect the config option of

[jira] [Closed] (FLINK-16336) Support new type inference for temporal table functions

[ https://issues.apache.org/jira/browse/FLINK-16336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-16336. Fix Version/s: 1.11.0 Resolution: Fixed Fixed in 1.11:

[GitHub] [flink] twalthr closed pull request #11253: [FLINK-16336][table] Add new type inference for temporal table functions

twalthr closed pull request #11253: [FLINK-16336][table] Add new type inference for temporal table functions URL: https://github.com/apache/flink/pull/11253 This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-16336) Support new type inference for temporal table functions

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

[jira] [Commented] (FLINK-16227) Streaming bucketing end-to-end test / test_streaming_bucketing.sh unstable

[ https://issues.apache.org/jira/browse/FLINK-16227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060053#comment-17060053 ] Zhijiang commented on FLINK-16227: -- Some instances 

[jira] [Comment Edited] (FLINK-14807) Add Table#collect api for fetching data to client

[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060077#comment-17060077 ] Caizhi Weng edited comment on FLINK-14807 at 3/16/20, 9:54 AM: --- Hi

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060077#comment-17060077 ] Caizhi Weng commented on FLINK-14807: - Hi [~sewen] The client receives the data through REST calls

[GitHub] [flink] flinkbot edited a comment on issue #11406: [FLINK-16494][k8s] Switch to enum type for config option KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY

flinkbot edited a comment on issue #11406: [FLINK-16494][k8s] Switch to enum type for config option KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY URL: https://github.com/apache/flink/pull/11406#issuecomment-599442456 ## CI report: * 0522d6b4226204b1834271b6b5f752ec7117c79c

[GitHub] [flink] flinkbot edited a comment on issue #11409: [FLINK-16592][docs] The doc of Streaming File Sink has a mistake of g…

flinkbot edited a comment on issue #11409: [FLINK-16592][docs] The doc of Streaming File Sink has a mistake of g… URL: https://github.com/apache/flink/pull/11409#issuecomment-599442587 ## CI report: * 04e87eaa9def80db545a84e29218e3c75d54e837 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11411: [hotfix] [docs] Fix typo in DataStream API walkthrough

flinkbot edited a comment on issue #11411: [hotfix] [docs] Fix typo in DataStream API walkthrough URL: https://github.com/apache/flink/pull/11411#issuecomment-599442694 ## CI report: * 71486c5c497b022f1d15c55eead44277df8965d1 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11410: [FLINK-16567][Documentation] Get the API error of the StreamQueryConf…

flinkbot edited a comment on issue #11410: [FLINK-16567][Documentation] Get the API error of the StreamQueryConf… URL: https://github.com/apache/flink/pull/11410#issuecomment-599442637 ## CI report: * d372924d05d8d2de87f54858b6772419e11dbad3 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11414: [FLINK-16606][python] Throw exceptions for the data types which are not currently supported

flinkbot edited a comment on issue #11414: [FLINK-16606][python] Throw exceptions for the data types which are not currently supported URL: https://github.com/apache/flink/pull/11414#issuecomment-599442876 ## CI report: * ef1c12148834bd5ee016f4099a4796620d684c6d Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11400: [FLINK-16586][network] Build ResultSubpartitionInfo and InputChannelInfo in respective constructors

flinkbot edited a comment on issue #11400: [FLINK-16586][network] Build ResultSubpartitionInfo and InputChannelInfo in respective constructors URL: https://github.com/apache/flink/pull/11400#issuecomment-598611898 ## CI report: * a86f1e2e6785237893201dac302bc50041610d73 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11412: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files

flinkbot edited a comment on issue #11412: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files URL: https://github.com/apache/flink/pull/11412#issuecomment-599442752 ## CI report: * 1e44ce32d9cfce535c2abbe9d9e33ee85c6decf9 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11408: [FLINK-15989][FLINK-16225] Improve direct and metaspace out-of-memory error handling

flinkbot edited a comment on issue #11408: [FLINK-15989][FLINK-16225] Improve direct and metaspace out-of-memory error handling URL: https://github.com/apache/flink/pull/11408#issuecomment-599442524 ## CI report: * 4614b57fc5790f02e874a3e60e34c0c1e0fbefe0 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese

flinkbot edited a comment on issue #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese URL: https://github.com/apache/flink/pull/11390#issuecomment-598048503 ## CI report: * 9117309ad85e4b7a35c6f0545ac303d122e8bf7c Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11413: [FLINK-16607][python] Update flink-fn-execution.proto adding more schema information

flinkbot edited a comment on issue #11413: [FLINK-16607][python] Update flink-fn-execution.proto adding more schema information URL: https://github.com/apache/flink/pull/11413#issuecomment-599442810 ## CI report: * 440ea4ddcf47bcda77584378f6f58dca1f8ef025 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11405: [FLINK-16413]Reduce hive source parallelism when limit push down

flinkbot edited a comment on issue #11405: [FLINK-16413]Reduce hive source parallelism when limit push down URL: https://github.com/apache/flink/pull/11405#issuecomment-599442389 ## CI report: * b196447b93a3c1bdb64fce172c2aea305e16093b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

flinkbot edited a comment on issue #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347#issuecomment-596323413 ## CI report: * a04e4412520adcc0f51cb9ce2b53c8ea70798bcc Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#issuecomment-596050968 ## CI report: * 1e95f02cc2803e695eb28597de8f7344362826fd UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11010: [FLINK-15836][k8s] Start a new pods watcher in KubernetesResourceManager when the old one is closed with exception

flinkbot edited a comment on issue #11010: [FLINK-15836][k8s] Start a new pods watcher in KubernetesResourceManager when the old one is closed with exception URL: https://github.com/apache/flink/pull/11010#issuecomment-581769412 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11359: [FLINK-16095] [docs-zh] Translate "Modules" page of "Table API & SQL" into Chinese

flinkbot edited a comment on issue #11359: [FLINK-16095] [docs-zh] Translate "Modules" page of "Table API & SQL" into Chinese URL: https://github.com/apache/flink/pull/11359#issuecomment-596916485 ## CI report: * 4d5019079937eb3a8d991d5e5e54a5570330f56b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir…

flinkbot edited a comment on issue #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir… URL: https://github.com/apache/flink/pull/11322#issuecomment-595233010 ## CI report: * 497c65724ea2499cd2a5b82a7ce4ffd2f8807502 Travis:

[GitHub] [flink] flinkbot commented on issue #11418: [FLINK-16613] make build trigger on azp more reliable

flinkbot commented on issue #11418: [FLINK-16613] make build trigger on azp more reliable URL: https://github.com/apache/flink/pull/11418#issuecomment-599468323 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] rmetzger merged pull request #11418: [FLINK-16613] make build trigger on azp more reliable

rmetzger merged pull request #11418: [FLINK-16613] make build trigger on azp more reliable URL: https://github.com/apache/flink/pull/11418 This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-15871) Support to start sidecar container

[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060037#comment-17060037 ] Yang Wang commented on FLINK-15871: --- [~yan234280533] In my opinion, the sidecar container will have

[jira] [Updated] (FLINK-15667) Support to mount Hadoop Configurations

[ https://issues.apache.org/jira/browse/FLINK-15667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15667: - Summary: Support to mount Hadoop Configurations (was: Hadoop Configurations Mount Support) >

[GitHub] [flink] godfreyhe commented on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

godfreyhe commented on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#issuecomment-599447421 it's better to add some tests in `RemoveRedundantLocalSortAggRuleTest` and `RemoveRedundantLocalHashAggRuleTest` about

[jira] [Updated] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable

[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-12030: - Fix Version/s: 1.11.0 > KafkaITCase.testMultipleSourcesOnePartition is unstable >

[GitHub] [flink] zhengcanbin opened a new pull request #11415: [FLINK-15667][k8s] Support to mount custom Hadoop Configurations

zhengcanbin opened a new pull request #11415: [FLINK-15667][k8s] Support to mount custom Hadoop Configurations URL: https://github.com/apache/flink/pull/11415 ## What is the purpose of the change This PR aims to add support for mounting custom Hadoop Configurations into the JM/TM

[jira] [Updated] (FLINK-15667) Support to mount Hadoop Configurations

[ https://issues.apache.org/jira/browse/FLINK-15667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15667: --- Labels: pull-request-available (was: ) > Support to mount Hadoop Configurations >

[GitHub] [flink] zhijiangW opened a new pull request #11416: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files

zhijiangW opened a new pull request #11416: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files URL: https://github.com/apache/flink/pull/11416 ## What is the purpose of the change back-port from #11412 ## Brief change log Update the copyright

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347#discussion_r392856449 ## File path:

[jira] [Assigned] (FLINK-16576) State inconsistency on restore with memory state backends

[ https://issues.apache.org/jira/browse/FLINK-16576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reassigned FLINK-16576: - Assignee: Congxian Qiu(klion26) > State inconsistency on restore with memory state backends >

[jira] [Updated] (FLINK-14233) All task state changes should be notified to SchedulingStrategy (SchedulerNG)

[ https://issues.apache.org/jira/browse/FLINK-14233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14233: Description: {{SchedulingStrategy}} requires task states to make scheduling decisions. At the moment,

[GitHub] [flink] flinkbot edited a comment on issue #11010: [FLINK-15836][k8s] Start a new pods watcher in KubernetesResourceManager when the old one is closed with exception

flinkbot edited a comment on issue #11010: [FLINK-15836][k8s] Start a new pods watcher in KubernetesResourceManager when the old one is closed with exception URL: https://github.com/apache/flink/pull/11010#issuecomment-581769412 ## CI report: *

[jira] [Created] (FLINK-16611) Datadog reporter should chunk large reports

Chesnay Schepler created FLINK-16611: Summary: Datadog reporter should chunk large reports Key: FLINK-16611 URL: https://issues.apache.org/jira/browse/FLINK-16611 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-538885706 ## CI report: * 06535d4ba4e27e933ec7d7adcaf937367d0cb5b4 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-538885706 ## CI report: * 06535d4ba4e27e933ec7d7adcaf937367d0cb5b4 Travis:

[GitHub] [flink] zhijiangW opened a new pull request #11417: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files

zhijiangW opened a new pull request #11417: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files URL: https://github.com/apache/flink/pull/11417 ## What is the purpose of the change back-port from #11412 ## Brief change log Update the copyright from

[jira] [Created] (FLINK-16613) Builds on Azure pipeline are not triggered

Robert Metzger created FLINK-16613: -- Summary: Builds on Azure pipeline are not triggered Key: FLINK-16613 URL: https://issues.apache.org/jira/browse/FLINK-16613 Project: Flink Issue Type:

[GitHub] [flink] AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r392903610 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r392907594 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r392933478 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r392914268 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r392930813 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r392927611 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r392925090 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r392897158 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r392932095 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r392897536 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r392905579 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r392898810 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r392906080 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r392923505 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator

AHeise commented on a change in pull request #11403: [FLINK-16316][operators] Implement new StreamOperatorBase as a replacement for AbstractStreamOperator URL: https://github.com/apache/flink/pull/11403#discussion_r392925814 ## File path:

[jira] [Updated] (FLINK-16227) Streaming bucketing end-to-end test / test_streaming_bucketing.sh unstable

[ https://issues.apache.org/jira/browse/FLINK-16227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16227: --- Fix Version/s: 1.11.0 > Streaming bucketing end-to-end test / test_streaming_bucketing.sh

[jira] [Updated] (FLINK-16227) Streaming bucketing end-to-end test / test_streaming_bucketing.sh unstable

[ https://issues.apache.org/jira/browse/FLINK-16227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16227: --- Priority: Blocker (was: Critical) > Streaming bucketing end-to-end test /

[GitHub] [flink] flinkbot commented on issue #11412: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files

flinkbot commented on issue #11412: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files URL: https://github.com/apache/flink/pull/11412#issuecomment-599442752 ## CI report: * 1e44ce32d9cfce535c2abbe9d9e33ee85c6decf9 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot commented on issue #11413: [FLINK-16607][python] Update flink-fn-execution.proto adding more schema information

flinkbot commented on issue #11413: [FLINK-16607][python] Update flink-fn-execution.proto adding more schema information URL: https://github.com/apache/flink/pull/11413#issuecomment-599442810 ## CI report: * 440ea4ddcf47bcda77584378f6f58dca1f8ef025 UNKNOWN Bot

[GitHub] [flink] flinkbot commented on issue #11410: [FLINK-16567][Documentation] Get the API error of the StreamQueryConf…

flinkbot commented on issue #11410: [FLINK-16567][Documentation] Get the API error of the StreamQueryConf… URL: https://github.com/apache/flink/pull/11410#issuecomment-599442637 ## CI report: * d372924d05d8d2de87f54858b6772419e11dbad3 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot commented on issue #11411: [hotfix] [docs] Fix typo in DataStream API walkthrough

flinkbot commented on issue #11411: [hotfix] [docs] Fix typo in DataStream API walkthrough URL: https://github.com/apache/flink/pull/11411#issuecomment-599442694 ## CI report: * 71486c5c497b022f1d15c55eead44277df8965d1 UNKNOWN Bot commands The @flinkbot bot

[GitHub] [flink] flinkbot commented on issue #11409: [FLINK-16592][docs] The doc of Streaming File Sink has a mistake of g…

flinkbot commented on issue #11409: [FLINK-16592][docs] The doc of Streaming File Sink has a mistake of g… URL: https://github.com/apache/flink/pull/11409#issuecomment-599442587 ## CI report: * 04e87eaa9def80db545a84e29218e3c75d54e837 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot commented on issue #11414: [FLINK-16606][python] Throw exceptions for the data types which are not currently supported

flinkbot commented on issue #11414: [FLINK-16606][python] Throw exceptions for the data types which are not currently supported URL: https://github.com/apache/flink/pull/11414#issuecomment-599442876 ## CI report: * ef1c12148834bd5ee016f4099a4796620d684c6d UNKNOWN Bot

[jira] [Updated] (FLINK-16454) Update the copyright year in NOTICE files

[ https://issues.apache.org/jira/browse/FLINK-16454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-16454: - Fix Version/s: shaded-11.0 > Update the copyright year in NOTICE files >

[GitHub] [flink] flinkbot edited a comment on issue #11400: [FLINK-16586][network] Build ResultSubpartitionInfo and InputChannelInfo in respective constructors

flinkbot edited a comment on issue #11400: [FLINK-16586][network] Build ResultSubpartitionInfo and InputChannelInfo in respective constructors URL: https://github.com/apache/flink/pull/11400#issuecomment-598611898 ## CI report: * a86f1e2e6785237893201dac302bc50041610d73 UNKNOWN

[GitHub] [flink] flinkbot commented on issue #11406: [FLINK-16494][k8s] Switch to enum type for config option KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY

flinkbot commented on issue #11406: [FLINK-16494][k8s] Switch to enum type for config option KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY URL: https://github.com/apache/flink/pull/11406#issuecomment-599442456 ## CI report: * 0522d6b4226204b1834271b6b5f752ec7117c79c

[GitHub] [flink] flinkbot commented on issue #11405: [FLINK-16413]Reduce hive source parallelism when limit push down

flinkbot commented on issue #11405: [FLINK-16413]Reduce hive source parallelism when limit push down URL: https://github.com/apache/flink/pull/11405#issuecomment-599442389 ## CI report: * b196447b93a3c1bdb64fce172c2aea305e16093b UNKNOWN Bot commands The @flinkbot

[GitHub] [flink] flinkbot edited a comment on issue #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese

flinkbot edited a comment on issue #11390: [FLINK-16096][docs-zh] Translate dev/table/catalog.zh.md into Chinese URL: https://github.com/apache/flink/pull/11390#issuecomment-598048503 ## CI report: * 9117309ad85e4b7a35c6f0545ac303d122e8bf7c Travis:

[GitHub] [flink] flinkbot commented on issue #11408: [FLINK-15989][FLINK-16225] Improve direct and metaspace out-of-memory error handling

flinkbot commented on issue #11408: [FLINK-15989][FLINK-16225] Improve direct and metaspace out-of-memory error handling URL: https://github.com/apache/flink/pull/11408#issuecomment-599442524 ## CI report: * 4614b57fc5790f02e874a3e60e34c0c1e0fbefe0 UNKNOWN Bot

[GitHub] [flink] flinkbot edited a comment on issue #11359: [FLINK-16095] [docs-zh] Translate "Modules" page of "Table API & SQL" into Chinese

flinkbot edited a comment on issue #11359: [FLINK-16095] [docs-zh] Translate "Modules" page of "Table API & SQL" into Chinese URL: https://github.com/apache/flink/pull/11359#issuecomment-596916485 ## CI report: * 4d5019079937eb3a8d991d5e5e54a5570330f56b Travis:

[GitHub] [flink] danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#discussion_r392910139 ## File path:

[jira] [Updated] (FLINK-16612) Submit job through the rest api, job name will be lost

[ https://issues.apache.org/jira/browse/FLINK-16612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junli Zhang updated FLINK-16612: Labels: Client JobName RESTful (was: ) > Submit job through the rest api, job name will be lost

[GitHub] [flink] flinkbot commented on issue #11416: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files

flinkbot commented on issue #11416: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files URL: https://github.com/apache/flink/pull/11416#issuecomment-599462170 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] rmetzger opened a new pull request #11418: [FLINK-16613] make build trigger on azp more reliable

rmetzger opened a new pull request #11418: [FLINK-16613] make build trigger on azp more reliable URL: https://github.com/apache/flink/pull/11418 This PR is to mitigate the current outage / issue with AZP: https://status.dev.azure.com/_event/179641421

[jira] [Commented] (FLINK-15871) Support to start sidecar container

[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060111#comment-17060111 ] Canbin Zheng commented on FLINK-15871: -- I think the sidecar container needs depth discussion to

[GitHub] [flink] flinkbot edited a comment on issue #11405: [FLINK-16413]Reduce hive source parallelism when limit push down

flinkbot edited a comment on issue #11405: [FLINK-16413]Reduce hive source parallelism when limit push down URL: https://github.com/apache/flink/pull/11405#issuecomment-599442389 ## CI report: * b196447b93a3c1bdb64fce172c2aea305e16093b Travis:

[GitHub] [flink] flinkbot commented on issue #11416: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files

flinkbot commented on issue #11416: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files URL: https://github.com/apache/flink/pull/11416#issuecomment-599465904 ## CI report: * 151c547f347ca9ad4ea61289ed1f5e65d134551a UNKNOWN Bot commands The

[GitHub] [flink] flinkbot commented on issue #11417: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files

flinkbot commented on issue #11417: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files URL: https://github.com/apache/flink/pull/11417#issuecomment-599465473 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-16613) Builds on Azure pipeline are not triggered

[ https://issues.apache.org/jira/browse/FLINK-16613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16613: --- Labels: pull-request-available (was: ) > Builds on Azure pipeline are not triggered >

[jira] [Resolved] (FLINK-16613) Builds on Azure pipeline are not triggered

[ https://issues.apache.org/jira/browse/FLINK-16613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-16613. Resolution: Fixed Resolved in 4a4baf0c81c23ed3125078500605a7db11f3cbba > Builds on Azure

[jira] [Commented] (FLINK-15640) Support to set label and node selector

[ https://issues.apache.org/jira/browse/FLINK-15640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060029#comment-17060029 ] Yang Wang commented on FLINK-15640: --- Hi [~hippo], sorry for the late response. Do you still want to

[jira] [Commented] (FLINK-15639) Support to set toleration for jobmanager and taskmanger

[ https://issues.apache.org/jira/browse/FLINK-15639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060030#comment-17060030 ] Yang Wang commented on FLINK-15639: --- [~yuzhaojing] Sorry for the late response. The decorator refactor

  1   2   3   4   >