[GitHub] [flink-web] gaoyunhaii commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

gaoyunhaii commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r861503193 ## _posts/2022-04-26-1.15-announcement.md: ## @@ -0,0 +1,434 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-04

[GitHub] [flink] Tartarus0zm commented on pull request #19608: [FLINK-27450][hive][JDK11]SessionState can't be initialized due to classloader

Tartarus0zm commented on PR #19608: URL: https://github.com/apache/flink/pull/19608#issuecomment-1112930329 @wuchong @luoyuxia @beyond1920 please take a look if you have time, thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink-web] infoverload commented on a diff in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

infoverload commented on code in PR #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r861495533 ## _posts/2022-03-16-async-sink-base.md: ## @@ -0,0 +1,160 @@ +--- +layout: post +title: "The Generic Asynchronous Base Sink" +date: 2022-04-05 16:00:00 +authors: +-

[GitHub] [flink-web] infoverload commented on a diff in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

infoverload commented on code in PR #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r861497710 ## _posts/2022-03-16-async-sink-base.md: ## @@ -0,0 +1,160 @@ +--- +layout: post +title: "The Generic Asynchronous Base Sink" +date: 2022-04-05 16:00:00 Review Comm

[GitHub] [flink-web] infoverload commented on a diff in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

infoverload commented on code in PR #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r861497594 ## _posts/2022-03-16-async-sink-base.md: ## @@ -0,0 +1,160 @@ +--- +layout: post +title: "The Generic Asynchronous Base Sink" +date: 2022-04-05 16:00:00 +authors: +-

[GitHub] [flink] flinkbot commented on pull request #19608: [FLINK-27450][hive][JDK11]SessionState can't be initialized due to classloader

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

[jira] [Commented] (FLINK-27450) [JDK 11] Hive SessionState can't be initialized due to classloader problem

