[GitHub] [flink] flinkbot edited a comment on pull request #17653: FLINK SQL checkpoint不生效

flinkbot edited a comment on pull request #17653: URL: https://github.com/apache/flink/pull/17653#issuecomment-958686553 ## CI report: * 0f14e4dd9bd38782b90a6a5633fad0d172421e86 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: * 7dfe3c64086dbe4ef1981c8e62512cb34552348b UNKNOWN * cbd34f22054a70de3d91d6508b05fdd7d7ae0cc3 Azure:

[jira] [Closed] (FLINK-24796) Exclude javadocs / node[_modules] directories from CI compile artifact

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

[GitHub] [flink] zentol merged pull request #17697: [FLINK-24796][ci] Reduce size of compile build artifact

zentol merged pull request #17697: URL: https://github.com/apache/flink/pull/17697 -- 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: * 7dfe3c64086dbe4ef1981c8e62512cb34552348b UNKNOWN * cbd34f22054a70de3d91d6508b05fdd7d7ae0cc3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * d98738ad4d70cc734983a0dc46da41f2c057b059 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * d98738ad4d70cc734983a0dc46da41f2c057b059 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17387: [WIP][FLINK-23486][state] ChangelogUploader metrics

flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 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: * 7dfe3c64086dbe4ef1981c8e62512cb34552348b UNKNOWN * cbd34f22054a70de3d91d6508b05fdd7d7ae0cc3 Azure:

[GitHub] [flink] twalthr closed pull request #17683: [hotfix][table-planner][tests] Fix a few links to FLINK jira tickets

twalthr closed pull request #17683: URL: https://github.com/apache/flink/pull/17683 -- 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-benchmarks] dawidwys merged pull request #39: [FLINK-24659] Drop RemoteBenchmarkBase.miniCluster field

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

[GitHub] [flink] flinkbot commented on pull request #17697: [FLINK-24796][ci] Reduce size of compile build artifact

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

[GitHub] [flink] Myasuka commented on a change in pull request #16582: [FLINK-21504][checkpoint] Introduce notification of subsumed checkpoint

Myasuka commented on a change in pull request #16582: URL: https://github.com/apache/flink/pull/16582#discussion_r743366210 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java ## @@ -339,78 +343,107

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

dawidwys commented on a change in pull request #17229: URL: https://github.com/apache/flink/pull/17229#discussion_r743688024 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/BatchingStateChangeUploader.java ## @@ -121,18 +127,17 @@ public

[GitHub] [flink] flinkbot commented on pull request #17695: [FLINK-24798][cli] Bump commons-cli to v1.5.0

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

[GitHub] [flink] leonardBang commented on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

leonardBang commented on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-961556377 > @leonardBang Would you be able to help with a review? Yes, my pleasure -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

flinkbot edited a comment on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-960641444 -- 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

[GitHub] [flink] Zakelly commented on pull request #17650: [FLINK-24475] Remove no longer used NestedMap* classes

Zakelly commented on pull request #17650: URL: https://github.com/apache/flink/pull/17650#issuecomment-961669486 -- 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

[GitHub] [flink] MartijnVisser commented on a change in pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

MartijnVisser commented on a change in pull request #17640: URL: https://github.com/apache/flink/pull/17640#discussion_r743649235 ## File path: docs/content/docs/connectors/datastream/formats/parquet.md ## @@ -0,0 +1,67 @@ +--- +title: "Parquet" +weight: 4 +type: docs

[GitHub] [flink] echauchot commented on pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

echauchot commented on pull request #17640: URL: https://github.com/apache/flink/pull/17640#issuecomment-961798766 -- 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

[GitHub] [flink] zentol commented on pull request #17697: [FLINK-24796][ci] Reduce size of compile build artifact

zentol commented on pull request #17697: URL: https://github.com/apache/flink/pull/17697#issuecomment-962144792 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17692: [FLINK-24489][CEP] The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the num

flinkbot edited a comment on pull request #17692: URL: https://github.com/apache/flink/pull/17692#issuecomment-961748638 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17645: [FLINK-24667][runtime] Fix error handling in ChannelStateCheckpointWriter

