[jira] [Commented] (FLINK-25293) Option to let fail if KafkaSource keeps failing to commit offset

[ https://issues.apache.org/jira/browse/FLINK-25293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464466#comment-17464466 ] rerorero commented on FLINK-25293: -- Okay, understood. If there could be a way to get the Kafka client

[jira] [Commented] (FLINK-25374) Azure pipeline get stalled on scanning project

[ https://issues.apache.org/jira/browse/FLINK-25374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464464#comment-17464464 ] Martijn Visser commented on FLINK-25374: [~trohrmann] Yes, after I freed up some diskspace I

[GitHub] [flink] tillrohrmann commented on a change in pull request #18083: [FLINK-25402] Introduce working directory for Flink processes

tillrohrmann commented on a change in pull request #18083: URL: https://github.com/apache/flink/pull/18083#discussion_r774488267 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypointUtils.java ## @@ -128,4 +132,80 @@ public static

[jira] [Assigned] (FLINK-17808) Rename checkpoint meta file to "_metadata" until it has completed writing

[ https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-17808: Assignee: Junfan Zhang > Rename checkpoint meta file to "_metadata" until it has completed

[jira] [Commented] (FLINK-17808) Rename checkpoint meta file to "_metadata" until it has completed writing

[ https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464459#comment-17464459 ] Yun Tang commented on FLINK-17808: -- Since [~zuston] had already provided a PR to review, already

[jira] [Commented] (FLINK-25330) Flink SQL doesn't retract all versions of Hbase data

[ https://issues.apache.org/jira/browse/FLINK-25330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464458#comment-17464458 ] Ibson commented on FLINK-25330: --- Hi [~jingge]   We use HBase as a dimension table, Each piece of data in

[jira] [Commented] (FLINK-25426) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP because it cannot allocate enough network buffers

[ https://issues.apache.org/jira/browse/FLINK-25426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464456#comment-17464456 ] Till Rohrmann commented on FLINK-25426: --- Another instance:

[jira] [Commented] (FLINK-25426) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP because it cannot allocate enough network buffers

[ https://issues.apache.org/jira/browse/FLINK-25426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464455#comment-17464455 ] Till Rohrmann commented on FLINK-25426: --- Another instance:

[jira] [Commented] (FLINK-25410) Flink CLI should exit when app is accepted with detach mode on Yarn

[ https://issues.apache.org/jira/browse/FLINK-25410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464454#comment-17464454 ] Till Rohrmann commented on FLINK-25410: --- I do see the problem [~zuston]. Could we rework the

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #43: Prepares Flink ML for 2.0.0 release

gaoyunhaii commented on a change in pull request #43: URL: https://github.com/apache/flink-ml/pull/43#discussion_r774483854 ## File path: tools/releasing/update_branch_version.sh ## @@ -0,0 +1,73 @@ +#!/usr/bin/env bash + +# +# Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #43: Prepares Flink ML for 2.0.0 release

gaoyunhaii commented on a change in pull request #43: URL: https://github.com/apache/flink-ml/pull/43#discussion_r774482471 ## File path: tools/releasing/create_python_sdk_release.sh ## @@ -0,0 +1,81 @@ +#!/usr/bin/env bash + +# +# Licensed to the Apache Software Foundation

[GitHub] [flink] matriv commented on a change in pull request #18162: [FLINK-25187][table-planner] Apply padding when CASTing to BINARY()

matriv commented on a change in pull request #18162: URL: https://github.com/apache/flink/pull/18162#discussion_r774482163 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/BinaryToBinaryCastRule.java ## @@ -60,18

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #43: Prepares Flink ML for 2.0.0 release

gaoyunhaii commented on a change in pull request #43: URL: https://github.com/apache/flink-ml/pull/43#discussion_r774481993 ## File path: tools/releasing/create_python_sdk_release.sh ## @@ -0,0 +1,81 @@ +#!/usr/bin/env bash + +# +# Licensed to the Apache Software Foundation

[GitHub] [flink] matriv commented on a change in pull request #18162: [FLINK-25187][table-planner] Apply padding when CASTing to BINARY()

matriv commented on a change in pull request #18162: URL: https://github.com/apache/flink/pull/18162#discussion_r774481392 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/BinaryToBinaryCastRule.java ## @@ -60,18

[jira] [Updated] (FLINK-7859) Allow field annotations to define TypeInformation

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

[jira] [Updated] (FLINK-7554) Add a testing RuntimeContext to test utilities

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

[jira] [Updated] (FLINK-7423) Always reuse an instance to get elements from the inputFormat

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

[jira] [Updated] (FLINK-7546) Support SUBMULTISET_OF Operator for Multiset SQL type

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

[jira] [Updated] (FLINK-7545) Support MEMBER OF Operator for Multiset SQL type

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

[jira] [Updated] (FLINK-7492) Memsql Connector

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

[jira] [Updated] (FLINK-7450) Bounded generic POJO field is identified as Object by TypeExtractor

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

[jira] [Updated] (FLINK-7607) Web Frontend Hangs with Large Numbers of Tasks

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

[jira] [Updated] (FLINK-13039) Clean up thrown exception lists of `ResultSubpartitionView#getNextBuffer`

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

[jira] [Updated] (FLINK-20392) Migrating bash e2e tests to Java/Docker

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

[jira] [Updated] (FLINK-12045) Support force migration between incompatible state schemas/serializers

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

[jira] [Updated] (FLINK-12138) Limit input split count of each source task for better failover experience

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

[jira] [Updated] (FLINK-22110) KinesisTableApiITCase.testTableApiSourceAndSink fails/hangs on Azure when building FlinkContainer

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

[jira] [Updated] (FLINK-12210) Fix a bug in AbstractPagedInputView.readLine

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

[jira] [Updated] (FLINK-12242) Support partition related operations in GenericHiveMetastoreCatalog

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

[jira] [Updated] (FLINK-24694) Translate "Checkpointing under backpressure" page into Chinese

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

[jira] [Updated] (FLINK-24024) Support session Window TVF

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

[jira] [Updated] (FLINK-12061) Add more window operator contract tests to table runtime

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

[jira] [Updated] (FLINK-12271) Display input field name list when throw Cannot resolve field exception

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

[jira] [Updated] (FLINK-12046) Increase records per invocation for serializerAvro benchmark to stabilize it

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

[jira] [Updated] (FLINK-12182) AggregateProjectMergeRule can not handle LogicalWindowAggregate

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

[jira] [Updated] (FLINK-12149) Support Proto for Streaming File Sink

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

[jira] [Updated] (FLINK-22611) add documentation about the semantics of timestamp for time window output

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

[GitHub] [flink] matriv commented on a change in pull request #18162: [FLINK-25187][table-planner] Apply padding when CASTing to BINARY()

matriv commented on a change in pull request #18162: URL: https://github.com/apache/flink/pull/18162#discussion_r774479369 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/casting/CastRulesTest.java ## @@ -656,6 +656,13 @@

[GitHub] [flink] Myasuka commented on a change in pull request #18083: [FLINK-25402] Introduce working directory for Flink processes

Myasuka commented on a change in pull request #18083: URL: https://github.com/apache/flink/pull/18083#discussion_r774478700 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypointUtils.java ## @@ -128,4 +132,80 @@ public static void

[jira] [Commented] (FLINK-25374) Azure pipeline get stalled on scanning project

[ https://issues.apache.org/jira/browse/FLINK-25374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464422#comment-17464422 ] Till Rohrmann commented on FLINK-25374: --- Great, thanks a lot [~MartijnVisser]. Does the disk

[GitHub] [flink] JingGe edited a comment on pull request #18014: [FLINK-24857][test][Kafka] Upgrade SourceReaderTestBase t…

JingGe edited a comment on pull request #18014: URL: https://github.com/apache/flink/pull/18014#issuecomment-1000191509 Fair enough. Since withFailMessage() will give you complete control over the custom message which turns out there is no "Expecting" and "but was" anymore, as() method

[GitHub] [flink] tillrohrmann commented on a change in pull request #18083: [FLINK-25402] Introduce working directory for Flink processes

tillrohrmann commented on a change in pull request #18083: URL: https://github.com/apache/flink/pull/18083#discussion_r774474658 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypointUtils.java ## @@ -128,4 +132,80 @@ public static

[jira] [Commented] (FLINK-24348) Kafka ITCases (e.g. KafkaTableITCase) fail with "ContainerLaunch Container startup failed"

[ https://issues.apache.org/jira/browse/FLINK-24348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464417#comment-17464417 ] Till Rohrmann commented on FLINK-24348: --- Hmm, doesn't all the communication happen locally because

[GitHub] [flink] flinkbot edited a comment on pull request #18150: [hotfix][docs] Fix incorrect dependency and markdown format

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

[GitHub] [flink] aihai removed a comment on pull request #18150: [hotfix][docs] Fix incorrect dependency and markdown format

aihai removed a comment on pull request #18150: URL: https://github.com/apache/flink/pull/18150#issuecomment-1000196048 > -- 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] aihai commented on pull request #18150: [hotfix][docs] Fix incorrect dependency and markdown format

aihai commented on pull request #18150: URL: https://github.com/apache/flink/pull/18150#issuecomment-1000196048 > -- 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.

[GitHub] [flink] aihai closed pull request #18150: [hotfix][docs] Fix incorrect dependency and markdown format

aihai closed pull request #18150: URL: https://github.com/apache/flink/pull/18150 -- 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] JingGe commented on pull request #18014: [FLINK-24857][test][Kafka] Upgrade SourceReaderTestBase t…

JingGe commented on pull request #18014: URL: https://github.com/apache/flink/pull/18014#issuecomment-1000195844 @fapaul Would you help merging it? Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Commented] (FLINK-25375) Update Log4j to 2.17.0

[ https://issues.apache.org/jira/browse/FLINK-25375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464415#comment-17464415 ] Martijn Visser commented on FLINK-25375: [~apaC1212] That's not planned at the moment. The Flink

[GitHub] [flink] flinkbot edited a comment on pull request #18150: [hotfix][docs] Fix incorrect dependency and markdown format

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

[GitHub] [flink] aihai commented on pull request #18150: [hotfix][docs] Fix incorrect dependency and markdown format

aihai commented on pull request #18150: URL: https://github.com/apache/flink/pull/18150#issuecomment-1000194433 @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] MartijnVisser commented on pull request #18175: [hotfix][doc] Remove duplicate dot in generating_watermarks.md

MartijnVisser commented on pull request #18175: URL: https://github.com/apache/flink/pull/18175#issuecomment-1000193101 > Thank you. I changed. Thank you, but your commit message is still `Update generating_watermarks.md`. Please check

[GitHub] [flink] flinkbot edited a comment on pull request #18183: [hotfix][doc] There is a link redirection problem in the Chinese document of Checkpointing

flinkbot edited a comment on pull request #18183: URL: https://github.com/apache/flink/pull/18183#issuecomment-999812530 ## CI report: * 06481b27234dcd9b06e2bfd780deca24979295ec Azure:

[GitHub] [flink] MartijnVisser commented on pull request #18150: [hotfix][docs] Fix incorrect dependency and markdown format

MartijnVisser commented on pull request #18150: URL: https://github.com/apache/flink/pull/18150#issuecomment-1000192450 Thank you @aihai - Since the build is currently failing (due to an external cause), please rebase your branch to get a green build -- This is an automated message from

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18055: [docs] Tutorial: Write Your First Flink SQL program

slinkydeveloper commented on a change in pull request #18055: URL: https://github.com/apache/flink/pull/18055#discussion_r774464622 ## File path: docs/content/docs/try-flink/write_flink_program_with_sql.md ## @@ -0,0 +1,262 @@ +--- +title: 'Write your first Flink program with

[GitHub] [flink] MartijnVisser commented on pull request #18172: [hotfix][doc] Change TableEnvironment attribute reference error

MartijnVisser commented on pull request #18172: URL: https://github.com/apache/flink/pull/18172#issuecomment-1000191719 > > Please update your commit message to follow the Code Style & Quality Guidelines, which can be found at

[GitHub] [flink] JingGe commented on pull request #18014: [FLINK-24857][test][Kafka] Upgrade SourceReaderTestBase t…

JingGe commented on pull request #18014: URL: https://github.com/apache/flink/pull/18014#issuecomment-1000191640 LGTM -- 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

[GitHub] [flink] JingGe commented on pull request #18014: [FLINK-24857][test][Kafka] Upgrade SourceReaderTestBase t…

JingGe commented on pull request #18014: URL: https://github.com/apache/flink/pull/18014#issuecomment-1000191509 Fair enough. Since withFailMessage() will give you complete control over the custom message which turns out there is no "Expecting" and "but was" anymore, as() method will be

[GitHub] [flink] flinkbot edited a comment on pull request #18183: [hotfix][doc] There is a link redirection problem in the Chinese document of Checkpointing

flinkbot edited a comment on pull request #18183: URL: https://github.com/apache/flink/pull/18183#issuecomment-999812530 ## CI report: * 06481b27234dcd9b06e2bfd780deca24979295ec Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18155: [hotfix][connectors][docs] Use big M letters for month in date format

flinkbot edited a comment on pull request #18155: URL: https://github.com/apache/flink/pull/18155#issuecomment-998116357 ## CI report: * e069bbba7310bdd313c37b7f01f13da3c9b416fd Azure:

[GitHub] [flink] MartijnVisser commented on pull request #18183: [hotfix][doc] There is a link redirection problem in the Chinese document of Checkpointing

MartijnVisser commented on pull request #18183: URL: https://github.com/apache/flink/pull/18183#issuecomment-1000189410 @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

[jira] [Commented] (FLINK-25293) Option to let fail if KafkaSource keeps failing to commit offset

[ https://issues.apache.org/jira/browse/FLINK-25293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464410#comment-17464410 ] Qingsheng Ren commented on FLINK-25293: --- Thanks for the clarification [~rero]~ From your

[jira] [Commented] (FLINK-25375) Update Log4j to 2.17.0

[ https://issues.apache.org/jira/browse/FLINK-25375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464409#comment-17464409 ] Gil Amsalem commented on FLINK-25375: - Hi [~knaufk]  Are you planning to release update for version

[jira] [Commented] (FLINK-25273) Some doubts about the FLINK-22848

[ https://issues.apache.org/jira/browse/FLINK-25273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464407#comment-17464407 ] Martijn Visser commented on FLINK-25273: [~lam167] Actually, a reply has been sent already 8

[jira] [Commented] (FLINK-25273) Some doubts about the FLINK-22848

[ https://issues.apache.org/jira/browse/FLINK-25273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464406#comment-17464406 ] Martijn Visser commented on FLINK-25273: [~lam167] There are currently a lot of people on a

[GitHub] [flink] flinkbot edited a comment on pull request #18126: [FLINK-25036][runtime] Add stage wise scheduling strategy

flinkbot edited a comment on pull request #18126: URL: https://github.com/apache/flink/pull/18126#issuecomment-995489268 ## CI report: * 906fd35e32d9ba5c487e0be3f06d9d89767e9b45 Azure:

[GitHub] [flink] alpinegizmo commented on a change in pull request #18055: [docs] Tutorial: Write Your First Flink SQL program

alpinegizmo commented on a change in pull request #18055: URL: https://github.com/apache/flink/pull/18055#discussion_r774454338 ## File path: docs/content/docs/try-flink/write_flink_program_with_sql.md ## @@ -0,0 +1,262 @@ +--- +title: 'Write your first Flink program with SQL'

[GitHub] [flink] alpinegizmo commented on a change in pull request #18055: [docs] Tutorial: Write Your First Flink SQL program

alpinegizmo commented on a change in pull request #18055: URL: https://github.com/apache/flink/pull/18055#discussion_r774454338 ## File path: docs/content/docs/try-flink/write_flink_program_with_sql.md ## @@ -0,0 +1,262 @@ +--- +title: 'Write your first Flink program with SQL'

[GitHub] [flink] flinkbot edited a comment on pull request #18126: [FLINK-25036][runtime] Add stage wise scheduling strategy

flinkbot edited a comment on pull request #18126: URL: https://github.com/apache/flink/pull/18126#issuecomment-995489268 ## CI report: * 906fd35e32d9ba5c487e0be3f06d9d89767e9b45 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * b976feccf7b2c67f9c5911a01100a86c64b6b953 Azure:

[GitHub] [flink] wanglijie95 commented on pull request #18126: [FLINK-25036][runtime] Add stage wise scheduling strategy

wanglijie95 commented on pull request #18126: URL: https://github.com/apache/flink/pull/18126#issuecomment-1000182031 @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] alpinegizmo commented on a change in pull request #18055: [docs] Tutorial: Write Your First Flink SQL program

alpinegizmo commented on a change in pull request #18055: URL: https://github.com/apache/flink/pull/18055#discussion_r774454338 ## File path: docs/content/docs/try-flink/write_flink_program_with_sql.md ## @@ -0,0 +1,262 @@ +--- +title: 'Write your first Flink program with SQL'

[GitHub] [flink] wanglijie95 commented on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

wanglijie95 commented on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-1000180931 @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 edited a comment on pull request #18147: [FLINK-25370][docs] update HBase SQL Connector Options table-name des…

flinkbot edited a comment on pull request #18147: URL: https://github.com/apache/flink/pull/18147#issuecomment-997161014 ## CI report: * 235d8d0a69395bc4ba4b474939f977a4d772d26b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18135: [FLINK-24809][table-common][table-planner] Fix precision for aggs on DECIMAL types

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

[GitHub] [flink] flinkbot edited a comment on pull request #18147: [FLINK-25370][docs] update HBase SQL Connector Options table-name des…

flinkbot edited a comment on pull request #18147: URL: https://github.com/apache/flink/pull/18147#issuecomment-997161014 ## CI report: * 235d8d0a69395bc4ba4b474939f977a4d772d26b Azure:

[GitHub] [flink] alpinegizmo commented on a change in pull request #18055: [docs] Tutorial: Write Your First Flink SQL program

alpinegizmo commented on a change in pull request #18055: URL: https://github.com/apache/flink/pull/18055#discussion_r774449400 ## File path: docs/content/docs/try-flink/write_flink_program_with_sql.md ## @@ -0,0 +1,262 @@ +--- +title: 'Write your first Flink program with SQL'

[GitHub] [flink] flinkbot edited a comment on pull request #18176: [FLINK-20286][connector-files] Support directory watching in filesystem table source

flinkbot edited a comment on pull request #18176: URL: https://github.com/apache/flink/pull/18176#issuecomment-999490583 ## CI report: * 4296115e87ccfbff7a2e4e7b88d5e5250f941dee Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18135: [FLINK-24809][table-common][table-planner] Fix precision for aggs on DECIMAL types

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

[GitHub] [flink] MartijnVisser commented on pull request #18147: [FLINK-25370][docs] update HBase SQL Connector Options table-name des…

MartijnVisser commented on pull request #18147: URL: https://github.com/apache/flink/pull/18147#issuecomment-1000176434 @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] matriv commented on a change in pull request #18162: [FLINK-25187][table-planner] Apply padding when CASTing to BINARY()

matriv commented on a change in pull request #18162: URL: https://github.com/apache/flink/pull/18162#discussion_r774448157 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/casting/CastRulesTest.java ## @@ -656,13 +656,6 @@

[jira] [Commented] (FLINK-17808) Rename checkpoint meta file to "_metadata" until it has completed writing

[ https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464399#comment-17464399 ] Junfan Zhang commented on FLINK-17808: -- Gentle ping [~yunta] . Do you have any ideas? > Rename

[GitHub] [flink] zuston commented on pull request #18158: [FLINK-25398] Show complete stacktrace when requesting thread dump

zuston commented on pull request #18158: URL: https://github.com/apache/flink/pull/18158#issuecomment-1000172913 @xintongsong Hi, could you help recheck this feature? Do community need this feature? If yes, i will go ahead. -- This is an automated message from the Apache Git

[jira] [Updated] (FLINK-25422) Azure pipelines are failing due to Python tests unable to install dependencies

[ https://issues.apache.org/jira/browse/FLINK-25422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25422: --- Fix Version/s: 1.15.0 > Azure pipelines are failing due to Python tests unable to install

[GitHub] [flink] flinkbot edited a comment on pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

flinkbot edited a comment on pull request #18068: URL: https://github.com/apache/flink/pull/18068#issuecomment-989975508 ## CI report: * f0b1ef0bd1e2babc2093a57b0b6b619c99cb551e Azure:

[GitHub] [flink] gaoyunhaii commented on pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

gaoyunhaii commented on pull request #18068: URL: https://github.com/apache/flink/pull/18068#issuecomment-1000170472 Hi @dawidwys @pnowojski could you also help to have a look at this PR~? Very thanks~ -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-14902) JDBCTableSource support AsyncLookupFunction

[ https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464387#comment-17464387 ] ranqiqiang commented on FLINK-14902: [~jark] [~ana4] [~hailong wang]  I don't know, the issue

[GitHub] [flink] flinkbot edited a comment on pull request #18186: [FLINK-25418][python] install dependencies completely offline

flinkbot edited a comment on pull request #18186: URL: https://github.com/apache/flink/pull/18186#issuecomment-184952 ## CI report: * 83454a55d776ac06f945c9c5e71bd5655e534d2a Azure:

[GitHub] [flink-ml] lindong28 commented on pull request #43: Prepares Flink ML for 2.0.0 release

lindong28 commented on pull request #43: URL: https://github.com/apache/flink-ml/pull/43#issuecomment-1000152557 @gaoyunhaii Could you help review this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink-ml] lindong28 opened a new pull request #43: Prepares Flink ML for 2.0.0 release

lindong28 opened a new pull request #43: URL: https://github.com/apache/flink-ml/pull/43 ## What is the purpose of the change The purpose of this PR is to prepares Flink ML for 2.0.0 release. ## Brief change log This PR makes the following changes: - Adds scripts

[GitHub] [flink] JingGe commented on pull request #18147: [FLINK-25370][docs] update HBase SQL Connector Options table-name des…

JingGe commented on pull request #18147: URL: https://github.com/apache/flink/pull/18147#issuecomment-1000148523 Thanks for your contribution. LGTM. -- 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

[jira] [Commented] (FLINK-25426) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP because it cannot allocate enough network buffers

[ https://issues.apache.org/jira/browse/FLINK-25426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464376#comment-17464376 ] Till Rohrmann commented on FLINK-25426: --- Another instance

[jira] [Updated] (FLINK-25341) Improve casting STRUCTURED type to STRING

[ https://issues.apache.org/jira/browse/FLINK-25341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani updated FLINK-25341: Summary: Improve casting STRUCTURED type to STRING (was: Improve casting

[jira] [Created] (FLINK-25427) SavepointITCase.testTriggerSavepointAndResumeWithNoClaim fails on AZP

Till Rohrmann created FLINK-25427: - Summary: SavepointITCase.testTriggerSavepointAndResumeWithNoClaim fails on AZP Key: FLINK-25427 URL: https://issues.apache.org/jira/browse/FLINK-25427 Project:

[jira] [Commented] (FLINK-25427) SavepointITCase.testTriggerSavepointAndResumeWithNoClaim fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464373#comment-17464373 ] Till Rohrmann commented on FLINK-25427: --- cc [~pnowojski], [~dwysakowicz] >

[jira] [Created] (FLINK-25428) Expose complex types CAST to String

Francesco Guardiani created FLINK-25428: --- Summary: Expose complex types CAST to String Key: FLINK-25428 URL: https://issues.apache.org/jira/browse/FLINK-25428 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #18173: [FLINK-25407][network] Fix the deadlock issue caused by LocalBufferPool#reserveSegments

flinkbot edited a comment on pull request #18173: URL: https://github.com/apache/flink/pull/18173#issuecomment-999423914 ## CI report: * 8fc8c93037dc8d6049456c62c95b217e76df4c2f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18155: [hotfix][connectors][docs] Use big M letters for month in date format

flinkbot edited a comment on pull request #18155: URL: https://github.com/apache/flink/pull/18155#issuecomment-998116357 ## CI report: * e069bbba7310bdd313c37b7f01f13da3c9b416fd Azure:

[jira] [Commented] (FLINK-23047) CassandraConnectorITCase.testCassandraBatchTupleFormat fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464372#comment-17464372 ] Till Rohrmann commented on FLINK-23047: --- +1 for disabling this test and re-enabling it after being

[jira] [Commented] (FLINK-23047) CassandraConnectorITCase.testCassandraBatchTupleFormat fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464370#comment-17464370 ] Till Rohrmann commented on FLINK-23047: --- Another instance:

<    1   2   3   4   5   6   >