[GitHub] [flink-web] joemoe commented on pull request #526: Announcement blogpost for the 1.15 release

2022-04-12 Thread GitBox
joemoe commented on PR #526: URL: https://github.com/apache/flink-web/pull/526#issuecomment-1096203572 > I would really like to see the experimental OpenAPI specification being part of the announcement. That's not something that existing users would stumble upon in the docs I'm afraid.

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

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848050374 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

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

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848050374 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

[GitHub] [flink] syhily opened a new pull request, #19431: [BK-1.15][FLINK-26645][Connector/pulsar] Support subscribe only one topic partition

2022-04-12 Thread GitBox
syhily opened a new pull request, #19431: URL: https://github.com/apache/flink/pull/19431 This is a backport PR for #19092. -- 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] masteryhx commented on pull request #19252: [FLINK-25867][docs] translate ChangelogBackend documentation to chinese

2022-04-12 Thread GitBox
masteryhx commented on PR #19252: URL: https://github.com/apache/flink/pull/19252#issuecomment-1096214264 > Thank for your review again @masteryhx , I hive fixed problems you mentioned. LGTM, @curcur Do you have any other inputs? -- This is an automated message from the Apache Git

[jira] [Created] (FLINK-27196) Remove old format interfaces

2022-04-12 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-27196: --- Summary: Remove old format interfaces Key: FLINK-27196 URL: https://issues.apache.org/jira/browse/FLINK-27196 Project: Flink Issue Type: Sub-ta

[GitHub] [flink] luoyuxia commented on a diff in pull request #19193: [FLINK-26813[SQL-API] Supports ADD/MODIFY column/watermark/constraint syntax parse for ALTER TABLE

2022-04-12 Thread GitBox
luoyuxia commented on code in PR #19193: URL: https://github.com/apache/flink/pull/19193#discussion_r848052149 ## flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterTableAdd.java: ## @@ -0,0 +1,129 @@ +/* + * Licensed to the Apache Software Found

[GitHub] [flink] flinkbot commented on pull request #19431: [BK-1.15][FLINK-26645][Connector/pulsar] Support subscribe only one topic partition

2022-04-12 Thread GitBox
flinkbot commented on PR #19431: URL: https://github.com/apache/flink/pull/19431#issuecomment-1096222321 ## CI report: * 34c43134839b3f8a7780942c54c7a657d585a882 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Assigned] (FLINK-27195) KafkaSourceReader offsetsToCommit should be mutable

2022-04-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-27195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk reassigned FLINK-27195: - Assignee: Mason Chen > KafkaSourceReader offsetsToCommit should be mutable > --

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

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848059221 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

[jira] [Commented] (FLINK-24700) Clarify semantics of filter, projection, partition, and metadata pushdown

2022-04-12 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520955#comment-17520955 ] Timo Walther commented on FLINK-24700: -- This was actually about improving the docum

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

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848060342 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

[GitHub] [flink] syhily opened a new pull request, #19433: [BK-1.14][FLINK-26645][Connector/pulsar] Support subscribe only one topic partition/

2022-04-12 Thread GitBox
syhily opened a new pull request, #19433: URL: https://github.com/apache/flink/pull/19433 This is a backport PR for #19092 -- 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. T

[jira] [Created] (FLINK-27197) Port ArrowTableSource and PythonInputFormatTableSource to DynamicTableSource

2022-04-12 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-27197: --- Summary: Port ArrowTableSource and PythonInputFormatTableSource to DynamicTableSource Key: FLINK-27197 URL: https://issues.apache.org/jira/browse/FLINK-27197

[GitHub] [flink] flinkbot commented on pull request #19432: [FLINK-27196][table] Remove SerializationSchemaFactory, DeserializationSchemaFactory and TableFormatFactory

2022-04-12 Thread GitBox
flinkbot commented on PR #19432: URL: https://github.com/apache/flink/pull/19432#issuecomment-1096232254 ## CI report: * cdc6be25f012b9c5f7231f3784732d027ead1590 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-27196) Remove old format interfaces

