[jira] [Updated] (FLINK-11459) Presto S3 does not show errors due to missing credentials with minio

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

[jira] [Updated] (FLINK-11794) Allow compression of row format files created by StreamingFileSink

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

[jira] [Updated] (FLINK-11783) Deadlock during Join operation

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

[jira] [Updated] (FLINK-11694) Enforce space before left curly brace

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

[jira] [Updated] (FLINK-11789) Checkpoint directories are not cleaned up after job termination

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

[jira] [Updated] (FLINK-16446) Add rate limiting feature for FlinkKafkaConsumer

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

[jira] [Updated] (FLINK-11520) Triggers should be provided the window state

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

[jira] [Updated] (FLINK-16618) Cannot use Hive GenericUDFBaseNumeric with Flink

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

[jira] [Updated] (FLINK-16578) join lateral table function with condition fails with exception

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

[jira] [Updated] (FLINK-16551) WebFrontendITCase.getFrontPage fails

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

[jira] [Updated] (FLINK-16553) Missing KafkaFetcher topic/partition metrics

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

[jira] [Updated] (FLINK-11438) Config for submitted job path

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

[jira] [Updated] (FLINK-16574) StreamingFileSink should rename files or fail if destination file already exists

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

[jira] [Updated] (FLINK-11517) Inefficient window state access when using RocksDB state backend

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

[jira] [Updated] (FLINK-16575) develop HBaseCatalog to integrate HBase metadata into Flink

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

[jira] [Updated] (FLINK-16596) Support Enum-Values as part of a Key

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

[jira] [Updated] (FLINK-11742) Push metrics to Pushgateway without "instance"

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

[jira] [Updated] (FLINK-16642) CSV TableSource / TableSink shouldn't be in flink-table-api-java-bridge package

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

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 25fa1e0515cdc6379564247749624b60ba5c4beb Azure:

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

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

[GitHub] [flink] matriv commented on a change in pull request #17811: [FLINK-24754] Implement CHAR/VARCHAR length validation for sinks

matriv commented on a change in pull request #17811: URL: https://github.com/apache/flink/pull/17811#discussion_r751692263 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/table/TableSinkITCase.scala ## @@ -635,6

[GitHub] [flink] matriv commented on a change in pull request #17811: [FLINK-24754] Implement CHAR/VARCHAR length validation for sinks

matriv commented on a change in pull request #17811: URL: https://github.com/apache/flink/pull/17811#discussion_r751691359 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/sink/ConstraintValidator.java ## @@ -0,0 +1,201 @@

[GitHub] [flink] matriv commented on a change in pull request #17811: [FLINK-24754] Implement CHAR/VARCHAR length validation for sinks

matriv commented on a change in pull request #17811: URL: https://github.com/apache/flink/pull/17811#discussion_r751690500 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/sink/ConstraintValidator.java ## @@ -0,0 +1,201 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 25fa1e0515cdc6379564247749624b60ba5c4beb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 25fa1e0515cdc6379564247749624b60ba5c4beb Azure:

[GitHub] [flink] matriv commented on a change in pull request #17811: [FLINK-24754] Implement CHAR/VARCHAR length validation for sinks

matriv commented on a change in pull request #17811: URL: https://github.com/apache/flink/pull/17811#discussion_r751687627 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/sink/ConstraintValidator.java ## @@ -0,0 +1,201 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 25fa1e0515cdc6379564247749624b60ba5c4beb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 25fa1e0515cdc6379564247749624b60ba5c4beb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 25fa1e0515cdc6379564247749624b60ba5c4beb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 25fa1e0515cdc6379564247749624b60ba5c4beb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 25fa1e0515cdc6379564247749624b60ba5c4beb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 25fa1e0515cdc6379564247749624b60ba5c4beb Azure:

