[GitHub] [flink] flinkbot edited a comment on pull request #17651: [FLINK-24656][docs] Add documentation for window deduplication

flinkbot edited a comment on pull request #17651: URL: https://github.com/apache/flink/pull/17651#issuecomment-958639580 ## CI report: * 526b8eddd977adbcf7a839722374995b24d446be Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17532: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

flinkbot edited a comment on pull request #17532: URL: https://github.com/apache/flink/pull/17532#issuecomment-948251540 ## CI report: * 6bf9e572bd13b954cad07b009c65dd4b72cc18ee Azure:

[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: * 87b6a197aeaa3dff11b7779cd62f26dbc6e1d046 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: * 7668c2b702f4a235424008f2c52e3cb8cab9b313 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

flinkbot edited a comment on pull request #17652: URL: https://github.com/apache/flink/pull/17652#issuecomment-958647607 ## CI report: * 2313f0b95da17c17318d84bcd0817483a9963f1c Azure:

[jira] [Created] (FLINK-24748) Remove CheckpointStatsTracker#getJobCheckpointingConfiguration

Chesnay Schepler created FLINK-24748: Summary: Remove CheckpointStatsTracker#getJobCheckpointingConfiguration Key: FLINK-24748 URL: https://issues.apache.org/jira/browse/FLINK-24748 Project:

[jira] [Updated] (FLINK-7957) Add MetricGroup#getLogicalScope

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

[jira] [Updated] (FLINK-8513) Add documentation for connecting to non-AWS S3 endpoints

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

[jira] [Updated] (FLINK-19039) Parallel Flink Kafka Consumers compete with each other

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

[jira] [Updated] (FLINK-20652) Improve the document for making the user could write a DataStream job that could be execute in the batch execution mode.

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

[jira] [Updated] (FLINK-19025) table sql write orc file but hive2.1.1 can not read

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

[jira] [Updated] (FLINK-19052) Performance issue with PojoSerializer

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

[jira] [Updated] (FLINK-22579) The description content of Kubernetes config Incomplete display

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

[GitHub] [flink] flinkbot edited a comment on pull request #17646: [FLINK-24740][testinfrastructure] Update testcontainers dependency to the latest version

flinkbot edited a comment on pull request #17646: URL: https://github.com/apache/flink/pull/17646#issuecomment-957837700 ## CI report: * b0fa94cae5ec305697ae851c1e23b12f8725f16b 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: * 7668c2b702f4a235424008f2c52e3cb8cab9b313 Azure:

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #17: [FLINK-24655][iteration] Support the checkpoints for the iteration

gaoyunhaii commented on a change in pull request #17: URL: https://github.com/apache/flink-ml/pull/17#discussion_r741845839 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/coordinator/SharedProgressAligner.java ## @@ -93,27 +98,28 @@ private

[GitHub] [flink] flinkbot edited a comment on pull request #17658: [FLINK-24684][table-planner] Add to string cast rules using the new CastRule stack

flinkbot edited a comment on pull request #17658: URL: https://github.com/apache/flink/pull/17658#issuecomment-958884763 ## CI report: * aabf462c9d34554539b5ca391419779d191bc0b8 Azure:

[GitHub] [flink] MartijnVisser commented on pull request #17625: [FLINK-24719][jdbc] Update Postgres test dependencies

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

[jira] [Commented] (FLINK-24611) Prevent JM from discarding state on checkpoint abortion

[ https://issues.apache.org/jira/browse/FLINK-24611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438020#comment-17438020 ] Roman Khachatryan commented on FLINK-24611: --- {quote}I think there might be left over artefacts

[jira] [Commented] (FLINK-24750) Single quotes converted to left/right single quotes during docs generation

[ https://issues.apache.org/jira/browse/FLINK-24750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438043#comment-17438043 ] Chesnay Schepler commented on FLINK-24750: -- I don't think this is really related to hugo, but

[jira] [Resolved] (FLINK-24655) Support checkpoint for jobs using iteration

[ https://issues.apache.org/jira/browse/FLINK-24655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao resolved FLINK-24655. - Resolution: Fixed > Support checkpoint for jobs using iteration >

[jira] [Closed] (FLINK-24655) Support checkpoint for jobs using iteration

[ https://issues.apache.org/jira/browse/FLINK-24655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-24655. --- > Support checkpoint for jobs using iteration > --- > >

[jira] [Commented] (FLINK-24655) Support checkpoint for jobs using iteration

[ https://issues.apache.org/jira/browse/FLINK-24655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438082#comment-17438082 ] Yun Gao commented on FLINK-24655: - Merge on master via 

[jira] [Commented] (FLINK-24413) Casting to a CHAR() and VARCHAR() doesn't trim the string to the specified precision

[ https://issues.apache.org/jira/browse/FLINK-24413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438092#comment-17438092 ] Marios Trivyzas commented on FLINK-24413: - Created FLINK-24753 as a followup to implement 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: * 2cc52f2ba2da22b2991dac89e26d5e97a0859e76 Azure:

[GitHub] [flink] Jiabao-Sun commented on pull request #17464: [FLINK-24413] Casting to a CHAR() and VARCHAR() doesn't trim the stri…

Jiabao-Sun commented on pull request #17464: URL: https://github.com/apache/flink/pull/17464#issuecomment-959162418 @matriv OK, that's fine. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] Jiabao-Sun closed pull request #17464: [FLINK-24413] Casting to a CHAR() and VARCHAR() doesn't trim the stri…

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

[GitHub] [flink] alpreu commented on a change in pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

alpreu commented on a change in pull request #17538: URL: https://github.com/apache/flink/pull/17538#discussion_r741988468 ## File path: flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBaseITCase.java

[jira] [Commented] (FLINK-24750) Single quotes converted to left/right single quotes during docs generation

[ https://issues.apache.org/jira/browse/FLINK-24750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438100#comment-17438100 ] Sergey Nuyanzin commented on FLINK-24750: - this replacement is done by typographer extension of

[GitHub] [flink] flinkbot edited a comment on pull request #17661: [hotfix][connectors][table][jdbc][docs] - Updated key handling section text

flinkbot edited a comment on pull request #17661: URL: https://github.com/apache/flink/pull/17661#issuecomment-958999087 ## CI report: * c76b25ce8f694180c2edddcdef3365109b2f9511 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17659: [FLINK-24748] Remove CheckpointStatsTracker#getJobCheckpointingConfiguration

flinkbot edited a comment on pull request #17659: URL: https://github.com/apache/flink/pull/17659#issuecomment-958903416 ## CI report: * fce9e7dd389de6b4c65b2da3fd283fb9dadb7e18 Azure:

[jira] [Updated] (FLINK-24730) Support prompt style in SqlCli

[ https://issues.apache.org/jira/browse/FLINK-24730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-24730: - Summary: Support prompt style in SqlCli (was: Support prompt in SqlCli) > Support prompt style in

[jira] [Updated] (FLINK-19008) Flink Job runs slow after restore + downscale from an incremental checkpoint (rocksdb)

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

[jira] [Updated] (FLINK-19044) Web UI reports incorrect timeline for the FINISHED state of a subtask

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

[GitHub] [flink] flinkbot commented on pull request #17659: [FLINK-24748] Remove CheckpointStatsTracker#getJobCheckpointingConfiguration

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

[GitHub] [flink] MartijnVisser commented on pull request #17654: [FLINK-24614][Connectors/PARQUET] Add Complex types support for parquet reader

MartijnVisser commented on pull request #17654: URL: https://github.com/apache/flink/pull/17654#issuecomment-958922514 @meetjunsu Thanks for the PR! Would this also make it possible to support this for DataStream API users? -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #17658: [FLINK-24684][table-planner] Add to string cast rules using the new CastRule stack

flinkbot edited a comment on pull request #17658: URL: https://github.com/apache/flink/pull/17658#issuecomment-958884763 ## CI report: * aabf462c9d34554539b5ca391419779d191bc0b8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17655: [FLINK-24728][tests] Add tests to ensure SQL file sink closes all created files

flinkbot edited a comment on pull request #17655: URL: https://github.com/apache/flink/pull/17655#issuecomment-958717470 ## CI report: * e59f6d6054272fe662cef532f57f82b668588174 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17658: [FLINK-24684][table-planner] Add to string cast rules using the new CastRule stack

flinkbot edited a comment on pull request #17658: URL: https://github.com/apache/flink/pull/17658#issuecomment-958884763 ## CI report: * aabf462c9d34554539b5ca391419779d191bc0b8 Azure:

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #17: [FLINK-24655][iteration] Support the checkpoints for the iteration

gaoyunhaii commented on a change in pull request #17: URL: https://github.com/apache/flink-ml/pull/17#discussion_r741842056 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/coordinator/SharedProgressAligner.java ## @@ -224,4 +261,28 @@ public

[jira] [Updated] (FLINK-24655) Support checkpoint for jobs using iteration

[ https://issues.apache.org/jira/browse/FLINK-24655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24655: --- Labels: pull-request-available (was: ) > Support checkpoint for jobs using iteration >

[GitHub] [flink] flinkbot edited a comment on pull request #17658: [FLINK-24684][table-planner] Add to string cast rules using the new CastRule stack

flinkbot edited a comment on pull request #17658: URL: https://github.com/apache/flink/pull/17658#issuecomment-958884763 ## CI report: * aabf462c9d34554539b5ca391419779d191bc0b8 Azure:

[GitHub] [flink] flinkbot commented on pull request #17660: [FLINK-24657][runtime] Added metric of the total real size of input/o…

flinkbot commented on pull request #17660: URL: https://github.com/apache/flink/pull/17660#issuecomment-958946039 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 #17660: [FLINK-24657][runtime] Added metric of the total real size of input/o…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17658: [FLINK-24684][table-planner] Add to string cast rules using the new CastRule stack

flinkbot edited a comment on pull request #17658: URL: https://github.com/apache/flink/pull/17658#issuecomment-958884763 ## CI report: * aabf462c9d34554539b5ca391419779d191bc0b8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17660: [FLINK-24657][runtime] Added metric of the total real size of input/o…

flinkbot edited a comment on pull request #17660: URL: https://github.com/apache/flink/pull/17660#issuecomment-958945516 ## CI report: * 17113ecdaedc7919eb7ec92613f5e0337d5b0f4b Azure:

[GitHub] [flink] akalash commented on a change in pull request #17660: [FLINK-24657][runtime] Added metric of the total real size of input/o…

akalash commented on a change in pull request #17660: URL: https://github.com/apache/flink/pull/17660#discussion_r741850840 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -497,6 +497,12 @@ public int

[jira] [Assigned] (FLINK-24507) Cleanup all the various date/time/timestamp utils

[ https://issues.apache.org/jira/browse/FLINK-24507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani reassigned FLINK-24507: --- Assignee: Francesco Guardiani > Cleanup all the various

[GitHub] [flink] TanYuxin-tyx commented on pull request #17532: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

TanYuxin-tyx commented on pull request #17532: URL: https://github.com/apache/flink/pull/17532#issuecomment-958978355 @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

[GitHub] [flink] flinkbot edited a comment on pull request #17625: [FLINK-24719][jdbc] Update Postgres test dependencies

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

[jira] [Commented] (FLINK-24713) Postpone resourceManager serving after the recovery phase has finished

[ https://issues.apache.org/jira/browse/FLINK-24713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438053#comment-17438053 ] Till Rohrmann commented on FLINK-24713: --- Introducing a configurable reconciliation interval before

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

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

[GitHub] [flink] matriv commented on pull request #17464: [FLINK-24413] Casting to a CHAR() and VARCHAR() doesn't trim the stri…

matriv commented on pull request #17464: URL: https://github.com/apache/flink/pull/17464#issuecomment-959134892 Hi @Jiabao-Sun, With: https://github.com/apache/flink/pull/17658 the implementation of this change should be done with the new structure for casting rules. If you don't mind,

[jira] [Created] (FLINK-24753) Enforce CHAR/VARCHAR precision when outputing to a Sink

Marios Trivyzas created FLINK-24753: --- Summary: Enforce CHAR/VARCHAR precision when outputing to a Sink Key: FLINK-24753 URL: https://issues.apache.org/jira/browse/FLINK-24753 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #17532: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

flinkbot edited a comment on pull request #17532: URL: https://github.com/apache/flink/pull/17532#issuecomment-948251540 ## CI report: * 9549c71bdc0ceec5fbccce3a0f3f4a04efc233f1 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 * 584c90bd5a903d91bfa85b687c170fbe9d058bd6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17625: [FLINK-24719][jdbc] Update Postgres test dependencies

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

[GitHub] [flink] MartijnVisser commented on pull request #17625: [FLINK-24719][jdbc] Update Postgres test dependencies

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

[GitHub] [flink] flinkbot edited a comment on pull request #17625: [FLINK-24719][jdbc] Update Postgres test dependencies

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

[jira] [Updated] (FLINK-18509) Introduce IgniteDialect

[ https://issues.apache.org/jira/browse/FLINK-18509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-18509: --- Summary: Introduce IgniteDialect (was: Introduce Ignite Dialect) > Introduce IgniteDialect

[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: * 7668c2b702f4a235424008f2c52e3cb8cab9b313 Azure:

[GitHub] [flink] flinkbot commented on pull request #17659: [FLINK-24748] Remove CheckpointStatsTracker#getJobCheckpointingConfiguration

flinkbot commented on pull request #17659: URL: https://github.com/apache/flink/pull/17659#issuecomment-958906178 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 edited a comment on pull request #17658: [FLINK-24684][table-planner] Add to string cast rules using the new CastRule stack

flinkbot edited a comment on pull request #17658: URL: https://github.com/apache/flink/pull/17658#issuecomment-958884763 ## CI report: * aabf462c9d34554539b5ca391419779d191bc0b8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17654: [FLINK-24614][Connectors/PARQUET] Add Complex types support for parquet reader

flinkbot edited a comment on pull request #17654: URL: https://github.com/apache/flink/pull/17654#issuecomment-958713350 ## CI report: * 8a4c81675b4dd943f0c8a86f6cd9515016ecddb5 Azure:

[jira] [Commented] (FLINK-24633) JobManager pod may stuck in containerCreating status during failover

[ https://issues.apache.org/jira/browse/FLINK-24633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437944#comment-17437944 ] Yang Wang commented on FLINK-24633: --- Actually, I am curious about why the JobManager pod stuck at 

[GitHub] [flink] akalash opened a new pull request #17660: [FLINK-24657][runtime] Added metric of the total real size of input/o…

akalash opened a new pull request #17660: URL: https://github.com/apache/flink/pull/17660 …utput buffers queue ## What is the purpose of the change *This PR adds two new metrics - outputQueueSize and inputQueueSize* ## Brief change log -

[GitHub] [flink] flinkbot edited a comment on pull request #14891: [FLINK-21289][deployment] FIX missing load pipeline.classpaths in app…

flinkbot edited a comment on pull request #14891: URL: https://github.com/apache/flink/pull/14891#issuecomment-774628149 ## CI report: * 1d879321a186ed21b45303b0fcd0c26ebdb63e93 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

flinkbot edited a comment on pull request #17525: URL: https://github.com/apache/flink/pull/17525#issuecomment-947380227 ## CI report: * 3a3ce88a936a7354d4f53add622010a4e27a89a1 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: * 5b69f91a4a12794ab8bedf0dfcf960247d96b4df Azure:

[GitHub] [flink-ml] weibozhao opened a new pull request #24: Flink 24557

weibozhao opened a new pull request #24: URL: https://github.com/apache/flink-ml/pull/24 develop knn algo with dataStream. -- 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.

[jira] [Commented] (FLINK-24745) Add support for Oracle OGG json parser in flink-json module

[ https://issues.apache.org/jira/browse/FLINK-24745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437989#comment-17437989 ] Leonard Xu commented on FLINK-24745: Nice feature, I'll help review this PR > Add support for

[GitHub] [flink] flinkbot edited a comment on pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

flinkbot edited a comment on pull request #17652: URL: https://github.com/apache/flink/pull/17652#issuecomment-958647607 ## CI report: * 2821a77a60feefd959cdf1f54e336ab4fcaa1a71 Azure:

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #17: [FLINK-24655][iteration] Support the checkpoints for the iteration

gaoyunhaii commented on a change in pull request #17: URL: https://github.com/apache/flink-ml/pull/17#discussion_r741862947 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/itcases/operators/ReduceAllRoundProcessFunction.java ## @@ -49,16 +59,53 @@

[GitHub] [flink] MartijnVisser commented on pull request #17626: [FLINK-24715][connectors][filesystems][formats] Update multiple Jackson dependencies to latest version

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

[GitHub] [flink] MartijnVisser commented on pull request #17646: [FLINK-24740][testinfrastructure] Update testcontainers dependency to the latest version

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

[GitHub] [flink] flinkbot edited a comment on pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

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

[jira] [Updated] (FLINK-24751) flink SQL comile failed cause by: java.lang.StackOverflowError

[ https://issues.apache.org/jira/browse/FLINK-24751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tao.yang03 updated FLINK-24751: --- Description: I have two temporal join  , but  sometimes  failed Cause by StackOverflowError. I try

[jira] [Closed] (FLINK-24751) flink SQL comile failed cause by: java.lang.StackOverflowError

[ https://issues.apache.org/jira/browse/FLINK-24751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-24751. -- Resolution: Incomplete Thanks for opening a ticket. I would recommend to post your SQL

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

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

[jira] [Commented] (FLINK-24750) Single quotes converted to left/right single quotes during docs generation

[ https://issues.apache.org/jira/browse/FLINK-24750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438071#comment-17438071 ] Chesnay Schepler commented on FLINK-24750: -- Those are all descriptions, right? I can see in the

[GitHub] [flink] xuyangzhong commented on a change in pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

xuyangzhong commented on a change in pull request #17652: URL: https://github.com/apache/flink/pull/17652#discussion_r741979153 ## File path:

[jira] [Created] (FLINK-24754) PushDownSepcs are better to be print by a clear order.

xuyang created FLINK-24754: -- Summary: PushDownSepcs are better to be print by a clear order. Key: FLINK-24754 URL: https://issues.apache.org/jira/browse/FLINK-24754 Project: Flink Issue Type:

[GitHub] [flink] MartijnVisser commented on pull request #17625: [FLINK-24719][jdbc] Update Postgres test dependencies

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

[GitHub] [flink] MartijnVisser commented on pull request #17625: [FLINK-24719][jdbc] Update Postgres test dependencies

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

[GitHub] [flink] slinkydeveloper opened a new pull request #17662: [FLINK-24747][table-planner] Add producedDataType to SupportsProjectionPushDown.applyProjection

slinkydeveloper opened a new pull request #17662: URL: https://github.com/apache/flink/pull/17662 ## What is the purpose of the change Add `producedDataType` to `SupportsProjectionPushDown.applyProjection`, in order to simplify usage of the interface for implementers. ##

[jira] [Updated] (FLINK-24747) Add producedDataType to SupportsProjectionPushDown.applyProjection

[ https://issues.apache.org/jira/browse/FLINK-24747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24747: --- Labels: pull-request-available (was: ) > Add producedDataType to

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17658: [FLINK-24684][table-planner] Add to string cast rules using the new CastRule stack

slinkydeveloper commented on a change in pull request #17658: URL: https://github.com/apache/flink/pull/17658#discussion_r742034054 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/AbstractCodeGeneratorCastRule.java

[GitHub] [flink] flinkbot edited a comment on pull request #17608: [FLINK-24550][rpc] Use ContextClassLoader for message deserialization

flinkbot edited a comment on pull request #17608: URL: https://github.com/apache/flink/pull/17608#issuecomment-954803172 ## CI report: * 5de7ecb7f3acc909a9f46372d4b07e9865103ce0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17643: [FLINK-24733][connector/pulsar] Data loss in pulsar source when using shared mode

flinkbot edited a comment on pull request #17643: URL: https://github.com/apache/flink/pull/17643#issuecomment-957416596 ## CI report: * cf441ef1184f44a76f08dcc304de6f1da8f0fd55 Azure:

[jira] [Assigned] (FLINK-24715) Update Jackson to latest version

[ https://issues.apache.org/jira/browse/FLINK-24715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-24715: -- Assignee: Martijn Visser > Update Jackson to latest version >

[GitHub] [flink] twalthr commented on a change in pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

twalthr commented on a change in pull request #17652: URL: https://github.com/apache/flink/pull/17652#discussion_r741769770 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #17536: [FLINK-24530][datastream] GlobalCommitter might not commit all records on drain

flinkbot edited a comment on pull request #17536: URL: https://github.com/apache/flink/pull/17536#issuecomment-948529514 ## CI report: * b9629cad521194d28cc6fd37d2997b8589af991e 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: * 7668c2b702f4a235424008f2c52e3cb8cab9b313 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17641: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

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

[GitHub] [flink] Myasuka commented on a change in pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

Myasuka commented on a change in pull request #17525: URL: https://github.com/apache/flink/pull/17525#discussion_r741790069 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java ## @@ -460,22 +461,66 @@ public void

[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: * 7668c2b702f4a235424008f2c52e3cb8cab9b313 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: * 7668c2b702f4a235424008f2c52e3cb8cab9b313 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17658: [FLINK-24684][table-planner] Add to string cast rules using the new CastRule stack

flinkbot edited a comment on pull request #17658: URL: https://github.com/apache/flink/pull/17658#issuecomment-958884763 ## CI report: * aabf462c9d34554539b5ca391419779d191bc0b8 Azure:

[GitHub] [flink-web] zentol merged pull request #478: add Flink Backward blog post

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

[GitHub] [flink] flinkbot edited a comment on pull request #17658: [FLINK-24684][table-planner] Add to string cast rules using the new CastRule stack

flinkbot edited a comment on pull request #17658: URL: https://github.com/apache/flink/pull/17658#issuecomment-958884763 ## CI report: * aabf462c9d34554539b5ca391419779d191bc0b8 Azure:

  1   2   3   4   5   6   7   8   9   10   >