2022-04-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27196: --- Labels: pull-request-available (was: ) > Remove old format interfaces > ---

[jira] [Commented] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-04-12 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520962#comment-17520962 ] luoyuxia commented on FLINK-27191: -- [~straw] Thanks for your attention. The basic idea

[jira] [Comment Edited] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-04-12 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520962#comment-17520962 ] luoyuxia edited comment on FLINK-27191 at 4/12/22 7:22 AM: --- [~

[GitHub] [flink] flinkbot commented on pull request #19433: [BK-1.14][FLINK-26645][Connector/pulsar] Support subscribe only one topic partition/

2022-04-12 Thread GitBox
flinkbot commented on PR #19433: URL: https://github.com/apache/flink/pull/19433#issuecomment-1096243899 ## CI report: * e5d89c986d70ef2cd5cefbc0c73e380386776f32 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

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

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848070234 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

[GitHub] [flink] Myasuka commented on pull request #19429: [hotfix][docs] Fix the "capacity-planning" page of "Tuning Checkpoints and Large State"

2022-04-12 Thread GitBox
Myasuka commented on PR #19429: URL: https://github.com/apache/flink/pull/19429#issuecomment-1096248513 @liuzhuang2017 I think we indluce this hotfix commit in your previous PR and I will rebase them when merging. -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] liuzhuang2017 commented on pull request #19429: [hotfix][docs] Fix the "capacity-planning" page of "Tuning Checkpoints and Large State"

2022-04-12 Thread GitBox
liuzhuang2017 commented on PR #19429: URL: https://github.com/apache/flink/pull/19429#issuecomment-1096261283 @Myasuka ,Thanks for your reply, I got 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

[jira] [Commented] (FLINK-27187) The attemptsPerUpload metric may be lower than it actually is

2022-04-12 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520965#comment-17520965 ] Roman Khachatryan commented on FLINK-27187: --- This ticket should be fine I thin

[jira] [Commented] (FLINK-27018) timestamp missing end zero when outputing to kafka

2022-04-12 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520966#comment-17520966 ] Yao Zhang commented on FLINK-27018: --- Hi all, The root cause is the different behaviou

[jira] [Closed] (FLINK-27193) Kyro Serialisation and Deserialisation returns a different object