[jira] [Comment Edited] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444812#comment-17444812 ] Jiahui Jiang edited comment on FLINK-16419 at 11/17/21, 10:11 PM: --

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 25fa1e0515cdc6379564247749624b60ba5c4beb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 25fa1e0515cdc6379564247749624b60ba5c4beb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 25fa1e0515cdc6379564247749624b60ba5c4beb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 25fa1e0515cdc6379564247749624b60ba5c4beb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 25fa1e0515cdc6379564247749624b60ba5c4beb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 25fa1e0515cdc6379564247749624b60ba5c4beb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 25fa1e0515cdc6379564247749624b60ba5c4beb Azure:

[GitHub] [flink] matriv commented on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

matriv commented on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-972069298 Thanks for the reviews @twalthr ! Please check again. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 25fa1e0515cdc6379564247749624b60ba5c4beb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 25fa1e0515cdc6379564247749624b60ba5c4beb Azure:

[GitHub] [flink] matriv commented on a change in pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

matriv commented on a change in pull request #17759: URL: https://github.com/apache/flink/pull/17759#discussion_r751610659 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSinkITCase.java ## @@ -0,0

[GitHub] [flink] flinkbot edited a comment on pull request #17822: Release 1.14 kafka3.0 bug

flinkbot edited a comment on pull request #17822: URL: https://github.com/apache/flink/pull/17822#issuecomment-971696959 ## CI report: * e68e30dc8c355f88169f6a9ac1c7044c895aff30 Azure:

[GitHub] [flink] fapaul commented on pull request #17401: [FLINK-24409][connectors] Fix metrics errors with topics names with periods

fapaul commented on pull request #17401: URL: https://github.com/apache/flink/pull/17401#issuecomment-971910179 @jherico sorry that was my fault :( I did not think about when copying your code instead of cherry-picking the commit. -- This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #17822: Release 1.14 kafka3.0 bug

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

[GitHub] [flink] flinkbot edited a comment on pull request #17776: [FLINK-24616][table] Add metadata from FileStatus in FileSystemTableSource

flinkbot edited a comment on pull request #17776: URL: https://github.com/apache/flink/pull/17776#issuecomment-966963854 ## CI report: * c9b605c84bbade0a3cc992a2081a97ab7e0ba581 Azure:

[GitHub] [flink] jherico closed pull request #17401: [FLINK-24409][connectors] Fix metrics errors with topics names with periods

jherico closed pull request #17401: URL: https://github.com/apache/flink/pull/17401 -- 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] jherico commented on pull request #17401: [FLINK-24409][connectors] Fix metrics errors with topics names with periods

jherico commented on pull request #17401: URL: https://github.com/apache/flink/pull/17401#issuecomment-971859106 ok, it's a pretty small change I know, but I'm kind of irked that #17773 appears to include my _exact_ changes but without my actual commit. -- This is an automated message

[GitHub] [flink] slinkydeveloper commented on pull request #17786: [FLINK-24889][table] Flink SQL Client should print correсtly multisets

slinkydeveloper commented on pull request #17786: URL: https://github.com/apache/flink/pull/17786#issuecomment-971839432 @twalthr Perhaps the point here is that `valueIsNullTerm` should always be false if `valueType` is not null, because null checks shouldn't be required? -- This is an

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * 2d2e314314c0aca9b334ff09dd744d075b47cb53 UNKNOWN * f544b6a2c65fdce599157dff4ecdc0fd9bb896ab Azure:

[GitHub] [flink-statefun] igalshilman merged pull request #276: [FLINK-24534] Use the async transport if transport is not specified.

igalshilman merged pull request #276: URL: https://github.com/apache/flink-statefun/pull/276 -- 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 #17776: [FLINK-24616][table] Add metadata from FileStatus in FileSystemTableSource

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

[GitHub] [flink] matriv commented on a change in pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

matriv commented on a change in pull request #17759: URL: https://github.com/apache/flink/pull/17759#discussion_r751498019 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSinkITCase.java ## @@ -0,0

