[jira] [Updated] (FLINK-7050) RFC Compliant CSV Parser for Table Source

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

[jira] [Updated] (FLINK-10409) Collection data sink does not propagate exceptions

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

[jira] [Updated] (FLINK-10382) Writer has already been opened while using AvroKeyValueSinkWriter and BucketingSink

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

[jira] [Updated] (FLINK-15642) Support to set JobManager readiness and liveness check

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

[jira] [Updated] (FLINK-10305) flink-conf.yaml grows continuously

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

[jira] [Updated] (FLINK-10408) Cannot use window information in Table functions

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

[jira] [Updated] (FLINK-10452) Expose Additional Metrics to Reason about Statesize

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

[jira] [Updated] (FLINK-10492) Document generic support for configuring AwsKinesisClient in the Kinesis Consumer

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

[jira] [Updated] (FLINK-10497) More fine grained control over access to REST endpoints

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

[GitHub] [flink] flinkbot edited a comment on pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

flinkbot edited a comment on pull request #17968: URL: https://github.com/apache/flink/pull/17968#issuecomment-982779420 ## CI report: * dd7448bed475516a6c5b49a9319352c595af14cc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18001: [FLINK-24086][runtime] Rebuilding the SharedStateRegistry only when the restore method is called for the first time

flinkbot edited a comment on pull request #18001: URL: https://github.com/apache/flink/pull/18001#issuecomment-985051499 ## CI report: * 102b5c31b2769cb38960d7ec52b4a720613956f8 Azure:

[GitHub] [flink] flinkbot commented on pull request #18001: [FLINK-24086][runtime] Rebuilding the SharedStateRegistry only when the restore method is called for the first time

flinkbot commented on pull request #18001: URL: https://github.com/apache/flink/pull/18001#issuecomment-985051499 ## CI report: * 102b5c31b2769cb38960d7ec52b4a720613956f8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #18001: [FLINK-24086][runtime] Rebuilding the SharedStateRegistry only when the restore method is called for the first time

flinkbot commented on pull request #18001: URL: https://github.com/apache/flink/pull/18001#issuecomment-985050651 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] rkhachatryan commented on pull request #17179: [FLINK-24086][checkpoint] Rebuilding the SharedStateRegistry only when the restore method is called for the first time.

rkhachatryan commented on pull request #17179: URL: https://github.com/apache/flink/pull/17179#issuecomment-985049946 I've opened #18001 to address the feedback above, rebase and merge it. Please feel free to review. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] rkhachatryan opened a new pull request #18001: [FLINK-24086][runtime] Rebuilding the SharedStateRegistry only when the restore method is called for the first time

rkhachatryan opened a new pull request #18001: URL: https://github.com/apache/flink/pull/18001 Copy of #17179 to rebase, address feedback and merge. ``` [FLINK-24086][checkpoint] Rebuilding the SharedStateRegistry only when the restore method is called for the first time.

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

flinkbot edited a comment on pull request #17948: URL: https://github.com/apache/flink/pull/17948#issuecomment-982001952 ## CI report: * 81cdba4665de17b508363705124e6276cd812eed Azure:

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

[GitHub] [flink] flinkbot edited a comment on pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

flinkbot edited a comment on pull request #17968: URL: https://github.com/apache/flink/pull/17968#issuecomment-982779420 ## CI report: * 1794d71dbbb0167dad0ec7a329432c0433b71d38 Azure:

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

flinkbot edited a comment on pull request #17968: URL: https://github.com/apache/flink/pull/17968#issuecomment-982779420 ## CI report: * aeebe5adc0d437f6b6c480457e35885d2e1db6a5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17996: [FLINK-23230] Fix protoc dependency for Apple Silicon / m1 support

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #18000: [hotfix][connectors/kinesis] Refactored utilities class out into a separate base connector

flinkbot edited a comment on pull request #18000: URL: https://github.com/apache/flink/pull/18000#issuecomment-984912328 ## CI report: * 42ac5f3dab7f2cf91be29e2e626b17ab0c2dc3b2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17998: [hotfix][connectors] Added to HTTP use very Versioning parameter to Kinesis Client

flinkbot edited a comment on pull request #17998: URL: https://github.com/apache/flink/pull/17998#issuecomment-984912161 ## CI report: * 13788f6d0319acf5ebbc2245a18f9fad33468908 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17999: [hotfix][connectors/opensearch] Refactored to base aws sink to allow for opensearch sink

flinkbot edited a comment on pull request #17999: URL: https://github.com/apache/flink/pull/17999#issuecomment-984912238 ## CI report: * 0cd652d34577f3650c562d7f353865c6162a1a61 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17997: [hotfix][connectors] Kinesalite Container very very rarely fails with ContainerLaunchException

