[GitHub] [flink] slinkydeveloper commented on a change in pull request #17256: [FLINK-23385][table] Implement COALESCE function

slinkydeveloper commented on a change in pull request #17256: URL: https://github.com/apache/flink/pull/17256#discussion_r708891859 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/TypeStrategies.java ## @@ -105,6 +105,23 @@ pub

[GitHub] [flink] flinkbot commented on pull request #17284: [hotfix][docs] Fix Blob Server configuration doc

flinkbot commented on pull request #17284: URL: https://github.com/apache/flink/pull/17284#issuecomment-919745222 ## CI report: * 8526528123dc9af8412c79752f65a93e46cf5e48 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #17276: [FLINK-24277][connector/kafka] And configuration for committing offset on checkpoint and disable it if group ID is not specified

flinkbot edited a comment on pull request #17276: URL: https://github.com/apache/flink/pull/17276#issuecomment-918968550 ## CI report: * 264a99cf27b1b4f67fc0b3ef7c85c307f3a8e9a2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] Airblader commented on a change in pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

Airblader commented on a change in pull request #17186: URL: https://github.com/apache/flink/pull/17186#discussion_r708877468 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/JsonFunctionsITCase.java ## @@ -420,8 +431,146 @@

[GitHub] [flink] flinkbot commented on pull request #17284: [hotfix][docs] Fix Blob Server configuration doc

flinkbot commented on pull request #17284: URL: https://github.com/apache/flink/pull/17284#issuecomment-919735184 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 pro

[GitHub] [flink] Airblader commented on a change in pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

Airblader commented on a change in pull request #17186: URL: https://github.com/apache/flink/pull/17186#discussion_r708871696 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/JsonFunctionsITCase.java ## @@ -54,6 +77,7 @@

[GitHub] [flink] juha-aiven opened a new pull request #17284: [hotfix][docs] Fix Blob Server configuration doc

juha-aiven opened a new pull request #17284: URL: https://github.com/apache/flink/pull/17284 Both TaskManager and JobManager use Blob Server. So fart, the configuration documentation says only JobManager uses it. ## What is the purpose of the change Change the docs to reflect

[GitHub] [flink] flinkbot edited a comment on pull request #17276: [FLINK-24277][connector/kafka] And configuration for committing offset on checkpoint and disable it if group ID is not specified

flinkbot edited a comment on pull request #17276: URL: https://github.com/apache/flink/pull/17276#issuecomment-918968550 ## CI report: * 264a99cf27b1b4f67fc0b3ef7c85c307f3a8e9a2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17271: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector.

flinkbot edited a comment on pull request #17271: URL: https://github.com/apache/flink/pull/17271#issuecomment-918597722 ## CI report: * 2e8733c07113a9fdede210b630f03df5349004e1 UNKNOWN * da750b4254250b0c455d0984422f7fe691289dc7 Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #17253: [FLINK-24182][task] Allow tasks to cleanly cancel without any interruptions

flinkbot edited a comment on pull request #17253: URL: https://github.com/apache/flink/pull/17253#issuecomment-917975072 ## CI report: * 643c4b37f20fceda9710afe7092a3215d940c2de Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17229: [WIP][FLINK-23381][state] Back-pressure on reaching state change to upload limit

flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * 9986c52e840ff3c58cb6b03560bc471e678da9ab Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16994: [FLINK-23991][yarn] Specifying yarn.staging-dir fail when staging scheme is…

flinkbot edited a comment on pull request #16994: URL: https://github.com/apache/flink/pull/16994#issuecomment-906233672 ## CI report: * 9ad206f8b390dba9437cafe3414905946d84e933 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16853: [FLINK-23827][table-planner] Fix ModifiedMonotonicity inference for s…

flinkbot edited a comment on pull request #16853: URL: https://github.com/apache/flink/pull/16853#issuecomment-900037847 ## CI report: * f5e25efd95ff00218559bcf35fbcec524bc5f6ed Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-17914) HistoryServerTest.testCleanExpiredJob:158->runArchiveExpirationTest:214 expected:<2> but was:<0>

