[GitHub] [flink] flinkbot commented on pull request #18376: [FLINK-25668][runtime] Support calcuate network memory for dynamic graph

2022-01-17 Thread GitBox
flinkbot commented on pull request #18376: URL: https://github.com/apache/flink/pull/18376#issuecomment-1014266348 ## CI report: * a415c9901fe5addb7e042b2ea760b2de95c736ca UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-23956) KafkaITCase.testOneSourceMultiplePartitions fails due to "The topic metadata failed to propagate to Kafka broker"

2022-01-17 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477029#comment-17477029 ] Yun Gao commented on FLINK-23956: -

[GitHub] [flink] flinkbot edited a comment on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18365: URL: https://github.com/apache/flink/pull/18365#issuecomment-1013081147 ## CI report: * ccea8f5fbc5e210d009dca55ffb566b2b7ea5437 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[jira] [Updated] (FLINK-25668) Support calcuate network memory for dynamic graph.

2022-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25668: --- Labels: pull-request-available (was: ) > Support calcuate network memory for dynamic

[GitHub] [flink] wanglijie95 opened a new pull request #18376: [FLINK-25668][runtime] Support calcuate network memory for dynamic graph

2022-01-17 Thread GitBox
wanglijie95 opened a new pull request #18376: URL: https://github.com/apache/flink/pull/18376 ## What is the purpose of the change Support calcuate network memory for dynamic graph. ## Brief change log a415c9901fe5addb7e042b2ea760b2de95c736ca Support calcuate network memory

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[jira] [Created] (FLINK-25671) npm ci failed with code EPROTO when downloading stylelint-config-prettier-8.0.2.tgz

2022-01-17 Thread Yun Gao (Jira)
Yun Gao created FLINK-25671: --- Summary: npm ci failed with code EPROTO when downloading stylelint-config-prettier-8.0.2.tgz Key: FLINK-25671 URL: https://issues.apache.org/jira/browse/FLINK-25671 Project:

[GitHub] [flink] metaswirl commented on a change in pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-17 Thread GitBox
metaswirl commented on a change in pull request #18169: URL: https://github.com/apache/flink/pull/18169#discussion_r785733137 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorStateChangelogStoragesManager.java ## @@ -124,10 +125,11 @@

[jira] [Commented] (FLINK-25635) Using sql client create hive catalog throw exception

2022-01-17 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477025#comment-17477025 ] Ingo Bürk commented on FLINK-25635: --- Are you using the correct version of flink-connector-hive as

[jira] [Assigned] (FLINK-25668) Support calcuate network memory for dynamic graph.

2022-01-17 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-25668: --- Assignee: Lijie Wang > Support calcuate network memory for dynamic graph. >

[jira] [Assigned] (FLINK-25669) Support register operator coordinators for newly initialized ExecutionJobVertex.

2022-01-17 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-25669: --- Assignee: Lijie Wang > Support register operator coordinators for newly initialized >

[GitHub] [flink] tillrohrmann commented on a change in pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-17 Thread GitBox
tillrohrmann commented on a change in pull request #18169: URL: https://github.com/apache/flink/pull/18169#discussion_r785726000 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorStateChangelogStoragesManager.java ## @@ -124,10 +125,11 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18297: [FLINK-25395][state] Fix TM error handling when uploading shared state

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18297: URL: https://github.com/apache/flink/pull/18297#issuecomment-1007316142 ## CI report: * 83a05868dd4718112ebcd8f92271d84aa90fa733 Azure:

[jira] [Created] (FLINK-25670) StateFun: Unable to handle oversize HTTP message if state size is large

2022-01-17 Thread Kyle (Jira)
Kyle created FLINK-25670: Summary: StateFun: Unable to handle oversize HTTP message if state size is large Key: FLINK-25670 URL: https://issues.apache.org/jira/browse/FLINK-25670 Project: Flink

[jira] [Comment Edited] (FLINK-25649) Scheduling jobs fails with org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException

2022-01-17 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17476945#comment-17476945 ] Zhu Zhu edited comment on FLINK-25649 at 1/17/22, 8:19 AM: --- Hi [~gdegrove],

[jira] [Commented] (FLINK-25648) Redundant to querying deployment when creating task manager pod

