[GitHub] [flink] flinkbot edited a comment on pull request #18314: [connectors/firehose] FLINK-24228 - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * ed94b1e53c2abe86110a4922368b23211474da42 Azure:

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r781414069 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/test/java/org/apache/flink/fs/gs/writer/GSRecoverableWriterTest.java ## @@ -0,0 +1,176 @@ +/*

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r781418333 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/test/java/org/apache/flink/fs/gs/utils/BlobUtilsTest.java ## @@ -0,0 +1,125 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #18320: [FLINK-25427] Decreased number of tests

flinkbot edited a comment on pull request #18320: URL: https://github.com/apache/flink/pull/18320#issuecomment-1008933892 ## CI report: * bff97576f03c57c0f3fd436c84b4edebcd2ce78a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [connectors/firehose] FLINK-24228 - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * ed94b1e53c2abe86110a4922368b23211474da42 Azure:

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r781415425 ## File path: tools/ci/maven-utils.sh ## @@ -104,7 +104,7 @@ MVN_GLOBAL_OPTIONS_WITHOUT_MIRROR+="--no-snapshot-updates " # enable non-interactive

[jira] [Commented] (FLINK-25581) Jobmanager does not archive completed jobs

[ https://issues.apache.org/jira/browse/FLINK-25581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472187#comment-17472187 ] Leonid Ilyevsky commented on FLINK-25581: - Yes, I did. There were no errors. Also I saw it

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r781414069 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/test/java/org/apache/flink/fs/gs/writer/GSRecoverableWriterTest.java ## @@ -0,0 +1,176 @@ +/*

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [connectors/firehose] FLINK-24228 - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * ed94b1e53c2abe86110a4922368b23211474da42 Azure:

[jira] [Commented] (FLINK-22411) Checkpoint failed caused by Mkdirs failed to create file, the path for Flink state.checkpoints.dir in docker-compose can not work from Flink Operations Playground

[ https://issues.apache.org/jira/browse/FLINK-22411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472186#comment-17472186 ] lvshuang commented on FLINK-22411: -- I have already in my computer create

[GitHub] [flink] flinkbot edited a comment on pull request #16207: [FLINK-23031][table-runtime]Make early processing time trigger d'ont repeat itself when no new element come in

flinkbot edited a comment on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * 595bc0bfe1081cd257dbec0051b18b9c166ccf82 Azure:

[jira] [Updated] (FLINK-22411) Checkpoint failed caused by Mkdirs failed to create file, the path for Flink state.checkpoints.dir in docker-compose can not work from Flink Operations Playground

[ https://issues.apache.org/jira/browse/FLINK-22411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lvshuang updated FLINK-22411: - Attachment: screenshot-1.png > Checkpoint failed caused by Mkdirs failed to create file, the path for

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [connectors/firehose] FLINK-24228 - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * ed94b1e53c2abe86110a4922368b23211474da42 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16207: [FLINK-23031][table-runtime]Make early processing time trigger d'ont repeat itself when no new element come in

flinkbot edited a comment on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * 595bc0bfe1081cd257dbec0051b18b9c166ccf82 Azure:

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r781345990 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/test/java/org/apache/flink/fs/gs/storage/MockBlobStorage.java ## @@ -0,0 +1,205 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #16207: [FLINK-23031][table-runtime]Make early processing time trigger d'ont repeat itself when no new element come in

flinkbot edited a comment on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * 595bc0bfe1081cd257dbec0051b18b9c166ccf82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [connectors/firehose] FLINK-24228 - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * ed94b1e53c2abe86110a4922368b23211474da42 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16207: [FLINK-23031][table-runtime]Make early processing time trigger d'ont repeat itself when no new element come in

flinkbot edited a comment on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * 595bc0bfe1081cd257dbec0051b18b9c166ccf82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18317: [FLINK-25576][BP 1.14][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

flinkbot edited a comment on pull request #18317: URL: https://github.com/apache/flink/pull/18317#issuecomment-1008884033 ## CI report: * b243b63a00bd7ae1870eb2ddcb1bb83f02fc2ee2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [connectors/firehose] FLINK-24228 - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * ed94b1e53c2abe86110a4922368b23211474da42 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16207: [FLINK-23031][table-runtime]Make early processing time trigger d'ont repeat itself when no new element come in

flinkbot edited a comment on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * 595bc0bfe1081cd257dbec0051b18b9c166ccf82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

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

[GitHub] [flink] flinkbot edited a comment on pull request #16207: [FLINK-23031][table-runtime]Make early processing time trigger d'ont repeat itself when no new element come in

flinkbot edited a comment on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * 595bc0bfe1081cd257dbec0051b18b9c166ccf82 Azure:

[jira] [Updated] (FLINK-21232) Introduce pluggable Hadoop delegation token providers

[ https://issues.apache.org/jira/browse/FLINK-21232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-21232: -- Labels: auto-unassigned pull-request-available (was: auto-deprioritized-major

[jira] [Updated] (FLINK-21232) Introduce pluggable Hadoop delegation token providers

[ https://issues.apache.org/jira/browse/FLINK-21232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-21232: -- Priority: Major (was: Minor) > Introduce pluggable Hadoop delegation token providers >

[jira] [Assigned] (FLINK-21232) Introduce pluggable Hadoop delegation token providers

[ https://issues.apache.org/jira/browse/FLINK-21232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-21232: - Assignee: Gabor Somogyi (was: jackwangcs) > Introduce pluggable Hadoop delegation

[GitHub] [flink] flinkbot edited a comment on pull request #16207: [FLINK-23031][table-runtime]Make early processing time trigger d'ont repeat itself when no new element come in

flinkbot edited a comment on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * 595bc0bfe1081cd257dbec0051b18b9c166ccf82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18318: [FLINK-25576][BP 1.13][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

flinkbot edited a comment on pull request #18318: URL: https://github.com/apache/flink/pull/18318#issuecomment-100611 ## CI report: * e8c0089788c0c0f2ac3f9d24d9204fcfff6a0785 Azure:

[GitHub] [flink] XComp commented on a change in pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

XComp commented on a change in pull request #18189: URL: https://github.com/apache/flink/pull/18189#discussion_r781378562 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/MiniDispatcher.java ## @@ -63,6 +63,7 @@ public MiniDispatcher(

[GitHub] [flink] flinkbot edited a comment on pull request #16207: [FLINK-23031][table-runtime]Make early processing time trigger d'ont repeat itself when no new element come in

flinkbot edited a comment on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * 595bc0bfe1081cd257dbec0051b18b9c166ccf82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18320: [FLINK-25427] Decreased number of tests

flinkbot edited a comment on pull request #18320: URL: https://github.com/apache/flink/pull/18320#issuecomment-1008933892 ## CI report: * bff97576f03c57c0f3fd436c84b4edebcd2ce78a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16207: [FLINK-23031][table-runtime]Make early processing time trigger d'ont repeat itself when no new element come in

flinkbot edited a comment on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * 595bc0bfe1081cd257dbec0051b18b9c166ccf82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.2 due to CVEs

flinkbot edited a comment on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848 ## CI report: * 32ffb361fa08a0e3017f711508fb0e5834a6fe69 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18320: [FLINK-25427] Decreased number of tests

flinkbot edited a comment on pull request #18320: URL: https://github.com/apache/flink/pull/18320#issuecomment-1008933892 ## CI report: * bff97576f03c57c0f3fd436c84b4edebcd2ce78a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16207: [FLINK-23031][table-runtime]Make early processing time trigger d'ont repeat itself when no new element come in

flinkbot edited a comment on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * 595bc0bfe1081cd257dbec0051b18b9c166ccf82 Azure:

[jira] [Commented] (FLINK-23031) Support to emit window result with periodic or non_periodic

[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472154#comment-17472154 ] Aitozi commented on FLINK-23031: Hi [~wenlong.lwl] I have done the refactor work, and fill the Jira

[jira] [Updated] (FLINK-23031) Support to emit window result with periodic or non_periodic

[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-23031: --- Description: Currently, Flink support early trigger for Window Operator, But it will trigger periodically

[jira] [Updated] (FLINK-23031) Support to emit window result with periodic or non_periodic

[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-23031: --- Description: Currently, Flink support early trigger for Window Operator, But it will trigger periodically

[jira] [Updated] (FLINK-23031) Support to emit window result with periodic or non_periodic

[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-23031: --- Description: Currently, Flink support early trigger for Window Operator, But it will trigger periodically

[jira] [Updated] (FLINK-23031) Support to emit window result with periodic or non_periodic

[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-23031: --- Description: Currently, Flink support early trigger for Window Operator, But it will trigger periodically

[GitHub] [flink] flinkbot edited a comment on pull request #18283: [FLINK-25390][table] Add API to support merging options from catalog table

flinkbot edited a comment on pull request #18283: URL: https://github.com/apache/flink/pull/18283#issuecomment-1006442061 ## CI report: * ad75062f2a516ec05c3cecaa41cec671e2faebce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16207: [FLINK-23031][table-runtime]Make early processing time trigger d'ont repeat itself when no new element come in

flinkbot edited a comment on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * 595bc0bfe1081cd257dbec0051b18b9c166ccf82 Azure:

[jira] [Updated] (FLINK-23031) Support to emit window result with periodic or non_periodic

[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-23031: --- Description: Currently, Flink support early trigger for Window Operator, But it will trigger periodically

[GitHub] [flink] flinkbot edited a comment on pull request #18319: [FLINK-25531][connectors/kafka] Set ProducerConfig 'retries' to 3 to speed up testRetryComittableOnRetriableError

flinkbot edited a comment on pull request #18319: URL: https://github.com/apache/flink/pull/18319#issuecomment-1008898822 ## CI report: * eb853c67af624764b4e5c0c3fce054a7fdedbf0e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18283: [FLINK-25390][table] Add API to support merging options from catalog table

flinkbot edited a comment on pull request #18283: URL: https://github.com/apache/flink/pull/18283#issuecomment-1006442061 ## CI report: * ad75062f2a516ec05c3cecaa41cec671e2faebce Azure:

[jira] [Commented] (FLINK-25230) Harden type serialization in JSON plan

[ https://issues.apache.org/jira/browse/FLINK-25230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472150#comment-17472150 ] Timo Walther commented on FLINK-25230: -- Fixed in master: commit

[jira] [Created] (FLINK-25597) Document which URI based config options works with local / general filesystem

David Morávek created FLINK-25597: - Summary: Document which URI based config options works with local / general filesystem Key: FLINK-25597 URL: https://issues.apache.org/jira/browse/FLINK-25597

[GitHub] [flink] flinkbot edited a comment on pull request #16207: [FLINK-23031][table-runtime]Make early processing time trigger d'ont repeat itself when no new element come in

flinkbot edited a comment on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * 595bc0bfe1081cd257dbec0051b18b9c166ccf82 Azure:

[GitHub] [flink] twalthr closed pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

twalthr closed pull request #18274: URL: https://github.com/apache/flink/pull/18274 -- 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 #18283: [FLINK-25390][table] Add API to support merging options from catalog table

flinkbot edited a comment on pull request #18283: URL: https://github.com/apache/flink/pull/18283#issuecomment-1006442061 ## CI report: * ad75062f2a516ec05c3cecaa41cec671e2faebce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

flinkbot edited a comment on pull request #18274: URL: https://github.com/apache/flink/pull/18274#issuecomment-1005845834 ## CI report: * a872e8c5d8aa822a0358d859a462c979a4965750 Azure:

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r781345990 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/test/java/org/apache/flink/fs/gs/storage/MockBlobStorage.java ## @@ -0,0 +1,205 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #16207: [FLINK-23031][table-planner-blink]Support to emit window result perio…

flinkbot edited a comment on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * 595bc0bfe1081cd257dbec0051b18b9c166ccf82 Azure:

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r781345990 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/test/java/org/apache/flink/fs/gs/storage/MockBlobStorage.java ## @@ -0,0 +1,205 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #18283: [FLINK-25390][table] Add API to support merging options from catalog table

flinkbot edited a comment on pull request #18283: URL: https://github.com/apache/flink/pull/18283#issuecomment-1006442061 ## CI report: * ad75062f2a516ec05c3cecaa41cec671e2faebce Azure:

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r781345990 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/test/java/org/apache/flink/fs/gs/storage/MockBlobStorage.java ## @@ -0,0 +1,205 @@ +/* + *

[GitHub] [flink] dmvk commented on a change in pull request #18286: [FLINK-25533] Forward preferred allocations into the DeclarativeSlotPoolBridge

dmvk commented on a change in pull request #18286: URL: https://github.com/apache/flink/pull/18286#discussion_r781301276 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/RequestSlotMatchingStrategy.java ## @@ -0,0 +1,58 @@ +/* + * Licensed

[GitHub] [flink] flinkbot edited a comment on pull request #18283: [FLINK-25390][table] Add API to support merging options from catalog table

flinkbot edited a comment on pull request #18283: URL: https://github.com/apache/flink/pull/18283#issuecomment-1006442061 ## CI report: * ad75062f2a516ec05c3cecaa41cec671e2faebce Azure:

[jira] [Comment Edited] (FLINK-23843) Exceptions during "SplitEnumeratorContext.runInCoordinatorThread()" should cause Global Failure instead of Process Kill

[ https://issues.apache.org/jira/browse/FLINK-23843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472136#comment-17472136 ] Etienne Chauchot edited comment on FLINK-23843 at 1/10/22, 4:19 PM:

[jira] [Commented] (FLINK-23843) Exceptions during "SplitEnumeratorContext.runInCoordinatorThread()" should cause Global Failure instead of Process Kill

[ https://issues.apache.org/jira/browse/FLINK-23843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472136#comment-17472136 ] Etienne Chauchot commented on FLINK-23843: -- What is the expected behavior in case an exception

[GitHub] [flink] flinkbot edited a comment on pull request #18283: [FLINK-25390][table] Add API to support merging options from catalog table

flinkbot edited a comment on pull request #18283: URL: https://github.com/apache/flink/pull/18283#issuecomment-1006442061 ## CI report: * ad75062f2a516ec05c3cecaa41cec671e2faebce Azure:

[jira] [Assigned] (FLINK-25531) The test testRetryCommittableOnRetriableError takes one hour before completing succesfully

[ https://issues.apache.org/jira/browse/FLINK-25531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Preuss reassigned FLINK-25531: Assignee: Alexander Preuss (was: Fabian Paul) > The test

[jira] [Commented] (FLINK-25483) When FlinkSQL writes ES, it will not write and update the null value field

[ https://issues.apache.org/jira/browse/FLINK-25483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472124#comment-17472124 ] 陈磊 commented on FLINK-25483: [~MartijnVisser] oh,no.I think you misunderstood me. Field a,b and c is an

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

flinkbot edited a comment on pull request #18274: URL: https://github.com/apache/flink/pull/18274#issuecomment-1005845834 ## CI report: * c445781fa99453f887f9d91978e5bb9ca9d1f91a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

flinkbot edited a comment on pull request #18274: URL: https://github.com/apache/flink/pull/18274#issuecomment-1005845834 ## CI report: * c445781fa99453f887f9d91978e5bb9ca9d1f91a Azure:

[GitHub] [flink] twalthr commented on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

twalthr commented on pull request #18274: URL: https://github.com/apache/flink/pull/18274#issuecomment-1009016694 Thanks everyone. I addressed all comments. I will merge this once the build is green. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

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

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r781315443 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/test/java/org/apache/flink/fs/gs/storage/MockBlobStorage.java ## @@ -0,0 +1,205 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

flinkbot edited a comment on pull request #18302: URL: https://github.com/apache/flink/pull/18302#issuecomment-1007550439 ## CI report: * cd00723fd58b214bf6de74a1b0ef657e31ba361c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18316: [hotfix][docs] Fixing multiple internal and external 404 links

flinkbot edited a comment on pull request #18316: URL: https://github.com/apache/flink/pull/18316#issuecomment-1008874978 ## CI report: * 716ceb4e65626fde5dee8a5f0b11c6ed266e40fd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

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

[GitHub] [flink] flinkbot edited a comment on pull request #18321: [FLINK-25224] Reuse globally defined version of hadoop (`hadoop.versi…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

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

[GitHub] [flink] flinkbot edited a comment on pull request #18283: [FLINK-25390][table] Add API to support merging options from catalog table

flinkbot edited a comment on pull request #18283: URL: https://github.com/apache/flink/pull/18283#issuecomment-1006442061 ## CI report: * ad75062f2a516ec05c3cecaa41cec671e2faebce Azure:

[GitHub] [flink] flinkbot commented on pull request #18321: [FLINK-25224] Reuse globally defined version of hadoop (`hadoop.versi…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18283: [FLINK-25390][table] Add API to support merging options from catalog table

flinkbot edited a comment on pull request #18283: URL: https://github.com/apache/flink/pull/18283#issuecomment-1006442061 ## CI report: * ad75062f2a516ec05c3cecaa41cec671e2faebce Azure:

[jira] [Updated] (FLINK-25592) Improvement of parser, optimizer and execution for Flink Batch SQL

[ https://issues.apache.org/jira/browse/FLINK-25592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-25592: --- Description: This is a parent JIRA to track improvements on Flink Batch SQL, including parser,

[GitHub] [flink] flinkbot edited a comment on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.2 due to CVEs

flinkbot edited a comment on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848 ## CI report: * 44a1bb12e8a24dabdc36794ac3a79b91e5ff89ce Azure:

[GitHub] [flink] flinkbot commented on pull request #18321: [FLINK-25224] Reuse globally defined version of hadoop (`hadoop.versi…

flinkbot commented on pull request #18321: URL: https://github.com/apache/flink/pull/18321#issuecomment-1009000271 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] dmvk opened a new pull request #18321: [FLINK-25224] Reuse globally defined version of hadoop (`hadoop.versi…

dmvk opened a new pull request #18321: URL: https://github.com/apache/flink/pull/18321 https://issues.apache.org/jira/browse/FLINK-25224 -- 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 a change in pull request #18037: [FLINK-25179] Add document for composite types support for parquet

MartijnVisser commented on a change in pull request #18037: URL: https://github.com/apache/flink/pull/18037#discussion_r781294398 ## File path: docs/content/docs/connectors/table/formats/parquet.md ## @@ -174,9 +174,24 @@ The following table lists the type mapping from Flink

[jira] [Comment Edited] (FLINK-25560) Add "sink.delete.mode" in HBase sql connector for retracting the latest version or all versions in changelog mode

[ https://issues.apache.org/jira/browse/FLINK-25560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472099#comment-17472099 ] Jing Ge edited comment on FLINK-25560 at 1/10/22, 3:24 PM: --- Thanks for your

[jira] [Commented] (FLINK-25560) Add "sink.delete.mode" in HBase sql connector for retracting the latest version or all versions in changelog mode

[ https://issues.apache.org/jira/browse/FLINK-25560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472099#comment-17472099 ] Jing Ge commented on FLINK-25560: - Based on the previous discussion, it is recommended to reach a

[jira] [Commented] (FLINK-25483) When FlinkSQL writes ES, it will not write and update the null value field

[ https://issues.apache.org/jira/browse/FLINK-25483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472095#comment-17472095 ] Martijn Visser commented on FLINK-25483: [~empcl] In your SQL statement, you are explicitly

[jira] [Assigned] (FLINK-25570) Introduce Sink V2 extension interfaces

[ https://issues.apache.org/jira/browse/FLINK-25570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-25570: --- Assignee: Fabian Paul > Introduce Sink V2 extension interfaces >

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * 94fa63008c237a2206befeae332159bf21cc1e1f Azure:

[jira] [Commented] (FLINK-25581) Jobmanager does not archive completed jobs

[ https://issues.apache.org/jira/browse/FLINK-25581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472092#comment-17472092 ] Chesnay Schepler commented on FLINK-25581: -- Did you check the JobManager logs for any errors?

[GitHub] [flink] godfreyhe commented on a change in pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

godfreyhe commented on a change in pull request #18274: URL: https://github.com/apache/flink/pull/18274#discussion_r781013103 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/DataTypeJsonDeserializer.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * 94fa63008c237a2206befeae332159bf21cc1e1f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18105: [FLINK-25266][e2e] Convert StreamingKafkaITCase to SmokeKafkaITCase covering application packaging

flinkbot edited a comment on pull request #18105: URL: https://github.com/apache/flink/pull/18105#issuecomment-993417620 ## CI report: * 46c0d678726ab191f950713a72750309bc9661a8 Azure:

[jira] [Comment Edited] (FLINK-25369) CatalogManager provide wrong tables or views in given catalog database

[ https://issues.apache.org/jira/browse/FLINK-25369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472077#comment-17472077 ] Ingo Bürk edited comment on FLINK-25369 at 1/10/22, 2:48 PM: - Fixed in

[GitHub] [flink] flinkbot edited a comment on pull request #18105: [FLINK-25266][e2e] Convert StreamingKafkaITCase to SmokeKafkaITCase covering application packaging

flinkbot edited a comment on pull request #18105: URL: https://github.com/apache/flink/pull/18105#issuecomment-993417620 ## CI report: * 46c0d678726ab191f950713a72750309bc9661a8 Azure:

[jira] [Resolved] (FLINK-25369) CatalogManager provide wrong tables or views in given catalog database

[ https://issues.apache.org/jira/browse/FLINK-25369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk resolved FLINK-25369. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master commit

[jira] [Assigned] (FLINK-25369) CatalogManager provide wrong tables or views in given catalog database

[ https://issues.apache.org/jira/browse/FLINK-25369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk reassigned FLINK-25369: - Assignee: Yubin Li > CatalogManager provide wrong tables or views in given catalog database >

[GitHub] [flink] fapaul commented on pull request #18105: [FLINK-25266][e2e] Convert StreamingKafkaITCase to SmokeKafkaITCase covering application packaging

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

[GitHub] [flink] Airblader closed pull request #18146: [FLINK-25369][table] CatalogManager provide right tables or views in given catalog database

Airblader closed pull request #18146: URL: https://github.com/apache/flink/pull/18146 -- 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] [Commented] (FLINK-25576) Update com.h2database:h2 to 2.0.206

[ https://issues.apache.org/jira/browse/FLINK-25576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472071#comment-17472071 ] Fabian Paul commented on FLINK-25576: - Merged in master: 6036df94be5dfe989ede1a75f1a1f72ccf09ace8 >

[GitHub] [flink] fapaul merged pull request #18301: [FLINK-25576][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

fapaul merged pull request #18301: URL: https://github.com/apache/flink/pull/18301 -- 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 #18320: [FLINK-25427] Decreased number of tests

flinkbot edited a comment on pull request #18320: URL: https://github.com/apache/flink/pull/18320#issuecomment-1008933892 ## CI report: * bff97576f03c57c0f3fd436c84b4edebcd2ce78a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [connectors/firehose] FLINK-24228 - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * ed94b1e53c2abe86110a4922368b23211474da42 Azure:

<    1   2   3   4   5   6   >