[GitHub] [flink] zicat commented on a change in pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

zicat commented on a change in pull request #16163: URL: https://github.com/apache/flink/pull/16163#discussion_r657706409 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/BridgingFunctionGenUtil.scala ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #16286: [FLINK-21445] Refactors the PackagedProgramRetriever implementation and adds configuration to PackagedProgram

flinkbot edited a comment on pull request #16286: URL: https://github.com/apache/flink/pull/16286#issuecomment-868270639 ## CI report: * 4cbaee738f213985ae8d6850b36005e0ebafd5bf UNKNOWN * 0556f30737fd827a1b18f9ec585faa1b26a43793 UNKNOWN *

[jira] [Created] (FLINK-23268) [DOCS]The link on page docs/dev/table/sql/queries/match_recognize/ is failed and 404 is returned

wuguihu created FLINK-23268: --- Summary: [DOCS]The link on page docs/dev/table/sql/queries/match_recognize/ is failed and 404 is returned Key: FLINK-23268 URL: https://issues.apache.org/jira/browse/FLINK-23268

[GitHub] [flink] flinkbot edited a comment on pull request #16352: [FLINK-23102][runtime] Accessing FlameGraphs while not being enabled …

flinkbot edited a comment on pull request #16352: URL: https://github.com/apache/flink/pull/16352#issuecomment-872812232 ## CI report: * 650ecc5d383fa6ace3293b5022e964107b99ba01 Azure:

[jira] [Updated] (FLINK-23150) Clean up the old implementation of code splitting