flinkbot edited a comment on pull request #17997: URL: https://github.com/apache/flink/pull/17997#issuecomment-984912079 ## CI report: * 174a6fc5ba77d3ed05bf90e62f0600fc7569ddfb Azure:

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

flinkbot edited a comment on pull request #17948: URL: https://github.com/apache/flink/pull/17948#issuecomment-982001952 ## CI report: * 691b269e723ec3ac98e48ca0f774bb3f1741af35 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18000: [hotfix][connectors/kinesis] Refactored utilities class out into a separate base connector

flinkbot edited a comment on pull request #18000: URL: https://github.com/apache/flink/pull/18000#issuecomment-984912328 ## CI report: * 42ac5f3dab7f2cf91be29e2e626b17ab0c2dc3b2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17999: [hotfix][connectors/opensearch] Refactored to base aws sink to allow for opensearch sink

flinkbot edited a comment on pull request #17999: URL: https://github.com/apache/flink/pull/17999#issuecomment-984912238 ## CI report: * 0cd652d34577f3650c562d7f353865c6162a1a61 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17998: [hotfix][connectors] Added to HTTP use very Versioning parameter to Kinesis Client

flinkbot edited a comment on pull request #17998: URL: https://github.com/apache/flink/pull/17998#issuecomment-984912161 ## CI report: * 13788f6d0319acf5ebbc2245a18f9fad33468908 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17997: [hotfix][connectors] Kinesalite Container very very rarely fails with ContainerLaunchException

flinkbot edited a comment on pull request #17997: URL: https://github.com/apache/flink/pull/17997#issuecomment-984912079 ## CI report: * 174a6fc5ba77d3ed05bf90e62f0600fc7569ddfb Azure:

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

flinkbot edited a comment on pull request #17948: URL: https://github.com/apache/flink/pull/17948#issuecomment-982001952 ## CI report: * 691b269e723ec3ac98e48ca0f774bb3f1741af35 Azure:

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

[jira] [Commented] (FLINK-25091) Official website document FileSink orc compression attribute reference error