[ https://issues.apache.org/jira/browse/FLINK-17914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17914: - Priority: Major (was: Minor) > HistoryServerTest.testCleanExpiredJob:158->runArchiveExpirationT

[jira] [Updated] (FLINK-17914) HistoryServerTest.testCleanExpiredJob:158->runArchiveExpirationTest:214 expected:<2> but was:<0>

[ https://issues.apache.org/jira/browse/FLINK-17914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17914: - Labels: (was: auto-deprioritized-major) > HistoryServerTest.testCleanExpiredJob:158->runArchiv

[jira] [Updated] (FLINK-17914) HistoryServerTest.testCleanExpiredJob:158->runArchiveExpirationTest:214 expected:<2> but was:<0>

[ https://issues.apache.org/jira/browse/FLINK-17914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17914: - Affects Version/s: (was: 1.12.0) 1.14.0 > HistoryServerTest.testClean

[jira] [Commented] (FLINK-17914) HistoryServerTest.testCleanExpiredJob:158->runArchiveExpirationTest:214 expected:<2> but was:<0>

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

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

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

[jira] [Commented] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

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

[jira] [Created] (FLINK-24288) YARNITCase.testPerJobWithArchive fails on azure

Xintong Song created FLINK-24288: Summary: YARNITCase.testPerJobWithArchive fails on azure Key: FLINK-24288 URL: https://issues.apache.org/jira/browse/FLINK-24288 Project: Flink Issue Type: B

[jira] [Updated] (FLINK-24287) Bump virtualenv to the latest version

[ https://issues.apache.org/jira/browse/FLINK-24287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-24287: Description: Currently, the virtualenv version (16.0.0) used in PyFlink tests is a little outdated(the lat

[jira] [Created] (FLINK-24287) Bump virtualenv to the latest version

Dian Fu created FLINK-24287: --- Summary: Bump virtualenv to the latest version Key: FLINK-24287 URL: https://issues.apache.org/jira/browse/FLINK-24287 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #17271: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector.

flinkbot edited a comment on pull request #17271: URL: https://github.com/apache/flink/pull/17271#issuecomment-918597722 ## CI report: * 2e8733c07113a9fdede210b630f03df5349004e1 UNKNOWN * 310ab4e05c1de65ada8d149db7e1a7b4386d6b49 Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #17253: [FLINK-24182][task] Allow tasks to cleanly cancel without any interruptions

flinkbot edited a comment on pull request #17253: URL: https://github.com/apache/flink/pull/17253#issuecomment-917975072 ## CI report: * 643c4b37f20fceda9710afe7092a3215d940c2de Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16994: [FLINK-23991][yarn] Specifying yarn.staging-dir fail when staging scheme is…

flinkbot edited a comment on pull request #16994: URL: https://github.com/apache/flink/pull/16994#issuecomment-906233672 ## CI report: * 9ad206f8b390dba9437cafe3414905946d84e933 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415322#comment-17415322 ] Piotr Nowojski commented on FLINK-24149: {quote} Regarding first checkpoint afte

[GitHub] [flink] flinkbot edited a comment on pull request #17271: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector.

flinkbot edited a comment on pull request #17271: URL: https://github.com/apache/flink/pull/17271#issuecomment-918597722 ## CI report: * 2e8733c07113a9fdede210b630f03df5349004e1 UNKNOWN * e3c72be5086f04150d193e144e3a3ec6d8410324 Azure: [CANCELED](https://dev.azure.com/apache-f

[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: * 7e524508a999c88c22e981f9ec8a6fcdc6cb07bf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] zuston commented on a change in pull request #16994: [FLINK-23991][yarn] Specifying yarn.staging-dir fail when staging scheme is…

zuston commented on a change in pull request #16994: URL: https://github.com/apache/flink/pull/16994#discussion_r708841307 ## File path: flink-yarn/src/test/java/org/apache/flink/yarn/YarnClusterDescriptorTest.java ## @@ -741,6 +742,37 @@ public void testDeployApplicationClus

[GitHub] [flink] syhily commented on pull request #17271: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector.

syhily commented on pull request #17271: URL: https://github.com/apache/flink/pull/17271#issuecomment-919700063 @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 c

[GitHub] [flink] syhily removed a comment on pull request #17271: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector.

syhily removed a comment on pull request #17271: URL: https://github.com/apache/flink/pull/17271#issuecomment-919670409 @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 sp

[jira] [Updated] (FLINK-21429) JsonFileCompactionITCase>CompactionITCaseBase.testNonPartition

[ https://issues.apache.org/jira/browse/FLINK-21429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21429: - Labels: test-stability (was: auto-deprioritized-major test-stability) > JsonFileCompactionITCas

[jira] [Updated] (FLINK-21429) JsonFileCompactionITCase>CompactionITCaseBase.testNonPartition

[ https://issues.apache.org/jira/browse/FLINK-21429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21429: - Priority: Major (was: Minor) > JsonFileCompactionITCase>CompactionITCaseBase.testNonPartition >

[jira] [Updated] (FLINK-21429) JsonFileCompactionITCase>CompactionITCaseBase.testNonPartition

[ https://issues.apache.org/jira/browse/FLINK-21429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21429: - Fix Version/s: 1.12.6 > JsonFileCompactionITCase>CompactionITCaseBase.testNonPartition > ---

[jira] [Commented] (FLINK-21429) JsonFileCompactionITCase>CompactionITCaseBase.testNonPartition

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

[GitHub] [flink] flinkbot edited a comment on pull request #17276: [FLINK-24277][connector/kafka] And configuration for committing offset on checkpoint and disable it if group ID is not specified

flinkbot edited a comment on pull request #17276: URL: https://github.com/apache/flink/pull/17276#issuecomment-918968550 ## CI report: * 264a99cf27b1b4f67fc0b3ef7c85c307f3a8e9a2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 7e524508a999c88c22e981f9ec8a6fcdc6cb07bf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22449) Casting an invalid constant string to int throws exception from SinkNotNullEnforcer

[ https://issues.apache.org/jira/browse/FLINK-22449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415315#comment-17415315 ] xuyangzhong commented on FLINK-22449: - link https://issues.apache.org/jira/browse/CA

[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-919678226 Hi @leonardBang Thanks very much for review. I've updated the pr. please have a look, thanks a lot. -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on pull request #17276: [FLINK-24277][connector/kafka] And configuration for committing offset on checkpoint and disable it if group ID is not specified

flinkbot edited a comment on pull request #17276: URL: https://github.com/apache/flink/pull/17276#issuecomment-918968550 ## CI report: * 264a99cf27b1b4f67fc0b3ef7c85c307f3a8e9a2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17271: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector.

flinkbot edited a comment on pull request #17271: URL: https://github.com/apache/flink/pull/17271#issuecomment-918597722 ## CI report: * 2e8733c07113a9fdede210b630f03df5349004e1 UNKNOWN * e3c72be5086f04150d193e144e3a3ec6d8410324 Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

flinkbot edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-904541061 ## CI report: * f35ae1fea51f76cc57860f9c28e2b6b5cd3a4040 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16853: [FLINK-23827][table-planner] Fix ModifiedMonotonicity inference for s…

flinkbot edited a comment on pull request #16853: URL: https://github.com/apache/flink/pull/16853#issuecomment-900037847 ## CI report: * f5e25efd95ff00218559bcf35fbcec524bc5f6ed Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

leonardBang commented on a change in pull request #17205: URL: https://github.com/apache/flink/pull/17205#discussion_r708814675 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/MatchRowTimeFunction.java ## @@ -0,0 +1,129

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

beyond1920 commented on a change in pull request #17205: URL: https://github.com/apache/flink/pull/17205#discussion_r708810575 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/MatchRowTimeFunction.java ## @@ -0,0 +1,129 @

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

beyond1920 commented on a change in pull request #17205: URL: https://github.com/apache/flink/pull/17205#discussion_r708810575 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/MatchRowTimeFunction.java ## @@ -0,0 +1,129 @

[GitHub] [flink] syhily commented on pull request #17271: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector.

syhily commented on pull request #17271: URL: https://github.com/apache/flink/pull/17271#issuecomment-919670409 @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 c

[GitHub] [flink] flinkbot edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

flinkbot edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-904541061 ## CI report: * f35ae1fea51f76cc57860f9c28e2b6b5cd3a4040 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16853: [FLINK-23827][table-planner] Fix ModifiedMonotonicity inference for s…

flinkbot edited a comment on pull request #16853: URL: https://github.com/apache/flink/pull/16853#issuecomment-900037847 ## CI report: * f5e25efd95ff00218559bcf35fbcec524bc5f6ed Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] zjuwangg commented on pull request #16853: [FLINK-23827][table-planner] Fix ModifiedMonotonicity inference for s…

zjuwangg commented on pull request #16853: URL: https://github.com/apache/flink/pull/16853#issuecomment-919666732 I reviewed latest change and thought it's right way to modify test case. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

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

[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415302#comment-17415302 ] Feifan Wang commented on FLINK-24149: - Hi [~pnowojski] , Is there any documentation

[GitHub] [flink] Myasuka commented on a change in pull request #17203: [FLINK-22944][state] Optimize writing state changelog

Myasuka commented on a change in pull request #17203: URL: https://github.com/apache/flink/pull/17203#discussion_r708803812 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateBackendHandle.java ## @@ -48,20 +49,25 @@ List ge

[jira] [Closed] (FLINK-24139) Push down more predicates through Join in stream mode

[ https://issues.apache.org/jira/browse/FLINK-24139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-24139. -- Resolution: Fixed Fixed in 1.15.0: f366f779efd586470b2668be8736ca992db3054c > Push down more predicat

[jira] [Assigned] (FLINK-24139) Push down more predicates through Join in stream mode

[ https://issues.apache.org/jira/browse/FLINK-24139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-24139: -- Assignee: xuyangzhong > Push down more predicates through Join in stream mode > -

[GitHub] [flink] zjuwangg commented on pull request #16853: [FLINK-23827][table-planner] Fix ModifiedMonotonicity inference for s…

zjuwangg commented on pull request #16853: URL: https://github.com/apache/flink/pull/16853#issuecomment-919663832 @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

[jira] [Updated] (FLINK-24139) Push down more predicates through Join in stream mode

[ https://issues.apache.org/jira/browse/FLINK-24139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-24139: --- Fix Version/s: 1.15.0 > Push down more predicates through Join in stream mode >

[GitHub] [flink] godfreyhe closed pull request #17272: [FLINK-24139][table-planner] Push down more predicates through Join in stream mode

godfreyhe closed pull request #17272: URL: https://github.com/apache/flink/pull/17272 -- 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-unsub

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

[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415298#comment-17415298 ] Feifan Wang commented on FLINK-24149: - Make checkpoint self-contained not only for c

[GitHub] [flink] PatrickRen commented on a change in pull request #17276: [FLINK-24277][connector/kafka] And configuration for committing offset on checkpoint and disable it if group ID is not specifi

PatrickRen commented on a change in pull request #17276: URL: https://github.com/apache/flink/pull/17276#discussion_r708127131 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java ## @@ -481,5 +489,2

[jira] [Commented] (FLINK-24286) Flink TableEnvironment executesql on IntelliJ leads to Could not find a file system implementation for scheme 's3a'

[ https://issues.apache.org/jira/browse/FLINK-24286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415290#comment-17415290 ] Jark Wu commented on FLINK-24286: - In IDEA, I think you need manually add the flink-s3-f

[jira] [Commented] (FLINK-23914) Make connector testing framework more verbose on test failure

[ https://issues.apache.org/jira/browse/FLINK-23914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415289#comment-17415289 ] Qingsheng Ren commented on FLINK-23914: --- Hi [~esexton], I think the pull request o

[jira] [Updated] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23944: - Priority: Critical (was: Blocker) > PulsarSourceITCase.testTaskManagerFailure is instable > ---

[jira] [Commented] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415284#comment-17415284 ] Xintong Song commented on FLINK-23944: -- [~renqs] This is happening again. Could you

[jira] [Reopened] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-23944: -- > PulsarSourceITCase.testTaskManagerFailure is instable >

[jira] [Updated] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22068: - Affects Version/s: 1.14.0 > FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure >

[jira] [Commented] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure

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

[jira] [Commented] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415280#comment-17415280 ] Yi Tang commented on FLINK-22275: - Thanks [~jark], [~lirui], and [~luoyuxia]. > Datagen

[GitHub] [flink] yittg commented on pull request #15703: [FLINK-22275][table] Support random past for timestamp types in datagen connector

yittg commented on pull request #15703: URL: https://github.com/apache/flink/pull/15703#issuecomment-919620066 Thanks @wuchong -- 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 comme

[GitHub] [flink] flinkbot edited a comment on pull request #17271: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector.

flinkbot edited a comment on pull request #17271: URL: https://github.com/apache/flink/pull/17271#issuecomment-918597722 ## CI report: * 2e8733c07113a9fdede210b630f03df5349004e1 UNKNOWN * e3c72be5086f04150d193e144e3a3ec6d8410324 Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #17271: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector.

flinkbot edited a comment on pull request #17271: URL: https://github.com/apache/flink/pull/17271#issuecomment-918597722 ## CI report: * 2e8733c07113a9fdede210b630f03df5349004e1 UNKNOWN * e3c72be5086f04150d193e144e3a3ec6d8410324 Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #17271: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector.

flinkbot edited a comment on pull request #17271: URL: https://github.com/apache/flink/pull/17271#issuecomment-918597722 ## CI report: * 2e8733c07113a9fdede210b630f03df5349004e1 UNKNOWN * e3c72be5086f04150d193e144e3a3ec6d8410324 Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #17282: [WIP]FLINK-23342] Introduce ShareableStateHandle

flinkbot edited a comment on pull request #17282: URL: https://github.com/apache/flink/pull/17282#issuecomment-919276028 ## CI report: * cf5203162045fe63756df24db64dd7c6ddc14410 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-7151) Support function DDL

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

[jira] [Updated] (FLINK-19822) Remove redundant shuffle for streaming

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

[GitHub] [flink] flinkbot edited a comment on pull request #17282: [WIP]FLINK-23342] Introduce ShareableStateHandle

flinkbot edited a comment on pull request #17282: URL: https://github.com/apache/flink/pull/17282#issuecomment-919276028 ## CI report: * cf5203162045fe63756df24db64dd7c6ddc14410 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17244: [FLINK-24234][connectors] FLIP-171: Adding Time & Byte Size Based Flushing to Async Sink Writer

flinkbot edited a comment on pull request #17244: URL: https://github.com/apache/flink/pull/17244#issuecomment-917396866 ## CI report: * 1ca846f4330a0c49a534dd9ac5f07db3ed9744bc UNKNOWN * 3a3f7cb098fcaec0edbbc3bdf8d557b57c924ff9 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] rkhachatryan commented on pull request #17229: [WIP][FLINK-23381][state] Back-pressure on reaching state change to upload limit

rkhachatryan commented on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-919539133 Sorry @complone but don't fully understand the question. This PR is not directly related to metrics. I also do not understand the purpose of the flowchart, but it also

[GitHub] [flink] flinkbot edited a comment on pull request #17271: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector.

flinkbot edited a comment on pull request #17271: URL: https://github.com/apache/flink/pull/17271#issuecomment-918597722 ## CI report: * 2e8733c07113a9fdede210b630f03df5349004e1 UNKNOWN * 4e6beec347eb8d231e3fcbb3e5a7c1ea8d83c323 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17229: [WIP][FLINK-23381][state] Back-pressure on reaching state change to upload limit

flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * 30c754d27fca90d410964a7549f53252e7b2a507 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17271: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector.

flinkbot edited a comment on pull request #17271: URL: https://github.com/apache/flink/pull/17271#issuecomment-918597722 ## CI report: * 2e8733c07113a9fdede210b630f03df5349004e1 UNKNOWN * 4e6beec347eb8d231e3fcbb3e5a7c1ea8d83c323 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17229: [WIP][FLINK-23381][state] Back-pressure on reaching state change to upload limit

flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * 30c754d27fca90d410964a7549f53252e7b2a507 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

flinkbot edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-904541061 ## CI report: * f35ae1fea51f76cc57860f9c28e2b6b5cd3a4040 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17271: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector.

flinkbot edited a comment on pull request #17271: URL: https://github.com/apache/flink/pull/17271#issuecomment-918597722 ## CI report: * 2e8733c07113a9fdede210b630f03df5349004e1 UNKNOWN * 4e6beec347eb8d231e3fcbb3e5a7c1ea8d83c323 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17271: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector.

flinkbot edited a comment on pull request #17271: URL: https://github.com/apache/flink/pull/17271#issuecomment-918597722 ## CI report: * 2e8733c07113a9fdede210b630f03df5349004e1 UNKNOWN * 4e6beec347eb8d231e3fcbb3e5a7c1ea8d83c323 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17268: [FLINK-24133][core] Network failure test replaced by comment in the code due to high expense of stabilizing such low important test

flinkbot edited a comment on pull request #17268: URL: https://github.com/apache/flink/pull/17268#issuecomment-918320586 ## CI report: * 530f9c472c1c4861ff0c6c3b751424969a33ed84 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] syhily commented on a change in pull request #17271: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector.

syhily commented on a change in pull request #17271: URL: https://github.com/apache/flink/pull/17271#discussion_r708477506 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-pulsar/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceOrderedE2ECase.java ## @@

[GitHub] [flink] syhily commented on a change in pull request #17271: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector.

syhily commented on a change in pull request #17271: URL: https://github.com/apache/flink/pull/17271#discussion_r708587908 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-pulsar/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceOrderedE2ECase.java ## @@

[jira] [Closed] (FLINK-24282) KafkaRecordSerializationSchema TopicSelector is not serializable

[ https://issues.apache.org/jira/browse/FLINK-24282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24282. Resolution: Fixed Fixed in: * master ** 2ae710671442e382888b615c65f8aed5781bfaa4 * 1.14 **

[jira] [Closed] (FLINK-24283) Pulsar connector won't use given hash ranges in Key_Shared mode

[ https://issues.apache.org/jira/browse/FLINK-24283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24283. Resolution: Fixed Fixed in: * master ** 724fb3d8701a31349a1f65dee496d0a62916d0ed * 1.14 **

[GitHub] [flink] dawidwys merged pull request #17281: [FLINK-24282][connectors/kafka] Make topic selector for KafkaSink ser…

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

[GitHub] [flink] dawidwys merged pull request #17280: [FLINK-24282][connectors/kafka] Make topic selector for KafkaSink ser…

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

[GitHub] [flink] dawidwys merged pull request #17283: [FLINK-24283][connector/pulsar] Use stick key consumer in Key_Shared subscription.

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

[GitHub] [flink] syhily removed a comment on pull request #17283: [FLINK-24283][connector/pulsar] Use stick key consumer in Key_Shared subscription.

syhily removed a comment on pull request #17283: URL: https://github.com/apache/flink/pull/17283#issuecomment-919445827 @fapaul Can you review this issue? -- 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] flinkbot edited a comment on pull request #17281: [FLINK-24282][connectors/kafka] Make topic selector for KafkaSink ser…

flinkbot edited a comment on pull request #17281: URL: https://github.com/apache/flink/pull/17281#issuecomment-919252089 ## CI report: * 684fbc3061604f40d6f2c5ad65c7eba097294159 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17283: [FLINK-24283][connector/pulsar] Use stick key consumer in Key_Shared subscription.

flinkbot edited a comment on pull request #17283: URL: https://github.com/apache/flink/pull/17283#issuecomment-919276152 ## CI report: * 9a64e19798b4baef7976b5ea0ea3da017a845d27 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17282: [WIP]FLINK-23342] Introduce ShareableStateHandle

flinkbot edited a comment on pull request #17282: URL: https://github.com/apache/flink/pull/17282#issuecomment-919276028 ## CI report: * cf5203162045fe63756df24db64dd7c6ddc14410 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17258: [WIP][FLINK-23342][state] State ownership: compute shared state on recovery (encoded in low-level state handles)

flinkbot edited a comment on pull request #17258: URL: https://github.com/apache/flink/pull/17258#issuecomment-918153476 ## CI report: * c514364a26fda745494972f348cced4e0df539bb UNKNOWN * 81531237c55e27c9028084fea1ff543b81f1bbe0 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17217: [FLINK-24186][table-planner] Allow multiple rowtime attributes for collect() and print()

flinkbot edited a comment on pull request #17217: URL: https://github.com/apache/flink/pull/17217#issuecomment-916047672 ## CI report: * 637c37904be8ebb0409b2fe37beead74882ca811 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] dawidwys commented on pull request #17283: [FLINK-24283][connector/pulsar] Use stick key consumer in Key_Shared subscription.

dawidwys commented on pull request #17283: URL: https://github.com/apache/flink/pull/17283#issuecomment-919449494 Yes, I will in a bit -- 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 specifi

[GitHub] [flink] syhily commented on pull request #17283: [FLINK-24283][connector/pulsar] Use stick key consumer in Key_Shared subscription.

syhily commented on pull request #17283: URL: https://github.com/apache/flink/pull/17283#issuecomment-919445827 @fapaul Can you review this issue? -- 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

  1   2   3   4   >