flinkbot edited a comment on pull request #17645: URL: https://github.com/apache/flink/pull/17645#issuecomment-957822962 -- 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

[GitHub] [flink] dawidwys commented on a change in pull request #17645: [FLINK-24667][runtime] Fix error handling in ChannelStateCheckpointWriter

dawidwys commented on a change in pull request #17645: URL: https://github.com/apache/flink/pull/17645#discussion_r743638339 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointFailureHandlingITCase.java ## @@ -0,0 +1,311 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #17687: [FLINK-24227][connectors] Improved AsyncSink base by adding a builder…

flinkbot edited a comment on pull request #17687: URL: https://github.com/apache/flink/pull/17687#issuecomment-961206353 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17689: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

flinkbot edited a comment on pull request #17689: URL: https://github.com/apache/flink/pull/17689#issuecomment-961619732 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17653: FLINK SQL checkpoint不生效

flinkbot edited a comment on pull request #17653: URL: https://github.com/apache/flink/pull/17653#issuecomment-958686553 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17700: [FLINK-24773][kafka] Fail job if unhandled exception occurs during committing

flinkbot edited a comment on pull request #17700: URL: https://github.com/apache/flink/pull/17700#issuecomment-961972204 -- 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

[GitHub] [flink] wenlong88 commented on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf agg

wenlong88 commented on pull request #17509: URL: https://github.com/apache/flink/pull/17509#issuecomment-961766089 LGTM for now， cc @JingsongLi would you help do the final review since this is a change on table-runtime -- 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 -- 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

[GitHub] [flink] echauchot commented on a change in pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

echauchot commented on a change in pull request #17640: URL: https://github.com/apache/flink/pull/17640#discussion_r743628436 ## File path: docs/content/docs/connectors/datastream/formats/azure_table_storage.md ## @@ -0,0 +1,130 @@ +--- +title: "Microsoft Azure table"

[GitHub] [flink] AHeise closed pull request #17682: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

AHeise closed pull request #17682: URL: https://github.com/apache/flink/pull/17682 -- 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] echauchot edited a comment on pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

echauchot edited a comment on pull request #17640: URL: https://github.com/apache/flink/pull/17640#issuecomment-961884112 -- 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.

[GitHub] [flink] flinkbot edited a comment on pull request #17674: [FLINK-24755][doc]Add guidance to solve the package sun.misc does not exist

flinkbot edited a comment on pull request #17674: URL: https://github.com/apache/flink/pull/17674#issuecomment-960623713 ## CI report: * f297b14850894166d4395910f68205ebb3e3ce71 Azure:

[GitHub] [flink] Tartarus0zm commented on pull request #17672: [FLINK-24761][table] Fix PartitionPruner code gen compile fail

Tartarus0zm commented on pull request #17672: URL: https://github.com/apache/flink/pull/17672#issuecomment-961817197 @tsreaper thank you for your reply. I have added test cases, please take a look, if you have time, thanks cc @KurtYoung -- This is an automated message from the

[GitHub] [flink] JingGe removed a comment on pull request #17574: [FLINK-24665][s3] Update Presto Hadoop dependency to v2.7.4-9

JingGe removed a comment on pull request #17574: URL: https://github.com/apache/flink/pull/17574#issuecomment-961425986 LGTM -- 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 #17663: [FLINK-24738][runtime] Ignoring buffer size announcement if the channel is released already

flinkbot edited a comment on pull request #17663: URL: https://github.com/apache/flink/pull/17663#issuecomment-959548410 -- 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

[GitHub] [flink] flinkbot commented on pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

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

[GitHub] [flink] flinkbot edited a comment on pull request #17679: [FLINK-24770] Remove error from JobStatusListener

flinkbot edited a comment on pull request #17679: URL: https://github.com/apache/flink/pull/17679#issuecomment-960792789 ## CI report: * c954966b6d8d000bb8498fe1bece6eae94c4f4ff UNKNOWN * d8bf558c545cc1eb9edb8808dfe6ec496e270897 Azure:

[GitHub] [flink] tsreaper commented on pull request #17672: [FLINK-24761][table] Fix PartitionPruner code gen compile fail