2022-01-17 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477021#comment-17477021 ] Till Rohrmann commented on FLINK-25648: --- If it is easy to fix and improves the deployment time

[jira] [Comment Edited] (FLINK-25635) Using sql client create hive catalog throw exception

2022-01-17 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477019#comment-17477019 ] Jing Zhang edited comment on FLINK-25635 at 1/17/22, 8:18 AM: -- I also

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18290: [FLINK-25391][connectors][formats] Update existing table factories/format factories for catalog table options forwarding

2022-01-17 Thread GitBox
slinkydeveloper commented on a change in pull request #18290: URL: https://github.com/apache/flink/pull/18290#discussion_r785724720 ## File path: flink-connectors/flink-connector-hbase-2.2/src/main/java/org/apache/flink/connector/hbase2/HBase2DynamicTableFactory.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #18297: [FLINK-25395][state] Fix TM error handling when uploading shared state

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18297: URL: https://github.com/apache/flink/pull/18297#issuecomment-1007316142 ## CI report: * 83a05868dd4718112ebcd8f92271d84aa90fa733 Azure:

[jira] [Comment Edited] (FLINK-25635) Using sql client create hive catalog throw exception

2022-01-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477018#comment-17477018 ] luoyuxia edited comment on FLINK-25635 at 1/17/22, 8:17 AM: Brought from the

[jira] [Comment Edited] (FLINK-25635) Using sql client create hive catalog throw exception

2022-01-17 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477019#comment-17477019 ] Jing Zhang edited comment on FLINK-25635 at 1/17/22, 8:17 AM: -- I also

[jira] [Comment Edited] (FLINK-25635) Using sql client create hive catalog throw exception

2022-01-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477018#comment-17477018 ] luoyuxia edited comment on FLINK-25635 at 1/17/22, 8:17 AM: Brought from the

[jira] [Commented] (FLINK-25635) Using sql client create hive catalog throw exception

2022-01-17 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477019#comment-17477019 ] Jing Zhang commented on FLINK-25635: I also encountered this problem today. The exception is:

[jira] [Comment Edited] (FLINK-25635) Using sql client create hive catalog throw exception

2022-01-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477018#comment-17477018 ] luoyuxia edited comment on FLINK-25635 at 1/17/22, 8:16 AM: Brought from the

[jira] [Comment Edited] (FLINK-25635) Using sql client create hive catalog throw exception

2022-01-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477018#comment-17477018 ] luoyuxia edited comment on FLINK-25635 at 1/17/22, 8:15 AM: Brought from the

[jira] [Closed] (FLINK-16478) add restApi to modify loglevel

2022-01-17 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-16478. - Resolution: Won't Do > add restApi to modify loglevel > --- > >

[jira] [Comment Edited] (FLINK-25635) Using sql client create hive catalog throw exception

2022-01-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477018#comment-17477018 ] luoyuxia edited comment on FLINK-25635 at 1/17/22, 8:14 AM: Brought from the

[jira] [Comment Edited] (FLINK-25635) Using sql client create hive catalog throw exception

2022-01-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477018#comment-17477018 ] luoyuxia edited comment on FLINK-25635 at 1/17/22, 8:14 AM: Brought from the

[jira] [Comment Edited] (FLINK-25635) Using sql client create hive catalog throw exception

2022-01-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477018#comment-17477018 ] luoyuxia edited comment on FLINK-25635 at 1/17/22, 8:14 AM: Brought from the

[GitHub] [flink] SteNicholas commented on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

2022-01-17 Thread GitBox
SteNicholas commented on pull request #17814: URL: https://github.com/apache/flink/pull/17814#issuecomment-1014246858 > The description for taskmanager.network.sort-shuffle.min-parallelism need also to be updated. @wsry , I would like to update the description for

[GitHub] [flink] flinkbot edited a comment on pull request #18350: [FLINK-25636][network] Change some default config values of blocking shuffle for better usability

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18350: URL: https://github.com/apache/flink/pull/18350#issuecomment-1012086932 ## CI report: * 9012a5147a0a2414ff9d6d9b8f447601e3dd98c3 Azure:

[jira] [Commented] (FLINK-25635) Using sql client create hive catalog throw exception

2022-01-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477018#comment-17477018 ] luoyuxia commented on FLINK-25635: -- Brought from the Jira

