[GitHub] [flink] masteryhx commented on a diff in pull request #19679: [FLINK-23143][state/changelog] Support state migration for ChangelogS…

masteryhx commented on code in PR #19679: URL: https://github.com/apache/flink/pull/19679#discussion_r920730839 ## flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java: ## @@ -565,18 +568,44 @@ public I

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #215: [FLINK-28533] SchemaChange supports updateColumnNullability and updateColumnComment

JingsongLi commented on code in PR #215: URL: https://github.com/apache/flink-table-store/pull/215#discussion_r920816147 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/schema/SchemaManager.java: ## @@ -172,34 +175,48 @@ public TableSchema commitChanges

[jira] [Commented] (FLINK-24787) Add more details of state latency tracking documentation

[ https://issues.apache.org/jira/browse/FLINK-24787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566670#comment-17566670 ] Hangxiang Yu commented on FLINK-24787: -- We may need to add some descriptions like

[jira] [Commented] (FLINK-26051) one sql has row_number =1 and the subsequent SQL has "case when" and "where" statement result Exception : The window can only be ordered in ASCENDING mode

[ https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1759#comment-1759 ] Jane Chan commented on FLINK-26051: --- Sorry for being late. I will open PR asap. > one

[jira] [Commented] (FLINK-28086) Table Store Catalog supports partition methods

[ https://issues.apache.org/jira/browse/FLINK-28086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1755#comment-1755 ] liwei li commented on FLINK-28086: -- may i have the ticket? > Table Store Catalog suppo

[jira] [Updated] (FLINK-28533) SchemaChange supports updateColumnNullability and updateColumnComment

[ https://issues.apache.org/jira/browse/FLINK-28533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28533: --- Labels: pull-request-available (was: ) > SchemaChange supports updateColumnNullability and

[GitHub] [flink-table-store] LadyForest closed pull request #215: [FLINK-28533] SchemaChange supports updateColumnNullability and updateColumnComment

LadyForest closed pull request #215: [FLINK-28533] SchemaChange supports updateColumnNullability and updateColumnComment URL: https://github.com/apache/flink-table-store/pull/215 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub an

[GitHub] [flink] lincoln-lil commented on pull request #19759: [FLINK-27623][table] Add 'table.exec.async-lookup.output-mode' to ExecutionConfigOptions

lincoln-lil commented on PR #19759: URL: https://github.com/apache/flink/pull/19759#issuecomment-1184042723 @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 specific co

[GitHub] [flink-table-store] pan3793 commented on a diff in pull request #213: [FLINK-28289] Introduce Spark2 Reader for table store

pan3793 commented on code in PR #213: URL: https://github.com/apache/flink-table-store/pull/213#discussion_r920786613 ## flink-table-store-spark2/pom.xml: ## @@ -0,0 +1,109 @@ + + +http://maven.apache.org/POM/4.0.0"; + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance

[GitHub] [flink-table-store] pan3793 commented on a diff in pull request #213: [FLINK-28289] Introduce Spark2 Reader for table store

pan3793 commented on code in PR #213: URL: https://github.com/apache/flink-table-store/pull/213#discussion_r920786017 ## flink-table-store-spark2/pom.xml: ## @@ -0,0 +1,109 @@ + + +http://maven.apache.org/POM/4.0.0"; + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance

[GitHub] [flink] flinkbot commented on pull request #20270: [FLINK-28316][runtime-web] add external JM and TM log links under history server

flinkbot commented on PR #20270: URL: https://github.com/apache/flink/pull/20270#issuecomment-1184028945 ## CI report: * e044893eca6fef9284fe4d47d21d67b7c9dacd81 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] Aitozi commented on pull request #20256: [FLINK-24713][Runtime/Coordination] Postpone resourceManager serving

Aitozi commented on PR #20256: URL: https://github.com/apache/flink/pull/20256#issuecomment-1184028495 @xintongsong please take a look on this PR. It's a new PR based on your suggestion in https://github.com/apache/flink/pull/19840. Also cc @KarmaGYZ Ps: I don't know why the flinkbot have

[GitHub] [flink] yangjunhan commented on pull request #20270: [FLINK-28316][runtime-web] add external JM and TM log links under history server

yangjunhan commented on PR #20270: URL: https://github.com/apache/flink/pull/20270#issuecomment-1184024941 Hi, @simplejason. This would the last subtask related to FLIP-241. Please help review it, thanks! -- This is an automated message from the Apache Git Service. To respond to the messa

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #213: [FLINK-28289] Introduce Spark2 Reader for table store

JingsongLi commented on code in PR #213: URL: https://github.com/apache/flink-table-store/pull/213#discussion_r920773837 ## docs/content/docs/engines/spark2.md: ## @@ -0,0 +1,62 @@ +--- +title: "Spark2" +weight: 4 +type: docs +aliases: +- /engines/spark2.html +--- + + +# Spark2

[jira] [Updated] (FLINK-28316) [UI] add external JM and TM log links under history server

[ https://issues.apache.org/jira/browse/FLINK-28316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28316: --- Labels: pull-request-available (was: ) > [UI] add external JM and TM log links under histor

[GitHub] [flink] yangjunhan opened a new pull request, #20270: [FLINK-28316][runtime-web] add external JM and TM log links under history server

yangjunhan opened a new pull request, #20270: URL: https://github.com/apache/flink/pull/20270 ## What is the purpose of the change This is a subtask referenced to [FLIP-241](https://cwiki.apache.org/confluence/display/FLINK/FLIP-241%3A+Completed+Jobs+Information+Enhancement),

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #213: [FLINK-28289] Introduce Spark2 Reader for table store

JingsongLi commented on code in PR #213: URL: https://github.com/apache/flink-table-store/pull/213#discussion_r920773520 ## docs/content/docs/engines/spark2.md: ## @@ -0,0 +1,62 @@ +--- +title: "Spark2" +weight: 4 +type: docs +aliases: +- /engines/spark2.html +--- + + +# Spark2

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #213: [FLINK-28289] Introduce Spark2 Reader for table store

JingsongLi commented on code in PR #213: URL: https://github.com/apache/flink-table-store/pull/213#discussion_r920772039 ## docs/content/docs/engines/spark2.md: ## @@ -0,0 +1,62 @@ +--- +title: "Spark2" +weight: 4 +type: docs +aliases: +- /engines/spark2.html +--- + + +# Spark2

[jira] [Commented] (FLINK-23487) IRSA doesn't work with S3

[ https://issues.apache.org/jira/browse/FLINK-23487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566648#comment-17566648 ] Sylvia Lin commented on FLINK-23487: Hey, when will the hadoop fix be available? Sin

[GitHub] [flink] 1996fanrui commented on pull request #20137: Just for CI

1996fanrui commented on PR #20137: URL: https://github.com/apache/flink/pull/20137#issuecomment-1184011752 @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 specific comment

[jira] [Commented] (FLINK-24031) I am trying to deploy Flink in kubernetes but when I launch the taskManager in other container I get a Exception

[ https://issues.apache.org/jira/browse/FLINK-24031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566640#comment-17566640 ] Sylvia Lin commented on FLINK-24031: [~wangyang0918] Yeah, i'm using below configMap

[GitHub] [flink] fredia commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

fredia commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r920745521 ## flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java: ## @@ -685,13 +687,27 @@ public CompletableFuture submitTask(

[GitHub] [flink] fredia commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

fredia commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r920723644 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateBackendLocalHandle.java: ## @@ -0,0 +1,116 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [flink] PatrickRen commented on pull request #20266: [FLINK-28250][Connector/Kafka] Fix exactly-once Kafka Sink out of memory (backport for 1.15)

PatrickRen commented on PR #20266: URL: https://github.com/apache/flink/pull/20266#issuecomment-1183975623 @charles-tan It looks like the author and email of the commit is weird (`root` and an internal address). Unfortunately I have merged it on master... Could you update the author and ema

[GitHub] [flink] flinkbot commented on pull request #20269: [FLINK-28548][Connectors / FileSystem] Fix the exception FileNotFoundException when the commit partition base path is not created

flinkbot commented on PR #20269: URL: https://github.com/apache/flink/pull/20269#issuecomment-1183973844 ## CI report: * 523e36049fdce6879da04eac35c9ad531fcdff6e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] PatrickRen merged pull request #20205: [FLINK-28250][Connector/Kafka] Fix exactly-once Kafka Sink out of memory

PatrickRen merged PR #20205: URL: https://github.com/apache/flink/pull/20205 -- 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: issues-unsubscr...@flink.ap

[jira] [Updated] (FLINK-28548) The commit partition base path is not created when no data is sent which may cause FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-28548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28548: --- Labels: pull-request-available (was: ) > The commit partition base path is not created when

[GitHub] [flink] Myracle opened a new pull request, #20269: [FLINK-28548][Connectors / FileSystem] Fix the exception FileNotFoundException when the commit partition base path is not created

Myracle opened a new pull request, #20269: URL: https://github.com/apache/flink/pull/20269 ## What is the purpose of the change *The commit partition base path is not created when no data is sent which may cause FileNotFoundException. Just fix it.* ## Brief change log

[GitHub] [flink] masteryhx commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

masteryhx commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r920736651 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateBackendLocalHandle.java: ## @@ -0,0 +1,116 @@ +/* + * Licensed to the Apache Soft

[jira] [Closed] (FLINK-28315) [UI] Introduce aggregate stats in tables of the subtasks and taskmanagers

[ https://issues.apache.org/jira/browse/FLINK-28315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28315. Resolution: Done master (1.16): 35e557afe9e8392b1b1ebb115f0c7134504b584d > [UI] Introduce aggrega

[GitHub] [flink] xintongsong closed pull request #20260: [FLINK-28315][runtime-web] introduce aggregate stats in tables of the subtasks and taskmanagers

xintongsong closed pull request #20260: [FLINK-28315][runtime-web] introduce aggregate stats in tables of the subtasks and taskmanagers URL: https://github.com/apache/flink/pull/20260 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

[jira] [Closed] (FLINK-28457) Flink add JobStatusHook support

[ https://issues.apache.org/jira/browse/FLINK-28457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-28457. --- Fix Version/s: 1.16.0 Resolution: Fixed > Flink add JobStatusHook support > -

[jira] [Commented] (FLINK-28457) Flink add JobStatusHook support

[ https://issues.apache.org/jira/browse/FLINK-28457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566630#comment-17566630 ] Yun Gao commented on FLINK-28457: - Merged on master via  ed236ee19d7bcaa0e09eff5875880e8

[GitHub] [flink] fredia commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

fredia commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r920731963 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateBackendLocalHandle.java: ## @@ -0,0 +1,116 @@ +/* + * Licensed to the Apache Softwar

[jira] [Assigned] (FLINK-28457) Flink add JobStatusHook support

[ https://issues.apache.org/jira/browse/FLINK-28457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-28457: --- Assignee: tartarus (was: Yun Gao) > Flink add JobStatusHook support >

[jira] [Commented] (FLINK-28499) resource leak when job failed with unknown status In Application Mode

[ https://issues.apache.org/jira/browse/FLINK-28499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566629#comment-17566629 ] Yang Wang commented on FLINK-28499: --- BTW, if the JobManager pod did not crash backoff

[jira] [Assigned] (FLINK-28457) Flink add JobStatusHook support

[ https://issues.apache.org/jira/browse/FLINK-28457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-28457: --- Assignee: Yun Gao > Flink add JobStatusHook support > --- > >

[GitHub] [flink] fredia commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

fredia commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r920731963 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateBackendLocalHandle.java: ## @@ -0,0 +1,116 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [flink] masteryhx commented on a diff in pull request #19679: [FLINK-23143][state/changelog] Support state migration for ChangelogS…

masteryhx commented on code in PR #19679: URL: https://github.com/apache/flink/pull/19679#discussion_r920731156 ## flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java: ## @@ -565,18 +568,44 @@ public I

[GitHub] [flink] gaoyunhaii closed pull request #20223: [FLINK-28457][runtime] Introduce JobStatusHook

gaoyunhaii closed pull request #20223: [FLINK-28457][runtime] Introduce JobStatusHook URL: https://github.com/apache/flink/pull/20223 -- 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 com

[GitHub] [flink] flinkbot commented on pull request #20268: [FLINK-26853][state] Update state serializer in StateMap when metaInfo changed

flinkbot commented on PR #20268: URL: https://github.com/apache/flink/pull/20268#issuecomment-1183961521 ## CI report: * 62ff65b50f51e28f1888c93578d0a45ae89e0526 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] masteryhx commented on a diff in pull request #19679: [FLINK-23143][state/changelog] Support state migration for ChangelogS…

masteryhx commented on code in PR #19679: URL: https://github.com/apache/flink/pull/19679#discussion_r920730839 ## flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java: ## @@ -565,18 +568,44 @@ public I

[jira] [Created] (FLINK-28548) The commit partition base path is not created when no data is sent which may cause FileNotFoundException

Liu created FLINK-28548: --- Summary: The commit partition base path is not created when no data is sent which may cause FileNotFoundException Key: FLINK-28548 URL: https://issues.apache.org/jira/browse/FLINK-28548

[jira] [Commented] (FLINK-28499) resource leak when job failed with unknown status In Application Mode

[ https://issues.apache.org/jira/browse/FLINK-28499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566628#comment-17566628 ] Yang Wang commented on FLINK-28499: --- I believe the Flink ResourceManager will not allo

[GitHub] [flink] masteryhx commented on a diff in pull request #19679: [FLINK-23143][state/changelog] Support state migration for ChangelogS…

masteryhx commented on code in PR #19679: URL: https://github.com/apache/flink/pull/19679#discussion_r920729213 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java: ## @@ -163,6 +170,32 @@ KeyGroupedInternalPriorityQueue create(

[jira] [Updated] (FLINK-26853) HeapStateBackend ignores metadata updates in certain cases

[ https://issues.apache.org/jira/browse/FLINK-26853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26853: --- Labels: pull-request-available (was: ) > HeapStateBackend ignores metadata updates in certa

[GitHub] [flink] masteryhx opened a new pull request, #20268: [FLINK-26853][state] Update state serializer in StateMap when metaInfo changed

masteryhx opened a new pull request, #20268: URL: https://github.com/apache/flink/pull/20268 ## What is the purpose of the change This pull request makes the state serializer in `StateMap` could be updated when the `RegisteredKeyValueStateBackendMetaInfo` in `StateTable` h

[GitHub] [flink] fredia commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

fredia commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r920723644 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateBackendLocalHandle.java: ## @@ -0,0 +1,116 @@ +/* + * Licensed to the Apache Softwar

[jira] [Closed] (FLINK-28536) Adds an internal postOptimize method for physical dag processing

[ https://issues.apache.org/jira/browse/FLINK-28536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-28536. -- Resolution: Fixed Fixed in master: 2073bd81d2ba5b17b5ab214d69ff022f177fe057 > Adds an internal postOp

[jira] [Updated] (FLINK-28547) Add IT cases for SpeculativeScheduler

[ https://issues.apache.org/jira/browse/FLINK-28547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-28547: --- Component/s: Runtime / Coordination > Add IT cases for SpeculativeScheduler > --

[jira] [Updated] (FLINK-28547) Add IT cases for SpeculativeScheduler

[ https://issues.apache.org/jira/browse/FLINK-28547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-28547: --- Fix Version/s: 1.16.0 > Add IT cases for SpeculativeScheduler >

[jira] [Created] (FLINK-28547) Add IT cases for SpeculativeScheduler

Lijie Wang created FLINK-28547: -- Summary: Add IT cases for SpeculativeScheduler Key: FLINK-28547 URL: https://issues.apache.org/jira/browse/FLINK-28547 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-27849) Harden correctness for non-deterministic updates present in the changelog pipeline

[ https://issues.apache.org/jira/browse/FLINK-27849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27849: Description: There commonly exists updates(which means not only RowKind.INSERT messages) in a str

[jira] [Commented] (FLINK-28539) Enable CompactionDynamicLevelBytes in FLASH_SSD_OPTIMIZED

[ https://issues.apache.org/jira/browse/FLINK-28539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566618#comment-17566618 ] Yanfei Lei commented on FLINK-28539: hi [~usamj] , you can use `setLevelCompactionDy

[jira] [Created] (FLINK-28546) Add the release logic for py39 and m1 wheel package

Huang Xingbo created FLINK-28546: Summary: Add the release logic for py39 and m1 wheel package Key: FLINK-28546 URL: https://issues.apache.org/jira/browse/FLINK-28546 Project: Flink Issue Typ

[jira] [Closed] (FLINK-28486) [docs-zh] Flink FileSystem SQL Connector Doc is not right

[ https://issues.apache.org/jira/browse/FLINK-28486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28486. Fix Version/s: 1.16.0 1.15.2 Resolution: Fixed master: 2124280084243c5d4

[GitHub] [flink] JingsongLi merged pull request #20255: [FLINK-28486][docs-zh] Flink FileSystem SQL Connector Doc is not right

JingsongLi merged PR #20255: URL: https://github.com/apache/flink/pull/20255 -- 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: issues-unsubscr...@flink.ap

[GitHub] [flink] JingsongLi commented on pull request #20255: [FLINK-28486][docs-zh] Flink FileSystem SQL Connector Doc is not right

JingsongLi commented on PR #20255: URL: https://github.com/apache/flink/pull/20255#issuecomment-1183932327 Thanks for the update, looks good to me! -- 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

[jira] [Closed] (FLINK-28285) Push filter into orc reader

[ https://issues.apache.org/jira/browse/FLINK-28285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28285. Resolution: Fixed master: 088955f72bddf8134934dfd21152e1933c0cab77 > Push filter into orc reader

[jira] [Commented] (FLINK-24031) I am trying to deploy Flink in kubernetes but when I launch the taskManager in other container I get a Exception

[ https://issues.apache.org/jira/browse/FLINK-24031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566612#comment-17566612 ] Yang Wang commented on FLINK-24031: --- Please make sure that the JobManager akka is list

[jira] [Commented] (FLINK-28198) CassandraConnectorITCase fails with timeout

[ https://issues.apache.org/jira/browse/FLINK-28198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566611#comment-17566611 ] Huang Xingbo commented on FLINK-28198: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink-kubernetes-operator] bgeng777 commented on a diff in pull request #317: [FLINK-28485][doc] Structure examples better and add README/doc

bgeng777 commented on code in PR #317: URL: https://github.com/apache/flink-kubernetes-operator/pull/317#discussion_r920706291 ## examples/README.md: ## @@ -0,0 +1,167 @@ + + +# Flink Kubernetes Operator Examples + +## Overview + +This directory contains few examples for the Fl

[GitHub] [flink-table-store] JingsongLi merged pull request #212: [FLINK-28285] Push filter into orc reader

JingsongLi merged PR #212: URL: https://github.com/apache/flink-table-store/pull/212 -- 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: issues-unsubscr...@

[jira] [Commented] (FLINK-28545) FlinkKafkaProducerITCase.testRestoreToCheckpointAfterExceedingProducersPool failed with TimeoutException: Topic flink-kafka-producer-fail-before-notify not present in

[ https://issues.apache.org/jira/browse/FLINK-28545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566608#comment-17566608 ] Huang Xingbo commented on FLINK-28545: -- cc [~renqs] > FlinkKafkaProducerITCase.tes

[jira] [Created] (FLINK-28545) FlinkKafkaProducerITCase.testRestoreToCheckpointAfterExceedingProducersPool failed with TimeoutException: Topic flink-kafka-producer-fail-before-notify not present in m

Huang Xingbo created FLINK-28545: Summary: FlinkKafkaProducerITCase.testRestoreToCheckpointAfterExceedingProducersPool failed with TimeoutException: Topic flink-kafka-producer-fail-before-notify not present in metadata after 6 ms

[jira] [Updated] (FLINK-28525) HiveDialectITCase.testTableWithSubDirsInPartitionDir failed with AssertJMultipleFailuresError

[ https://issues.apache.org/jira/browse/FLINK-28525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28525: - Fix Version/s: 1.16.0 > HiveDialectITCase.testTableWithSubDirsInPartitionDir failed with > Asse

[GitHub] [flink] zoltar9264 commented on a diff in pull request #20103: [FLINK-28178][runtime-web] Show the delegated StateBackend and whethe…

zoltar9264 commented on code in PR #20103: URL: https://github.com/apache/flink/pull/20103#discussion_r920699386 ## flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ArchivedExecutionGraph.java: ## @@ -391,6 +400,7 @@ public static ArchivedExecutionGraph creat

[GitHub] [flink] zoltar9264 commented on a diff in pull request #20103: [FLINK-28178][runtime-web] Show the delegated StateBackend and whethe…

zoltar9264 commented on code in PR #20103: URL: https://github.com/apache/flink/pull/20103#discussion_r920700958 ## flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/AccessExecutionGraph.java: ## @@ -176,6 +176,13 @@ public interface AccessExecutionGraph extend

[GitHub] [flink] zoltar9264 commented on a diff in pull request #20103: [FLINK-28178][runtime-web] Show the delegated StateBackend and whethe…

zoltar9264 commented on code in PR #20103: URL: https://github.com/apache/flink/pull/20103#discussion_r920700958 ## flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/AccessExecutionGraph.java: ## @@ -176,6 +176,13 @@ public interface AccessExecutionGraph extend

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #213: [FLINK-28289] Introduce Spark2 Reader for table store

JingsongLi commented on code in PR #213: URL: https://github.com/apache/flink-table-store/pull/213#discussion_r920695866 ## flink-table-store-spark2/pom.xml: ## @@ -0,0 +1,135 @@ + + +http://maven.apache.org/POM/4.0.0"; + xmlns:xsi="http://www.w3.org/2001/XMLSchema-insta

[GitHub] [flink] bgeng777 commented on a diff in pull request #19065: [FLINK-26047][yarn] Support usrlib in HDFS for YARN application mode

bgeng777 commented on code in PR #19065: URL: https://github.com/apache/flink/pull/19065#discussion_r920289017 ## flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNApplicationITCase.java: ## @@ -88,6 +88,22 @@ void testApplicationClusterWithRemoteUserJar() throws Excepti

[GitHub] [flink] zoltar9264 commented on a diff in pull request #20103: [FLINK-28178][runtime-web] Show the delegated StateBackend and whethe…

zoltar9264 commented on code in PR #20103: URL: https://github.com/apache/flink/pull/20103#discussion_r920699386 ## flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ArchivedExecutionGraph.java: ## @@ -391,6 +400,7 @@ public static ArchivedExecutionGraph creat

[jira] [Commented] (FLINK-28198) CassandraConnectorITCase fails with timeout

[ https://issues.apache.org/jira/browse/FLINK-28198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566590#comment-17566590 ] Huang Xingbo commented on FLINK-28198: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-28529) ChangelogPeriodicMaterializationSwitchStateBackendITCase.testSwitchFromDisablingToEnablingInClaimMode failed with CheckpointException: Checkpoint expired before comple

[ https://issues.apache.org/jira/browse/FLINK-28529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566585#comment-17566585 ] Huang Xingbo commented on FLINK-28529: -- Anther failed instance https://dev.azure.c

[jira] [Commented] (FLINK-28495) Fix typos or mistakes of Flink CEP Document in the official website

[ https://issues.apache.org/jira/browse/FLINK-28495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566586#comment-17566586 ] Biao Geng commented on FLINK-28495: --- [~martijnvisser] Sure. I can take this ticket. >

[GitHub] [flink] godfreyhe closed pull request #20262: [FLINK-28536][table-planner] Adds an internal postOptimize method for physical dag processing

godfreyhe closed pull request #20262: [FLINK-28536][table-planner] Adds an internal postOptimize method for physical dag processing URL: https://github.com/apache/flink/pull/20262 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[GitHub] [flink-table-store] tsreaper commented on a diff in pull request #212: [FLINK-28285] Push filter into orc reader

tsreaper commented on code in PR #212: URL: https://github.com/apache/flink-table-store/pull/212#discussion_r920696233 ## flink-table-store-core/src/test/java/org/apache/flink/table/store/table/WritePreemptMemoryTest.java: ## @@ -60,6 +60,10 @@ public void writeSinglePartition()

[jira] [Commented] (FLINK-26721) PulsarSourceITCase.testSavepoint failed on azure pipeline

[ https://issues.apache.org/jira/browse/FLINK-26721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566582#comment-17566582 ] Huang Xingbo commented on FLINK-26721: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Closed] (FLINK-24788) Report RocksDB statistics as metrics

[ https://issues.apache.org/jira/browse/FLINK-24788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-24788. Resolution: Fixed > Report RocksDB statistics as metrics > > >

[jira] [Closed] (FLINK-27703) FileChannelManagerImplTest.testDirectoriesCleanupOnKillWithoutCallerHook failed with The marker file was not found within 10000 msecs

[ https://issues.apache.org/jira/browse/FLINK-27703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo closed FLINK-27703. Resolution: Fixed Thanks [~gaoyunhaii] for the investigation. Merged the commit 4f7ebbb4f91ad27aa

[jira] [Resolved] (FLINK-24786) Introduce RocksDB's statistics related options

[ https://issues.apache.org/jira/browse/FLINK-24786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-24786. -- Resolution: Fixed merged in master: 46e0014d3fe9be9af5f1fd75dc03dcc967a7fb4a > Introduce RocksDB's st

[GitHub] [flink] Myasuka merged pull request #19701: [FLINK-24786][state] Introduce and expose RocksDB statistics as metrics

Myasuka merged PR #19701: URL: https://github.com/apache/flink/pull/19701 -- 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: issues-unsubscr...@flink.apach

[GitHub] [flink] Myasuka commented on pull request #19701: [FLINK-24786][state] Introduce and expose RocksDB statistics as metrics

Myasuka commented on PR #19701: URL: https://github.com/apache/flink/pull/19701#issuecomment-1183909941 @masteryhx Thanks for the review, and I will merge this PR since the CI is green finally. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] 1996fanrui commented on pull request #20233: [FLINK-28474][checkpoint] Fix the bug ChannelStateWriteResult might not fail after checkpoint abort

1996fanrui commented on PR #20233: URL: https://github.com/apache/flink/pull/20233#issuecomment-1183909068 @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 specific comment

[GitHub] [flink] HuangXingBo closed pull request #20239: [FLINK-27703][core] Extend timeout and add logs for FileChannelManagerImplTest

HuangXingBo closed pull request #20239: [FLINK-27703][core] Extend timeout and add logs for FileChannelManagerImplTest URL: https://github.com/apache/flink/pull/20239 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

[jira] [Closed] (FLINK-28525) HiveDialectITCase.testTableWithSubDirsInPartitionDir failed with AssertJMultipleFailuresError

[ https://issues.apache.org/jira/browse/FLINK-28525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo closed FLINK-28525. Resolution: Fixed Merged into master via f23ae51fa4f28d7ca4d8c194ac6fc1a05fb5515c > HiveDialectIT

[GitHub] [flink] HuangXingBo closed pull request #20259: [FLINK-28525][hive] Fix unstable test for HiveDialectITCase#testTableWithSubDirsInPartitionDir

HuangXingBo closed pull request #20259: [FLINK-28525][hive] Fix unstable test for HiveDialectITCase#testTableWithSubDirsInPartitionDir URL: https://github.com/apache/flink/pull/20259 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[jira] [Updated] (FLINK-28316) [UI] add external JM and TM log links under history server

[ https://issues.apache.org/jira/browse/FLINK-28316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junhan Yang updated FLINK-28316: Summary: [UI] add external JM and TM log links under history server (was: [UI] add external taskm

[GitHub] [flink] lincoln-lil commented on a diff in pull request #19759: [FLINK-27623][table] Add 'table.exec.async-lookup.output-mode' to ExecutionConfigOptions

lincoln-lil commented on code in PR #19759: URL: https://github.com/apache/flink/pull/19759#discussion_r920650717 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecLookupJoin.java: ## @@ -46,7 +46,7 @@ public BatchExec

[GitHub] [flink] HuangXingBo commented on pull request #19864: [FLINK-27162][runtime] Trigger non-periodic checkpoint in 'timer' thread

HuangXingBo commented on PR #19864: URL: https://github.com/apache/flink/pull/19864#issuecomment-1183896134 Hi @akalash , could you rebase master and push again? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] zoltar9264 commented on a diff in pull request #20103: [FLINK-28178][runtime-web] Show the delegated StateBackend and whethe…

zoltar9264 commented on code in PR #20103: URL: https://github.com/apache/flink/pull/20103#discussion_r920678551 ## flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java: ## @@ -65,6 +65,8 @@ public class CheckpointConfigInfo im

[GitHub] [flink] zoltar9264 commented on a diff in pull request #20103: [FLINK-28178][runtime-web] Show the delegated StateBackend and whethe…

zoltar9264 commented on code in PR #20103: URL: https://github.com/apache/flink/pull/20103#discussion_r920675336 ## flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/AccessExecutionGraph.java: ## @@ -176,6 +176,13 @@ public interface AccessExecutionGraph extend

[jira] [Updated] (FLINK-27162) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed on azure

[ https://issues.apache.org/jira/browse/FLINK-27162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-27162: - Priority: Critical (was: Major) > RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeye

[jira] [Commented] (FLINK-27162) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed on azure

[ https://issues.apache.org/jira/browse/FLINK-27162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566575#comment-17566575 ] Huang Xingbo commented on FLINK-27162: -- another instance https://dev.azure.com/apa

[jira] [Created] (FLINK-28544) Elasticsearch6SinkE2ECase failed with no space left on device

Huang Xingbo created FLINK-28544: Summary: Elasticsearch6SinkE2ECase failed with no space left on device Key: FLINK-28544 URL: https://issues.apache.org/jira/browse/FLINK-28544 Project: Flink

[GitHub] [flink] xintongsong commented on pull request #20260: [FLINK-28315][runtime-web] introduce aggregate stats in tables of the subtasks and taskmanagers

xintongsong commented on PR #20260: URL: https://github.com/apache/flink/pull/20260#issuecomment-1183864392 @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 specific commen

[GitHub] [flink] lincoln-lil commented on pull request #20262: [FLINK-28536][table-planner] Adds an internal postOptimize method for physical dag processing

lincoln-lil commented on PR #20262: URL: https://github.com/apache/flink/pull/20262#issuecomment-1183863653 @godfreyhe thank you for reviewing this! I've updated the pr according to your comments. -- This is an automated message from the Apache Git Service. To respond to the message, ple

[jira] [Closed] (FLINK-27376) Hive dialect supports "select current_database()"

[ https://issues.apache.org/jira/browse/FLINK-27376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-27376. - Resolution: Implemented Merged in the master: 641fb893a3e3bc7478413984c3287fcdb56ad845 > Hive d

[jira] [Assigned] (FLINK-27376) Hive dialect supports "select current_database()"

[ https://issues.apache.org/jira/browse/FLINK-27376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-27376: - Assignee: luoyuxia > Hive dialect supports "select current_database()" > --

[GitHub] [flink] fsk119 merged pull request #19218: [FLINK-27376][sql] Support current_database function

fsk119 merged PR #19218: URL: https://github.com/apache/flink/pull/19218 -- 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: issues-unsubscr...@flink.apache

  1   2   3   4   >