[ https://issues.apache.org/jira/browse/FLINK-23150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-23150: Description: In the third step we clean up the old implementation of code splitting. (was: In

[jira] [Created] (FLINK-23267) Activate Java code splitter for all generated classes

Caizhi Weng created FLINK-23267: --- Summary: Activate Java code splitter for all generated classes Key: FLINK-23267 URL: https://issues.apache.org/jira/browse/FLINK-23267 Project: Flink Issue

[jira] [Commented] (FLINK-22677) Scheduler should invoke ShuffleMaster#registerPartitionWithProducer by a real asynchronous fashion

[ https://issues.apache.org/jira/browse/FLINK-22677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375218#comment-17375218 ] Zhu Zhu commented on FLINK-22677: - One thing need to mention is that I did not change

[jira] [Commented] (FLINK-22677) Scheduler should invoke ShuffleMaster#registerPartitionWithProducer by a real asynchronous fashion

[ https://issues.apache.org/jira/browse/FLINK-22677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375217#comment-17375217 ] Zhu Zhu commented on FLINK-22677: - Problems below could happen if enabling partition registration is

[GitHub] [flink] XComp commented on pull request #16286: [FLINK-21445] Refactors the PackagedProgramRetriever implementation and adds configuration to PackagedProgram

XComp commented on pull request #16286: URL: https://github.com/apache/flink/pull/16286#issuecomment-874463733 I reorganized the commits squashing most of them together and rebased the branch to the most recent `master` -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #16383: [FLINK-22677][runtime] DefaultScheduler supports async registration of produced partitions

flinkbot edited a comment on pull request #16383: URL: https://github.com/apache/flink/pull/16383#issuecomment-874451793 ## CI report: * 2261906218ec3345b677703e3f79511436e5eac9 Azure:

[jira] [Assigned] (FLINK-23126) Refactor smoke-e2e into smoke-e2e-common and smoke-e2e-embedded

[ https://issues.apache.org/jira/browse/FLINK-23126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-23126: --- Assignee: Evans Ye > Refactor smoke-e2e into smoke-e2e-common and

[jira] [Comment Edited] (FLINK-23237) Add log to print data that failed to deserialize when ignore-parse-error=true

[ https://issues.apache.org/jira/browse/FLINK-23237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375188#comment-17375188 ] hehuiyuan edited comment on FLINK-23237 at 7/6/21, 4:54 AM: [~Aiden Gong] 

[jira] [Commented] (FLINK-23126) Refactor smoke-e2e into smoke-e2e-common and smoke-e2e-embedded

[ https://issues.apache.org/jira/browse/FLINK-23126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375213#comment-17375213 ] Tzu-Li (Gordon) Tai commented on FLINK-23126: - Assigning this to [~evans_ye], as he is the

[jira] [Commented] (FLINK-20321) Get NPE when using AvroDeserializationSchema to deserialize null input

[ https://issues.apache.org/jira/browse/FLINK-20321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375211#comment-17375211 ] hehuiyuan commented on FLINK-20321: --- Hi [~jark] , is it considered merging to 1.12? > Get NPE when

[GitHub] [flink] flinkbot edited a comment on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

flinkbot edited a comment on pull request #11877: URL: https://github.com/apache/flink/pull/11877#issuecomment-618273998 ## CI report: * 109e1d36469b537f997a7c844e57e23729a1af21 Azure:

[jira] [Issue Comment Deleted] (FLINK-23237) Add log to print data that failed to deserialize when ignore-parse-error=true

[ https://issues.apache.org/jira/browse/FLINK-23237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-23237: -- Comment: was deleted (was:   CSV format: {code:java} @Override public RowData deserialize(byte[]

[jira] [Commented] (FLINK-10734) Temporal joins on heavily filtered tables might fail in planning

[ https://issues.apache.org/jira/browse/FLINK-10734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375207#comment-17375207 ] Leonard Xu commented on FLINK-10734: [~twalthr] Although the bug still exits in legacy temporal join

[GitHub] [flink] flinkbot commented on pull request #16383: [FLINK-22677][runtime] DefaultScheduler supports async registration of produced partitions

flinkbot commented on pull request #16383: URL: https://github.com/apache/flink/pull/16383#issuecomment-874451793 ## CI report: * 2261906218ec3345b677703e3f79511436e5eac9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16353: [FLINK-23074][connector-hive] Shade parquet class in hive-exec to prevent conflict.

flinkbot edited a comment on pull request #16353: URL: https://github.com/apache/flink/pull/16353#issuecomment-872850709 ## CI report: * 2cfdc338bbed942d0110eec248f2558b6ad80744 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16332: [FLINK-22386] Introduce cache for docker images used during testing

flinkbot edited a comment on pull request #16332: URL: https://github.com/apache/flink/pull/16332#issuecomment-871230385 ## CI report: * 6fbeae06b2487f2c26d447dd2fc11f545c7c30c3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16192: [FLINK-22954][table-planner-blink] Rewrite Join on constant TableFunctionScan to Correlate

flinkbot edited a comment on pull request #16192: URL: https://github.com/apache/flink/pull/16192#issuecomment-863860019 ## CI report: * 5723b973413cc91205872e93e6c876bea2163fde Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

flinkbot edited a comment on pull request #11877: URL: https://github.com/apache/flink/pull/11877#issuecomment-618273998 ## CI report: * 109e1d36469b537f997a7c844e57e23729a1af21 Azure:

[jira] [Closed] (FLINK-23225) There is some mismatches between the current translation and the latest English version on the Flink-Architecture page

[ https://issues.apache.org/jira/browse/FLINK-23225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23225. --- Fix Version/s: 1.14.0 Assignee: wuguihu Resolution: Fixed Fixed in master:

[GitHub] [flink] wuchong merged pull request #16363: [FLINK-23225][doc-zh]Fixed some mismatches in the translation pages

wuchong merged pull request #16363: URL: https://github.com/apache/flink/pull/16363 -- 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:

[jira] [Resolved] (FLINK-22884) Select view columns fail when store metadata with hive

[ https://issues.apache.org/jira/browse/FLINK-22884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-22884. Fix Version/s: 1.13.3 1.14.0 Resolution: Fixed Fixed in master:

[GitHub] [flink] flinkbot edited a comment on pull request #16367: [FLINK-21448][configuration] Randomize ITTests for delegating state backend

flinkbot edited a comment on pull request #16367: URL: https://github.com/apache/flink/pull/16367#issuecomment-873765195 ## CI report: * 45c95095271826d9d9263b914d1a31de36e6bd0e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16353: [FLINK-23074][connector-hive] Shade parquet class in hive-exec to prevent conflict.

flinkbot edited a comment on pull request #16353: URL: https://github.com/apache/flink/pull/16353#issuecomment-872850709 ## CI report: * 2cfdc338bbed942d0110eec248f2558b6ad80744 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16192: [FLINK-22954][table-planner-blink] Rewrite Join on constant TableFunctionScan to Correlate

flinkbot edited a comment on pull request #16192: URL: https://github.com/apache/flink/pull/16192#issuecomment-863860019 ## CI report: * 5723b973413cc91205872e93e6c876bea2163fde Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

flinkbot edited a comment on pull request #16163: URL: https://github.com/apache/flink/pull/16163#issuecomment-861284972 ## CI report: * 00f7cd34fc503db8cc116dd201bcc7f54a4b6f20 UNKNOWN * da303c24e513b0678794526c6351003b6e76cb6d UNKNOWN *

[jira] [Commented] (FLINK-23237) Add log to print data that failed to deserialize when ignore-parse-error=true

[ https://issues.apache.org/jira/browse/FLINK-23237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375189#comment-17375189 ] hehuiyuan commented on FLINK-23237: ---   CSV format: {code:java} @Override public RowData

[jira] [Comment Edited] (FLINK-23237) Add log to print data that failed to deserialize when ignore-parse-error=true

[ https://issues.apache.org/jira/browse/FLINK-23237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375188#comment-17375188 ] hehuiyuan edited comment on FLINK-23237 at 7/6/21, 3:50 AM: [~Aiden Gong] 

[GitHub] [flink] flinkbot commented on pull request #16383: [FLINK-22677][runtime] DefaultScheduler supports async registration of produced partitions

flinkbot commented on pull request #16383: URL: https://github.com/apache/flink/pull/16383#issuecomment-874437979 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Commented] (FLINK-23237) Add log to print data that failed to deserialize when ignore-parse-error=true

[ https://issues.apache.org/jira/browse/FLINK-23237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375188#comment-17375188 ] hehuiyuan commented on FLINK-23237: --- [~Aiden Gong] thanks , code is right.   Additionally, add log

[jira] [Updated] (FLINK-22662) YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint fail

[ https://issues.apache.org/jira/browse/FLINK-22662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22662: - Labels: pull-request-available test-stability (was: pull-request-available stale-assigned

[jira] [Updated] (FLINK-22677) Scheduler should invoke ShuffleMaster#registerPartitionWithProducer by a real asynchronous fashion

[ https://issues.apache.org/jira/browse/FLINK-22677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22677: --- Labels: pull-request-available (was: ) > Scheduler should invoke

[jira] [Updated] (FLINK-23237) Add log to print data that failed to deserialize when ignore-parse-error=true

[ https://issues.apache.org/jira/browse/FLINK-23237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-23237: -- Description: Add log to print error data that failed to deserialize when set `ignore-parse-error` =

[jira] [Updated] (FLINK-23237) Add log to print data that failed to deserialize when ignore-parse-error=true

[ https://issues.apache.org/jira/browse/FLINK-23237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-23237: -- Summary: Add log to print data that failed to deserialize when ignore-parse-error=true (was: Add

[GitHub] [flink] zhuzhurk opened a new pull request #16383: [FLINK-22677][runtime] DefaultScheduler supports async registration of produced partitions

zhuzhurk opened a new pull request #16383: URL: https://github.com/apache/flink/pull/16383 ## What is the purpose of the change This PR is to improve `DefaultScheduler` to support async registration of produced partitions. More details see FLINK-22677. ## Brief change

[GitHub] [flink] zhangyy91 commented on a change in pull request #16367: [FLINK-21448][configuration] Randomize ITTests for delegating state backend

zhangyy91 commented on a change in pull request #16367: URL: https://github.com/apache/flink/pull/16367#discussion_r664216072 ## File path: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java ## @@ -75,36 +81,28 @@

[GitHub] [flink] Zakelly commented on a change in pull request #16341: [FLINK-21804][state/changelog] Create and wire changelog storage with state backend

Zakelly commented on a change in pull request #16341: URL: https://github.com/apache/flink/pull/16341#discussion_r664212980 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/StateChangelogStorageLoader.java ## @@ -18,26 +18,81 @@ package

[jira] [Commented] (FLINK-23219) temproary join ttl configruation does not take effect

[ https://issues.apache.org/jira/browse/FLINK-23219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375181#comment-17375181 ] Caizhi Weng commented on FLINK-23219: - Hi [~waywtdcc]! Thanks for your interest in contributing to

[GitHub] [flink] lirui-apache closed pull request #16149: [FLINK-22884][hive] HiveCatalog should mark views as generic and stor…

lirui-apache closed pull request #16149: URL: https://github.com/apache/flink/pull/16149 -- 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 #16367: [FLINK-21448][configuration] Randomize ITTests for delegating state backend

flinkbot edited a comment on pull request #16367: URL: https://github.com/apache/flink/pull/16367#issuecomment-873765195 ## CI report: * 45c95095271826d9d9263b914d1a31de36e6bd0e Azure:

[GitHub] [flink] JingsongLi commented on a change in pull request #16349: [FLINK-23150][table-planner-blink] Enable Java code splitting for all generated classes

JingsongLi commented on a change in pull request #16349: URL: https://github.com/apache/flink/pull/16349#discussion_r664210234 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/TableConfigOptions.java ## @@ -94,8 +94,16 @@ private

[GitHub] [flink] flinkbot edited a comment on pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

flinkbot edited a comment on pull request #16163: URL: https://github.com/apache/flink/pull/16163#issuecomment-861284972 ## CI report: * 00f7cd34fc503db8cc116dd201bcc7f54a4b6f20 UNKNOWN * da303c24e513b0678794526c6351003b6e76cb6d UNKNOWN *

[GitHub] [flink] zhuzhurk commented on a change in pull request #16173: [FLINK-15031][runtime] Calculate required shuffle memory before allocating slots if resources are specified

zhuzhurk commented on a change in pull request #16173: URL: https://github.com/apache/flink/pull/16173#discussion_r664211331 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/EdgeManagerBuildUtilTest.java ## @@ -0,0 +1,135 @@ +/* + * Licensed

[GitHub] [flink] zhuzhurk commented on a change in pull request #16173: [FLINK-15031][runtime] Calculate required shuffle memory before allocating slots if resources are specified

zhuzhurk commented on a change in pull request #16173: URL: https://github.com/apache/flink/pull/16173#discussion_r664210637 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/EdgeManagerBuildUtilTest.java ## @@ -0,0 +1,135 @@ +/* + * Licensed

[GitHub] [flink] zhuzhurk commented on a change in pull request #16173: [FLINK-15031][runtime] Calculate required shuffle memory before allocating slots if resources are specified

zhuzhurk commented on a change in pull request #16173: URL: https://github.com/apache/flink/pull/16173#discussion_r664210637 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/EdgeManagerBuildUtilTest.java ## @@ -0,0 +1,135 @@ +/* + * Licensed

[GitHub] [flink] Zakelly commented on a change in pull request #16341: [FLINK-21804][state/changelog] Create and wire changelog storage with state backend

Zakelly commented on a change in pull request #16341: URL: https://github.com/apache/flink/pull/16341#discussion_r664210116 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java ## @@ -669,13 +677,18 @@ private void

[GitHub] [flink] Zakelly commented on a change in pull request #16341: [FLINK-21804][state/changelog] Create and wire changelog storage with state backend

Zakelly commented on a change in pull request #16341: URL: https://github.com/apache/flink/pull/16341#discussion_r664210116 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java ## @@ -669,13 +677,18 @@ private void

[jira] [Commented] (FLINK-22752) Add robust default state configuration to StateFun

[ https://issues.apache.org/jira/browse/FLINK-22752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375162#comment-17375162 ] Yun Tang commented on FLINK-22752: -- [~sewen], you could refer to

[GitHub] [flink] Zakelly commented on a change in pull request #16341: [FLINK-21804][state/changelog] Create and wire changelog storage with state backend

Zakelly commented on a change in pull request #16341: URL: https://github.com/apache/flink/pull/16341#discussion_r664208282 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/StateChangelogStorageLoader.java ## @@ -28,16 +34,51 @@ /** A thin

[GitHub] [flink] deadwind4 commented on pull request #16353: [FLINK-23074][connector-hive] Shade parquet class in hive-exec to prevent conflict.

deadwind4 commented on pull request #16353: URL: https://github.com/apache/flink/pull/16353#issuecomment-874428808 @lirui-apache please review it. -- 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

[GitHub] [flink] ZhijieYang commented on a change in pull request #16348: [FLINK-16093][docs-zh]Translate "System Functions" page of "Functions" into Chinese

ZhijieYang commented on a change in pull request #16348: URL: https://github.com/apache/flink/pull/16348#discussion_r664206146 ## File path: docs/data/sql_functions_zh.yml ## @@ -0,0 +1,820 @@ +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor

[GitHub] [flink] zhangyy91 commented on a change in pull request #16367: [FLINK-21448][configuration] Randomize ITTests for delegating state backend

zhangyy91 commented on a change in pull request #16367: URL: https://github.com/apache/flink/pull/16367#discussion_r664206130 ## File path: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java ## @@ -75,36 +81,28 @@

[GitHub] [flink] ZhijieYang commented on a change in pull request #16348: [FLINK-16093][docs-zh]Translate "System Functions" page of "Functions" into Chinese

ZhijieYang commented on a change in pull request #16348: URL: https://github.com/apache/flink/pull/16348#discussion_r664205889 ## File path: docs/content.zh/docs/dev/table/functions/systemFunctions.md ## @@ -24,161 +24,161 @@ specific language governing permissions and

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375153#comment-17375153 ] Xintong Song commented on FLINK-22889: --

[jira] [Commented] (FLINK-22387) UpsertKafkaTableITCase hangs when setting up kafka

[ https://issues.apache.org/jira/browse/FLINK-22387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375154#comment-17375154 ] Xintong Song commented on FLINK-22387: --

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375152#comment-17375152 ] Xintong Song commented on FLINK-22889: --

[jira] [Commented] (FLINK-22195) YARNHighAvailabilityITCase.testClusterClientRetrieval because of TestTimedOutException

[ https://issues.apache.org/jira/browse/FLINK-22195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375151#comment-17375151 ] Xintong Song commented on FLINK-22195: --

[jira] [Commented] (FLINK-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout

[ https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375148#comment-17375148 ] Xintong Song commented on FLINK-22457: --

[jira] [Created] (FLINK-23266) HA per-job cluster (rocks, non-incremental) hangs on Azure

Xintong Song created FLINK-23266: Summary: HA per-job cluster (rocks, non-incremental) hangs on Azure Key: FLINK-23266 URL: https://issues.apache.org/jira/browse/FLINK-23266 Project: Flink

[GitHub] [flink] ZhijieYang commented on a change in pull request #16348: [FLINK-16093][docs-zh]Translate "System Functions" page of "Functions" into Chinese

ZhijieYang commented on a change in pull request #16348: URL: https://github.com/apache/flink/pull/16348#discussion_r664203922 ## File path: docs/content.zh/docs/dev/table/functions/systemFunctions.md ## @@ -24,161 +24,161 @@ specific language governing permissions and

[jira] [Closed] (FLINK-20863) Exclude network memory from ResourceProfile

[ https://issues.apache.org/jira/browse/FLINK-20863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-20863. -- Resolution: Invalid > Exclude network memory from ResourceProfile >

[jira] [Commented] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375144#comment-17375144 ] Ada Wong commented on FLINK-23074: -- I agree > There is a class conflict between flink-connector-hive

[jira] [Updated] (FLINK-23263) LocalBufferPool can not request memory.

[ https://issues.apache.org/jira/browse/FLINK-23263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-23263: - Issue Type: Bug (was: Improvement) > LocalBufferPool can not request memory. >

[jira] [Created] (FLINK-23265) Support evenly spread out in fine-grained resource management

Yangze Guo created FLINK-23265: -- Summary: Support evenly spread out in fine-grained resource management Key: FLINK-23265 URL: https://issues.apache.org/jira/browse/FLINK-23265 Project: Flink

[jira] [Updated] (FLINK-14193) Update Web UI for fine grained TM/Slot resources

[ https://issues.apache.org/jira/browse/FLINK-14193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-14193: --- Parent: FLINK-23264 Issue Type: Sub-task (was: Improvement) > Update Web UI for fine

[jira] [Updated] (FLINK-14193) Update Web UI for fine grained TM/Slot resources

[ https://issues.apache.org/jira/browse/FLINK-14193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-14193: --- Parent: (was: FLINK-21924) Issue Type: Improvement (was: Sub-task) > Update Web UI for

[GitHub] [flink] ZhijieYang commented on a change in pull request #16348: [FLINK-16093][docs-zh]Translate "System Functions" page of "Functions" into Chinese

ZhijieYang commented on a change in pull request #16348: URL: https://github.com/apache/flink/pull/16348#discussion_r664202757 ## File path: docs/content.zh/docs/dev/table/functions/systemFunctions.md ## @@ -24,161 +24,161 @@ specific language governing permissions and

[jira] [Updated] (FLINK-21288) Support redundant task managers for fine grained resource management

[ https://issues.apache.org/jira/browse/FLINK-21288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-21288: --- Parent: FLINK-23264 Issue Type: Sub-task (was: Improvement) > Support redundant task

[GitHub] [flink] RocMarshal commented on a change in pull request #16348: [FLINK-16093][docs-zh]Translate "System Functions" page of "Functions" into Chinese

RocMarshal commented on a change in pull request #16348: URL: https://github.com/apache/flink/pull/16348#discussion_r663860259 ## File path: docs/content.zh/docs/dev/table/functions/systemFunctions.md ## @@ -24,161 +24,161 @@ specific language governing permissions and

[jira] [Created] (FLINK-23264) Fine Grained Resource Management Phase 2

Yangze Guo created FLINK-23264: -- Summary: Fine Grained Resource Management Phase 2 Key: FLINK-23264 URL: https://issues.apache.org/jira/browse/FLINK-23264 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-21288) Support redundant task managers for fine grained resource management

[ https://issues.apache.org/jira/browse/FLINK-21288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-21288: --- Parent: (was: FLINK-21924) Issue Type: Improvement (was: Sub-task) > Support redundant

[jira] [Updated] (FLINK-21924) Fine Grained Resource Management Phase 1

[ https://issues.apache.org/jira/browse/FLINK-21924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-21924: --- Summary: Fine Grained Resource Management Phase 1 (was: Fine Grained Resource Management) > Fine

[jira] [Commented] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375141#comment-17375141 ] Rui Li commented on FLINK-23074: How about just {{org.apache.hive.shaded.parquet}}, as we're relocating

[jira] [Updated] (FLINK-23263) LocalBufferPool can not request memory.

[ https://issues.apache.org/jira/browse/FLINK-23263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-23263: - Description: Flink job is running, bug it can not consume kafka data. This following is exception.

[GitHub] [flink] gaoyunhaii commented on pull request #16351: [FLINK-22972][datastream] Remove StreamOperator#dispose in favour of close and finish

gaoyunhaii commented on pull request #16351: URL: https://github.com/apache/flink/pull/16351#issuecomment-874418272 Very thanks @dawidwys for the updates! The PR LGTM now~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Created] (FLINK-23263) LocalBufferPool can not request memory.

Ada Wong created FLINK-23263: Summary: LocalBufferPool can not request memory. Key: FLINK-23263 URL: https://issues.apache.org/jira/browse/FLINK-23263 Project: Flink Issue Type: Improvement

[GitHub] [flink] lirui-apache commented on pull request #16149: [FLINK-22884][hive] HiveCatalog should mark views as generic and stor…

lirui-apache commented on pull request #16149: URL: https://github.com/apache/flink/pull/16149#issuecomment-874418005 Test has passed in my personal pipeline: https://dev.azure.com/lirui-apache/flink/_build/results?buildId=564=results -- This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #16352: [FLINK-23102][runtime] Accessing FlameGraphs while not being enabled …

flinkbot edited a comment on pull request #16352: URL: https://github.com/apache/flink/pull/16352#issuecomment-872812232 ## CI report: * 907aa7dd533f687a697737778326b7f12b9f389f Azure:

[GitHub] [flink] ZhijieYang commented on a change in pull request #16348: [FLINK-16093][docs-zh]Translate "System Functions" page of "Functions" into Chinese

ZhijieYang commented on a change in pull request #16348: URL: https://github.com/apache/flink/pull/16348#discussion_r664195807 ## File path: docs/content.zh/docs/dev/table/functions/systemFunctions.md ## @@ -24,161 +24,161 @@ specific language governing permissions and

[jira] [Commented] (FLINK-23235) SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375128#comment-17375128 ] Yingjie Cao commented on FLINK-23235: - The error seems to be similar. But FLINK-20010 has been

[jira] [Closed] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-22073. Resolution: Duplicate > ParquetFileCompactionITCase fails on Azure >

[jira] [Commented] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375115#comment-17375115 ] Jingsong Lee commented on FLINK-22073: -- I will close this Jira, feel free to re-open it if the

[jira] [Commented] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375112#comment-17375112 ] Jingsong Lee commented on FLINK-22073: -- It hasn't reappeared for a long time. It should have been

[jira] [Created] (FLINK-23262) FileReadingWatermarkITCase.testWatermarkEmissionWithChaining fails on azure

Xintong Song created FLINK-23262: Summary: FileReadingWatermarkITCase.testWatermarkEmissionWithChaining fails on azure Key: FLINK-23262 URL: https://issues.apache.org/jira/browse/FLINK-23262 Project:

[GitHub] [flink] pltbkd commented on pull request #16357: [FLINK-23209] Introduce HeartbeatListener.notifyTargetUnreachable

pltbkd commented on pull request #16357: URL: https://github.com/apache/flink/pull/16357#issuecomment-874405107 By default the heartbeat timeout is 50s while interval is 10s, so there may not be a significant improvement only to reduce the interval. But I find that the default

[GitHub] [flink] flinkbot edited a comment on pull request #16352: [FLINK-23102][runtime] Accessing FlameGraphs while not being enabled …

flinkbot edited a comment on pull request #16352: URL: https://github.com/apache/flink/pull/16352#issuecomment-872812232 ## CI report: * 907aa7dd533f687a697737778326b7f12b9f389f Azure:

[jira] [Commented] (FLINK-23101) Flame Graphs initial view says it is 18800 days in the past

[ https://issues.apache.org/jira/browse/FLINK-23101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375101#comment-17375101 ] Yao Zhang commented on FLINK-23101: --- Hi [~afedulov] [~NicoK], By fixing FLINK-23102, I realized this

[GitHub] [flink] paul8263 commented on a change in pull request #16352: [FLINK-23102][runtime] Accessing FlameGraphs while not being enabled …

paul8263 commented on a change in pull request #16352: URL: https://github.com/apache/flink/pull/16352#discussion_r664178197 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobVertexFlameGraphHandler.java ## @@ -63,6 +66,7 @@ public

[jira] [Commented] (FLINK-22042) Fix reading bigint(20) UNSIGNED type field cannot be cast

[ https://issues.apache.org/jira/browse/FLINK-22042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375075#comment-17375075 ] Wei Mingzhi commented on FLINK-22042: - This bug still exists and the patch [~jingzi] posted fixes

[GitHub] [flink] rkhachatryan commented on a change in pull request #16367: [FLINK-21448][configuration] Randomize ITTests for delegating state backend

rkhachatryan commented on a change in pull request #16367: URL: https://github.com/apache/flink/pull/16367#discussion_r664170207 ## File path: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java ## @@ -75,36 +81,28

[jira] [Created] (FLINK-23261) StateFun - HTTP State Access Interface

Stephan Ewen created FLINK-23261: Summary: StateFun - HTTP State Access Interface Key: FLINK-23261 URL: https://issues.apache.org/jira/browse/FLINK-23261 Project: Flink Issue Type:

[jira] [Commented] (FLINK-22483) Recover checkpoints when JobMaster gains leadership

[ https://issues.apache.org/jira/browse/FLINK-22483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375056#comment-17375056 ] Eduardo Winpenny Tejedor commented on FLINK-22483: -- Awesome! Let me know what you think

[jira] [Updated] (FLINK-22949) java.io.InvalidClassException With Flink Kafka Beam

[ https://issues.apache.org/jira/browse/FLINK-22949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22949: --- I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community

[jira] [Updated] (FLINK-22787) Fix parse error when input statement has inline comments

[ https://issues.apache.org/jira/browse/FLINK-22787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22787: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-20899) encounter ClassCastException when calculating cost in HepPlanner

[ https://issues.apache.org/jira/browse/FLINK-20899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20899: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-21444) Lookup joins should deal with intermediate table scans correctly

[ https://issues.apache.org/jira/browse/FLINK-21444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21444: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-21648) FLIP-151: Incremental snapshots for heap-based state backend

[ https://issues.apache.org/jira/browse/FLINK-21648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21648: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

  1   2   3   4   5   6   7   >