[jira] [Updated] (FLINK-25635) Using sql client create hive catalog throw exception

2022-01-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-25635: - Attachment: image-2022-01-17-16-13-07-674.png > Using sql client create hive catalog throw exception >

[jira] [Commented] (FLINK-25667) AdaptiveSchedulerTest.testStatusMetrics is not stable

2022-01-17 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477016#comment-17477016 ] Lijie Wang commented on FLINK-25667:

[jira] [Updated] (FLINK-25635) Using sql client create hive catalog throw exception

2022-01-17 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-25635: --- Attachment: image-2022-01-17-16-09-28-364.png > Using sql client create hive catalog throw

[GitHub] [flink] flinkbot edited a comment on pull request #17938: [FLINK-25073][streaming] Introduce TreeMode description for vertices

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #17938: URL: https://github.com/apache/flink/pull/17938#issuecomment-981363546 ## CI report: * ce5293639c33d92109455f6d831678dba9858f83 Azure:

[GitHub] [flink] matriv commented on pull request #18356: [hotfix][flink-annotations] Add v1.15 as the next Flink version to master

2022-01-17 Thread GitBox
matriv commented on pull request #18356: URL: https://github.com/apache/flink/pull/18356#issuecomment-1014242940 > This step should be documented in the release guide and/or be automated in the release scripts. Thx for the remark @zentol, We have added this step to the guide

[GitHub] [flink] flinkbot edited a comment on pull request #18368: [FLINK-18356][Azure] Enforce memory limits for docker containers

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18368: URL: https://github.com/apache/flink/pull/18368#issuecomment-1013194055 ## CI report: * 85f29ae74ca544e58ec6c46ba2bad95e0abf861e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18362: [hotfix][Apache Kafka Connector][docs] Fixed kafka.md sink example error

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18362: URL: https://github.com/apache/flink/pull/18362#issuecomment-1012985250 ## CI report: * 5cf7c25f9ab637f5bebb7205e8078c146c5653d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17938: [FLINK-25073][streaming] Introduce TreeMode description for vertices

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #17938: URL: https://github.com/apache/flink/pull/17938#issuecomment-981363546 ## CI report: * ce5293639c33d92109455f6d831678dba9858f83 Azure:

[jira] [Updated] (FLINK-25033) Let some scheduler components updatable

2022-01-17 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-25033: --- Description: Many scheduler components rely on the execution topology to make decisions. Some of

[jira] [Created] (FLINK-25669) Support register operator coordinators for newly initialized ExecutionJobVertex.

2022-01-17 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-25669: -- Summary: Support register operator coordinators for newly initialized ExecutionJobVertex. Key: FLINK-25669 URL: https://issues.apache.org/jira/browse/FLINK-25669

[GitHub] [flink] gaoyunhaii commented on pull request #17938: [FLINK-25073][streaming] Introduce TreeMode description for vertices

2022-01-17 Thread GitBox
gaoyunhaii commented on pull request #17938: URL: https://github.com/apache/flink/pull/17938#issuecomment-1014237851 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Updated] (FLINK-25635) Using sql client create hive catalog throw exception

2022-01-17 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-25635: --- Priority: Blocker (was: Major) > Using sql client create hive catalog throw exception >

[GitHub] [flink-ml] gaoyunhaii closed pull request #55: [hotfix] Remove redundant directories

2022-01-17 Thread GitBox
gaoyunhaii closed pull request #55: URL: https://github.com/apache/flink-ml/pull/55 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #18368: [FLINK-18356][Azure] Enforce memory limits for docker containers

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18368: URL: https://github.com/apache/flink/pull/18368#issuecomment-1013194055 ## CI report: * 85f29ae74ca544e58ec6c46ba2bad95e0abf861e Azure:

[jira] [Created] (FLINK-25668) Support calcuate network memory for dynamic graph.

2022-01-17 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-25668: -- Summary: Support calcuate network memory for dynamic graph. Key: FLINK-25668 URL: https://issues.apache.org/jira/browse/FLINK-25668 Project: Flink Issue Type:

[jira] [Updated] (FLINK-25667) AdaptiveSchedulerTest.testStatusMetrics is not stable

2022-01-17 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25667: Priority: Critical (was: Major) > AdaptiveSchedulerTest.testStatusMetrics is not stable >

<    2   3   4   5   6   7