tsreaper commented on pull request #17672: URL: https://github.com/apache/flink/pull/17672#issuecomment-961729196 Sorry for misleading. As all test classes are in the same class path, if we create a new udf class in test it will still be loaded by the default class loader. One way to work

[GitHub] [flink-web] dawidwys merged pull request #479: Fix typos in Flink 1.14.0 release note

dawidwys merged pull request #479: URL: https://github.com/apache/flink-web/pull/479 -- 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] JingGe commented on pull request #17574: [FLINK-24665][s3] Update Presto Hadoop dependency to v2.7.4-9

JingGe commented on pull request #17574: URL: https://github.com/apache/flink/pull/17574#issuecomment-961425986 LGTM -- 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

[GitHub] [flink] curcur merged pull request #17621: [FLINK-24551][runtime] Read BUFFER_DEBLOAT_SAMPLES from task manager …

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

[GitHub] [flink] flinkbot commented on pull request #17691: [FLINK-24586][table] SQL functions should return STRING instead of VARCHAR(2000)

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

[GitHub] [flink] fapaul commented on a change in pull request #17696: [FLINK-24765][kafka] Bump Kafka version to 2.8

fapaul commented on a change in pull request #17696: URL: https://github.com/apache/flink/pull/17696#discussion_r743698529 ## File path: flink-connectors/flink-connector-kafka/pom.xml ## @@ -111,6 +111,15 @@ under the License. test +

[GitHub] [flink] dmvk commented on a change in pull request #17607: [FLINK-24543][runtime] Avoid possible inconsistencies of ZookeeperSta…

dmvk commented on a change in pull request #17607: URL: https://github.com/apache/flink/pull/17607#discussion_r743562938 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java ## @@ -154,54 +158,75 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

flinkbot edited a comment on pull request #17690: URL: https://github.com/apache/flink/pull/17690#issuecomment-961660965 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17671: [FLINK-24749][coordination] Reuse CheckpointStatsTracker

flinkbot edited a comment on pull request #17671: URL: https://github.com/apache/flink/pull/17671#issuecomment-960546813 -- 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

[GitHub] [flink] zentol commented on a change in pull request #17671: [FLINK-24749][coordination] Reuse CheckpointStatsTracker

zentol commented on a change in pull request #17671: URL: https://github.com/apache/flink/pull/17671#discussion_r743480869 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionGraphFactory.java ## @@ -80,6 +85,13 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #17387: [WIP][FLINK-23486][state] ChangelogUploader metrics

flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 -- 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

[jira] [Commented] (FLINK-24783) Improve monitoring experience and usability of state backend