[ https://issues.apache.org/jira/browse/FLINK-27450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529814#comment-17529814 ] tartarus commented on FLINK-27450: -- [~jark] please assign to me, I will create a pr to

[GitHub] [flink-web] infoverload commented on a diff in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

infoverload commented on code in PR #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r861494065 ## _posts/2022-03-16-async-sink-base.md: ## @@ -0,0 +1,160 @@ +--- +layout: post +title: "The Generic Asynchronous Base Sink" +date: 2022-04-05 16:00:00 +authors: +-

[jira] [Updated] (FLINK-27450) [JDK 11] Hive SessionState can't be initialized due to classloader problem

[ https://issues.apache.org/jira/browse/FLINK-27450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27450: --- Labels: pull-request-available (was: ) > [JDK 11] Hive SessionState can't be initialized du

[GitHub] [flink-kubernetes-operator] SteNicholas commented on pull request #189: [FLINK-27422] Do not create temporary pod template files for JobManager and TaskManager if not configured explicitly

SteNicholas commented on PR #189: URL: https://github.com/apache/flink-kubernetes-operator/pull/189#issuecomment-1112924525 @wangyang0918 , PTAL. -- 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

[GitHub] [flink] Tartarus0zm opened a new pull request, #19608: [FLINK-27450][hive][JDK11]SessionState can't be initialized due to classloader

Tartarus0zm opened a new pull request, #19608: URL: https://github.com/apache/flink/pull/19608 ## What is the purpose of the change Refer to [HIVE-21237](https://issues.apache.org/jira/browse/HIVE-21237), choose hive version 2.3.7 to support jdk11 ## Brief change log * u

[GitHub] [flink-web] infoverload commented on a diff in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

infoverload commented on code in PR #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r861494550 ## _posts/2022-03-16-async-sink-base.md: ## @@ -0,0 +1,160 @@ +--- +layout: post +title: "The Generic Asynchronous Base Sink" +date: 2022-04-05 16:00:00 +authors: +-

[GitHub] [flink-web] infoverload commented on a diff in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

infoverload commented on code in PR #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r861494189 ## _posts/2022-03-16-async-sink-base.md: ## @@ -0,0 +1,160 @@ +--- +layout: post +title: "The Generic Asynchronous Base Sink" +date: 2022-04-05 16:00:00 +authors: +-

[jira] [Created] (FLINK-27450) [JDK 11] Hive SessionState can't be initialized due to classloader problem

tartarus created FLINK-27450: Summary: [JDK 11] Hive SessionState can't be initialized due to classloader problem Key: FLINK-27450 URL: https://issues.apache.org/jira/browse/FLINK-27450 Project: Flink

[jira] [Updated] (FLINK-25636) FLIP-199: Change some default config values of blocking shuffle for better usability

[ https://issues.apache.org/jira/browse/FLINK-25636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-25636: Release Note: Since 1.15, sort-shuffle has become the default blocking shuffle implementation and

[jira] [Updated] (FLINK-25636) FLIP-199: Change some default config values of blocking shuffle for better usability

[ https://issues.apache.org/jira/browse/FLINK-25636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-25636: Release Note: Since 1.15, sort-shuffle has become the default blocking shuffle implementation and

[jira] [Updated] (FLINK-25636) FLIP-199: Change some default config values of blocking shuffle for better usability

[ https://issues.apache.org/jira/browse/FLINK-25636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-25636: Release Note: Since 1.15, sort-shuffle has become the default blocking shuffle implementation and

[jira] [Updated] (FLINK-25636) FLIP-199: Change some default config values of blocking shuffle for better usability

[ https://issues.apache.org/jira/browse/FLINK-25636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-25636: Release Note: Since 1.15, sort-shuffle has become the default blocking shuffle implementation and

[jira] [Updated] (FLINK-25636) FLIP-199: Change some default config values of blocking shuffle for better usability

[ https://issues.apache.org/jira/browse/FLINK-25636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-25636: Release Note: Since 1.15, sort-shuffle has become the default blocking shuffle implementation and

[jira] [Commented] (FLINK-27434) How to convert 'Schema' to 'ResolvedSchema' within 'Catalog'?

[ https://issues.apache.org/jira/browse/FLINK-27434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529795#comment-17529795 ] Shengkai Fang commented on FLINK-27434: --- Why are you plan to get the memeber from

[jira] [Assigned] (FLINK-25447) batch query cannot generate plan when a sorted view into multi sinks

[ https://issues.apache.org/jira/browse/FLINK-25447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25447: -- Assignee: Zheng yunhong > batch query cannot generate plan when a sorted view into multi sink

[jira] [Closed] (FLINK-27417) Flink JDBC SQL Connector：SELECT * FROM table WHERE co > 100; mysql will execute SELECT * FROM table to scan the whole table

[ https://issues.apache.org/jira/browse/FLINK-27417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-27417. - Resolution: Duplicate > Flink JDBC SQL Connector：SELECT * FROM table WHERE co > 100; mysql will

[jira] [Commented] (FLINK-27417) Flink JDBC SQL Connector：SELECT * FROM table WHERE co > 100; mysql will execute SELECT * FROM table to scan the whole table

[ https://issues.apache.org/jira/browse/FLINK-27417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529784#comment-17529784 ] Shengkai Fang commented on FLINK-27417: --- [~haojiawei] I think it's not a bug just

[GitHub] [flink] fsk119 commented on pull request #19498: [FLINK-26588][docs]Translate the new CAST documentation to Chinese

fsk119 commented on PR #19498: URL: https://github.com/apache/flink/pull/19498#issuecomment-1112900350 Could you share the screen snapshot about the doc you modified? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] fsk119 commented on pull request #19498: [FLINK-26588][docs]Translate the new CAST documentation to Chinese

fsk119 commented on PR #19498: URL: https://github.com/apache/flink/pull/19498#issuecomment-1112900057 Sorry for the late response. I will review it soon.. -- 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

[GitHub] [flink-docker] gaoyunhaii closed pull request #114: Merge adjacent RUN commands to avoid too much levels

gaoyunhaii closed pull request #114: Merge adjacent RUN commands to avoid too much levels URL: https://github.com/apache/flink-docker/pull/114 -- 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 spe

[GitHub] [flink-docker] gaoyunhaii commented on pull request #114: Merge adjacent RUN commands to avoid too much levels

gaoyunhaii commented on PR #114: URL: https://github.com/apache/flink-docker/pull/114#issuecomment-1112898263 Thanks @zhuzhurk for the review! Merged~ -- 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

[jira] [Commented] (FLINK-27449) The comment is lost when creating a Table from Datastream and Schema

[ https://issues.apache.org/jira/browse/FLINK-27449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529781#comment-17529781 ] Shengkai Fang commented on FLINK-27449: --- Hi, [~Yu.an]. You can open a PR to fix it

[jira] [Commented] (FLINK-27435) Kubernetes Operator keeps savepoint history

[ https://issues.apache.org/jira/browse/FLINK-27435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529778#comment-17529778 ] Gyula Fora commented on FLINK-27435: Do you think we should add this to the status o

[GitHub] [flink] WencongLiu closed pull request #19596: [FLINK-25970][core] Add type of original exception to the detailMessage of SerializedThrowable.

WencongLiu closed pull request #19596: [FLINK-25970][core] Add type of original exception to the detailMessage of SerializedThrowable. URL: https://github.com/apache/flink/pull/19596 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[GitHub] [flink] xintongsong commented on pull request #19596: [FLINK-25970][core] Add type of original exception to the detailMessage of SerializedThrowable.

xintongsong commented on PR #19596: URL: https://github.com/apache/flink/pull/19596#issuecomment-1112879304 And you should not open a PR to `release-1.14.3-rc1`. Normally PRs should be opened to the `master` branch. -- This is an automated message from the Apache Git Service. To respond t

[GitHub] [flink] xintongsong commented on pull request #19596: [FLINK-25970][core] Add type of original exception to the detailMessage of SerializedThrowable.

xintongsong commented on PR #19596: URL: https://github.com/apache/flink/pull/19596#issuecomment-1112878445 Hi @WencongLiu, I think the code changes show that you've understood the issue correctly. I have mainly two comments: 1. I'm not sure about the `className(message)` format. Notic

[jira] [Closed] (FLINK-25636) FLIP-199: Change some default config values of blocking shuffle for better usability

[ https://issues.apache.org/jira/browse/FLINK-25636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-25636. --- Release Note: Since 1.15, sort-shuffle has become the default blocking shuffle implementation and sh

[jira] [Commented] (FLINK-27444) Create standalone mode ClusterDescriptor

[ https://issues.apache.org/jira/browse/FLINK-27444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529760#comment-17529760 ] Gyula Fora commented on FLINK-27444: What do we mean here? There is already a Standa

[jira] [Commented] (FLINK-26497) Cast Exception when use split agg with multiple filters

[ https://issues.apache.org/jira/browse/FLINK-26497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529757#comment-17529757 ] Jingsong Lee commented on FLINK-26497: -- [~337361...@qq.com] Done, thanks! > Cast E

[jira] [Assigned] (FLINK-26497) Cast Exception when use split agg with multiple filters

[ https://issues.apache.org/jira/browse/FLINK-26497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-26497: Assignee: Yunhong Zheng > Cast Exception when use split agg with multiple filters > -

[jira] [Reopened] (FLINK-25636) FLIP-199: Change some default config values of blocking shuffle for better usability

[ https://issues.apache.org/jira/browse/FLINK-25636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao reopened FLINK-25636: - > FLIP-199: Change some default config values of blocking shuffle for better > usability >

[jira] [Comment Edited] (FLINK-27449) The comment is lost when creating a Table from Datastream and Schema

[ https://issues.apache.org/jira/browse/FLINK-27449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529749#comment-17529749 ] Yuan Huang edited comment on FLINK-27449 at 4/29/22 4:00 AM:

[jira] [Commented] (FLINK-27449) The comment is lost when creating a Table from Datastream and Schema

[ https://issues.apache.org/jira/browse/FLINK-27449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529749#comment-17529749 ] Yuan Huang commented on FLINK-27449: - Thank you for your reply. So since it is a bu

[jira] [Commented] (FLINK-27449) The comment is lost when creating a Table from Datastream and Schema

[ https://issues.apache.org/jira/browse/FLINK-27449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529745#comment-17529745 ] Shengkai Fang commented on FLINK-27449: --- Hi. Thanks for your report. I think it's

[jira] [Commented] (FLINK-26497) Cast Exception when use split agg with multiple filters

[ https://issues.apache.org/jira/browse/FLINK-26497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529744#comment-17529744 ] Yunhong Zheng commented on FLINK-26497: --- Hi [~lzljs3620320] , could you assign thi

[jira] [Commented] (FLINK-25242) UDF with primitive int argument does not accept int values even after a not null filter

[ https://issues.apache.org/jira/browse/FLINK-25242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529743#comment-17529743 ] Yunhong Zheng commented on FLINK-25242: --- Hi [~godfreyhe] , please assign this to m

[jira] [Commented] (FLINK-27420) Suspended SlotManager fail to reregister metrics when started again

[ https://issues.apache.org/jira/browse/FLINK-27420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529741#comment-17529741 ] Ben Augarten commented on FLINK-27420: -- [~xtsong] – thanks, I posted a PR against m

[jira] [Commented] (FLINK-27155) Reduce multiple reads to the same Changelog file in the same taskmanager during restore

[ https://issues.apache.org/jira/browse/FLINK-27155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529740#comment-17529740 ] Feifan Wang commented on FLINK-27155: - Thanks [~ym] and [~roman] , is there any incl

[jira] [Commented] (FLINK-27391) Support Hive bucket table

[ https://issues.apache.org/jira/browse/FLINK-27391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529739#comment-17529739 ] luoyuxia commented on FLINK-27391: -- [~tartarus] Sorry for missing the feature of readin

[jira] [Updated] (FLINK-27449) The comment is lost when creating a Table from Datastream and Schema

[ https://issues.apache.org/jira/browse/FLINK-27449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-27449: -- Priority: Major (was: Critical) > The comment is lost when creating a Table from Datastream a

[jira] [Commented] (FLINK-25447) batch query cannot generate plan when a sorted view into multi sinks

[ https://issues.apache.org/jira/browse/FLINK-25447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529738#comment-17529738 ] Yunhong Zheng commented on FLINK-25447: --- Hi, [~godfreyhe]  Can you assign this to

[GitHub] [flink] flinkbot commented on pull request #19607: [FLINK-27420][runtime] Recreate metric groups for each new RM to avoid metric loss

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

[jira] [Updated] (FLINK-27420) Suspended SlotManager fail to reregister metrics when started again

[ https://issues.apache.org/jira/browse/FLINK-27420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27420: --- Labels: pull-request-available (was: ) > Suspended SlotManager fail to reregister metrics w

[GitHub] [flink] baugarten opened a new pull request, #19607: [FLINK-27420][runtime] Recreate metric groups for each new RM to avoid metric loss

baugarten opened a new pull request, #19607: URL: https://github.com/apache/flink/pull/19607 ## What is the purpose of the change Recreate the metric groups for slot manager and resource manager when leadership is granted. This resolves an issue where the metric group is closed w

[GitHub] [flink-web] gaoyunhaii commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

gaoyunhaii commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r861431542 ## _posts/2022-04-26-1.15-announcement.md: ## @@ -0,0 +1,434 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-04

[GitHub] [flink-web] gaoyunhaii commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

gaoyunhaii commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r861431461 ## _posts/2022-04-26-1.15-announcement.md: ## @@ -0,0 +1,434 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-04

[GitHub] [flink] swuferhong commented on pull request #19579: [FLINK-25097][table-planner] Fix bug in inner join when the filter co…

swuferhong commented on PR #19579: URL: https://github.com/apache/flink/pull/19579#issuecomment-1112830466 Hi @godfreyhe could you please help review this PR. Thanks！ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[jira] [Commented] (FLINK-27364) Support DESC EXTENDED partition statement for partitioned table

[ https://issues.apache.org/jira/browse/FLINK-27364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529709#comment-17529709 ] Jingsong Lee commented on FLINK-27364: -- If [~nicholasjiang]  still have time to dev

[jira] [Updated] (FLINK-27449) The comment is lost when creating a Table from Datastream and Schema

[ https://issues.apache.org/jira/browse/FLINK-27449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Huang updated FLINK-27449: Description:   A user reported that the comment was lost when creating a Table from Datastream a

[jira] [Updated] (FLINK-27449) The comment is lost when creating a Table from Datastream and Schema

[ https://issues.apache.org/jira/browse/FLINK-27449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Huang updated FLINK-27449: Description: User reported that the comment was lost when creating a Table from Datastream and Sc

[jira] [Updated] (FLINK-27449) The comment is lost when creating a Table from Datastream and Schema

[ https://issues.apache.org/jira/browse/FLINK-27449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Huang updated FLINK-27449: Summary: The comment is lost when creating a Table from Datastream and Schema (was: The comment i

[jira] [Updated] (FLINK-27449) The comment is lost when printing table schema

[ https://issues.apache.org/jira/browse/FLINK-27449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Huang updated FLINK-27449: Description: User reported that the comment was lost when creating a table from datastream and sc

[jira] [Created] (FLINK-27449) The comment is lost when printing table schema

Yuan Huang created FLINK-27449: --- Summary: The comment is lost when printing table schema Key: FLINK-27449 URL: https://issues.apache.org/jira/browse/FLINK-27449 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-21301) Decouple window aggregate allow lateness with state ttl configuration

[ https://issues.apache.org/jira/browse/FLINK-21301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529678#comment-17529678 ] Shawn Liu edited comment on FLINK-21301 at 4/28/22 10:59 PM: -

[jira] [Commented] (FLINK-21301) Decouple window aggregate allow lateness with state ttl configuration

[ https://issues.apache.org/jira/browse/FLINK-21301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529678#comment-17529678 ] Shawn Liu commented on FLINK-21301: --- [~lzljs3620320]  what is the table config for lat

[jira] [Commented] (FLINK-27364) Support DESC EXTENDED partition statement for partitioned table

[ https://issues.apache.org/jira/browse/FLINK-27364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529674#comment-17529674 ] Nicholas Jiang commented on FLINK-27364: [~lsy], IMO, the pull request for FLINK

[jira] [Updated] (FLINK-27422) Do not create temporary pod template files for JobManager and TaskManager if not configured explicitly

[ https://issues.apache.org/jira/browse/FLINK-27422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27422: --- Labels: Starter pull-request-available (was: Starter) > Do not create temporary pod templat

[GitHub] [flink-kubernetes-operator] SteNicholas opened a new pull request, #189: [FLINK-27422] Do not create temporary pod template files for JobManager and TaskManager if not configured explicitly

SteNicholas opened a new pull request, #189: URL: https://github.com/apache/flink-kubernetes-operator/pull/189 It doesn't need to create temporary pod template files for JobManager and TaskManager if it is not configured explicitly via `.spec.JobManagerSpec.podTemplate` or `.spec.TaskManage

[GitHub] [flink-web] infoverload commented on a diff in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

infoverload commented on code in PR #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r861299671 ## _posts/2022-03-16-async-sink-base.md: ## @@ -0,0 +1,160 @@ +--- +layout: post +title: "The Generic Asynchronous Base Sink" +date: 2022-04-05 16:00:00 +authors: +-

[GitHub] [flink-web] infoverload commented on a diff in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

infoverload commented on code in PR #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r861298315 ## _posts/2022-03-16-async-sink-base.md: ## @@ -0,0 +1,160 @@ +--- +layout: post +title: "The Generic Asynchronous Base Sink" +date: 2022-04-05 16:00:00 +authors: +-

[GitHub] [flink-web] infoverload commented on a diff in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

infoverload commented on code in PR #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r861295620 ## _posts/2022-03-16-async-sink-base.md: ## @@ -0,0 +1,160 @@ +--- +layout: post +title: "The Generic Asynchronous Base Sink" +date: 2022-04-05 16:00:00 +authors: +-

[GitHub] [flink-web] infoverload commented on a diff in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

infoverload commented on code in PR #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r861295620 ## _posts/2022-03-16-async-sink-base.md: ## @@ -0,0 +1,160 @@ +--- +layout: post +title: "The Generic Asynchronous Base Sink" +date: 2022-04-05 16:00:00 +authors: +-

[GitHub] [flink-web] infoverload commented on a diff in pull request #517: [FLINK-24370] Addition of blog post describing features and usage of the Async Sink…

infoverload commented on code in PR #517: URL: https://github.com/apache/flink-web/pull/517#discussion_r861293470 ## _posts/2022-03-16-async-sink-base.md: ## @@ -0,0 +1,160 @@ +--- +layout: post +title: "The Generic Asynchronous Base Sink" +date: 2022-04-05 16:00:00 +authors: +-

[jira] [Comment Edited] (FLINK-24491) ExecutionGraphInfo may not be archived when the dispatcher terminates

[ https://issues.apache.org/jira/browse/FLINK-24491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529392#comment-17529392 ] Matthias Pohl edited comment on FLINK-24491 at 4/28/22 8:06 PM: --

[jira] [Comment Edited] (FLINK-24491) ExecutionGraphInfo may not be archived when the dispatcher terminates

[ https://issues.apache.org/jira/browse/FLINK-24491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529392#comment-17529392 ] Matthias Pohl edited comment on FLINK-24491 at 4/28/22 8:05 PM: --

[jira] [Resolved] (FLINK-27382) Make Job mode wait with cluster shutdown until the cleanup is done

[ https://issues.apache.org/jira/browse/FLINK-27382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-27382. --- Fix Version/s: 1.16.0 1.15.1 Resolution: Fixed master: 3690c3f4457

[GitHub] [flink] XComp merged pull request #19603: [FLINK-27382][BP-1.15][runtime] Moves cluster shutdown to when the job cleanup is done in job mode

XComp merged PR #19603: URL: https://github.com/apache/flink/pull/19603 -- 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.

[GitHub] [flink] XComp merged pull request #19567: [FLINK-27382][runtime] Moves cluster shutdown to when the job cleanup is done in job mode

XComp merged PR #19567: URL: https://github.com/apache/flink/pull/19567 -- 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.

[GitHub] [flink] afedulov commented on a diff in pull request #19405: [FLINK-27066] Reintroduce e2e tests in ES as Java tests.

afedulov commented on code in PR #19405: URL: https://github.com/apache/flink/pull/19405#discussion_r861131896 ## flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/src/main/java/org/apache/flink/streaming/tests/ElasticsearchTestEmitter.java: ## @@ -0,0 +1,45 @@

[jira] [Commented] (FLINK-27129) Hardcoded namespace in FlinkDeployment manifests may fail to deploy

[ https://issues.apache.org/jira/browse/FLINK-27129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529612#comment-17529612 ] Ted Chang commented on FLINK-27129: --- [~wangyang0918] Please review the PR [https://gi

[jira] [Updated] (FLINK-27129) Hardcoded namespace in FlinkDeployment manifests may fail to deploy

[ https://issues.apache.org/jira/browse/FLINK-27129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27129: --- Labels: newbie pull-request-available (was: newbie) > Hardcoded namespace in FlinkDeploymen

[GitHub] [flink-kubernetes-operator] tedhtchang opened a new pull request, #188: [FLINK-27129][docs] Hardcoded namespace in FlinkDeployment manifests may fail to deploy

tedhtchang opened a new pull request, #188: URL: https://github.com/apache/flink-kubernetes-operator/pull/188 Remove hardcode default namespace from the flinkdeployment examples. Document the step to create flinkdeployment in other namespaces when watchNamespaces not used. Signed-o

[jira] [Resolved] (FLINK-25511) Pre-emptively uploaded changelog not discarded up if materialized before checkpoint

[ https://issues.apache.org/jira/browse/FLINK-25511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-25511. --- Resolution: Fixed Merged into master as 5b58ef66a8835bf22db23e1d9836a1e9f4d94045..c

[jira] [Commented] (FLINK-23143) Support state migration

[ https://issues.apache.org/jira/browse/FLINK-23143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529581#comment-17529581 ] Roman Khachatryan commented on FLINK-23143: --- Do you mind sharing your POC? II

[GitHub] [flink] rkhachatryan merged pull request #19550: [FLINK-25511][state/changelog] Discard pre-emptively uploaded state changes not included into any checkpoint

rkhachatryan merged PR #19550: URL: https://github.com/apache/flink/pull/19550 -- 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.

[GitHub] [flink] XComp commented on pull request #19603: [FLINK-27382][BP-1.15][runtime] Moves cluster shutdown to when the job cleanup is done in job mode

XComp commented on PR #19603: URL: https://github.com/apache/flink/pull/19603#issuecomment-1112491432 @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. To

[GitHub] [flink] afedulov commented on a diff in pull request #19405: [FLINK-27066] Reintroduce e2e tests in ES as Java tests.

afedulov commented on code in PR #19405: URL: https://github.com/apache/flink/pull/19405#discussion_r861131896 ## flink-end-to-end-tests/flink-end-to-end-tests-common-elasticsearch/src/main/java/org/apache/flink/streaming/tests/ElasticsearchTestEmitter.java: ## @@ -0,0 +1,45 @@

[GitHub] [flink] empcl commented on pull request #19573: [FLINK-27384] solve the problem that the latest data cannot be read under the creat…

empcl commented on PR #19573: URL: https://github.com/apache/flink/pull/19573#issuecomment-1112448067 @luoyuxia Regarding adding test cases, I'm sorry, I can't verify this change on HivePartitionFetcherTest. Because, the test case above HivePartitionFetcherTest cannot actually obtain the sp

[GitHub] [flink] empcl commented on a diff in pull request #19573: [FLINK-27384] solve the problem that the latest data cannot be read under the creat…

empcl commented on code in PR #19573: URL: https://github.com/apache/flink/pull/19573#discussion_r861119613 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HivePartitionFetcherContextBase.java: ## @@ -139,16 +138,9 @@ public List get

[GitHub] [flink] zentol commented on pull request #19571: [FLINK-27394] Integrate the Flink Elasticsearch documentation in the Flink documentation

zentol commented on PR #19571: URL: https://github.com/apache/flink/pull/19571#issuecomment-1112439000 guess go is indeed missing in the CI images; will prepare an update -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Updated] (FLINK-27429) Implement Vertica JDBC Dialect

[ https://issues.apache.org/jira/browse/FLINK-27429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-27429: Affects Version/s: 1.16.0 > Implement Vertica JDBC Dialect > -- > >

[jira] [Assigned] (FLINK-27429) Implement Vertica JDBC Dialect

[ https://issues.apache.org/jira/browse/FLINK-27429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-27429: --- Assignee: Jasmin Redzepovic > Implement Vertica JDBC Dialect >

[jira] [Closed] (FLINK-26298) [JUnit5 Migration] Module: flink-rpc-core

[ https://issues.apache.org/jira/browse/FLINK-26298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-26298. Resolution: Fixed master: c9b5e2f5d5351aa80192881c7af4d13987ed2e04 > [JUnit5 Migration] M

[jira] [Updated] (FLINK-27416) FLIP-225: Implement standalone mode support in the kubernetes operator

[ https://issues.apache.org/jira/browse/FLINK-27416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Usamah Jassat updated FLINK-27416: -- Description: [https://cwiki.apache.org/confluence/display/FLINK/FLIP-225%3A+Implement+standalo

[GitHub] [flink] zentol merged pull request #18877: [FLINK-26298][rpc][tests] Migrate tests to JUnit5

zentol merged PR #18877: URL: https://github.com/apache/flink/pull/18877 -- 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

[jira] [Updated] (FLINK-27443) Add standalone mode parameters and decorators

[ https://issues.apache.org/jira/browse/FLINK-27443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27443: --- Labels: pull-request-available (was: ) > Add standalone mode parameters and decorators > -

[GitHub] [flink-kubernetes-operator] usamj opened a new pull request, #187: [FLINK-27443] Create standalone mode parameters and decorators for JM and TMs

usamj opened a new pull request, #187: URL: https://github.com/apache/flink-kubernetes-operator/pull/187 This PR creates decorators and parameters which contain information needed to create JM and TM deployments in standalone mode. These will then be used by the Standalone ClusterDescriptor

[GitHub] [flink] syhily commented on a diff in pull request #19430: [BK-1.15][FLINK-26931][Connector/pulsar] Make the producer name and consumer name unique in Pulsar

syhily commented on code in PR #19430: URL: https://github.com/apache/flink/pull/19430#discussion_r861034376 ## flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config/PulsarSinkConfigUtils.java: ## @@ -70,7 +71,10 @@ public static Pr

[jira] [Created] (FLINK-27448) Enable standalone mode for old Flink versions

Usamah Jassat created FLINK-27448: - Summary: Enable standalone mode for old Flink versions Key: FLINK-27448 URL: https://issues.apache.org/jira/browse/FLINK-27448 Project: Flink Issue Type: S

[GitHub] [flink] syhily commented on pull request #19430: [BK-1.15][FLINK-26931][Connector/pulsar] Make the producer name and consumer name unique in Pulsar

syhily commented on PR #19430: URL: https://github.com/apache/flink/pull/19430#issuecomment-1112349280 > Since this PR fixes an actual bug, I would expect to add a test case. Can you add one so that the issue does not arise again? I think this could be hard to test. Because we just us

[jira] [Created] (FLINK-27447) Implement last-state with ZooKeeper HA

Usamah Jassat created FLINK-27447: - Summary: Implement last-state with ZooKeeper HA Key: FLINK-27447 URL: https://issues.apache.org/jira/browse/FLINK-27447 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27445) Create Flink Standalone Service

Usamah Jassat created FLINK-27445: - Summary: Create Flink Standalone Service Key: FLINK-27445 URL: https://issues.apache.org/jira/browse/FLINK-27445 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27446) Introduce Standalone Mode

Usamah Jassat created FLINK-27446: - Summary: Introduce Standalone Mode Key: FLINK-27446 URL: https://issues.apache.org/jira/browse/FLINK-27446 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27444) Create standalone mode ClusterDescriptor

Usamah Jassat created FLINK-27444: - Summary: Create standalone mode ClusterDescriptor Key: FLINK-27444 URL: https://issues.apache.org/jira/browse/FLINK-27444 Project: Flink Issue Type: Sub-ta

  1   2   3   >