[ https://issues.apache.org/jira/browse/FLINK-25091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452604#comment-17452604 ] Martijn Visser commented on FLINK-25091: Resolved in master:

[jira] [Updated] (FLINK-25091) Official website document FileSink orc compression attribute reference error

[ https://issues.apache.org/jira/browse/FLINK-25091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25091: --- Fix Version/s: 1.15.0 1.14.1 1.13.4

[jira] [Assigned] (FLINK-25091) Official website document FileSink orc compression attribute reference error

[ https://issues.apache.org/jira/browse/FLINK-25091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25091: -- Assignee: XiangQianLiu > Official website document FileSink orc compression

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

[GitHub] [flink] MartijnVisser commented on pull request #17950: [FLINK-25091] change Official website document "FileSink" orc compression attribute reference error

MartijnVisser commented on pull request #17950: URL: https://github.com/apache/flink/pull/17950#issuecomment-984990530 @PxPt Thanks for your PR. Can you also create backports to the release-1.14 and release-1.13 branch? If not, I can also help you out. -- This is an automated message

[GitHub] [flink] flinkbot edited a comment on pull request #17811: [FLINK-24753] 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: * 77e5a142b3a98c91f9ca2ab9a507b14df6e09e30 Azure:

[GitHub] [flink] AHeise commented on a change in pull request #17996: [FLINK-23230] Fix protoc dependency for Apple Silicon / m1 support

AHeise commented on a change in pull request #17996: URL: https://github.com/apache/flink/pull/17996#discussion_r761441463 ## File path: flink-formats/flink-parquet/pom.xml ## @@ -131,8 +131,17 @@ under the License. org.apache.hadoop

[GitHub] [flink] AHeise merged pull request #17839: [FLINK-24859] document new connectors formats

AHeise merged pull request #17839: URL: https://github.com/apache/flink/pull/17839 -- 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 commented on pull request #17839: [FLINK-24859] document new connectors formats

AHeise commented on pull request #17839: URL: https://github.com/apache/flink/pull/17839#issuecomment-984972401 Thank you again for your contribution! -- 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

[GitHub] [flink] AHeise merged pull request #17463: [Hotfix] Fix typos.

AHeise merged pull request #17463: URL: https://github.com/apache/flink/pull/17463 -- 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 commented on pull request #17463: [Hotfix] Fix typos.

AHeise commented on pull request #17463: URL: https://github.com/apache/flink/pull/17463#issuecomment-984971788 I like also these small contributions, especially in this case where we have many typos at once. So Thank you very much! -- This is an automated message from the Apache Git

[GitHub] [flink] AHeise merged pull request #17950: [FLINK-25091] change Official website document "FileSink" orc compression attribute reference error

AHeise merged pull request #17950: URL: https://github.com/apache/flink/pull/17950 -- 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] [Resolved] (FLINK-21407) Clarify which sources and APIs support which formats

[ https://issues.apache.org/jira/browse/FLINK-21407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-21407. - Fix Version/s: 1.14.1 Resolution: Fixed > Clarify which sources and APIs support which

[jira] [Commented] (FLINK-21407) Clarify which sources and APIs support which formats

[ https://issues.apache.org/jira/browse/FLINK-21407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452592#comment-17452592 ] Arvid Heise commented on FLINK-21407: - Merged into 1.14 as

[GitHub] [flink] AHeise merged pull request #17960: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc. Backport to release 1.14

AHeise merged pull request #17960: URL: https://github.com/apache/flink/pull/17960 -- 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 #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: * a00b5d1b5b821ccb7b7d2f71f1303e30c7a04b13 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17995: [POC] Prevent configurations in user jars

flinkbot edited a comment on pull request #17995: URL: https://github.com/apache/flink/pull/17995#issuecomment-984654154 ## CI report: * 85b9766aed25e67c07ff9fa66bdd43d7adb38a8c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17811: [FLINK-24753] 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: * 015cbd9b21236c69a89e99c0b3dea9e139583052 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17985: [FLINK-25111][table-api][table-planner] Add config option to determine CAST behaviour

flinkbot edited a comment on pull request #17985: URL: https://github.com/apache/flink/pull/17985#issuecomment-983795245 ## CI report: * 85641184c3381144a875242cf47a57c3bf843b99 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17985: [FLINK-25111][table-api][table-planner] Add config option to determine CAST behaviour

flinkbot edited a comment on pull request #17985: URL: https://github.com/apache/flink/pull/17985#issuecomment-983795245 ## CI report: * 85641184c3381144a875242cf47a57c3bf843b99 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

flinkbot edited a comment on pull request #17968: URL: https://github.com/apache/flink/pull/17968#issuecomment-982779420 ## CI report: * a8759e1fafa27e7fed61852e9e9b882cd809fcbc Azure:

[jira] [Resolved] (FLINK-24921) FileSourceSplit should not be visible in the user API in ParquetColumnarRowInputFormat

[ https://issues.apache.org/jira/browse/FLINK-24921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-24921. - Resolution: Abandoned > FileSourceSplit should not be visible in the user API in >

[GitHub] [flink] matriv commented on pull request #17985: [FLINK-25111][table-api][table-planner] Add config option to determine CAST behaviour

matriv commented on pull request #17985: URL: https://github.com/apache/flink/pull/17985#issuecomment-984934658 Thx @twalthr Please check again, apologies, I've already squashed the fixup commits to the 2 commits of the PR. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #17972: [FLINK-24506][config] Adds checkpoint directory to CheckpointConfig

flinkbot edited a comment on pull request #17972: URL: https://github.com/apache/flink/pull/17972#issuecomment-983423604 ## CI report: * 093c94c12cf6a1e513ba8f711d6dcaa421fd73a2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17811: [FLINK-24753] 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: * 7c4a2defd2bb94bdb9a7c0803412886b6e173ce1 Azure:

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

matriv commented on pull request #17811: URL: https://github.com/apache/flink/pull/17811#issuecomment-984928410 @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] rkhachatryan commented on a change in pull request #17945: [FLINK-21027][state] Introduce KeyedStateBackend#isSafeToReuseState for opmitization hint

rkhachatryan commented on a change in pull request #17945: URL: https://github.com/apache/flink/pull/17945#discussion_r761393530 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateBackend.java ## @@ -137,10 +137,25 @@ */ boolean

[GitHub] [flink] flinkbot edited a comment on pull request #17967: [FLINK-25096][runtime] Fixes empty exception history for JobInitializationException

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

[GitHub] [flink] flinkbot edited a comment on pull request #17999: [hotfix][connectors/opensearch] Refactored to base aws sink to allow for opensearch sink

flinkbot edited a comment on pull request #17999: URL: https://github.com/apache/flink/pull/17999#issuecomment-984912238 ## CI report: * 0cd652d34577f3650c562d7f353865c6162a1a61 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17997: [hotfix][connectors] Kinesalite Container very very rarely fails with ContainerLaunchException

flinkbot edited a comment on pull request #17997: URL: https://github.com/apache/flink/pull/17997#issuecomment-984912079 ## CI report: * 174a6fc5ba77d3ed05bf90e62f0600fc7569ddfb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17998: [hotfix][connectors] Added to HTTP use very Versioning parameter to Kinesis Client

flinkbot edited a comment on pull request #17998: URL: https://github.com/apache/flink/pull/17998#issuecomment-984912161 ## CI report: * 13788f6d0319acf5ebbc2245a18f9fad33468908 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18000: [hotfix][connectors/kinesis] Refactored utilities class out into a separate base connector

flinkbot edited a comment on pull request #18000: URL: https://github.com/apache/flink/pull/18000#issuecomment-984912328 ## CI report: * 42ac5f3dab7f2cf91be29e2e626b17ab0c2dc3b2 Azure:

[GitHub] [flink] AHeise commented on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

AHeise commented on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-984914459 Your build failed because of ``` [ERROR] Failed to execute goal com.diffplug.spotless:spotless-maven-plugin:2.4.2:check (spotless-check) on project flink-core: The

[GitHub] [flink] AHeise commented on a change in pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

AHeise commented on a change in pull request #17958: URL: https://github.com/apache/flink/pull/17958#discussion_r761381259 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ## @@ -431,6 +433,14 @@ public Task( // finally,

[GitHub] [flink] flinkbot commented on pull request #18000: [hotfix][connectors/kinesis] Refactored utilities class out into a separate base connector

flinkbot commented on pull request #18000: URL: https://github.com/apache/flink/pull/18000#issuecomment-984912689 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #17999: [hotfix][connectors/opensearch] Refactored to base aws sink to allow for opensearch sink

flinkbot commented on pull request #17999: URL: https://github.com/apache/flink/pull/17999#issuecomment-984912714 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #17998: [hotfix][connectors] Added to HTTP use very Versioning parameter to Kinesis Client

flinkbot commented on pull request #17998: URL: https://github.com/apache/flink/pull/17998#issuecomment-984912740 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #18000: [hotfix][connectors/kinesis] Refactored utilities class out into a separate base connector

flinkbot commented on pull request #18000: URL: https://github.com/apache/flink/pull/18000#issuecomment-984912328 ## CI report: * 42ac5f3dab7f2cf91be29e2e626b17ab0c2dc3b2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #17999: [hotfix][connectors/opensearch] Refactored to base aws sink to allow for opensearch sink

flinkbot commented on pull request #17999: URL: https://github.com/apache/flink/pull/17999#issuecomment-984912238 ## CI report: * 0cd652d34577f3650c562d7f353865c6162a1a61 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #17998: [hotfix][connectors] Added to HTTP use very Versioning parameter to Kinesis Client

flinkbot commented on pull request #17998: URL: https://github.com/apache/flink/pull/17998#issuecomment-984912161 ## CI report: * 13788f6d0319acf5ebbc2245a18f9fad33468908 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #17997: [hotfix][connectors] Kinesalite Container very very rarely fails with ContainerLaunchException

flinkbot commented on pull request #17997: URL: https://github.com/apache/flink/pull/17997#issuecomment-984912079 ## CI report: * 174a6fc5ba77d3ed05bf90e62f0600fc7569ddfb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #17997: [hotfix][connectors] Kinesalite Container very very rarely fails with ContainerLaunchException

flinkbot commented on pull request #17997: URL: https://github.com/apache/flink/pull/17997#issuecomment-984910579 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] CrynetLogistics opened a new pull request #18000: [hotfix][connectors/kinesis] Refactored utilities class out into a separate base connector

CrynetLogistics opened a new pull request #18000: URL: https://github.com/apache/flink/pull/18000 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid

[GitHub] [flink] CrynetLogistics opened a new pull request #17999: [hotfix][connectors/opensearch] Refactored to base aws sink to allow for opensearch sink

CrynetLogistics opened a new pull request #17999: URL: https://github.com/apache/flink/pull/17999 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid

[GitHub] [flink] CrynetLogistics opened a new pull request #17998: [hotfix][connectors] Added to HTTP use very Versioning parameter to Kinesis Client

CrynetLogistics opened a new pull request #17998: URL: https://github.com/apache/flink/pull/17998 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid

[GitHub] [flink] CrynetLogistics opened a new pull request #17997: [hotfix][connectors] Kinesalite Container very very rarely fails with ContainerLaunchException

CrynetLogistics opened a new pull request #17997: URL: https://github.com/apache/flink/pull/17997 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid

[GitHub] [flink] flinkbot edited a comment on pull request #17962: [FLINK-22113][table-planner] Implement column uniqueness checking for TableSourceTable

flinkbot edited a comment on pull request #17962: URL: https://github.com/apache/flink/pull/17962#issuecomment-982536751 ## CI report: * 98d2d8e386c9f6b28a5991aee4f4c8ef78eaabca Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17994: [FLINK-24456][Connectors / Kafka,Table SQL / Ecosystem] Support bound…

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

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

flinkbot edited a comment on pull request #17948: URL: https://github.com/apache/flink/pull/17948#issuecomment-982001952 ## CI report: * 691b269e723ec3ac98e48ca0f774bb3f1741af35 Azure:

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

flinkbot edited a comment on pull request #17948: URL: https://github.com/apache/flink/pull/17948#issuecomment-982001952 ## CI report: * 691b269e723ec3ac98e48ca0f774bb3f1741af35 Azure:

[jira] [Commented] (FLINK-25137) Cannot do window aggregation after a regular join: Window can only be defined on a time attribute column

[ https://issues.apache.org/jira/browse/FLINK-25137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452538#comment-17452538 ] Hongbo commented on FLINK-25137: Hi [~wenlong.lwl]  [~jingzhang] Thanks for the response!  

[GitHub] [flink] matriv commented on a change in pull request #17985: [FLINK-25111][table-api][table-planner] Add config option to determine CAST behaviour

matriv commented on a change in pull request #17985: URL: https://github.com/apache/flink/pull/17985#discussion_r761347437 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java ## @@ -376,6 +379,17 @@

[jira] [Commented] (FLINK-24385) Add TRY_CAST function to be able to handle errors

[ https://issues.apache.org/jira/browse/FLINK-24385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452537#comment-17452537 ] Marios Trivyzas commented on FLINK-24385: - Adjust docs on 

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

flinkbot edited a comment on pull request #17948: URL: https://github.com/apache/flink/pull/17948#issuecomment-982001952 ## CI report: * 691b269e723ec3ac98e48ca0f774bb3f1741af35 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

flinkbot edited a comment on pull request #17968: URL: https://github.com/apache/flink/pull/17968#issuecomment-982779420 ## CI report: * b63e8c5437e7f7a1cd6e6356489e20034d94256a Azure:

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

flinkbot edited a comment on pull request #17948: URL: https://github.com/apache/flink/pull/17948#issuecomment-982001952 ## CI report: * 691b269e723ec3ac98e48ca0f774bb3f1741af35 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

flinkbot edited a comment on pull request #17968: URL: https://github.com/apache/flink/pull/17968#issuecomment-982779420 ## CI report: * b63e8c5437e7f7a1cd6e6356489e20034d94256a Azure:

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

flinkbot edited a comment on pull request #17948: URL: https://github.com/apache/flink/pull/17948#issuecomment-982001952 ## CI report: * 691b269e723ec3ac98e48ca0f774bb3f1741af35 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

flinkbot edited a comment on pull request #17968: URL: https://github.com/apache/flink/pull/17968#issuecomment-982779420 ## CI report: * b63e8c5437e7f7a1cd6e6356489e20034d94256a Azure:

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

flinkbot edited a comment on pull request #17948: URL: https://github.com/apache/flink/pull/17948#issuecomment-982001952 ## CI report: * 691b269e723ec3ac98e48ca0f774bb3f1741af35 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

flinkbot edited a comment on pull request #17968: URL: https://github.com/apache/flink/pull/17968#issuecomment-982779420 ## CI report: * b63e8c5437e7f7a1cd6e6356489e20034d94256a Azure:

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

flinkbot edited a comment on pull request #17948: URL: https://github.com/apache/flink/pull/17948#issuecomment-982001952 ## CI report: * 691b269e723ec3ac98e48ca0f774bb3f1741af35 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

flinkbot edited a comment on pull request #17968: URL: https://github.com/apache/flink/pull/17968#issuecomment-982779420 ## CI report: * b63e8c5437e7f7a1cd6e6356489e20034d94256a Azure:

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

flinkbot edited a comment on pull request #17948: URL: https://github.com/apache/flink/pull/17948#issuecomment-982001952 ## CI report: * 691b269e723ec3ac98e48ca0f774bb3f1741af35 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17968: [FLINK-23532] Unify stop-with-savepoint without and with drain

flinkbot edited a comment on pull request #17968: URL: https://github.com/apache/flink/pull/17968#issuecomment-982779420 ## CI report: * b63e8c5437e7f7a1cd6e6356489e20034d94256a Azure:

<    1   2   3   4   5   6   7   8   9   >