[jira] [Updated] (FLINK-22108) Ephemeral socket address was checkpointed to state and restored back in CollectSinkOperatorCoordinator

[ https://issues.apache.org/jira/browse/FLINK-22108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22108: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-22189) Flink SQL Client Hudi batch write crashes JobManager

[ https://issues.apache.org/jira/browse/FLINK-22189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22189: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-22488) KafkaSourceLegacyITCase.testOneToOneSources failed due to "OperatorEvent from an OperatorCoordinator to a task was lost"

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

[jira] [Updated] (FLINK-20945) flink hive insert heap out of memory

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

[jira] [Updated] (FLINK-12557) Improve the DDL property keys to be more concise and readble

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

[jira] [Updated] (FLINK-21083) Streaming write partitioned table needs to handle null partition value

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

[jira] [Updated] (FLINK-21803) Tumbling / Sliding windows are unaware of daylight savings time

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

[jira] [Updated] (FLINK-12577) Flink uses Kryo serializer if given a SpecificRecord type

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

[jira] [Updated] (FLINK-15826) Add renameFunction() to Catalog

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

[jira] [Updated] (FLINK-21001) Flink job is blocked while using tableEnvironment with tableFunction and join

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

[jira] [Updated] (FLINK-21205) Maybe remove Locality enum

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

[jira] [Updated] (FLINK-20867) Support ship files from local/remote path to k8s pod

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

[jira] [Updated] (FLINK-20985) end the stream-job in docker container will remain some zombie processes in 1.11, these useless processes not be maked as zombie but still exist in 1.12

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

[jira] [Updated] (FLINK-14954) Publish OpenAPI specification of REST Monitoring API

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

[GitHub] [flink] flinkbot edited a comment on pull request #17907: Async sink table

flinkbot edited a comment on pull request #17907: URL: https://github.com/apache/flink/pull/17907#issuecomment-979080179 ## CI report: * ab362ac419cf1ac1e21c4d6fd3ef3ddf54cf5dfb Azure:

[GitHub] [flink] flinkbot commented on pull request #17908: [FLINK-25058][tests] Consider exceptions for API annotation scanning

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

[GitHub] [flink] flinkbot commented on pull request #17908: [FLINK-25058][tests] Consider exceptions for API annotation scanning

flinkbot commented on pull request #17908: URL: https://github.com/apache/flink/pull/17908#issuecomment-979081034 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] flinkbot commented on pull request #17907: Async sink table

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

[jira] [Updated] (FLINK-25058) Declared exceptions should be considered in architectural tests

[ https://issues.apache.org/jira/browse/FLINK-25058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25058: --- Labels: pull-request-available (was: ) > Declared exceptions should be considered in

[GitHub] [flink] Airblader opened a new pull request #17908: [FLINK-25058][tests] Consider exceptions for API annotation scanning

Airblader opened a new pull request #17908: URL: https://github.com/apache/flink/pull/17908 ## What is the purpose of the change This expands the architectural tests for API annotation consistency to also check the (declared) exception types. ## Verifying this change

[GitHub] [flink] flinkbot commented on pull request #17907: Async sink table

flinkbot commented on pull request #17907: URL: https://github.com/apache/flink/pull/17907#issuecomment-979078915 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] [Created] (FLINK-25058) Declared exceptions should be considered in architectural tests

Ingo Bürk created FLINK-25058: - Summary: Declared exceptions should be considered in architectural tests Key: FLINK-25058 URL: https://issues.apache.org/jira/browse/FLINK-25058 Project: Flink

[jira] [Updated] (FLINK-25057) Streaming File Sink writing to HDFS

[ https://issues.apache.org/jira/browse/FLINK-25057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hanjie updated FLINK-25057: --- Summary: Streaming File Sink writing to HDFS (was: Streaming File Sink writing to the HDFS) > Streaming

[jira] [Created] (FLINK-25057) Streaming File Sink writing to the HDFS

hanjie created FLINK-25057: -- Summary: Streaming File Sink writing to the HDFS Key: FLINK-25057 URL: https://issues.apache.org/jira/browse/FLINK-25057 Project: Flink Issue Type: Improvement

[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:

[GitHub] [flink] vahmed-hamdy opened a new pull request #17907: Async sink table

vahmed-hamdy opened a new pull request #17907: URL: https://github.com/apache/flink/pull/17907 ## What is the purpose of the change *User stories:* - As a Flink user, I’d like to use the Table API for the new Kinesis Data Streams sink. *Context:*

[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:

[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: * 0c454e3be378ab1ddfb19dd872d91fc3275f3800 Azure:

[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: * 0c5756a45b29a7c3787d663c9321a94cc126b3a3 Azure:

[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_r756761865 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/AmbiguousTableFactoryException.java ## @@ -26,6 +27,7 @@ import

[GitHub] [flink] flinkbot edited a comment on pull request #17811: [FLINK-24754] Implement CHAR/VARCHAR length validation for sinks

flinkbot edited a comment on pull request #17811: URL: https://github.com/apache/flink/pull/17811#issuecomment-970441907 ## CI report: * 0b973d5f4cd91f0b20c98ec0e6671cf7efa52cdd Azure:

[GitHub] [flink] CrynetLogistics commented on a change in pull request #17345: [FLINK-24227][connectors/kinesis] Added Kinesis Data Streams Sink i…

CrynetLogistics commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r756760460 ## File path:

[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-979068302 @AHeise I've run the test locally more than 10 times and didn't see any failing tests. Maybe it make sense to merge it for now and open a new Jira ticket if it fails again. --

[GitHub] [flink] flinkbot edited a comment on pull request #17811: [FLINK-24754] Implement CHAR/VARCHAR length validation for sinks

flinkbot edited a comment on pull request #17811: URL: https://github.com/apache/flink/pull/17811#issuecomment-970441907 ## CI report: * 0b973d5f4cd91f0b20c98ec0e6671cf7efa52cdd Azure:

[GitHub] [flink] AHeise commented on a change in pull request #17870: [FLINK-24596][kafka] Fix buffered KafkaUpsert sink

AHeise commented on a change in pull request #17870: URL: https://github.com/apache/flink/pull/17870#discussion_r756753970 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java ## @@ -228,10

[jira] [Assigned] (FLINK-25022) ClassLoader leak with ThreadLocals on the JM when submitting a job through the REST API

[ https://issues.apache.org/jira/browse/FLINK-25022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-25022: Assignee: Chesnay Schepler > ClassLoader leak with ThreadLocals on the JM when

[jira] [Created] (FLINK-25056) Modify Flink dashboard task manager page, "Path, ID" column，to support sorting by id.

john created FLINK-25056: Summary: Modify Flink dashboard task manager page, "Path, ID" column，to support sorting by id. Key: FLINK-25056 URL: https://issues.apache.org/jira/browse/FLINK-25056 Project: Flink

[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=17449092#comment-17449092 ] Marios Trivyzas commented on FLINK-24576: - Still makes sense to port boolean -> decimal, float,

[GitHub] [flink] fapaul commented on a change in pull request #17892: [FLINK-25038][testutils] Refactor FlinkContainer to split JM and TMs to individual containers and support HA

fapaul commented on a change in pull request #17892: URL: https://github.com/apache/flink/pull/17892#discussion_r756728229 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/pom.xml ## @@ -146,6 +146,12 @@ under the License.

[GitHub] [flink] flinkbot edited a comment on pull request #17906: [hotfix][table-common] Replace DataType.projectFields with Projection type

flinkbot edited a comment on pull request #17906: URL: https://github.com/apache/flink/pull/17906#issuecomment-979056025 ## CI report: * aef9772b33d766c093f1e286d145ea32c757696d Azure:

[jira] [Comment Edited] (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=17449060#comment-17449060 ] Francesco Guardiani edited comment on FLINK-24576 at 11/25/21, 10:11 AM:

[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:

[GitHub] [flink] flinkbot commented on pull request #17906: [hotfix][table-common] Replace DataType.projectFields with Projection type

flinkbot commented on pull request #17906: URL: https://github.com/apache/flink/pull/17906#issuecomment-979057528 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] flinkbot commented on pull request #17906: [hotfix][table-common] Replace DataType.projectFields with Projection type

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

[GitHub] [flink] flinkbot edited a comment on pull request #17899: [FLINK-24446][Table SQL/Planner] Casting from STRING to TIMESTAMP_LTZ looses fractional seconds

flinkbot edited a comment on pull request #17899: URL: https://github.com/apache/flink/pull/17899#issuecomment-978728442 ## CI report: * c9abec78c59f5c1a7823e02baadfc6c8e18a6c06 Azure:

[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_r756745307 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/AmbiguousTableFactoryException.java ## @@ -26,6 +27,7 @@

[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_r756745307 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/AmbiguousTableFactoryException.java ## @@ -26,6 +27,7 @@

[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:

[GitHub] [flink] slinkydeveloper opened a new pull request #17906: [hotfix][table-common] Replace DataType.projectFields with Projection type

slinkydeveloper opened a new pull request #17906: URL: https://github.com/apache/flink/pull/17906 ## What is the purpose of the change [FLINK-24399](https://issues.apache.org/jira/browse/FLINK-24399) introduced new methods to perform data types projections in `DataType`. **Note**:

[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:

[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:

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

dmvk commented on pull request #17179: URL: https://github.com/apache/flink/pull/17179#issuecomment-979051062 We're also preparing some follow-up PRs that build on top of this one. It would be great if we could finish it soon ;) -- This is an automated message from the Apache Git

[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:

[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:

[GitHub] [flink] flinkbot edited a comment on pull request #17905: [FLINK-24980] Introduce numBytesProduced counter into ResultPartition to record the size of result partition.

flinkbot edited a comment on pull request #17905: URL: https://github.com/apache/flink/pull/17905#issuecomment-979045985 ## CI report: * 0ef17f2152395847d231acff55c846201b96e358 Azure:

[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:

[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:

[GitHub] [flink] flinkbot commented on pull request #17905: [FLINK-24980] Introduce numBytesProduced counter into ResultPartition to record the size of result partition.

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

[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:

[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:

[GitHub] [flink] flinkbot commented on pull request #17905: [FLINK-24980] Introduce numBytesProduced counter into ResultPartition to record the size of result partition.

flinkbot commented on pull request #17905: URL: https://github.com/apache/flink/pull/17905#issuecomment-979044899 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] alpreu commented on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

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

[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:

[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:

[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

[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

[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:

[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:

[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 #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:

[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:

[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

[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:

[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:

[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:

[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:

[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:

[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:

[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:

[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=17449065#comment-17449065 ] Yun Tang commented on FLINK-21321: -- [~legojoey17] Would you please update the PR? > Change RocksDB

[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:

[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:

[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:

[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

[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=17449062#comment-17449062 ] Shammon commented on FLINK-25027: - [~MartijnVisser] Thanks and I will work on it soon :) > Allow GC of

[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:

[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:

[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:

[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 >

[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

[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: -

[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] 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

[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:

[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=17449060#comment-17449060 ] Francesco Guardiani commented on FLINK-24576: - So in FLINK-24902 it still makes sense to

[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:

[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

[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

[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:

[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

<    1   2   3   4   5   6   7   >