[GitHub] [flink] flinkbot edited a comment on pull request #17933: [FLINK-24948][jdbc] Fix bug that special character in column names breaks JDBC statement parsing

flinkbot edited a comment on pull request #17933: URL: https://github.com/apache/flink/pull/17933#issuecomment-980508183 ## CI report: * 78d03eb751dfc0b74613d7c5855e6d0dd5f0fc00 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-25076) Simplify name of SQL operators

[ https://issues.apache.org/jira/browse/FLINK-25076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449773#comment-17449773 ] junbiao chen commented on FLINK-25076: -- Could you cite an example? > Simplify name

[GitHub] [flink] flinkbot edited a comment on pull request #17935: [FLINK-14438][core] Fix RowTypeInfo.equals()

flinkbot edited a comment on pull request #17935: URL: https://github.com/apache/flink/pull/17935#issuecomment-980516470 ## CI report: * 79fae89afd065ef8be12dcb54bfa85c6a3c3a837 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #17935: [FLINK-14438][core] Fix RowTypeInfo.equals()

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

[GitHub] [flink] flinkbot commented on pull request #17935: [FLINK-14438][core] Fix RowTypeInfo.equals()

flinkbot commented on pull request #17935: URL: https://github.com/apache/flink/pull/17935#issuecomment-980516470 ## CI report: * 79fae89afd065ef8be12dcb54bfa85c6a3c3a837 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-14438) Fix RowTypeInfo.equals()

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

[GitHub] [flink] shenzhu opened a new pull request #17935: [FLINK-14438][core] Fix RowTypeInfo.equals()

shenzhu opened a new pull request #17935: URL: https://github.com/apache/flink/pull/17935 ## What is the purpose of the change [FLINK-14438](https://issues.apache.org/jira/browse/FLINK-14438): Fix RowTypeInfo.equals() to consider field names. ## Brief change log

[GitHub] [flink] flinkbot edited a comment on pull request #17934: [FLINK-25083]Fix Flaky RowTest

flinkbot edited a comment on pull request #17934: URL: https://github.com/apache/flink/pull/17934#issuecomment-980515424 ## CI report: * 2cf66390cb9ab7243ac6faadf2f433aa1334984b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #17934: [FLINK-25083]Fix Flaky RowTest

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

[GitHub] [flink] flinkbot commented on pull request #17934: [FLINK-25083]Fix Flaky RowTest

flinkbot commented on pull request #17934: URL: https://github.com/apache/flink/pull/17934#issuecomment-980515424 ## CI report: * 2cf66390cb9ab7243ac6faadf2f433aa1334984b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-25083) Flaky Test in RowTest

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

[GitHub] [flink] HildoYe opened a new pull request #17934: [FLINK-25083]Fix Flaky RowTest

HildoYe opened a new pull request #17934: URL: https://github.com/apache/flink/pull/17934 ## What is the purpose of the change The tests `testRowNamed` and `testDeepToString` are flaky due to the non-deterministic order of HashMap. In this PR the order is fixed with the use

[jira] [Created] (FLINK-25083) Flaky Test in RowTest

Minyang Ye created FLINK-25083: -- Summary: Flaky Test in RowTest Key: FLINK-25083 URL: https://issues.apache.org/jira/browse/FLINK-25083 Project: Flink Issue Type: Improvement Component

[jira] [Commented] (FLINK-14438) Fix RowTypeInfo.equals()

[ https://issues.apache.org/jira/browse/FLINK-14438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449769#comment-17449769 ] Shen Zhu commented on FLINK-14438: -- Hey [~twalthr] , I'm interested in working on this

[GitHub] [flink] flinkbot edited a comment on pull request #17560: [FLINK-22315][table] Support ADD column/constraint/watermark for ALTER TABLE statement.

flinkbot edited a comment on pull request #17560: URL: https://github.com/apache/flink/pull/17560#issuecomment-951002521 ## CI report: * 2f7d301efba608404032a246c8204b2ce62b8a25 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #17560: [FLINK-22315][table] Support ADD column/constraint/watermark for ALTER TABLE statement.

flinkbot edited a comment on pull request #17560: URL: https://github.com/apache/flink/pull/17560#issuecomment-951002521 ## CI report: * 6207c0492807434173487d39e7f2f53b1a60d50c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17560: [FLINK-22315][table] Support ADD column/constraint/watermark for ALTER TABLE statement.

flinkbot edited a comment on pull request #17560: URL: https://github.com/apache/flink/pull/17560#issuecomment-951002521 ## CI report: * 6207c0492807434173487d39e7f2f53b1a60d50c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17933: [FLINK-24948][jdbc] Fix bug that special character in column names breaks JDBC statement parsing

flinkbot edited a comment on pull request #17933: URL: https://github.com/apache/flink/pull/17933#issuecomment-980508183 ## CI report: * 78d03eb751dfc0b74613d7c5855e6d0dd5f0fc00 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #17933: [FLINK-24948][jdbc] Fix bug that special character in column names breaks JDBC statement parsing

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

[GitHub] [flink] flinkbot commented on pull request #17933: [FLINK-24948][jdbc] Fix bug that special character in column names breaks JDBC statement parsing

flinkbot commented on pull request #17933: URL: https://github.com/apache/flink/pull/17933#issuecomment-980508183 ## CI report: * 78d03eb751dfc0b74613d7c5855e6d0dd5f0fc00 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-24948) Special character in column names breaks JDBC statement parsing

[ https://issues.apache.org/jira/browse/FLINK-24948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24948: --- Labels: pull-request-available (was: ) > Special character in column names breaks JDBC stat

[GitHub] [flink] link3280 opened a new pull request #17933: [FLINK-24948][jdbc] Fix bug that special character in column names breaks JDBC statement parsing

link3280 opened a new pull request #17933: URL: https://github.com/apache/flink/pull/17933 ## What is the purpose of the change Currently, JDBC connector assumes columns names respect Java identifier naming restrictions, but databases that support JDBC may have different naming rest

[GitHub] [flink] Aitozi closed pull request #17554: [FLINK-24624][Kubernetes]Kill cluster when starting kubernetes session or application cluster failed

Aitozi closed pull request #17554: URL: https://github.com/apache/flink/pull/17554 -- 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: issues-unsubscr

[GitHub] [flink] Aitozi commented on a change in pull request #17554: [FLINK-24624][Kubernetes]Kill cluster when starting kubernetes session or application cluster failed

Aitozi commented on a change in pull request #17554: URL: https://github.com/apache/flink/pull/17554#discussion_r757741776 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java ## @@ -256,36 +244,51 @@ private String getWebMo

[GitHub] [flink] flinkbot edited a comment on pull request #17560: [FLINK-22315][table] Support ADD column/constraint/watermark for ALTER TABLE statement.

flinkbot edited a comment on pull request #17560: URL: https://github.com/apache/flink/pull/17560#issuecomment-951002521 ## CI report: * 6207c0492807434173487d39e7f2f53b1a60d50c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17560: [FLINK-22315][table] Support ADD column/constraint/watermark for ALTER TABLE statement.

flinkbot edited a comment on pull request #17560: URL: https://github.com/apache/flink/pull/17560#issuecomment-951002521 ## CI report: * 6207c0492807434173487d39e7f2f53b1a60d50c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-15202) Increment metric when Interval Join record is late

[ https://issues.apache.org/jira/browse/FLINK-15202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449721#comment-17449721 ] Shen Zhu commented on FLINK-15202: -- Hey [~klion26] , I'm interested in working on this

[GitHub] [flink] Ivan0626 commented on pull request #14344: [docs] fix typos in Basic Concepts documentation

Ivan0626 commented on pull request #14344: URL: https://github.com/apache/flink/pull/14344#issuecomment-980491559 fix typos -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[jira] [Updated] (FLINK-25082) RMQSource is not parallel

[ https://issues.apache.org/jira/browse/FLINK-25082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mike Lynch updated FLINK-25082: --- Description: The official [documentation|https://nightlies.apache.org/flink/flink-docs-release-1.14

[jira] [Created] (FLINK-25082) RMQSource is not parallel

Mike Lynch created FLINK-25082: -- Summary: RMQSource is not parallel Key: FLINK-25082 URL: https://issues.apache.org/jira/browse/FLINK-25082 Project: Flink Issue Type: Bug Components: C

[jira] [Commented] (FLINK-24466) Interval Join late events handling behaviour is not consistent

[ https://issues.apache.org/jira/browse/FLINK-24466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449708#comment-17449708 ] Shen Zhu commented on FLINK-24466: -- Hey [~slinkydeveloper] , thanks for writing the pat

[jira] [Updated] (FLINK-19158) Revisit java e2e download timeouts

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

[jira] [Updated] (FLINK-12090) Can the log on the Apache Flink Dashboard be partitioned by day?

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

[jira] [Updated] (FLINK-20983) FlinkKafkaProducerITCase.testMigrateFromAtExactlyOnceToAtLeastOnce failed with Timeout expired after 60000milliseconds while awaiting InitProducerId

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

[jira] [Updated] (FLINK-17969) Enhance Flink (Task) logging to include job name as context diagnostic information

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

[jira] [Updated] (FLINK-17110) Make StreamExecutionEnvironment#configure also affects StreamExecutionEnvironment#configuration

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

[jira] [Updated] (FLINK-21282) Support UPDATE for flink sql

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

[jira] [Updated] (FLINK-9382) Inconsistent file storage behavior in FileCache

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

[jira] [Updated] (FLINK-9268) RockDB errors from WindowOperator

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

[jira] [Updated] (FLINK-21015) Wait for checkpoint cleanup completion during shutdown

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

[jira] [Updated] (FLINK-12172) Flink fails to close pending BucketingSink

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

[jira] [Updated] (FLINK-12118) Documentation in left navigation is not in step with its content

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

[jira] [Updated] (FLINK-12173) Optimize "SELECT DISTINCT" into Deduplicate with keep first row

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

[jira] [Updated] (FLINK-21060) Could not create the DispatcherResourceManagerComponent

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

[jira] [Updated] (FLINK-12093) Apache Flink:Active MQ consumer job is getting finished after first message consume.

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

[jira] [Updated] (FLINK-9396) Allow streaming sources (especially Files, Kafka) to set max queued input elements

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

[jira] [Updated] (FLINK-21281) Support DELETE FROM for flink sql

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

[jira] [Updated] (FLINK-12243) Support generic table stats related operations in HiveCatalog

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

[jira] [Updated] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread

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

[jira] [Updated] (FLINK-20094) Make JobMaster.jobStatusChanged directly called by JobManagerJobStatusListener

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

[jira] [Updated] (FLINK-12186) Add implementation of FLIP-23 - Model Serving

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

[jira] [Updated] (FLINK-12294) Kafka connector, work with grouping partitions

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

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * e90077b322d2826456b7fbf4ba6f2c0c22f4c137 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-24573) ZooKeeperJobGraphsStoreITCase crashes JVM

[ https://issues.apache.org/jira/browse/FLINK-24573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449678#comment-17449678 ] Matthias edited comment on FLINK-24573 at 11/26/21, 10:23 PM:

[jira] [Comment Edited] (FLINK-24573) ZooKeeperJobGraphsStoreITCase crashes JVM

[ https://issues.apache.org/jira/browse/FLINK-24573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449678#comment-17449678 ] Matthias edited comment on FLINK-24573 at 11/26/21, 10:20 PM:

[GitHub] [flink] flinkbot edited a comment on pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

flinkbot edited a comment on pull request #17919: URL: https://github.com/apache/flink/pull/17919#issuecomment-979659835 ## CI report: * 8e8aaa7df0ebae7ec45b9bc2e61ea8e55d9f45b8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-24573) ZooKeeperJobGraphsStoreITCase crashes JVM

[ https://issues.apache.org/jira/browse/FLINK-24573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24573: - Attachment: logs-ci_build-test_ci_build_core-1637952435.zip > ZooKeeperJobGraphsStoreITCase crashes JVM

[jira] [Commented] (FLINK-24573) ZooKeeperJobGraphsStoreITCase crashes JVM

[ https://issues.apache.org/jira/browse/FLINK-24573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449678#comment-17449678 ] Matthias commented on FLINK-24573: -- We experienced the same odd behavior on our Flink f

[GitHub] [flink] XComp commented on a change in pull request #17928: [FLINK-25080] Moves unit tests into flink-core

XComp commented on a change in pull request #17928: URL: https://github.com/apache/flink/pull/17928#discussion_r757701025 ## File path: flink-test-utils-parent/flink-test-utils/pom.xml ## @@ -57,6 +57,14 @@ under the License. compile +

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 50b889f3b887a3dafc99e8928f96c31b460b11a8 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * a4a0c2567a2a4733ead4821a53db599f7f61ed1d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 12d370196fdbe6ff098e8c93512b90fb774aa5c6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 12d370196fdbe6ff098e8c93512b90fb774aa5c6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

flinkbot edited a comment on pull request #17919: URL: https://github.com/apache/flink/pull/17919#issuecomment-979659835 ## CI report: * 87fd0c5c53eab00390b5e49eb4a5f51663b00928 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

flinkbot edited a comment on pull request #17919: URL: https://github.com/apache/flink/pull/17919#issuecomment-979659835 ## CI report: * 87fd0c5c53eab00390b5e49eb4a5f51663b00928 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 12d370196fdbe6ff098e8c93512b90fb774aa5c6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] shenzhu commented on pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

shenzhu commented on pull request #17919: URL: https://github.com/apache/flink/pull/17919#issuecomment-980395218 > @shenzhu Could please adjust the title of your PR to: > > ``` > [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY > ``` > > ?

[GitHub] [flink] shenzhu commented on a change in pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

shenzhu commented on a change in pull request #17919: URL: https://github.com/apache/flink/pull/17919#discussion_r757682218 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/StringToBinaryCastRule.java ## @@ -45,6 +52,

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 12d370196fdbe6ff098e8c93512b90fb774aa5c6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 12d370196fdbe6ff098e8c93512b90fb774aa5c6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 12d370196fdbe6ff098e8c93512b90fb774aa5c6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 12d370196fdbe6ff098e8c93512b90fb774aa5c6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 12d370196fdbe6ff098e8c93512b90fb774aa5c6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 12d370196fdbe6ff098e8c93512b90fb774aa5c6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 12d370196fdbe6ff098e8c93512b90fb774aa5c6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 12d370196fdbe6ff098e8c93512b90fb774aa5c6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 12d370196fdbe6ff098e8c93512b90fb774aa5c6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 12d370196fdbe6ff098e8c93512b90fb774aa5c6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 12d370196fdbe6ff098e8c93512b90fb774aa5c6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 12d370196fdbe6ff098e8c93512b90fb774aa5c6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 12d370196fdbe6ff098e8c93512b90fb774aa5c6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 12d370196fdbe6ff098e8c93512b90fb774aa5c6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 12d370196fdbe6ff098e8c93512b90fb774aa5c6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 12d370196fdbe6ff098e8c93512b90fb774aa5c6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 12d370196fdbe6ff098e8c93512b90fb774aa5c6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 81279df4656e9aa5055b7d9469dfa4dceee97014 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 81279df4656e9aa5055b7d9469dfa4dceee97014 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17932: [FLINK-25079][table-common] Add some initial assertj assertions for table data and types apis

flinkbot edited a comment on pull request #17932: URL: https://github.com/apache/flink/pull/17932#issuecomment-980084610 ## CI report: * 25b5f673226d428f7487b4d2161110049af0386a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17931: [FLINK-25075] Refactor PlannerExpressionParser, removing the reflection to instantiate it

flinkbot edited a comment on pull request #17931: URL: https://github.com/apache/flink/pull/17931#issuecomment-980071064 ## CI report: * 64bad8b9969ee451ff7b5082c42d53f994aa1f8c Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17560: [FLINK-22315][table] Support ADD column/constraint/watermark for ALTER TABLE statement.

flinkbot edited a comment on pull request #17560: URL: https://github.com/apache/flink/pull/17560#issuecomment-951002521 ## CI report: * 6207c0492807434173487d39e7f2f53b1a60d50c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] tillrohrmann merged pull request #17926: [FLINK-24789][BP-1.14][runtime] Trigger checkpoint disposal prior completing t…

tillrohrmann merged pull request #17926: URL: https://github.com/apache/flink/pull/17926 -- 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: issues-un

[jira] [Closed] (FLINK-24789) IllegalStateException with CheckpointCleaner being closed already

[ https://issues.apache.org/jira/browse/FLINK-24789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-24789. - Resolution: Fixed Fixed via 1.15.0: e42890fc67f55702f8aa61e465a16b251d0bc87a 1.14.1: 0258419c66

[GitHub] [flink] tillrohrmann closed pull request #17693: [FLINK-24789][runtime] Trigger checkpoint disposal prior completing t…

tillrohrmann closed pull request #17693: URL: https://github.com/apache/flink/pull/17693 -- 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: issues-un

[jira] [Closed] (FLINK-24543) Zookeeper connection issue causes inconsistent state in Flink

[ https://issues.apache.org/jira/browse/FLINK-24543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-24543. - Resolution: Fixed Fixed via 1.15.0: 3d7ad08ea24cb632d0d3db6dc942bb052ab9b464 1.14.1: 0a5481b271

[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: * 59f24655f7b7376033be5a0234f211bb8a58a83a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] tillrohrmann merged pull request #17681: [FLINK-24543][BP-1.13][runtime] Avoid possible inconsistencies of ZookeeperSta…

tillrohrmann merged pull request #17681: URL: https://github.com/apache/flink/pull/17681 -- 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: issues-un

[GitHub] [flink] flinkbot edited a comment on pull request #17897: [FLINK-24687][table] Move FileSystemTableSource/Sink in flink-connector-files

flinkbot edited a comment on pull request #17897: URL: https://github.com/apache/flink/pull/17897#issuecomment-977984065 ## CI report: * 80e8bf5ce37a240ba2abcce2356552b4fbee8a36 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #17681: URL: https://github.com/apache/flink/pull/17681#issuecomment-960861704 ## CI report: * 5883510177f1f9524b175ec12575c9c02f4fe122 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #17681: URL: https://github.com/apache/flink/pull/17681#issuecomment-960861704 ## CI report: * 5883510177f1f9524b175ec12575c9c02f4fe122 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] Airblader commented on a change in pull request #17897: [FLINK-24687][table] Move FileSystemTableSource/Sink in flink-connector-files

Airblader commented on a change in pull request #17897: URL: https://github.com/apache/flink/pull/17897#discussion_r757626258 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/stream/compact/CompactOperator.java ## @@ -68,

  1   2   3   4   5   >