[jira] [Commented] (FLINK-24727) Running Kerberized YARN per-job on Docker test (no fat-jar) fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-24727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445413#comment-17445413 ] Till Rohrmann commented on FLINK-24727: --- Thanks a lot for the analysis [~guoyangze]! > Running

[jira] [Commented] (FLINK-24886) flink flame args bug, may we need to modify TimeUtils to supports m

[ https://issues.apache.org/jira/browse/FLINK-24886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445411#comment-17445411 ] Till Rohrmann commented on FLINK-24886: --- Thanks for reporting this issue [~jackylau]. If we change

[GitHub] [flink] matriv commented on a change in pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

matriv commented on a change in pull request #17759: URL: https://github.com/apache/flink/pull/17759#discussion_r751487330 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/sink/StreamRecordTimestampInserter.java ## @@ -0,0

[jira] [Updated] (FLINK-24886) flink flame args bug, may we need to modify TimeUtils to supports m

[ https://issues.apache.org/jira/browse/FLINK-24886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-24886: -- Fix Version/s: 1.14.1 1.13.4 > flink flame args bug, may we need to modify

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

[ https://issues.apache.org/jira/browse/FLINK-24611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445399#comment-17445399 ] Roman Khachatryan commented on FLINK-24611: --- I've published

[GitHub] [flink] flinkbot edited a comment on pull request #17820: [FLINK-24931][flink-scala] Remove deprecated/unused class files in flink-scala module.

flinkbot edited a comment on pull request #17820: URL: https://github.com/apache/flink/pull/17820#issuecomment-971490716 ## CI report: * c6b5780096468663e8b40c0112bcc50709c2adf5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17765: [FLINK-24851][Connectors / Kafka] KafkaSourceBuilder: auto.offset.reset is ignored

flinkbot edited a comment on pull request #17765: URL: https://github.com/apache/flink/pull/17765#issuecomment-966280320 ## CI report: * f685e489ab65297dc229f7e7f8c25bd481b25cad Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-24611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-24611: -- Description:

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

[ https://issues.apache.org/jira/browse/FLINK-24611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-24611: -- Description:

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

[ https://issues.apache.org/jira/browse/FLINK-24611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-24611: -- Description: When a checkpoint is aborted, JM discards any state that was sent to it

[jira] [Resolved] (FLINK-24409) Kafka topics with periods in their names generate a constant stream of errors

[ https://issues.apache.org/jira/browse/FLINK-24409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-24409. - Fix Version/s: 1.15.0 1.14.1 Resolution: Fixed > Kafka topics with

[jira] [Commented] (FLINK-24409) Kafka topics with periods in their names generate a constant stream of errors

[ https://issues.apache.org/jira/browse/FLINK-24409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445368#comment-17445368 ] Fabian Paul commented on FLINK-24409: - Merged - master: da8ef265e3f78ec71aad43b4f8209884eaf3a860 -

[GitHub] [flink] flinkbot edited a comment on pull request #17822: Release 1.14 kafka3.0 bug

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

[GitHub] [flink] flinkbot edited a comment on pull request #17822: Release 1.14 kafka3.0 bug

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

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

[GitHub] [flink] AHeise merged pull request #17799: [FLINK-24409][kafka] Fix collection of KafkaSourceReaderMetrics for topics containing periods

AHeise merged pull request #17799: URL: https://github.com/apache/flink/pull/17799 -- 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] AHeise merged pull request #17773: [FLINK-24409][kafka] Fix collection of KafkaSourceReaderMetrics for t…

AHeise merged pull request #17773: URL: https://github.com/apache/flink/pull/17773 -- 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 #17637: [FLINK-24708][planner] Fix wrong results of the IN operator

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

[GitHub] [flink] flinkbot edited a comment on pull request #17733: [FLINK-24835][table-planner] Fix bug in `RelTimeIndicatorConverter` when materialize time attribute fields of regular join's inputs

flinkbot edited a comment on pull request #17733: URL: https://github.com/apache/flink/pull/17733#issuecomment-963997692 ## CI report: * 18aaf820f88ba2ff98f329182872bed3911736e5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17765: [FLINK-24851][Connectors / Kafka] KafkaSourceBuilder: auto.offset.reset is ignored

flinkbot edited a comment on pull request #17765: URL: https://github.com/apache/flink/pull/17765#issuecomment-966280320 ## CI report: * f76190c826f1a8fa405a0f7d930edcc26a861fc7 Azure:

[GitHub] [flink] twalthr commented on a change in pull request #17776: [FLINK-24616][table] Add metadata from FileStatus in FileSystemTableSource

twalthr commented on a change in pull request #17776: URL: https://github.com/apache/flink/pull/17776#discussion_r751387893 ## File path: docs/content/docs/connectors/table/filesystem.md ## @@ -122,22 +122,22 @@ The following connector metadata can be accessed as metadata

[jira] [Closed] (FLINK-24776) Clarify semantics of DecodingFormat and its data type

[ https://issues.apache.org/jira/browse/FLINK-24776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24776. Fix Version/s: 1.15.0 Release Note: The DecodingFormat interfaces was used for both

[jira] [Updated] (FLINK-24776) Clarify semantics of DecodingFormat and its data type

[ https://issues.apache.org/jira/browse/FLINK-24776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24776: - Description: Today the {{org.apache.flink.table.connector.format.DecodingFormat}} interface

[GitHub] [flink] twalthr closed pull request #17768: [FLINK-24776][table] Clarify DecodingFormat and introduce ProjectableDecodingFormat

twalthr closed pull request #17768: URL: https://github.com/apache/flink/pull/17768 -- 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 #17776: [FLINK-24616][table] Add metadata from FileStatus in FileSystemTableSource

flinkbot edited a comment on pull request #17776: URL: https://github.com/apache/flink/pull/17776#issuecomment-966963854 ## CI report: * 21176437115a072f31e502b7ee4f020f857885e4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17820: [FLINK-24931][flink-scala] Remove deprecated/unused class files in flink-scala module.

flinkbot edited a comment on pull request #17820: URL: https://github.com/apache/flink/pull/17820#issuecomment-971490716 ## CI report: * c6b5780096468663e8b40c0112bcc50709c2adf5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17822: Release 1.14 kafka3.0 bug

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

[GitHub] [flink] flinkbot edited a comment on pull request #17821: [FLINK-23620] Replace Flink Configuration YAML parser with SnakeYAML

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

[GitHub] [flink] flinkbot edited a comment on pull request #17776: [FLINK-24616][table] Add metadata from FileStatus in FileSystemTableSource

flinkbot edited a comment on pull request #17776: URL: https://github.com/apache/flink/pull/17776#issuecomment-966963854 ## CI report: * 21176437115a072f31e502b7ee4f020f857885e4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17820: [FLINK-24931][flink-scala] Remove deprecated/unused class files in flink-scala module.

flinkbot edited a comment on pull request #17820: URL: https://github.com/apache/flink/pull/17820#issuecomment-971490716 ## CI report: * c6b5780096468663e8b40c0112bcc50709c2adf5 Azure:

[GitHub] [flink] flinkbot commented on pull request #17822: Release 1.14 kafka3.0 bug

flinkbot commented on pull request #17822: URL: https://github.com/apache/flink/pull/17822#issuecomment-971699451 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] RocMarshal commented on pull request #17820: [FLINK-24931][flink-scala] Remove deprecated/unused class files in flink-scala module.

RocMarshal commented on pull request #17820: URL: https://github.com/apache/flink/pull/17820#issuecomment-971699402 @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 commented on pull request #17822: Release 1.14 kafka3.0 bug

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

[GitHub] [flink] flinkbot edited a comment on pull request #17776: [FLINK-24616][table] Add metadata from FileStatus in FileSystemTableSource

flinkbot edited a comment on pull request #17776: URL: https://github.com/apache/flink/pull/17776#issuecomment-966963854 ## CI report: * 21176437115a072f31e502b7ee4f020f857885e4 Azure:

[GitHub] [flink] cleverblue opened a new pull request #17822: Release 1.14 kafka3.0 bug

cleverblue opened a new pull request #17822: URL: https://github.com/apache/flink/pull/17822 RESOURCE_PARAMS extraction logs: jvm_params: -Xmx2051014652 -Xms2051014652 -XX:MaxMetaspaceSize=268435456 dynamic_configs: -D jobmanager.memory.off-heap.size=134217728b -D

[GitHub] [flink] flinkbot edited a comment on pull request #17776: [FLINK-24616][table] Add metadata from FileStatus in FileSystemTableSource

flinkbot edited a comment on pull request #17776: URL: https://github.com/apache/flink/pull/17776#issuecomment-966963854 ## CI report: * 21176437115a072f31e502b7ee4f020f857885e4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17776: [FLINK-24616][table] Add metadata from FileStatus in FileSystemTableSource

flinkbot edited a comment on pull request #17776: URL: https://github.com/apache/flink/pull/17776#issuecomment-966963854 ## CI report: * 21176437115a072f31e502b7ee4f020f857885e4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17776: [FLINK-24616][table] Add metadata from FileStatus in FileSystemTableSource

flinkbot edited a comment on pull request #17776: URL: https://github.com/apache/flink/pull/17776#issuecomment-966963854 ## CI report: * 21176437115a072f31e502b7ee4f020f857885e4 Azure:

[GitHub] [flink] twalthr commented on a change in pull request #17811: [FLINK-24754] Implement CHAR/VARCHAR length validation for sinks

twalthr commented on a change in pull request #17811: URL: https://github.com/apache/flink/pull/17811#discussion_r751335868 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/table/TableSinkITCase.scala ## @@ -635,6

[GitHub] [flink] flinkbot edited a comment on pull request #17776: [FLINK-24616][table] Add metadata from FileStatus in FileSystemTableSource

flinkbot edited a comment on pull request #17776: URL: https://github.com/apache/flink/pull/17776#issuecomment-966963854 ## CI report: * 21176437115a072f31e502b7ee4f020f857885e4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17776: [FLINK-24616][table] Add metadata from FileStatus in FileSystemTableSource

flinkbot edited a comment on pull request #17776: URL: https://github.com/apache/flink/pull/17776#issuecomment-966963854 ## CI report: * 21176437115a072f31e502b7ee4f020f857885e4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17776: [FLINK-24616][table] Add metadata from FileStatus in FileSystemTableSource

flinkbot edited a comment on pull request #17776: URL: https://github.com/apache/flink/pull/17776#issuecomment-966963854 ## CI report: * 21176437115a072f31e502b7ee4f020f857885e4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17776: [FLINK-24616][table] Add metadata from FileStatus in FileSystemTableSource

flinkbot edited a comment on pull request #17776: URL: https://github.com/apache/flink/pull/17776#issuecomment-966963854 ## CI report: * 21176437115a072f31e502b7ee4f020f857885e4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17776: [FLINK-24616][table] Add metadata from FileStatus in FileSystemTableSource

flinkbot edited a comment on pull request #17776: URL: https://github.com/apache/flink/pull/17776#issuecomment-966963854 ## CI report: * 21176437115a072f31e502b7ee4f020f857885e4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17776: [FLINK-24616][table] Add metadata from FileStatus in FileSystemTableSource

flinkbot edited a comment on pull request #17776: URL: https://github.com/apache/flink/pull/17776#issuecomment-966963854 ## CI report: * 21176437115a072f31e502b7ee4f020f857885e4 Azure:

<    1   2   3   4   5   >