2022-04-12 Thread Akshay Hazari (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Akshay Hazari closed FLINK-27193. - Resolution: Fixed > Kyro Serialisation and Deserialisation returns a different object > ---

[jira] [Created] (FLINK-27198) Cleanup tests testing legacy TableSink/TableSource

2022-04-12 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-27198: --- Summary: Cleanup tests testing legacy TableSink/TableSource Key: FLINK-27198 URL: https://issues.apache.org/jira/browse/FLINK-27198 Project: Flink

[jira] [Created] (FLINK-27199) Bump Pulsar to 2.10.0 for increasing the test stability

2022-04-12 Thread Yufan Sheng (Jira)
Yufan Sheng created FLINK-27199: --- Summary: Bump Pulsar to 2.10.0 for increasing the test stability Key: FLINK-27199 URL: https://issues.apache.org/jira/browse/FLINK-27199 Project: Flink Issue T

[GitHub] [flink] leizhou666 opened a new pull request, #19434: [FLINK-27121][docs-zh]Translate "Configuration#overview" paragraph and the code example in "Application Development > Table API & SQL" to

2022-04-12 Thread GitBox
leizhou666 opened a new pull request, #19434: URL: https://github.com/apache/flink/pull/19434 ## What is the purpose of the change https://issues.apache.org/jira/browse/FLINK-27121 Translate "Configuration#overview" paragraph and the code example in "Application Development > Table

[jira] [Updated] (FLINK-27121) Translate "Configuration#overview" paragraph and the code example in "Application Development > Table API & SQL" to Chinese

2022-04-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27121: --- Labels: chinese-translation pull-request-available (was: chinese-translation) > Translate

[jira] [Created] (FLINK-27200) Replace CollectionTableSource and CollectionTableSink with new table stack alternatives

2022-04-12 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-27200: --- Summary: Replace CollectionTableSource and CollectionTableSink with new table stack alternatives Key: FLINK-27200 URL: https://issues.apache.org/jira/browse/FLINK-27

[GitHub] [flink] leizhou666 closed pull request #19434: [FLINK-27121][docs-zh]Translate "Configuration#overview" paragraph and the code example in "Application Development > Table API & SQL" to Chines

2022-04-12 Thread GitBox
leizhou666 closed pull request #19434: [FLINK-27121][docs-zh]Translate "Configuration#overview" paragraph and the code example in "Application Development > Table API & SQL" to Chinese URL: https://github.com/apache/flink/pull/19434 -- This is an automated message from the Apache Git Service

[GitHub] [flink] baisui1981 commented on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

2022-04-12 Thread GitBox
baisui1981 commented on PR #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-1096292743 @RocMarshal @zentol @AHeise PTAL thx -- 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

[GitHub] [flink] leizhou666 opened a new pull request, #19435: [FLINK-27121][docs-zh]Translate "Configuration#overview" paragraph and the code example in "Application Development > Table API & SQL" to

2022-04-12 Thread GitBox
leizhou666 opened a new pull request, #19435: URL: https://github.com/apache/flink/pull/19435 ## What is the purpose of the change https://issues.apache.org/jira/browse/FLINK-27121 Translate "Configuration#overview" paragraph and the code example in "Application Development > Table

[GitHub] [flink] twalthr closed pull request #19014: [FLINK-24586][table-planner] JSON_VALUE should return STRING instead of VARCHAR(2000)

2022-04-12 Thread GitBox
twalthr closed pull request #19014: [FLINK-24586][table-planner] JSON_VALUE should return STRING instead of VARCHAR(2000) URL: https://github.com/apache/flink/pull/19014 -- 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] zentol merged pull request #19347: [FLINK-27035][python][tests] Reduce memory usage of ByteArrayWrapperSerializerTest

2022-04-12 Thread GitBox
zentol merged PR #19347: URL: https://github.com/apache/flink/pull/19347 -- 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] [Closed] (FLINK-27035) Reduce memory usage of ByteArrayWrapperSerializerTest

2022-04-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-27035. Resolution: Fixed master: f089a99ce73ad15531a4d1b72899d8367fab662a > Reduce memory usage

[jira] [Commented] (FLINK-27187) The attemptsPerUpload metric may be lower than it actually is

2022-04-12 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520998#comment-17520998 ] Feifan Wang commented on FLINK-27187: - Ok. I'm glad to do this work, can you assign

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

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848109282 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

[GitHub] [flink] flinkbot commented on pull request #19435: [FLINK-27121][docs-zh]Translate "Configuration#overview" paragraph and the code example in "Application Development > Table API & SQL" to Ch

2022-04-12 Thread GitBox
flinkbot commented on PR #19435: URL: https://github.com/apache/flink/pull/19435#issuecomment-1096311247 ## CI report: * fcaa334d18d33ffdd739674e821c538b13ed8215 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-27201) Remove CollectTableSink

2022-04-12 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-27201: --- Summary: Remove CollectTableSink Key: FLINK-27201 URL: https://issues.apache.org/jira/browse/FLINK-27201 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-27187) The attemptsPerUpload metric may be lower than it actually is

2022-04-12 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-27187: -- Issue Type: Improvement (was: Bug) > The attemptsPerUpload metric may be lower than i

[jira] [Updated] (FLINK-27187) The attemptsPerUpload metric may be lower than it actually is

2022-04-12 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-27187: -- Component/s: Runtime / Metrics > The attemptsPerUpload metric may be lower than it act

[jira] [Updated] (FLINK-27187) The attemptsPerUpload metric may be lower than it actually is

2022-04-12 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-27187: -- Fix Version/s: 1.16.0 > The attemptsPerUpload metric may be lower than it actually is

[jira] [Assigned] (FLINK-27187) The attemptsPerUpload metric may be lower than it actually is

2022-04-12 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-27187: - Assignee: Feifan Wang > The attemptsPerUpload metric may be lower than it actua

[jira] [Commented] (FLINK-27187) The attemptsPerUpload metric may be lower than it actually is

2022-04-12 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520999#comment-17520999 ] Roman Khachatryan commented on FLINK-27187: --- Sure, I've assigned the ticket to

[GitHub] [flink] matriv commented on a diff in pull request #19426: [FLINK-25928][table-planner] Throw validation error early for CAST

2022-04-12 Thread GitBox
matriv commented on code in PR #19426: URL: https://github.com/apache/flink/pull/19426#discussion_r848115742 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/utils/LogicalTypeCasts.java: ## @@ -589,6 +591,37 @@ protected Boolean defaultMethod(

[GitHub] [flink] MartijnVisser commented on pull request #19428: [FLINK-25694] [file-system] Ugrade Presto

2022-04-12 Thread GitBox
MartijnVisser commented on PR #19428: URL: https://github.com/apache/flink/pull/19428#issuecomment-1096319860 Thanks for the PR @David-N-Perkins but we need to also make changes to the NOTICE files, since this newer version has different version numbers ``` 20:46:51,337 DEBUG o

[jira] [Commented] (FLINK-26977) JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithRestartsShouldSimplyRestartInTerminate failed on azure

2022-04-12 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521002#comment-17521002 ] Yun Gao commented on FLINK-26977: - The problem seems to related to adaptive scheduler, p

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

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848128512 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

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

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848128512 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

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

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848133827 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

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

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848135979 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

[jira] [Commented] (FLINK-26762) Add the overdraft buffer in BufferPool to reduce unaligned checkpoint being blocked

2022-04-12 Thread fanrui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521011#comment-17521011 ] fanrui commented on FLINK-26762: Hi [~akalashnikov] , thanks a lot for your sincere repl

[jira] [Closed] (FLINK-24586) SQL functions should return STRING instead of VARCHAR(2000)

2022-04-12 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24586. Fix Version/s: 1.15.1 (was: 1.15.0) Resolution: Fixed Unfortunately,

[GitHub] [flink] XComp commented on a diff in pull request #19275: [FLINK-24491][runtime] Make the job termination wait until the archiving of ExecutionGraphInfo finishes

2022-04-12 Thread GitBox
XComp commented on code in PR #19275: URL: https://github.com/apache/flink/pull/19275#discussion_r847412599 ## flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java: ## @@ -1103,23 +1095,60 @@ private void archiveExecutionGraph(ExecutionGraphInfo execu

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

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848138561 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

[GitHub] [flink] XComp commented on a diff in pull request #19275: [FLINK-24491][runtime] Make the job termination wait until the archiving of ExecutionGraphInfo finishes

2022-04-12 Thread GitBox
XComp commented on code in PR #19275: URL: https://github.com/apache/flink/pull/19275#discussion_r848128604 ## flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java: ## @@ -421,6 +421,8 @@ public void testCancellationOfCanceledTerminalDoesNotThrowE

[GitHub] [flink] XComp commented on a diff in pull request #19275: [FLINK-24491][runtime] Make the job termination wait until the archiving of ExecutionGraphInfo finishes

2022-04-12 Thread GitBox
XComp commented on code in PR #19275: URL: https://github.com/apache/flink/pull/19275#discussion_r848138048 ## flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java: ## @@ -1215,17 +1244,23 @@ private CompletableFuture waitForTerminatingJob(

[GitHub] [flink] lsyldliu commented on a diff in pull request #19193: [FLINK-26813[SQL-API] Supports ADD/MODIFY column/watermark/constraint syntax parse for ALTER TABLE

2022-04-12 Thread GitBox
lsyldliu commented on code in PR #19193: URL: https://github.com/apache/flink/pull/19193#discussion_r848149924 ## flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterTableAdd.java: ## @@ -0,0 +1,129 @@ +/* + * Licensed to the Apache Software Found

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

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848155050 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #165: [FLINK-26140] Support rollback strategies

2022-04-12 Thread GitBox
gyfora commented on code in PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#discussion_r848156847 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/ApplicationObserver.java: ## @@ -144,4 +148,22 @@ pri

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #165: [FLINK-26140] Support rollback strategies

2022-04-12 Thread GitBox
gyfora commented on PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#issuecomment-1096378492 Based on some discussion with @morhidi we decided to have the rollback related configs simply as part of the `flinkConfiguration` in order to avoid polluting the CRD --

[GitHub] [flink] gaborgsomogyi commented on a diff in pull request #19372: [FLINK-26043][runtime][security] Add periodic kerberos relogin to KerberosDelegationTokenManager

2022-04-12 Thread GitBox
gaborgsomogyi commented on code in PR #19372: URL: https://github.com/apache/flink/pull/19372#discussion_r848157811 ## flink-runtime/src/main/java/org/apache/flink/runtime/security/token/KerberosDelegationTokenManager.java: ## @@ -110,13 +126,84 @@ public void obtainDelegationTo

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #165: [FLINK-26140] Support rollback strategies

2022-04-12 Thread GitBox
morhidi commented on PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#issuecomment-1096384761 Thank you @gyfora for working on such a great feature. I'll have closer look later today. For the first read I was wondering if we could call the property `kubernetes.ope

[GitHub] [flink] gaborgsomogyi commented on a diff in pull request #19372: [FLINK-26043][runtime][security] Add periodic kerberos relogin to KerberosDelegationTokenManager

2022-04-12 Thread GitBox
gaborgsomogyi commented on code in PR #19372: URL: https://github.com/apache/flink/pull/19372#discussion_r848157811 ## flink-runtime/src/main/java/org/apache/flink/runtime/security/token/KerberosDelegationTokenManager.java: ## @@ -110,13 +126,84 @@ public void obtainDelegationTo

[GitHub] [flink] flinkbot commented on pull request #19436: [FLINK-27201][table] Remove CollectTableSink

2022-04-12 Thread GitBox
flinkbot commented on PR #19436: URL: https://github.com/apache/flink/pull/19436#issuecomment-1096390247 ## CI report: * c0b31af43847fd64efada5c5c38d1b110583874e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

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

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848168636 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

[jira] [Updated] (FLINK-27201) Remove CollectTableSink

2022-04-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27201: --- Labels: pull-request-available (was: ) > Remove CollectTableSink > ---

[jira] [Created] (FLINK-27202) NullPointerException on stop-with-savepoint with AsyncWaitOperator followed by FlinkKafkaProducer

2022-04-12 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-27202: -- Summary: NullPointerException on stop-with-savepoint with AsyncWaitOperator followed by FlinkKafkaProducer Key: FLINK-27202 URL: https://issues.apache.org/jira/browse/FLINK-2

[GitHub] [flink] gaborgsomogyi commented on a diff in pull request #19372: [FLINK-26043][runtime][security] Add periodic kerberos relogin to KerberosDelegationTokenManager

2022-04-12 Thread GitBox
gaborgsomogyi commented on code in PR #19372: URL: https://github.com/apache/flink/pull/19372#discussion_r847507611 ## flink-runtime/src/main/java/org/apache/flink/runtime/security/token/KerberosDelegationTokenManager.java: ## @@ -110,13 +126,84 @@ public void obtainDelegationTo

[GitHub] [flink] matriv commented on a diff in pull request #19426: [FLINK-25928][table-planner] Throw validation error early for CAST

2022-04-12 Thread GitBox
matriv commented on code in PR #19426: URL: https://github.com/apache/flink/pull/19426#discussion_r848115742 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/utils/LogicalTypeCasts.java: ## @@ -589,6 +591,37 @@ protected Boolean defaultMethod(

[GitHub] [flink] matriv commented on a diff in pull request #19436: [FLINK-27201][table] Remove CollectTableSink

2022-04-12 Thread GitBox
matriv commented on code in PR #19436: URL: https://github.com/apache/flink/pull/19436#discussion_r848183500 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/batch/ExplainTest.scala: ## @@ -19,10 +19,12 @@ package org.apache.flink.table.api.batch

[jira] [Commented] (FLINK-27121) Translate "Configuration#overview" paragraph and the code example in "Application Development > Table API & SQL" to Chinese

2022-04-12 Thread LEI ZHOU (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521030#comment-17521030 ] LEI ZHOU commented on FLINK-27121: -- hi [~matriv] , I had open a PR to complete this(FLI

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

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848191644 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

[GitHub] [flink] twalthr commented on a diff in pull request #19436: [FLINK-27201][table] Remove CollectTableSink

2022-04-12 Thread GitBox
twalthr commented on code in PR #19436: URL: https://github.com/apache/flink/pull/19436#discussion_r848191439 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/batch/sql/DagOptimizationTest.scala: ## @@ -34,67 +33,67 @@ class DagOptimizationTe

[jira] [Commented] (FLINK-26822) Add Source implementation for Cassandra connector

2022-04-12 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521031#comment-17521031 ] Etienne Chauchot commented on FLINK-26822: -- [~martijnvisser] or [~arvid] can yo

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

2022-04-12 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848197466 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

[jira] [Assigned] (FLINK-26052) Update chinese documentation regarding FLIP-203

2022-04-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-26052: -- Assignee: (was: Shen Zhu) > Update chinese documentation regarding FLIP-203 > ---

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #161: [FLINK-27141] Improve FlinkService#waitForClusterShutdown logic

2022-04-12 Thread GitBox
gyfora merged PR #161: URL: https://github.com/apache/flink-kubernetes-operator/pull/161 -- 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] [Closed] (FLINK-27141) Improve FlinkService#waitForClusterShutdown logic

2022-04-12 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-27141. -- Resolution: Fixed merged to main: a83435212fabfcf82e7a7f26d455dc1f319090ca > Improve FlinkService#wai

[jira] [Commented] (FLINK-27202) NullPointerException on stop-with-savepoint with AsyncWaitOperator followed by FlinkKafkaProducer

2022-04-12 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521037#comment-17521037 ] Dawid Wysakowicz commented on FLINK-27202: -- I think it should be fixed in 1.14

[jira] [Closed] (FLINK-27202) NullPointerException on stop-with-savepoint with AsyncWaitOperator followed by FlinkKafkaProducer

2022-04-12 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-27202. Fix Version/s: 1.14.0 Resolution: Fixed > NullPointerException on stop-with-savepoi

[jira] [Created] (FLINK-27203) Add supports for uploading jars from object storage (s3, gcs, oss)

2022-04-12 Thread Xin Hao (Jira)
Xin Hao created FLINK-27203: --- Summary: Add supports for uploading jars from object storage (s3, gcs, oss) Key: FLINK-27203 URL: https://issues.apache.org/jira/browse/FLINK-27203 Project: Flink Iss

[GitHub] [flink] liuzhuang2017 opened a new pull request, #19437: [hotfix][streaming-java][runtime] Fix code comments.

2022-04-12 Thread GitBox
liuzhuang2017 opened a new pull request, #19437: URL: https://github.com/apache/flink/pull/19437 ## What is the purpose of the change Missing "id" on line 36 in JobLeaderIdService interface. On line 173 in the StreamingJobGraphGenerator class, changed "iff" to "if and o

[jira] [Commented] (FLINK-26822) Add Source implementation for Cassandra connector

2022-04-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521041#comment-17521041 ] Martijn Visser commented on FLINK-26822: [~echauchot] Of course, just did that :

[jira] [Comment Edited] (FLINK-26822) Add Source implementation for Cassandra connector

2022-04-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521041#comment-17521041 ] Martijn Visser edited comment on FLINK-26822 at 4/12/22 9:38 AM: -

[jira] [Assigned] (FLINK-26822) Add Source implementation for Cassandra connector

2022-04-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-26822: -- Assignee: Etienne Chauchot > Add Source implementation for Cassandra connector >

[GitHub] [flink] slinkydeveloper commented on a diff in pull request #19436: [FLINK-27201][table] Remove CollectTableSink

2022-04-12 Thread GitBox
slinkydeveloper commented on code in PR #19436: URL: https://github.com/apache/flink/pull/19436#discussion_r848217684 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/batch/sql/LegacySinkTest.scala: ## @@ -1,101 +0,0 @@ -/* - * Licensed to th

[GitHub] [flink] slinkydeveloper commented on a diff in pull request #19436: [FLINK-27201][table] Remove CollectTableSink

2022-04-12 Thread GitBox
slinkydeveloper commented on code in PR #19436: URL: https://github.com/apache/flink/pull/19436#discussion_r848219745 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/batch/ExplainTest.scala: ## @@ -19,10 +19,12 @@ package org.apache.flink.table.api.

[GitHub] [flink] beyond1920 closed pull request #19105: [FLINK-26681][hive] support sql statement end with ";" for Hive dialect query

2022-04-12 Thread GitBox
beyond1920 closed pull request #19105: [FLINK-26681][hive] support sql statement end with ";" for Hive dialect query URL: https://github.com/apache/flink/pull/19105 -- 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-kubernetes-operator] Aitozi commented on pull request #165: [FLINK-26140] Support rollback strategies

2022-04-12 Thread GitBox
Aitozi commented on PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#issuecomment-1096459201 > Based on some discussion with @morhidi we decided to have the rollback related configs simply as part of the `flinkConfiguration` in order to avoid polluting the CRD

[jira] [Assigned] (FLINK-26681) Support sql statement end with ";" for Hive dialect

2022-04-12 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang reassigned FLINK-26681: -- Assignee: luoyuxia > Support sql statement end with ";" for Hive dialect > --

[jira] [Commented] (FLINK-26681) Support sql statement end with ";" for Hive dialect

2022-04-12 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521046#comment-17521046 ] Jing Zhang commented on FLINK-26681: Fixed in master: 36660cce32e7dbacf9b2408c6d65d8

[jira] [Commented] (FLINK-27183) Optimize CepOperator by using temporal state

2022-04-12 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521045#comment-17521045 ] Nicholas Jiang commented on FLINK-27183: [~danderson], I mainly maintain Flink C

[jira] [Closed] (FLINK-26681) Support sql statement end with ";" for Hive dialect

2022-04-12 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang closed FLINK-26681. -- Resolution: Fixed > Support sql statement end with ";" for Hive dialect >

[jira] [Updated] (FLINK-26681) Support sql statement end with ";" for Hive dialect

2022-04-12 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-26681: --- Issue Type: Bug (was: Improvement) > Support sql statement end with ";" for Hive dialect >

[GitHub] [flink] flinkbot commented on pull request #19437: [hotfix][streaming-java][runtime] Fix code comments.

2022-04-12 Thread GitBox
flinkbot commented on PR #19437: URL: https://github.com/apache/flink/pull/19437#issuecomment-1096466114 ## CI report: * ad8622a3d786172a3661cb3a6f0a91847fc0e2b5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-26811) Document CRD upgrade process

2022-04-12 Thread Ted Chang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521050#comment-17521050 ] Ted Chang commented on FLINK-26811: --- [~gyfora]  I am trying to solve step 4 below by [

[jira] [Assigned] (FLINK-26977) JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithRestartsShouldSimplyRestartInTerminate failed on azure

2022-04-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-26977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek reassigned FLINK-26977: - Assignee: David Morávek > JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackW

[jira] [Updated] (FLINK-26681) Support sql statement end with ";" for Hive dialect

2022-04-12 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-26681: --- Fix Version/s: 1.15.1 (was: 1.15.0) > Support sql statement end with ";" for

  1   2   3   4   5   6   7   8   >