[GitHub] [flink] flinkbot edited a comment on pull request #17539: [FLINK-24612][connectors/kafka] Configure Kafka test container log le…

flinkbot edited a comment on pull request #17539: URL: https://github.com/apache/flink/pull/17539#issuecomment-948660144 ## CI report: * 89a35a2710f77b9b7629edbfba526eb71ef250c9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 981d862138bdd5d770e7740014bf1588aa441433 Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

rkhachatryan commented on a change in pull request #16606: URL: https://github.com/apache/flink/pull/16606#discussion_r733855539 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 350543e62c31c69fb5805a334c186e38468a9df7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 350543e62c31c69fb5805a334c186e38468a9df7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 350543e62c31c69fb5805a334c186e38468a9df7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17454: [FLINK-24500][table] Moved DecimalDataUtils and SqlDateTimeUtils to table-common

flinkbot edited a comment on pull request #17454: URL: https://github.com/apache/flink/pull/17454#issuecomment-940730352 ## CI report: * ef55cc57001926789b89b7a2576aa314a49d3faa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 350543e62c31c69fb5805a334c186e38468a9df7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 350543e62c31c69fb5805a334c186e38468a9df7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 350543e62c31c69fb5805a334c186e38468a9df7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17515: [FLINK-24575][table-runtime] Migrate TestRowDataCsvInputFormat to DeserializationSchemaFactory

flinkbot edited a comment on pull request #17515: URL: https://github.com/apache/flink/pull/17515#issuecomment-946422818 ## CI report: * d7c1fcc67b1a7905b29506234c71139b0744e606 Azure:

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

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 350543e62c31c69fb5805a334c186e38468a9df7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 350543e62c31c69fb5805a334c186e38468a9df7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 350543e62c31c69fb5805a334c186e38468a9df7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17541: [FLINK-24189] Perform buffer debloating per single gate

flinkbot edited a comment on pull request #17541: URL: https://github.com/apache/flink/pull/17541#issuecomment-948765818 ## CI report: * 9a4f892294645741be037fc2daf930e7a437929f Azure:

[GitHub] [flink] zentol commented on a change in pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

zentol commented on a change in pull request #17474: URL: https://github.com/apache/flink/pull/17474#discussion_r733837865 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherCachedOperationsHandler.java ## @@ -0,0 +1,121 @@ +/* + *

[GitHub] [flink] zentol commented on a change in pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

zentol commented on a change in pull request #17474: URL: https://github.com/apache/flink/pull/17474#discussion_r733837865 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherCachedOperationsHandler.java ## @@ -0,0 +1,121 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 350543e62c31c69fb5805a334c186e38468a9df7 Azure:

[GitHub] [flink] flinkbot commented on pull request #17541: [FLINK-24189] Perform buffer debloating per single gate

flinkbot commented on pull request #17541: URL: https://github.com/apache/flink/pull/17541#issuecomment-948768027 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] zentol commented on a change in pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

zentol commented on a change in pull request #17474: URL: https://github.com/apache/flink/pull/17474#discussion_r733837580 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/TriggerSavepointParameters.java ## @@ -0,0 +1,91 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot commented on pull request #17541: [FLINK-24189] Perform buffer debloating per single gate

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

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 350543e62c31c69fb5805a334c186e38468a9df7 Azure:

[jira] [Updated] (FLINK-24189) Buffer debloating for multiple gates

