[jira] [Commented] (FLINK-25048) 在某个option后设置watermark，如果这个option里面有 outputTag，则此outputTag 不会有数据输出，只会在主流输出数据

[ https://issues.apache.org/jira/browse/FLINK-25048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448996#comment-17448996 ] Yao Zhang commented on FLINK-25048: --- Hi [~liangxinli] , I debugged the StreamGraph ge

[GitHub] [flink] cc13ny commented on a change in pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

cc13ny commented on a change in pull request #17847: URL: https://github.com/apache/flink/pull/17847#discussion_r756646953 ## File path: flink-connectors/flink-connector-mongodb/pom.xml ## @@ -0,0 +1,200 @@ + + +http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/

[jira] [Closed] (FLINK-24294) Resources leak in the StreamTask constructor

[ https://issues.apache.org/jira/browse/FLINK-24294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24294. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in: * master ** 0be100bca749a8bf20dc

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

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

[GitHub] [flink] shenzhu commented on pull request #17793: [FLINK-21565][Table SQL/API] Support more integer types in TIMESTAMPADD

shenzhu commented on pull request #17793: URL: https://github.com/apache/flink/pull/17793#issuecomment-978933817 Hey @twalthr , would you mind taking a look at this PR when you have a moment? Thanks! -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] AHeise merged pull request #17851: [FLINK-21214][kafka/IT] add retry rule for testScaleDownBeforeFirstCh…

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

[jira] [Commented] (FLINK-21214) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed

[ https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449009#comment-17449009 ] Arvid Heise commented on FLINK-21214: - Merged into 1.13 as 408ba03902621f69b996a19af

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17898: [FLINK-25047][table] Resolve architectural violations

slinkydeveloper commented on a change in pull request #17898: URL: https://github.com/apache/flink/pull/17898#discussion_r756658654 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/NoMatchingTableFactoryException.java ## @@ -28,6 +29,7 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17900: [FLINK-24803][Table SQL/Planner] Fix cast BINARY/VARBINARY to STRING

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

[GitHub] [flink] flinkbot edited a comment on pull request #17900: [FLINK-24803][Table SQL/Planner] Fix cast BINARY/VARBINARY to STRING

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

[GitHub] [flink] AHeise commented on a change in pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

AHeise commented on a change in pull request #17847: URL: https://github.com/apache/flink/pull/17847#discussion_r756664448 ## File path: flink-connectors/flink-connector-mongodb/src/main/java/org/apache/flink/mongodb/streaming/sink/MongoBulkWriter.java ## @@ -0,0 +1,272 @@ +pa

[jira] [Commented] (FLINK-11813) Standby per job mode Dispatchers don't know job's JobSchedulingStatus

[ https://issues.apache.org/jira/browse/FLINK-11813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449015#comment-17449015 ] Matthias commented on FLINK-11813: -- FYI: [FLIP-194|https://cwiki.apache.org/confluence

[jira] [Commented] (FLINK-25039) AZP fails with license check

[ https://issues.apache.org/jira/browse/FLINK-25039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449017#comment-17449017 ] Till Rohrmann commented on FLINK-25039: --- https://dev.azure.com/apache-flink/apache

[jira] [Updated] (FLINK-25039) AZP fails with license check

[ https://issues.apache.org/jira/browse/FLINK-25039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25039: -- Priority: Blocker (was: Critical) > AZP fails with license check > --

[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=17449020#comment-17449020 ] Till Rohrmann commented on FLINK-23944: --- https://dev.azure.com/apache-flink/apache

[jira] [Closed] (FLINK-24449) PulsarSourceITCase>SourceTestSuiteBase.testTaskManagerFailure fails with record mismatch

[ https://issues.apache.org/jira/browse/FLINK-24449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-24449. - Resolution: Duplicate > PulsarSourceITCase>SourceTestSuiteBase.testTaskManagerFailure fails with

[jira] [Commented] (FLINK-24763) ParquetFileSystemITCase.testLimitableBulkFormat failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449022#comment-17449022 ] Till Rohrmann commented on FLINK-24763: --- Another instance: https://dev.azure.com/

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 ## CI report: * 1ce5968cac8a461a937b59feae490bb0c840cd4b 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 #17811: [FLINK-24754] Implement CHAR/VARCHAR length validation for sinks

Airblader commented on a change in pull request #17811: URL: https://github.com/apache/flink/pull/17811#discussion_r756662813 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java ## @@ -381,11 +394,44 @@

[jira] [Commented] (FLINK-24935) Python module failed to compile due to "Could not create local repository"

[ https://issues.apache.org/jira/browse/FLINK-24935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449028#comment-17449028 ] Till Rohrmann commented on FLINK-24935: --- Another instance: https://dev.azure.com/

[jira] [Updated] (FLINK-24935) Python module failed to compile due to "Could not create local repository"

[ https://issues.apache.org/jira/browse/FLINK-24935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-24935: -- Priority: Critical (was: Major) > Python module failed to compile due to "Could not create lo

[jira] [Commented] (FLINK-10737) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449029#comment-17449029 ] Till Rohrmann commented on FLINK-10737: --- Another instance: https://dev.azure.com/

[jira] [Updated] (FLINK-10737) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10737: -- Affects Version/s: 1.12.5 > FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint failed

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

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

[jira] [Commented] (FLINK-24764) pyflink/table/tests/test_udf.py hang on Azure

[ https://issues.apache.org/jira/browse/FLINK-24764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449033#comment-17449033 ] Till Rohrmann commented on FLINK-24764: --- Another instance: https://dev.azure.com/

[jira] [Updated] (FLINK-24764) pyflink/table/tests/test_udf.py hang on Azure

[ https://issues.apache.org/jira/browse/FLINK-24764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-24764: -- Affects Version/s: 1.14.0 > pyflink/table/tests/test_udf.py hang on Azure > --

[jira] [Commented] (FLINK-24764) pyflink/table/tests/test_udf.py hang on Azure

[ https://issues.apache.org/jira/browse/FLINK-24764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449034#comment-17449034 ] Till Rohrmann commented on FLINK-24764: --- [~dianfu] could you take a look at this p

[jira] [Assigned] (FLINK-24902) Port boolean <-> numeric casting logic to CastRule

[ https://issues.apache.org/jira/browse/FLINK-24902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani reassigned FLINK-24902: --- Assignee: Francesco Guardiani > Port boolean <-> numeric casting logic to C

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 ## CI report: * 1ce5968cac8a461a937b59feae490bb0c840cd4b 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 #17898: [FLINK-25047][table] Resolve architectural violations

Airblader commented on a change in pull request #17898: URL: https://github.com/apache/flink/pull/17898#discussion_r756680828 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/NoMatchingTableFactoryException.java ## @@ -28,6 +29,7 @@ import

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

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

[jira] [Created] (FLINK-25051) Port raw <-> binary logic to CastRule

Francesco Guardiani created FLINK-25051: --- Summary: Port raw <-> binary logic to CastRule Key: FLINK-25051 URL: https://issues.apache.org/jira/browse/FLINK-25051 Project: Flink Issue Typ

[jira] [Created] (FLINK-25052) Port row to row cast logic to CastRule

Francesco Guardiani created FLINK-25052: --- Summary: Port row to row cast logic to CastRule Key: FLINK-25052 URL: https://issues.apache.org/jira/browse/FLINK-25052 Project: Flink Issue Ty

[jira] [Assigned] (FLINK-25051) Port raw <-> binary logic to CastRule

[ https://issues.apache.org/jira/browse/FLINK-25051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani reassigned FLINK-25051: --- Assignee: (was: Francesco Guardiani) > Port raw <-> binary logic to Cas

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #17898: [FLINK-25047][table] Resolve architectural violations

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

[jira] [Created] (FLINK-25053) Document how to use the usrlib to load code in the user code class loader

Till Rohrmann created FLINK-25053: - Summary: Document how to use the usrlib to load code in the user code class loader Key: FLINK-25053 URL: https://issues.apache.org/jira/browse/FLINK-25053 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #17898: [FLINK-25047][table] Resolve architectural violations

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

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #17895: [FLINK-25039][build] Disable shading of test jar by default

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

[GitHub] [flink] autophagy commented on pull request #17896: [FLINK-25041][e2e] Improve error handling for missing environment variables in E2E tests

autophagy commented on pull request #17896: URL: https://github.com/apache/flink/pull/17896#issuecomment-978978694 @fapaul Sure, thats a good idea. I will add those. -- 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] flinkbot edited a comment on pull request #17895: [FLINK-25039][build] Disable shading of test jar by default

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

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

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

[jira] [Commented] (FLINK-24902) Port boolean <-> numeric casting logic to CastRule

[ https://issues.apache.org/jira/browse/FLINK-24902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449050#comment-17449050 ] Marios Trivyzas commented on FLINK-24902: - Since we have already dropped support

[jira] [Created] (FLINK-25054) flink sql System (Built-in) Functions 【SHA2】，hashLength validation Unsurpport

chenbowen created FLINK-25054: - Summary: flink sql System (Built-in) Functions 【SHA2】，hashLength validation Unsurpport Key: FLINK-25054 URL: https://issues.apache.org/jira/browse/FLINK-25054 Project: Flin

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #17822: Release 1.14 kafka3.0 bug

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

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

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

[jira] [Commented] (FLINK-24576) Drop support for casting decimal numerics to boolean for SQL

[ https://issues.apache.org/jira/browse/FLINK-24576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449051#comment-17449051 ] Francesco Guardiani commented on FLINK-24576: - Does this issue applies to th

[jira] [Updated] (FLINK-25027) Allow GC of a finished job's JobMaster before the slot timeout is reached

[ https://issues.apache.org/jira/browse/FLINK-25027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-25027: -- Priority: Major (was: Critical) > Allow GC of a finished job's JobMaster before the slot time

[jira] [Updated] (FLINK-24596) Bugs in sink.buffer-flush before upsert-kafka

[ https://issues.apache.org/jira/browse/FLINK-24596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24596: --- Fix Version/s: 1.15.0 1.14.1 > Bugs in sink.buffer-flush before upsert-ka

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

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

[jira] [Commented] (FLINK-25027) Allow GC of a finished job's JobMaster before the slot timeout is reached

[ https://issues.apache.org/jira/browse/FLINK-25027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449052#comment-17449052 ] Martijn Visser commented on FLINK-25027: [~zjureel] I've assigned it to you > A

[jira] [Assigned] (FLINK-25027) Allow GC of a finished job's JobMaster before the slot timeout is reached

[ https://issues.apache.org/jira/browse/FLINK-25027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25027: -- Assignee: Shammon > Allow GC of a finished job's JobMaster before the slot timeout is

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

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

[jira] [Commented] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449053#comment-17449053 ] Martijn Visser commented on FLINK-20188: [~monster#12] Please keep us posted on

[jira] [Commented] (FLINK-24576) Drop support for casting decimal numerics to boolean for SQL

[ https://issues.apache.org/jira/browse/FLINK-24576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449054#comment-17449054 ] Marios Trivyzas commented on FLINK-24576: - Currently, we support the inverse for

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 ## CI report: * 4978168c923c603963d721202712d5ee8694d58f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Assigned] (FLINK-22113) UniqueKey constraint is lost with multiple sources join in SQL

[ https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-22113: -- Assignee: Marios Trivyzas > UniqueKey constraint is lost with multiple sources join i

[GitHub] [flink] MonsterChenzhuo commented on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

MonsterChenzhuo commented on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-979003283 @Airblader Sorry, I'm a newbie, so I took the time to learn a bit about Git today. I think it should now match what you said: add flink-architecture-tests. -- This is

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 ## CI report: * 4978168c923c603963d721202712d5ee8694d58f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] JingGe opened a new pull request #17904: [FLINK-21214][kafka/IT] add retry rule

JingGe opened a new pull request #17904: URL: https://github.com/apache/flink/pull/17904 ## What is the purpose of the change hardening the test on the old releases with retry rules, the issue has been solved after bumping Kafka to 2.8.1. ## Brief change log - Tes

[GitHub] [flink] matriv commented on a change in pull request #17811: [FLINK-24754] Implement CHAR/VARCHAR length validation for sinks

matriv commented on a change in pull request #17811: URL: https://github.com/apache/flink/pull/17811#discussion_r756706803 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSinkITCase.java ## @@ -187,6 +

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 ## CI report: * 4978168c923c603963d721202712d5ee8694d58f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #17904: [FLINK-21214][kafka/IT] add retry rule

flinkbot commented on pull request #17904: URL: https://github.com/apache/flink/pull/17904#issuecomment-979009600 ## CI report: * 1c5d1f22188db0d0326eba9e30ea944009ab630f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #17904: [FLINK-21214][kafka/IT] add retry rule

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

[jira] [Commented] (FLINK-24576) Drop support for casting decimal numerics to boolean for SQL

[ https://issues.apache.org/jira/browse/FLINK-24576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449060#comment-17449060 ] Francesco Guardiani commented on FLINK-24576: - So in FLINK-24902 it still ma

[jira] [Created] (FLINK-25055) Support listen and notify mechanism for PartitionRequest

Shammon created FLINK-25055: --- Summary: Support listen and notify mechanism for PartitionRequest Key: FLINK-25055 URL: https://issues.apache.org/jira/browse/FLINK-25055 Project: Flink Issue Type: Im

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 ## CI report: * 4978168c923c603963d721202712d5ee8694d58f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] JingGe commented on pull request #17888: [FLINK-24077][hbase2/HBaseConnectorITCase] fix sporadic ut failing

JingGe commented on pull request #17888: URL: https://github.com/apache/flink/pull/17888#issuecomment-979013267 It looks like the the @flinkbot run azure command does not work if the last CI was successful. -- This is an automated message from the Apache Git Service. To respond to the me

[GitHub] [flink] rkhachatryan commented on pull request #17179: [FLINK-24086][checkpoint] Rebuilding the SharedStateRegistry only when the restore method is called for the first time.

rkhachatryan commented on pull request #17179: URL: https://github.com/apache/flink/pull/17179#issuecomment-979013078 Hi @liming30 , are you planning to merge this PR in 1.15? I'd like to merge #17774 in 1.15; and it depends on this PR (mostly for moving `SharedStateRegistry` closer to `

[GitHub] [flink] flinkbot edited a comment on pull request #17904: [FLINK-21214][kafka/IT] add retry rule

flinkbot edited a comment on pull request #17904: URL: https://github.com/apache/flink/pull/17904#issuecomment-979009600 ## CI report: * 46e84e63d42b1edee16084e67f24e5d42d0936b0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@fli

[jira] [Updated] (FLINK-25055) Support listen and notify mechanism for PartitionRequest

[ https://issues.apache.org/jira/browse/FLINK-25055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-25055: Description: We submit batch jobs to flink session cluster with eager scheduler for olap. JM deploys subt

[jira] [Updated] (FLINK-23528) stop-with-savepoint can fail with FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-23528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-23528: --- Fix Version/s: (was: 1.14.1) > stop-with-savepoint can fail with FlinkKinesisConsumer >

[GitHub] [flink] flinkbot edited a comment on pull request #17888: [FLINK-24077][hbase2/HBaseConnectorITCase] fix sporadic ut failing

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

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 ## CI report: * 4978168c923c603963d721202712d5ee8694d58f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #17904: [FLINK-21214][kafka/IT] add retry rule

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

[jira] [Commented] (FLINK-25027) Allow GC of a finished job's JobMaster before the slot timeout is reached

[ https://issues.apache.org/jira/browse/FLINK-25027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449062#comment-17449062 ] Shammon commented on FLINK-25027: - [~MartijnVisser] Thanks and I will work on it soon :)

[GitHub] [flink] JingGe edited a comment on pull request #17888: [FLINK-24077][hbase2/HBaseConnectorITCase] fix sporadic ut failing

JingGe edited a comment on pull request #17888: URL: https://github.com/apache/flink/pull/17888#issuecomment-979013267 It looks like the @flinkbot run azure command does not work if the last CI was successful. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 92e7e87fa796da7d37a3cf27b52c151b5c746f70 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17888: [FLINK-24077][hbase2/HBaseConnectorITCase] fix sporadic ut failing

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

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 ## CI report: * 4978168c923c603963d721202712d5ee8694d58f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-21321) Change RocksDB incremental checkpoint re-scaling to use deleteRange

[ https://issues.apache.org/jira/browse/FLINK-21321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449065#comment-17449065 ] Yun Tang commented on FLINK-21321: -- [~legojoey17] Would you please update the PR? > Ch

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 92e7e87fa796da7d37a3cf27b52c151b5c746f70 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17903: [hotfix][csv] Remove duplicate code.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 ## CI report: * 4978168c923c603963d721202712d5ee8694d58f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 92e7e87fa796da7d37a3cf27b52c151b5c746f70 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 ## CI report: * 4978168c923c603963d721202712d5ee8694d58f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 92e7e87fa796da7d37a3cf27b52c151b5c746f70 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 ## CI report: * 4978168c923c603963d721202712d5ee8694d58f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] matriv commented on a change in pull request #17811: [FLINK-24754] Implement CHAR/VARCHAR length validation for sinks

matriv commented on a change in pull request #17811: URL: https://github.com/apache/flink/pull/17811#discussion_r756726143 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/data/UpdatableRowData.java ## @@ -17,23 +17,33 @@ package org.apache

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 92e7e87fa796da7d37a3cf27b52c151b5c746f70 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 ## CI report: * 4978168c923c603963d721202712d5ee8694d58f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] matriv commented on a change in pull request #17811: [FLINK-24754] Implement CHAR/VARCHAR length validation for sinks

matriv commented on a change in pull request #17811: URL: https://github.com/apache/flink/pull/17811#discussion_r756727589 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSinkITCase.java ## @@ -187,6 +

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 92e7e87fa796da7d37a3cf27b52c151b5c746f70 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 ## CI report: * 4978168c923c603963d721202712d5ee8694d58f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] wanglijie95 opened a new pull request #17905: [FLINK-24980] Introduce numBytesProduced counter into ResultPartition to record the size of result partition.

wanglijie95 opened a new pull request #17905: URL: https://github.com/apache/flink/pull/17905 ## What is the purpose of the change The adaptive batch scheduler needs to know the size of each result partition when the task is finished. This pr will introduce the numBytesProduce

[jira] [Updated] (FLINK-24980) Collect sizes of finished BLOCKING result partitions

[ https://issues.apache.org/jira/browse/FLINK-24980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24980: --- Labels: pull-request-available (was: ) > Collect sizes of finished BLOCKING result partitio

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * 92e7e87fa796da7d37a3cf27b52c151b5c746f70 Azure: [FAILURE](https://dev.azure.com/apache-fl

  1   2   3   4   5   6   7   >