[GitHub] [flink] flinkbot edited a comment on pull request #16513: [FLINK-23389][Formats] Glue schema registry JSON support

flinkbot edited a comment on pull request #16513: URL: https://github.com/apache/flink/pull/16513#issuecomment-881248601 ## CI report: * b83590dcb652ec96755c63e5ec7c9761fc96d87b UNKNOWN * 0ab16329651532d687f521ce9f6e75885f85d575 UNKNOWN *

[jira] [Closed] (FLINK-23378) ContinuousProcessingTimeTrigger最后一个定时器无法触发

[ https://issues.apache.org/jira/browse/FLINK-23378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] frey closed FLINK-23378. Fix Version/s: (was: 1.12.3) 1.14.1 Resolution: Fixed >

[jira] [Commented] (FLINK-24197) Streaming File Sink end-to-end test fails with : "RestClientException: [File upload failed.]"

[ https://issues.apache.org/jira/browse/FLINK-24197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412340#comment-17412340 ] Chesnay Schepler commented on FLINK-24197: -- I believe this to be an exotic bug in netty, and

[jira] [Created] (FLINK-24222) Use ContextClassLoaderExtension in ReporterSetupTest

Chesnay Schepler created FLINK-24222: Summary: Use ContextClassLoaderExtension in ReporterSetupTest Key: FLINK-24222 URL: https://issues.apache.org/jira/browse/FLINK-24222 Project: Flink

[jira] [Closed] (FLINK-24193) Test service entries cause noise in other tests

[ https://issues.apache.org/jira/browse/FLINK-24193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24193. Resolution: Fixed master: Extension added: a5e83afb510aafa05aac31413e2b59704c374aa3 REST

[GitHub] [flink] zentol merged pull request #17184: [FLINK-24193][tests] Add ClassLoaderExtension

zentol merged pull request #17184: URL: https://github.com/apache/flink/pull/17184 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Closed] (FLINK-24209) Jdbc connector uses postgres testcontainers in compile scope

[ https://issues.apache.org/jira/browse/FLINK-24209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24209. Resolution: Fixed master/1.14 are not affected. 1.13:

[GitHub] [flink] flinkbot edited a comment on pull request #17208: [BP-1.14][FLINK-23773][connector/kafka] Mark empty splits as finished to cleanup states in SplitFetcher

flinkbot edited a comment on pull request #17208: URL: https://github.com/apache/flink/pull/17208#issuecomment-915763233 ## CI report: * e677f27ac5d53678debb68648ac7ddc18dc2fb2c Azure:

[GitHub] [flink] zentol merged pull request #17197: [FLINK-24209][jdbc][build] Add test scope

zentol merged pull request #17197: URL: https://github.com/apache/flink/pull/17197 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot commented on pull request #17209: FLINK-23378

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

[jira] [Updated] (FLINK-23378) ContinuousProcessingTimeTrigger最后一个定时器无法触发

[ https://issues.apache.org/jira/browse/FLINK-23378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23378: --- Labels: pull-request-available (was: ) > ContinuousProcessingTimeTrigger最后一个定时器无法触发 >

[GitHub] [flink] frey66 opened a new pull request #17209: FLINK-23378

frey66 opened a new pull request #17209: URL: https://github.com/apache/flink/pull/17209 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them on

[GitHub] [flink] flinkbot commented on pull request #17208: [BP-1.14][FLINK-23773][connector/kafka] Mark empty splits as finished to cleanup states in SplitFetcher

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

[GitHub] [flink] flinkbot edited a comment on pull request #17207: [FLINK-22901][table-planner-blink] Introduce getUpsertKeys in FlinkRelMetadataQuery

flinkbot edited a comment on pull request #17207: URL: https://github.com/apache/flink/pull/17207#issuecomment-915750810 ## CI report: * 4f8b0f5ad64d4fe7c998042ec2b6b1ecec714be5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16513: [FLINK-23389][Formats] Glue schema registry JSON support

flinkbot edited a comment on pull request #16513: URL: https://github.com/apache/flink/pull/16513#issuecomment-881248601 ## CI report: * b83590dcb652ec96755c63e5ec7c9761fc96d87b UNKNOWN * 0ab16329651532d687f521ce9f6e75885f85d575 UNKNOWN *

[GitHub] [flink] godfreyhe commented on a change in pull request #17118: [FLINK-22603][table-planner]The digest can be produced by SourceAbilitySpec.

godfreyhe commented on a change in pull request #17118: URL: https://github.com/apache/flink/pull/17118#discussion_r704944200 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/schema/TableSourceTable.scala ## @@ -44,8 +43,8 @@

[jira] [Updated] (FLINK-24149) Make checkpoint self-contained and relocatable

[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-24149: Summary: Make checkpoint self-contained and relocatable (was: Make checkpoint relocatable) >

[jira] [Updated] (FLINK-24149) Make checkpoint relocatable

[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-24149: Description: h3. 1. Backgroud FLINK-5763 proposal make savepoint relocatable, checkpoint has

[jira] [Commented] (FLINK-24149) Make checkpoint relocatable

[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412326#comment-17412326 ] Feifan Wang commented on FLINK-24149: - Hi [~pnowojski], remove the current distinction between

[GitHub] [flink] flinkbot commented on pull request #17207: [FLINK-22901][table-planner-blink] Introduce getUpsertKeys in FlinkRelMetadataQuery

flinkbot commented on pull request #17207: URL: https://github.com/apache/flink/pull/17207#issuecomment-915750810 ## CI report: * 4f8b0f5ad64d4fe7c998042ec2b6b1ecec714be5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16513: [FLINK-23389][Formats] Glue schema registry JSON support

flinkbot edited a comment on pull request #16513: URL: https://github.com/apache/flink/pull/16513#issuecomment-881248601 ## CI report: * b83590dcb652ec96755c63e5ec7c9761fc96d87b UNKNOWN * 0ab16329651532d687f521ce9f6e75885f85d575 UNKNOWN *

[jira] [Comment Edited] (FLINK-24041) [FLIP-171] Generic AsyncSinkBase

[ https://issues.apache.org/jira/browse/FLINK-24041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412322#comment-17412322 ] Piotr Nowojski edited comment on FLINK-24041 at 9/9/21, 4:18 AM: - I had

[GitHub] [flink] flinkbot commented on pull request #17208: [BP-1.14][FLINK-23773][connector/kafka] Mark empty splits as finished to cleanup states in SplitFetcher

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

[GitHub] [flink] PatrickRen opened a new pull request #17208: [BP-1.14][FLINK-23773][connector/kafka] Mark empty splits as finished to cleanup states in SplitFetcher

PatrickRen opened a new pull request #17208: URL: https://github.com/apache/flink/pull/17208 Unchanged backport of #16870 on release-1.14 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Commented] (FLINK-20370) Result is wrong when sink primary key is not the same with query

[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412323#comment-17412323 ] Jingsong Lee commented on FLINK-20370: -- [~jark] I updated cases. I think UpsertMaterialize can

[jira] [Comment Edited] (FLINK-24041) [FLIP-171] Generic AsyncSinkBase

[ https://issues.apache.org/jira/browse/FLINK-24041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412322#comment-17412322 ] Piotr Nowojski edited comment on FLINK-24041 at 9/9/21, 3:56 AM: - I had

[GitHub] [flink] flinkbot commented on pull request #17207: [FLINK-22901][table-planner-blink] Introduce getUpsertKeys in FlinkRelMetadataQuery

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

[GitHub] [flink] pnowojski edited a comment on pull request #17068: [FLINK-24041][connectors] Flip 171 - Abstract Async Sink Base

pnowojski edited a comment on pull request #17068: URL: https://github.com/apache/flink/pull/17068#issuecomment-915740659 I had to revert this as 1702c9e4f4b because of build failures. Looks like this PR hasn't been rebased and conflicted with another change in the master.

[jira] [Comment Edited] (FLINK-24041) [FLIP-171] Generic AsyncSinkBase

[ https://issues.apache.org/jira/browse/FLINK-24041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412322#comment-17412322 ] Piotr Nowojski edited comment on FLINK-24041 at 9/9/21, 3:54 AM: - I had

[jira] [Comment Edited] (FLINK-20370) Result is wrong when sink primary key is not the same with query

[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412302#comment-17412302 ] Jingsong Lee edited comment on FLINK-20370 at 9/9/21, 3:54 AM: --- Yes, it

[jira] [Reopened] (FLINK-24041) [FLIP-171] Generic AsyncSinkBase

[ https://issues.apache.org/jira/browse/FLINK-24041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reopened FLINK-24041: I had to revert this as 1702c9e because of build failures. Looks like this PR hasn't been

[GitHub] [flink] pnowojski commented on pull request #17068: [FLINK-24041][connectors] Flip 171 - Abstract Async Sink Base

pnowojski commented on pull request #17068: URL: https://github.com/apache/flink/pull/17068#issuecomment-915740659 I had to revert this as 1702c9e4f4b because of build failures. Looks like this PR hasn't been rebased and conflicted with another change in the master. -- This is an

[jira] [Commented] (FLINK-24214) A submit job failure crashes the sql client

[ https://issues.apache.org/jira/browse/FLINK-24214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412321#comment-17412321 ] Jark Wu commented on FLINK-24214: - >From the stack trace, you should be using Flink version <= 1.12,

[GitHub] [flink] flinkbot edited a comment on pull request #16513: [FLINK-23389][Formats] Glue schema registry JSON support

flinkbot edited a comment on pull request #16513: URL: https://github.com/apache/flink/pull/16513#issuecomment-881248601 ## CI report: * b83590dcb652ec96755c63e5ec7c9761fc96d87b UNKNOWN * 0ab16329651532d687f521ce9f6e75885f85d575 UNKNOWN *

[jira] [Comment Edited] (FLINK-20370) Result is wrong when sink primary key is not the same with query

[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412302#comment-17412302 ] Jingsong Lee edited comment on FLINK-20370 at 9/9/21, 3:51 AM: --- Yes, it

[jira] [Comment Edited] (FLINK-20370) Result is wrong when sink primary key is not the same with query

[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412302#comment-17412302 ] Jingsong Lee edited comment on FLINK-20370 at 9/9/21, 3:50 AM: --- Yes, it

[jira] [Updated] (FLINK-22901) Introduce getChangeLogUpsertKeys in FlinkRelMetadataQuery

[ https://issues.apache.org/jira/browse/FLINK-22901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-22901: - Fix Version/s: 1.13.3 > Introduce getChangeLogUpsertKeys in FlinkRelMetadataQuery >

[jira] [Reopened] (FLINK-22901) Introduce getChangeLogUpsertKeys in FlinkRelMetadataQuery

[ https://issues.apache.org/jira/browse/FLINK-22901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reopened FLINK-22901: -- re-open for 1.13 > Introduce getChangeLogUpsertKeys in FlinkRelMetadataQuery >

[jira] [Commented] (FLINK-20370) Result is wrong when sink primary key is not the same with query

[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412318#comment-17412318 ] Jark Wu commented on FLINK-20370: - [~lzljs3620320] there is 4th case: input is changelog, but there is

[GitHub] [flink] JingsongLi opened a new pull request #17207: [FLINK-22901][table] Introduce getUpsertKeys in FlinkRelMetadataQuery

JingsongLi opened a new pull request #17207: URL: https://github.com/apache/flink/pull/17207 Cherry-pick #16096 ## What is the purpose of the change For fix FLINK-20374, we need to resolve streaming computation disorder. we need to introduce a change log upsert keys, this is

[jira] [Commented] (FLINK-20370) Result is wrong when sink primary key is not the same with query

[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412317#comment-17412317 ] Jark Wu commented on FLINK-20370: - [~lzljs3620320] could UpsertMaterialize also solve this problem? >

[GitHub] [flink] becketqin commented on pull request #17064: [FLINK-24059][Connectors/Common] Allow SourceReaderTestBase.NUM_SPLITS to be overridden

becketqin commented on pull request #17064: URL: https://github.com/apache/flink/pull/17064#issuecomment-915734942 Thanks for the patch. LGTM. Merged to master d4c483fadd3df32045fbb2ee117d0a6eeab9276e -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-10230) Support 'SHOW CREATE VIEW' syntax to print the query of a view

[ https://issues.apache.org/jira/browse/FLINK-10230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412313#comment-17412313 ] Jark Wu commented on FLINK-10230: - I'm fine with both SHOW CREATE TABLE and SHOW CREATE VIEW.

[GitHub] [flink] becketqin merged pull request #17064: [FLINK-24059][Connectors/Common] Allow SourceReaderTestBase.NUM_SPLITS to be overridden

becketqin merged pull request #17064: URL: https://github.com/apache/flink/pull/17064 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #17023: [FLINK-24043][runtime] Reuse the code of 'check savepoint preconditions'.

gaoyunhaii commented on a change in pull request #17023: URL: https://github.com/apache/flink/pull/17023#discussion_r704923725 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java ## @@ -825,22 +824,9 @@ public void

[GitHub] [flink] gaoyunhaii commented on a change in pull request #17023: [FLINK-24043][runtime] Reuse the code of 'check savepoint preconditions'.

gaoyunhaii commented on a change in pull request #17023: URL: https://github.com/apache/flink/pull/17023#discussion_r704923725 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java ## @@ -825,22 +824,9 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #17118: [FLINK-22603][table-planner]The digest can be produced by SourceAbilitySpec.

flinkbot edited a comment on pull request #17118: URL: https://github.com/apache/flink/pull/17118#issuecomment-911539514 ## CI report: * Unknown: [CANCELED](TBD) * 02e870f42aad87379e45b2aaf3fed2e8351fc0a2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16513: [FLINK-23389][Formats] Glue schema registry JSON support

flinkbot edited a comment on pull request #16513: URL: https://github.com/apache/flink/pull/16513#issuecomment-881248601 ## CI report: * b83590dcb652ec96755c63e5ec7c9761fc96d87b UNKNOWN * 0ab16329651532d687f521ce9f6e75885f85d575 UNKNOWN *

[jira] [Commented] (FLINK-22455) FlinkRelBuilder#windowAggregate will throw ClassCastException when function reuse

[ https://issues.apache.org/jira/browse/FLINK-22455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412307#comment-17412307 ] xuyangzhong commented on FLINK-22455: - Hi, [~tartarus]. I'm trying to solve this issue recently, and

[GitHub] [flink] flinkbot edited a comment on pull request #17206: [FLINK-24199][python] Expose StreamExecutionEnvironment#configure in Python API

flinkbot edited a comment on pull request #17206: URL: https://github.com/apache/flink/pull/17206#issuecomment-915706736 ## CI report: * 169c8d343e362c0244d2c977bab4db6ac2b47ee1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17118: [FLINK-22603][table-planner]The digest can be produced by SourceAbilitySpec.

flinkbot edited a comment on pull request #17118: URL: https://github.com/apache/flink/pull/17118#issuecomment-911539514 ## CI report: * Unknown: [CANCELED](TBD) * 02e870f42aad87379e45b2aaf3fed2e8351fc0a2 UNKNOWN Bot commands The @flinkbot bot supports the

[jira] [Commented] (FLINK-20370) Result is wrong when sink primary key is not the same with query

[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412302#comment-17412302 ] Jingsong Lee commented on FLINK-20370: -- Yes, it seems that the only solution is single parallelism.

[jira] [Closed] (FLINK-24196) Translate "EXPLAIN Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24196. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: 125cb70a232b6a6e52c099c6a280414e2f896ad5 >

[GitHub] [flink] wuchong merged pull request #17195: [FLINK-24196][doc]Translate "EXPLAIN Statements" page of "SQL" into C…

wuchong merged pull request #17195: URL: https://github.com/apache/flink/pull/17195 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Comment Edited] (FLINK-24195) Translate "DESCRIBE Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412293#comment-17412293 ] Jark Wu edited comment on FLINK-24195 at 9/9/21, 2:42 AM: -- Fixed in master:

[jira] [Closed] (FLINK-24195) Translate "DESCRIBE Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24195. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in maste: 7b436773fc8eda6bb5f3c01b917d15d15aa70521 >

[GitHub] [flink] wuchong merged pull request #17192: [FLINK-24195][doc]Translate "DESCRIBE Statements" page of "SQL" into …

wuchong merged pull request #17192: URL: https://github.com/apache/flink/pull/17192 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #16513: [FLINK-23389][Formats] Glue schema registry JSON support

flinkbot edited a comment on pull request #16513: URL: https://github.com/apache/flink/pull/16513#issuecomment-881248601 ## CI report: * b83590dcb652ec96755c63e5ec7c9761fc96d87b UNKNOWN * 0ab16329651532d687f521ce9f6e75885f85d575 UNKNOWN *

[jira] [Assigned] (FLINK-24219) Translate "SET Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24219: --- Assignee: wuguihu > Translate "SET Statements" page of "SQL" into Chinese >

[jira] [Assigned] (FLINK-24218) Translate "UNLOAD Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24218: --- Assignee: wuguihu > Translate "UNLOAD Statements" page of "SQL" into Chinese >

[jira] [Assigned] (FLINK-24217) Translate "LOAD Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24217: --- Assignee: wuguihu > Translate "LOAD Statements" page of "SQL" into Chinese >

[jira] [Assigned] (FLINK-24220) Translate "RESET Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24220: --- Assignee: wuguihu > Translate "RESET Statements" page of "SQL" into Chinese >

[jira] [Assigned] (FLINK-24221) Translate "JAR Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24221: --- Assignee: wuguihu > Translate "JAR Statements" page of "SQL" into Chinese >

[jira] [Commented] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate follows after Match because the output type does not updated after input rowtime attribute changed

[ https://issues.apache.org/jira/browse/FLINK-24168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412286#comment-17412286 ] Jark Wu commented on FLINK-24168: - +1 to only fix in master. Actually, we also not fix in master, but

[jira] [Updated] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate follows after Match because the output type does not updated after input rowtime attribute changed f

[ https://issues.apache.org/jira/browse/FLINK-24168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-24168: --- Fix Version/s: (was: 1.14.0) 1.15.0 > Rowtime type is not correct for

[jira] [Commented] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate follows after Match because the output type does not updated after input rowtime attribute changed

[ https://issues.apache.org/jira/browse/FLINK-24168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412284#comment-17412284 ] godfrey he commented on FLINK-24168: I would like to fix it only in master, not including 1.13 and

[jira] [Comment Edited] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate follows after Match because the output type does not updated after input rowtime attribute ch

[ https://issues.apache.org/jira/browse/FLINK-24168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412282#comment-17412282 ] JING ZHANG edited comment on FLINK-24168 at 9/9/21, 2:29 AM: - One more

[GitHub] [flink] xuyangzhong commented on pull request #17118: [FLINK-22603][table-planner]The digest can be produced by SourceAbilitySpec.

xuyangzhong commented on pull request #17118: URL: https://github.com/apache/flink/pull/17118#issuecomment-915709849 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Commented] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate follows after Match because the output type does not updated after input rowtime attribute changed

[ https://issues.apache.org/jira/browse/FLINK-24168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412282#comment-17412282 ] JING ZHANG commented on FLINK-24168: One more question, the bug already exists in 1.13,  the result

[GitHub] [flink] flinkbot commented on pull request #17206: [FLINK-24199][python] Expose StreamExecutionEnvironment#configure in Python API

flinkbot commented on pull request #17206: URL: https://github.com/apache/flink/pull/17206#issuecomment-915706736 ## CI report: * 169c8d343e362c0244d2c977bab4db6ac2b47ee1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17205: [FLINK-24168][table-planner] Update MATCH_ROWTIME function which could receive 0 argument or 1 argument

flinkbot edited a comment on pull request #17205: URL: https://github.com/apache/flink/pull/17205#issuecomment-915449441 ## CI report: * 911c37bbcc7b9ec9603ae72bede52bc2b464642c Azure:

[GitHub] [flink] beyond1920 commented on pull request #17205: [FLINK-24168][table-planner] Update MATCH_ROWTIME function which could receive 0 argument or 1 argument

beyond1920 commented on pull request #17205: URL: https://github.com/apache/flink/pull/17205#issuecomment-915706498 cc @twalthr @leonardBang @wuchong @godfreyhe . Please have a look, thanks very much. -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate follows after Match because the output type does not updated after input rowtime attribute changed

[ https://issues.apache.org/jira/browse/FLINK-24168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412276#comment-17412276 ] JING ZHANG commented on FLINK-24168: [~twalthr] [~jark] [~Leonard Xu] Thanks for all suggestions.

[GitHub] [flink] flinkbot edited a comment on pull request #17205: [FLINK-24168][table-planner] Update MATCH_ROWTIME function which could receive 0 argument or 1 argument

flinkbot edited a comment on pull request #17205: URL: https://github.com/apache/flink/pull/17205#issuecomment-915449441 ## CI report: * 911c37bbcc7b9ec9603ae72bede52bc2b464642c Azure:

[GitHub] [flink] flinkbot commented on pull request #17206: [FLINK-24199][python] Expose StreamExecutionEnvironment#configure in Python API

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

[jira] [Updated] (FLINK-24199) Expose StreamExecutionEnvironment#configure in Python API

[ https://issues.apache.org/jira/browse/FLINK-24199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24199: --- Labels: pull-request-available (was: ) > Expose StreamExecutionEnvironment#configure in

[GitHub] [flink] SteNicholas opened a new pull request #17206: [FLINK-24199][python] Expose StreamExecutionEnvironment#configure in Python API

SteNicholas opened a new pull request #17206: URL: https://github.com/apache/flink/pull/17206 ## What is the purpose of the change *There are certain parameters that can be configured only through the underlying configuration of `StreamExecutionEnvironment` e.g.

[GitHub] [flink] SteNicholas commented on pull request #17105: [FLINK-23704][streaming] FLIP-27 sources are not generating LatencyMarkers

SteNicholas commented on pull request #17105: URL: https://github.com/apache/flink/pull/17105#issuecomment-915681646 > @SteNicholas , do you think we can get this into 1.14? Do you have time to finish it this week? @AHeise , of course yes. I will update this PR today. -- This is

[jira] [Updated] (FLINK-23583) Easy way to remove metadata before serializing row data for connector implementations

[ https://issues.apache.org/jira/browse/FLINK-23583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23583: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-23684) KafkaITCase.testAutoOffsetRetrievalAndCommitToKafka fails with NoSuchElementException

[ https://issues.apache.org/jira/browse/FLINK-23684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23684: --- Labels: stale-assigned test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-16556) TopSpeedWindowing should implement checkpointing for its source

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

[GitHub] [flink] flinkbot edited a comment on pull request #17188: [FLINK-23864][docs] Add pulsar connector document

flinkbot edited a comment on pull request #17188: URL: https://github.com/apache/flink/pull/17188#issuecomment-914560045 ## CI report: * 2603f6050baeaf45f3b062ae48891d00d4f86a31 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17205: [FLINK-24168][table-planner] Update MATCH_ROWTIME function which could receive 0 argument or 1 argument

flinkbot edited a comment on pull request #17205: URL: https://github.com/apache/flink/pull/17205#issuecomment-915449441 ## CI report: * 911c37bbcc7b9ec9603ae72bede52bc2b464642c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17184: [FLINK-24193][tests] Add ClassLoaderExtension

flinkbot edited a comment on pull request #17184: URL: https://github.com/apache/flink/pull/17184#issuecomment-914328876 ## CI report: * 39e7b6d0a0eb8f68fa58b66856694470919491d0 UNKNOWN * 96b93be4eed6db33c1638f5b6e2a0c2f508c0f05 Azure:

[GitHub] [flink] dannycranmer commented on a change in pull request #17189: [FLINK-23528][connectors/kinesis] Improving and reenable FlinkKinesisITCase

dannycranmer commented on a change in pull request #17189: URL: https://github.com/apache/flink/pull/17189#discussion_r704784987 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java

[jira] [Commented] (FLINK-23888) Flink azure fs doesn't work

[ https://issues.apache.org/jira/browse/FLINK-23888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412190#comment-17412190 ] Chesnay Schepler commented on FLINK-23888: -- I'm well aware of the principle behind parent-first

[GitHub] [flink] flinkbot edited a comment on pull request #17204: [FLINK-22942] [sql/planner] Disable UPSERT INTO statement

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

[GitHub] [flink] flinkbot edited a comment on pull request #17189: [FLINK-23528][connectors/kinesis] Improving and reenable FlinkKinesisITCase

flinkbot edited a comment on pull request #17189: URL: https://github.com/apache/flink/pull/17189#issuecomment-914637509 ## CI report: * a9fe3682e269eafffef3e4f37734996199d59d4b Azure:

[jira] [Resolved] (FLINK-24041) [FLIP-171] Generic AsyncSinkBase

[ https://issues.apache.org/jira/browse/FLINK-24041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-24041. --- Resolution: Done > [FLIP-171] Generic AsyncSinkBase > > >

[jira] [Updated] (FLINK-24041) [FLIP-171] Generic AsyncSinkBase

[ https://issues.apache.org/jira/browse/FLINK-24041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-24041: -- Fix Version/s: 1.15.0 > [FLIP-171] Generic AsyncSinkBase > >

[jira] [Commented] (FLINK-24041) [FLIP-171] Generic AsyncSinkBase

[ https://issues.apache.org/jira/browse/FLINK-24041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412180#comment-17412180 ] Danny Cranmer commented on FLINK-24041: --- [~CrynetLogistics] can you please link the related Async

[GitHub] [flink] dannycranmer merged pull request #17068: [FLINK-24041][connectors] Flip 171 - Abstract Async Sink Base

dannycranmer merged pull request #17068: URL: https://github.com/apache/flink/pull/17068 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] dannycranmer commented on pull request #17068: [FLINK-24041][connectors] Flip 171 - Abstract Async Sink Base

dannycranmer commented on pull request #17068: URL: https://github.com/apache/flink/pull/17068#issuecomment-915550882 LGTM, merging -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17203: [WIP][FLINK-22944][state] Optimize writing state changelog

flinkbot edited a comment on pull request #17203: URL: https://github.com/apache/flink/pull/17203#issuecomment-915404842 ## CI report: * a4683e8c521180f39b7714b9884cd71520dac1c6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17199: [FLINK-23848][connector/pulsar] Fix the consumer not found error in test. [1.14]

flinkbot edited a comment on pull request #17199: URL: https://github.com/apache/flink/pull/17199#issuecomment-915288286 ## CI report: * 852571fd2ee436ef97c309efd01e4a054abf4426 Azure:

[jira] [Commented] (FLINK-23888) Flink azure fs doesn't work

[ https://issues.apache.org/jira/browse/FLINK-23888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412172#comment-17412172 ] Liviu Firu commented on FLINK-23888: h5. classloader.parent-first-patterns.default is set to 

[GitHub] [flink] flinkbot edited a comment on pull request #17201: [FLINK-23944][connector/pulsar] Enable PulsarSourceITCase.testTaskManagerFailure

flinkbot edited a comment on pull request #17201: URL: https://github.com/apache/flink/pull/17201#issuecomment-915343401 ## CI report: * e0146a377cd299771eb4db29143d4fd39390f135 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17202: [BP-1.14][FLINK-22889][tests] Increase timeouts in JdbcExactlyOnceSinkE2eTest

flinkbot edited a comment on pull request #17202: URL: https://github.com/apache/flink/pull/17202#issuecomment-915371073 ## CI report: * 565c4103d73e5512a4ef00db59bc3de6ff4b11ae Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17200: [FLINK-24161] Fix interplay of stop-with-savepoint w/o drain with final checkpoints

flinkbot edited a comment on pull request #17200: URL: https://github.com/apache/flink/pull/17200#issuecomment-915343275 ## CI report: * 7f7d2b646137038a84fce12b25825e12d80ddf48 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17188: [FLINK-23864][docs] Add pulsar connector document

flinkbot edited a comment on pull request #17188: URL: https://github.com/apache/flink/pull/17188#issuecomment-914560045 ## CI report: * f2302fc7d5f4c0f7d46fd9ceb76fa2813554ad90 Azure:

  1   2   3   4   5   >