[ https://issues.apache.org/jira/browse/FLINK-24189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24189: --- Labels: pull-request-available (was: ) > Buffer debloating for multiple gates >

[GitHub] [flink] dawidwys opened a new pull request #17541: [FLINK-24189] Perform buffer debloating per single gate

dawidwys opened a new pull request #17541: URL: https://github.com/apache/flink/pull/17541 ## What is the purpose of the change This PR moves calculating throughput as well debloating buffers to the gate level. It should help with situations when there is a significant

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 350543e62c31c69fb5805a334c186e38468a9df7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 350543e62c31c69fb5805a334c186e38468a9df7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 350543e62c31c69fb5805a334c186e38468a9df7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 350543e62c31c69fb5805a334c186e38468a9df7 Azure:

[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_r733820258 ## File path: flink-formats/flink-avro/pom.xml ## @@ -26,7 +26,7 @@ under the License. org.apache.flink flink-formats

[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_r733820258 ## File path: flink-formats/flink-avro/pom.xml ## @@ -26,7 +26,7 @@ under the License. org.apache.flink flink-formats

[GitHub] [flink] flinkbot edited a comment on pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

flinkbot edited a comment on pull request #17537: URL: https://github.com/apache/flink/pull/17537#issuecomment-948566240 ## CI report: * 522f93600f3e7a7be82a34433ba0ca5a474910ed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 350543e62c31c69fb5805a334c186e38468a9df7 Azure:

[GitHub] [flink] nicoweidner commented on a change in pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

nicoweidner commented on a change in pull request #17474: URL: https://github.com/apache/flink/pull/17474#discussion_r733817341 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/async/AbstractAsynchronousOperationHandlersTest.java ## @@ -194,11

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 350543e62c31c69fb5805a334c186e38468a9df7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * a9a0b1cf0c1bf5596df411a1838388d797d999fa Azure:

[GitHub] [flink] dawidwys merged pull request #17440: [FLINK-24468][runtime] Wait for the channel activation before creating partition request client

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

[jira] [Closed] (FLINK-24468) NPE when notifyNewBufferSize

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

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * a9a0b1cf0c1bf5596df411a1838388d797d999fa Azure:

[jira] [Commented] (FLINK-24579) FlinkSQL does not print correctly content of arrays nested into maps

[ https://issues.apache.org/jira/browse/FLINK-24579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432549#comment-17432549 ] Francesco Guardiani commented on FLINK-24579: - Hi! Thanks for the PR but we are already

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

[GitHub] [flink] flinkbot edited a comment on pull request #17540: [FLINK-24331][tests] Forbid to finish the TestEventSource if it has not sent at least one value

flinkbot edited a comment on pull request #17540: URL: https://github.com/apache/flink/pull/17540#issuecomment-948708384 ## CI report: * 63a67bc0f1dcdc5e161089efdc856ce7f8325666 Azure:

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

[GitHub] [flink] flinkbot edited a comment on pull request #17493: [FLINK-24019][build][dist] Package Scala APIs separately

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

[GitHub] [flink] flinkbot edited a comment on pull request #17465: [FLINK-24488][connectors/kafka] KafkaRecordSerializationSchemaBuilder does not forward timestamp

flinkbot edited a comment on pull request #17465: URL: https://github.com/apache/flink/pull/17465#issuecomment-942425244 ## CI report: * e501f19931561b4c685f5064857794c690ff1d28 Azure:

[GitHub] [flink] xmarker commented on pull request #17465: [FLINK-24488][connectors/kafka] KafkaRecordSerializationSchemaBuilder does not forward timestamp

xmarker commented on pull request #17465: URL: https://github.com/apache/flink/pull/17465#issuecomment-948712106 @fapaul I have pushed with rebase , thinks for your review -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot commented on pull request #17540: [FLINK-24331][tests] Forbid to finish the TestEventSource if it has not sent at least one value

flinkbot commented on pull request #17540: URL: https://github.com/apache/flink/pull/17540#issuecomment-948710561 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] xmarker commented on pull request #17465: [FLINK-24488][connectors/kafka] KafkaRecordSerializationSchemaBuilder does not forward timestamp

xmarker commented on pull request #17465: URL: https://github.com/apache/flink/pull/17465#issuecomment-948708235 > @xmarker can you rebase your changes on the latest master. Some tests seem to fail and I wonder if these instabilities are fixed on the latest master version. --

[GitHub] [flink] flinkbot commented on pull request #17540: [FLINK-24331][tests] Forbid to finish the TestEventSource if it has not sent at least one value

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

[GitHub] [flink] xmarker closed pull request #17465: [FLINK-24488][connectors/kafka] KafkaRecordSerializationSchemaBuilder does not forward timestamp

xmarker closed pull request #17465: URL: https://github.com/apache/flink/pull/17465 -- 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 #17465: [FLINK-24488][connectors/kafka] KafkaRecordSerializationSchemaBuilder does not forward timestamp

flinkbot edited a comment on pull request #17465: URL: https://github.com/apache/flink/pull/17465#issuecomment-942425244 ## CI report: * e501f19931561b4c685f5064857794c690ff1d28 Azure:

[jira] [Updated] (FLINK-24331) PartiallyFinishedSourcesITCase fails with "No downstream received 0 from xxx;"

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

[jira] [Assigned] (FLINK-15550) testCancelTaskExceptionAfterTaskMarkedFailed failed on azure

[ https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-15550: - Assignee: Anton Kalashnikov > testCancelTaskExceptionAfterTaskMarkedFailed

[GitHub] [flink] flinkbot edited a comment on pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API

flinkbot edited a comment on pull request #17374: URL: https://github.com/apache/flink/pull/17374#issuecomment-929172201 ## CI report: * d60e9d9c898fe4881864b46e7e3344458e748797 Azure:

[GitHub] [flink] akalash opened a new pull request #17540: [FLINK-24331][tests] Forbid to finish the TestEventSource if it has not sent at least one value

akalash opened a new pull request #17540: URL: https://github.com/apache/flink/pull/17540 ## What is the purpose of the change *This PR fixes the problem with zero sent values from source* ## Brief change log - *Forbid to finish the TestEventSource if it

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

[GitHub] [flink] flinkbot edited a comment on pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * ec1ebf9f4ddb11927d3cc8c32ab4967c1202ad49 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * ec1ebf9f4ddb11927d3cc8c32ab4967c1202ad49 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17535: [FLINK-24609][akka][build] Use same Scala properties as root pom

flinkbot edited a comment on pull request #17535: URL: https://github.com/apache/flink/pull/17535#issuecomment-948487840 ## CI report: * 743640e83c9caed3f2af3c94ce4aee6228d244bb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17454: [FLINK-24500][table] Moved DecimalDataUtils and SqlDateTimeUtils to table-common

flinkbot edited a comment on pull request #17454: URL: https://github.com/apache/flink/pull/17454#issuecomment-940730352 ## CI report: * 890d97bb905765039c08607e5b9931e19711a017 Azure:

[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_r733745562 ## 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 #17534: [FLINK-24610][table-planner] Support sql projection common expression…

flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * 560a641314a73950039f7a544d81a155d773ad01 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17454: [FLINK-24500][table] Moved DecimalDataUtils and SqlDateTimeUtils to table-common

flinkbot edited a comment on pull request #17454: URL: https://github.com/apache/flink/pull/17454#issuecomment-940730352 ## CI report: * 890d97bb905765039c08607e5b9931e19711a017 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

flinkbot edited a comment on pull request #17472: URL: https://github.com/apache/flink/pull/17472#issuecomment-943076656 ## CI report: * e377697fc0cb853615137e934d268650259762f4 Azure:

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

fapaul commented on a change in pull request #17501: URL: https://github.com/apache/flink/pull/17501#discussion_r733739540 ## 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 #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * a9a0b1cf0c1bf5596df411a1838388d797d999fa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17454: [FLINK-24500][table] Moved DecimalDataUtils and SqlDateTimeUtils to table-common

flinkbot edited a comment on pull request #17454: URL: https://github.com/apache/flink/pull/17454#issuecomment-940730352 ## CI report: * 890d97bb905765039c08607e5b9931e19711a017 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17518: [FLINK-24018][build] Remove Scala dependencies from Java APIs

flinkbot edited a comment on pull request #17518: URL: https://github.com/apache/flink/pull/17518#issuecomment-946526433 ## CI report: * 708f2a7720d6f1ed80d60a2103e995e066b40646 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

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

[GitHub] [flink] flinkbot edited a comment on pull request #17454: [FLINK-24500][table] Moved DecimalDataUtils and SqlDateTimeUtils to table-common

flinkbot edited a comment on pull request #17454: URL: https://github.com/apache/flink/pull/17454#issuecomment-940730352 ## CI report: * 890d97bb905765039c08607e5b9931e19711a017 Azure:

[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_r733731918 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java ## @@ -0,0 +1,189 @@ +/* + *

[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_r733730691 ## 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 #17539: [FLINK-24612][connectors/kafka] Configure Kafka test container log le…

flinkbot edited a comment on pull request #17539: URL: https://github.com/apache/flink/pull/17539#issuecomment-948660144 ## CI report: * 89a35a2710f77b9b7629edbfba526eb71ef250c9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

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

[GitHub] [flink] flinkbot edited a comment on pull request #17454: [FLINK-24500][table] Moved DecimalDataUtils and SqlDateTimeUtils to table-common

flinkbot edited a comment on pull request #17454: URL: https://github.com/apache/flink/pull/17454#issuecomment-940730352 ## CI report: * 890d97bb905765039c08607e5b9931e19711a017 Azure:

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

JingGe commented on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-948663153 > Thanks for the nice discussion! I think I now better understand the contribution. > > Can you rename the class `AvroParquetRecordFormat` to `ParquetAvro...`? The

[GitHub] [flink] flinkbot commented on pull request #17539: [FLINK-24612][connectors/kafka] Configure Kafka test container log le…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * ec1ebf9f4ddb11927d3cc8c32ab4967c1202ad49 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

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

[GitHub] [flink] flinkbot commented on pull request #17539: [FLINK-24612][connectors/kafka] Configure Kafka test container log le…

flinkbot commented on pull request #17539: URL: https://github.com/apache/flink/pull/17539#issuecomment-948658808 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 #17454: [FLINK-24500][table] Moved DecimalDataUtils and SqlDateTimeUtils to table-common

flinkbot edited a comment on pull request #17454: URL: https://github.com/apache/flink/pull/17454#issuecomment-940730352 ## CI report: * 890d97bb905765039c08607e5b9931e19711a017 Azure:

[GitHub] [flink] fapaul commented on pull request #17465: [FLINK-24488][connectors/kafka] KafkaRecordSerializationSchemaBuilder does not forward timestamp

fapaul commented on pull request #17465: URL: https://github.com/apache/flink/pull/17465#issuecomment-948655265 @xmarker can you rebase your changes on the latest master. Some tests seem to fail and I wonder if these instabilities are fixed on the latest master version. -- This is an

[jira] [Updated] (FLINK-24560) flink-yarn-tests should copy examples after package phase

[ https://issues.apache.org/jira/browse/FLINK-24560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24560: --- Labels: pull-request-available (was: ) > flink-yarn-tests should copy examples after

[jira] [Updated] (FLINK-24612) Kafka test container creates a large amount of logs

[ https://issues.apache.org/jira/browse/FLINK-24612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24612: --- Labels: pull-request-available (was: ) > Kafka test container creates a large amount of

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

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

[GitHub] [flink] zentol commented on pull request #17491: [FLINK-24560][build][yarn] Copy example jars in pre-integration-test phase

zentol commented on pull request #17491: URL: https://github.com/apache/flink/pull/17491#issuecomment-948654087 > Do you have an idea why the PR is not picked up and linked in the Jira ticket? No, I guess some issue with the mirroring. -- This is an automated message from the

[GitHub] [flink] fapaul opened a new pull request #17539: [FLINK-24612][connectors/kafka] Configure Kafka test container log le…

fapaul opened a new pull request #17539: URL: https://github.com/apache/flink/pull/17539 …vels accordingly to test logger ## What is the purpose of the change This PR should reduce the overall log size generated by our tests using the Kafka testcontainer because we

[GitHub] [flink] flinkbot edited a comment on pull request #17454: [FLINK-24500][table] Moved DecimalDataUtils and SqlDateTimeUtils to table-common

flinkbot edited a comment on pull request #17454: URL: https://github.com/apache/flink/pull/17454#issuecomment-940730352 ## CI report: * 890d97bb905765039c08607e5b9931e19711a017 Azure:

[GitHub] [flink] twalthr edited a comment on pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

twalthr edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-948652702 Logically they might belong together but only `CastExecutor` is really necessary in common. We should try to keep this module slim. And the concept of `CastRule` and

[GitHub] [flink] twalthr commented on pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

twalthr commented on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-948652702 Logically they might belong together but only `CastExecutor` is really necessary in common. We should try to keep this module slim. And the concept of `CastRule` and

[GitHub] [flink] twalthr commented on a change in pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

twalthr commented on a change in pull request #17522: URL: https://github.com/apache/flink/pull/17522#discussion_r733714592 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/casting/CastRule.java ## @@ -0,0 +1,60 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

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

[GitHub] [flink] flinkbot edited a comment on pull request #17454: [FLINK-24500][table] Moved DecimalDataUtils and SqlDateTimeUtils to table-common

flinkbot edited a comment on pull request #17454: URL: https://github.com/apache/flink/pull/17454#issuecomment-940730352 ## CI report: * 976000b7712fd93e394433501bca3c55a4fb0977 Azure:

[GitHub] [flink] ndeslandes closed pull request #15419: [FLINK-22018][Connectors/JDBC] Remove error log on retries in JdbcBatchingOutputFormat

ndeslandes closed pull request #15419: URL: https://github.com/apache/flink/pull/15419 -- 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 #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

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

[GitHub] [flink] flinkbot edited a comment on pull request #17454: [FLINK-24500][table] Moved DecimalDataUtils and SqlDateTimeUtils to table-common

flinkbot edited a comment on pull request #17454: URL: https://github.com/apache/flink/pull/17454#issuecomment-940730352 ## CI report: * 976000b7712fd93e394433501bca3c55a4fb0977 Azure:

[GitHub] [flink] JingsongLi commented on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

JingsongLi commented on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-948644481 @JingGe @slinkydeveloper Good suggestion, we should put the IO operation on the fetcher side. @tsreaper +1 to "we should never call the hasNext method if there is no more

[jira] [Assigned] (FLINK-24612) Kafka test container creates a large amount of logs

[ https://issues.apache.org/jira/browse/FLINK-24612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-24612: --- Assignee: Fabian Paul > Kafka test container creates a large amount of logs >

[jira] [Created] (FLINK-24612) Kafka test container creates a large amount of logs

Fabian Paul created FLINK-24612: --- Summary: Kafka test container creates a large amount of logs Key: FLINK-24612 URL: https://issues.apache.org/jira/browse/FLINK-24612 Project: Flink Issue

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

<    1   2   3   4   5   >