[ https://issues.apache.org/jira/browse/FLINK-24783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439496#comment-17439496 ] Nico Kruber commented on FLINK-24783: - FYI: I'm actually planning to upstream a couple of options

[GitHub] [flink] MartijnVisser commented on pull request #17574: [FLINK-24665][s3] Update Presto Hadoop dependency to v2.7.4-9

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

[GitHub] [flink] dawidwys commented on pull request #17645: [FLINK-24667][runtime] Fix error handling in ChannelStateCheckpointWriter

dawidwys commented on pull request #17645: URL: https://github.com/apache/flink/pull/17645#issuecomment-961878632 @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 #17598: [WIP][FLINK-24703][connectors][formats] Add FileSource support for reading CSV files.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 -- 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

[GitHub] [flink] eskabetxe commented on a change in pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

eskabetxe commented on a change in pull request #17676: URL: https://github.com/apache/flink/pull/17676#discussion_r743560497 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcTestFixture.java ## @@ -149,7 +149,7 @@ private

[GitHub] [flink-ml] lindong28 commented on a change in pull request #10: [FLINK-24354][FLIP-174] Improve the WithParams interface

lindong28 commented on a change in pull request #10: URL: https://github.com/apache/flink-ml/pull/10#discussion_r74341 ## File path: flink-ml-api/src/test/java/org/apache/flink/ml/api/core/StageTest.java ## @@ -0,0 +1,345 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] flinkbot edited a comment on pull request #17681: [FLINK-24543][runtime] Avoid possible inconsistencies of ZookeeperSta…

flinkbot edited a comment on pull request #17681: URL: https://github.com/apache/flink/pull/17681#issuecomment-960861704 -- 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

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

[GitHub] [flink] CrynetLogistics commented on a change in pull request #17687: [FLINK-24227][connectors] Improved AsyncSink base by adding a builder…

CrynetLogistics commented on a change in pull request #17687: URL: https://github.com/apache/flink/pull/17687#discussion_r743542460 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java ## @@ -172,6

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

flinkbot edited a comment on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-958746170 -- 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

[GitHub] [flink] dawidwys commented on a change in pull request #17663: [FLINK-24738][runtime] Ignoring buffer size announcement if the channel is released already

dawidwys commented on a change in pull request #17663: URL: https://github.com/apache/flink/pull/17663#discussion_r743601715 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java ## @@ -338,10 +338,13 @@ void

[GitHub] [flink] JingGe commented on a change in pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

JingGe commented on a change in pull request #17501: URL: https://github.com/apache/flink/pull/17501#discussion_r743200328 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java ## @@ -0,0 +1,189 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #16582: [FLINK-21504][checkpoint] Introduce notification of subsumed checkpoint

flinkbot edited a comment on pull request #16582: URL: https://github.com/apache/flink/pull/16582#issuecomment-885598535 -- 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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17527: [hotfix][docs] Add link from README.md to 'Building Flink from Source'

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

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

flinkbot edited a comment on pull request #17601: URL: https://github.com/apache/flink/pull/17601#issuecomment-954546978 -- 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

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

[GitHub] [flink] cshuo commented on a change in pull request #17634: [FLINK-24691][table-common] Fix precision for sum on decimal types

cshuo commented on a change in pull request #17634: URL: https://github.com/apache/flink/pull/17634#discussion_r743368304 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/SumAggFunction.java ## @@ -66,7 +66,10

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

matriv commented on a change in pull request #17658: URL: https://github.com/apache/flink/pull/17658#discussion_r743578729 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/BinaryToStringCastRule.java ## @@ -0,0

[GitHub] [flink] AHeise commented on pull request #17682: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

AHeise commented on pull request #17682: URL: https://github.com/apache/flink/pull/17682#issuecomment-961925059 I just realized that 1.12 will probably not have a new release, so we can omit this backport. I would have merged it without compilation issue but it seems to require some more

[GitHub] [flink] AHeise commented on pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

AHeise commented on pull request #17640: URL: https://github.com/apache/flink/pull/17640#issuecomment-961928372 > @AHeise @MartijnVisser 2 general questions: > > 1. the current PR is a port of [this PR](https://github.com/apache/flink/pull/17523/files) for 1.13 that was asked

[GitHub] [flink] ruanhang1993 commented on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

ruanhang1993 commented on pull request #17601: URL: https://github.com/apache/flink/pull/17601#issuecomment-961592246 @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] xuyangzhong commented on pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

xuyangzhong commented on pull request #17652: URL: https://github.com/apache/flink/pull/17652#issuecomment-961639325 @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 #17650: [FLINK-24475] Remove no longer used NestedMap* classes

flinkbot edited a comment on pull request #17650: URL: https://github.com/apache/flink/pull/17650#issuecomment-958638599 -- 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

[GitHub] [flink] zentol merged pull request #17593: [FLINK-24603][e2e] Add test for Scala-free Flink

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

[GitHub] [flink] flinkbot commented on pull request #17694: [FLINK-24414][table-planner] Remove example test for left padding of decimals

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

[GitHub] [flink] zentol merged pull request #17578: [FLINK-24208][rest] Support user-supplied Savepoint triggerId

zentol merged pull request #17578: URL: https://github.com/apache/flink/pull/17578 -- 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] zentol commented on a change in pull request #17696: [FLINK-24765][kafka] Bump Kafka version to 2.8

zentol commented on a change in pull request #17696: URL: https://github.com/apache/flink/pull/17696#discussion_r743682100 ## File path: flink-connectors/flink-connector-kafka/pom.xml ## @@ -111,6 +111,15 @@ under the License. test +

[GitHub] [flink] flinkbot edited a comment on pull request #17670: [FLINK-24760][docs] Update user document for batch window tvf

flinkbot edited a comment on pull request #17670: URL: https://github.com/apache/flink/pull/17670#issuecomment-960539433 -- 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

[GitHub] [flink] tillrohrmann commented on a change in pull request #17607: [FLINK-24543][runtime] Avoid possible inconsistencies of ZookeeperSta…

tillrohrmann commented on a change in pull request #17607: URL: https://github.com/apache/flink/pull/17607#discussion_r743521497 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java ## @@ -154,54 +158,75 @@ public

[GitHub] [flink] flinkbot commented on pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key

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

[GitHub] [flink] MartijnVisser commented on pull request #17667: [hotfix][docs]fix kafka datastream connector mistake

MartijnVisser commented on pull request #17667: URL: https://github.com/apache/flink/pull/17667#issuecomment-961882890 @AHeise Please merge -- 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 #17694: [FLINK-24414][table-planner] Remove example test for left padding of decimals

flinkbot edited a comment on pull request #17694: URL: https://github.com/apache/flink/pull/17694#issuecomment-961828996 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17697: [FLINK-24796][ci] Reduce size of compile build artifact

flinkbot edited a comment on pull request #17697: URL: https://github.com/apache/flink/pull/17697#issuecomment-961911493 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17662: [FLINK-24747][table-planner] Add producedDataType to SupportsProjectionPushDown.applyProjection

flinkbot edited a comment on pull request #17662: URL: https://github.com/apache/flink/pull/17662#issuecomment-959311032 ## CI report: * 304b6add79698d3dd7289d5adae12cc2379e8da4 Azure:

[GitHub] [flink] MartijnVisser commented on a change in pull request #17696: [FLINK-24765][kafka] Bump Kafka version to 2.8

MartijnVisser commented on a change in pull request #17696: URL: https://github.com/apache/flink/pull/17696#discussion_r743651095 ## File path: flink-connectors/flink-connector-kafka/pom.xml ## @@ -111,6 +111,15 @@ under the License. test

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

rkhachatryan commented on a change in pull request #17229: URL: https://github.com/apache/flink/pull/17229#discussion_r743933585 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/BatchingStateChangeUploader.java ## @@ -121,18 +127,17 @@

[GitHub] [flink] eskabetxe commented on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

eskabetxe commented on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-961794935 -- 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

[GitHub] [flink] flinkbot commented on pull request #17700: [FLINK-24773][kafka] Fail job if unhandled exception occurs during committing

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

[GitHub] [flink] AHeise merged pull request #17648: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

AHeise merged pull request #17648: URL: https://github.com/apache/flink/pull/17648 -- 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] zentol merged pull request #17671: [FLINK-24749][coordination] Reuse CheckpointStatsTracker

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

[GitHub] [flink] flinkbot commented on pull request #17692: [FLINK-24489][CEP] The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of

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

[GitHub] [flink] akalash commented on a change in pull request #17664: [FLINK-24658][runtime] Added debug logs for BufferDebloater

akalash commented on a change in pull request #17664: URL: https://github.com/apache/flink/pull/17664#discussion_r743785933 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/throughput/BufferDebloater.java ## @@ -50,6 +54,14 @@ public BufferDebloater(

[GitHub] [flink] AHeise merged pull request #17626: [FLINK-24715][connectors][filesystems][formats] Update multiple Jackson dependencies to v2.13.0

AHeise merged pull request #17626: URL: https://github.com/apache/flink/pull/17626 -- 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 #17648: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

flinkbot edited a comment on pull request #17648: URL: https://github.com/apache/flink/pull/17648#issuecomment-957889509 ## CI report: * 3a428e7ab40488c56415b3e2ff3d5364d287df9d Azure:

[GitHub] [flink] MartijnVisser commented on pull request #17646: [FLINK-24740][testinfrastructure] Update testcontainers dependency to v1.16.2

MartijnVisser commented on pull request #17646: URL: https://github.com/apache/flink/pull/17646#issuecomment-961738654 @AHeise Please merge -- 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 commented on pull request #17689: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

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

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

MartijnVisser commented on pull request #17625: URL: https://github.com/apache/flink/pull/17625#issuecomment-961738493 @AHeise Please merge -- 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 commented on pull request #17693: [FLINK-24789][runtime] Trigger checkpoint disposal prior completing t…

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

<    1   2   3   4   5   6   7   8   9   10   >