[GitHub] [flink] flinkbot edited a comment on pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

flinkbot edited a comment on pull request #17988: URL: https://github.com/apache/flink/pull/17988#issuecomment-984363654 ## CI report: * 19a283c42da777c55b3b1e29bbab04edf4db6bd6 Azure:

[jira] [Commented] (FLINK-25292) Azure failed due to unable to fetch some archives

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

[jira] [Comment Edited] (FLINK-25292) Azure failed due to unable to fetch some archives

[ https://issues.apache.org/jira/browse/FLINK-25292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465137#comment-17465137 ] Yun Gao edited comment on FLINK-25292 at 12/25/21, 3:38 AM:

[jira] [Updated] (FLINK-25292) Azure failed due to unable to fetch some archives

[ https://issues.apache.org/jira/browse/FLINK-25292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25292: Priority: Blocker (was: Critical) > Azure failed due to unable to fetch some archives >

[jira] [Commented] (FLINK-25292) Azure failed due to unable to fetch some archives

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

[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=17465135#comment-17465135 ] Yun Gao commented on FLINK-25426: -

[jira] [Comment Edited] (FLINK-18356) Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465130#comment-17465130 ] Yun Gao edited comment on FLINK-18356 at 12/25/21, 3:35 AM: Table tests on

[jira] [Commented] (FLINK-25292) Azure failed due to unable to fetch some archives

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

[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=17465133#comment-17465133 ] Yun Gao commented on FLINK-25427: -

[jira] [Comment Edited] (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=17465131#comment-17465131 ] Yun Gao edited comment on FLINK-25426 at 12/25/21, 3:35 AM:

[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=17465132#comment-17465132 ] Yun Gao commented on FLINK-23047: -

[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=17465131#comment-17465131 ] Yun Gao commented on FLINK-25426: -

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process

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

[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=17465129#comment-17465129 ] Yun Gao commented on FLINK-23047: -

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

lipusheng commented on pull request #18147: URL: https://github.com/apache/flink/pull/18147#issuecomment-1000967223 @fapaul can you help me merge 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-25292) Azure failed due to unable to fetch some archives

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

[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=17465127#comment-17465127 ] Yun Gao commented on FLINK-23047: - 1.13:

[jira] [Commented] (FLINK-22306) KafkaITCase.testCollectingSchema failed on AZP

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

[jira] [Updated] (FLINK-22306) KafkaITCase.testCollectingSchema failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-22306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22306: Labels: test-stability (was: ) > KafkaITCase.testCollectingSchema failed on AZP >

[jira] [Updated] (FLINK-22306) KafkaITCase.testCollectingSchema failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-22306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22306: Labels: (was: auto-deprioritized-critical auto-deprioritized-major test-stability) >

[jira] [Commented] (FLINK-22765) ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable

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

[jira] [Reopened] (FLINK-22765) ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable

[ https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reopened FLINK-22765: - > ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable >

[jira] [Commented] (FLINK-24261) KafkaSourceITCase.testMultipleSplits fails due to "Cannot create topic"

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

[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=17465123#comment-17465123 ] Yun Gao commented on FLINK-23047: - Very thanks [~echauchot] for taking care this issue! Another

[GitHub] [flink] flinkbot edited a comment on pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

flinkbot edited a comment on pull request #17988: URL: https://github.com/apache/flink/pull/17988#issuecomment-984363654 ## CI report: * e7be85162e0b431d518ab1ffe8b59283338d00b7 Azure:

[jira] [Created] (FLINK-25442) HBaseConnectorITCase.testTableSink failed on azure

Yun Gao created FLINK-25442: --- Summary: HBaseConnectorITCase.testTableSink failed on azure Key: FLINK-25442 URL: https://issues.apache.org/jira/browse/FLINK-25442 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

flinkbot edited a comment on pull request #17988: URL: https://github.com/apache/flink/pull/17988#issuecomment-984363654 ## CI report: * e7be85162e0b431d518ab1ffe8b59283338d00b7 Azure:

[GitHub] [flink] Myracle commented on a change in pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

Myracle commented on a change in pull request #17988: URL: https://github.com/apache/flink/pull/17988#discussion_r775101619 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveOptions.java ## @@ -51,4 +51,11 @@

[GitHub] [flink] Myracle commented on a change in pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

Myracle commented on a change in pull request #17988: URL: https://github.com/apache/flink/pull/17988#discussion_r775101619 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveOptions.java ## @@ -51,4 +51,11 @@

[jira] [Commented] (FLINK-25292) Azure failed due to unable to fetch some archives

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

[GitHub] [flink] flinkbot edited a comment on pull request #17873: [FLINK-25009][CLI] Output slotSharingGroup as part of JsonGraph

flinkbot edited a comment on pull request #17873: URL: https://github.com/apache/flink/pull/17873#issuecomment-975923151 ## CI report: * 7a5e46abcb427fbec0eb93842085f8d4d45bc561 Azure:

[jira] [Updated] (FLINK-11673) add example for streaming operators's broadcast

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

[jira] [Updated] (FLINK-6363) Document precedence rules of Kryo serializer registrations

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

[jira] [Updated] (FLINK-11639) Provide readSequenceFile for Hadoop new API

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

[jira] [Updated] (FLINK-6713) Document how to allow multiple Kafka consumers / producers to authenticate using different credentials

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

[jira] [Updated] (FLINK-6209) StreamPlanEnvironment always has a parallelism of 1

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

[jira] [Updated] (FLINK-6224) RemoteStreamEnvironment not resolve ip of JobManager to hostname

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

[jira] [Updated] (FLINK-6343) Migrate from discouraged Java serialization for all sources / sinks

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

[jira] [Updated] (FLINK-6370) FileAlreadyExistsException on startup

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

[jira] [Updated] (FLINK-6309) Memory consumer weights should be calculated in job vertex level

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

[jira] [Updated] (FLINK-6605) Allow users to specify a default name for processing time in Table API

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

[jira] [Updated] (FLINK-6477) The first time to click Taskmanager cannot get the actual data

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

[jira] [Updated] (FLINK-11543) Type mismatch AssertionError in FilterJoinRule

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

[jira] [Updated] (FLINK-6424) Add basic helper functions for map type

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

[jira] [Updated] (FLINK-11616) Flink official document has an error

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

[jira] [Updated] (FLINK-11619) Make ScheduleMode configurable via user code or configuration file

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

[jira] [Updated] (FLINK-11672) Add example for streaming operators's connect

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

[jira] [Updated] (FLINK-6446) Various improvements to the Web Frontend

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

[jira] [Updated] (FLINK-11698) Add readMapRedTextFile API for HadoopInputs

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

[jira] [Updated] (FLINK-11620) table example add kafka

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

[jira] [Updated] (FLINK-11697) Add readMapReduceTextFile API for HadoopInputs

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

[jira] [Updated] (FLINK-11695) Make sharedStateDir could create sub-directories to avoid MaxDirectoryItemsExceededException

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

[GitHub] [flink] flinkbot edited a comment on pull request #17873: [FLINK-25009][CLI] Output slotSharingGroup as part of JsonGraph

flinkbot edited a comment on pull request #17873: URL: https://github.com/apache/flink/pull/17873#issuecomment-975923151 ## CI report: * Unknown: [CANCELED](TBD) * 7a5e46abcb427fbec0eb93842085f8d4d45bc561 Azure:

[GitHub] [flink] xinbinhuang commented on pull request #17873: [FLINK-25009][CLI] Output slotSharingGroup as part of JsonGraph

xinbinhuang commented on pull request #17873: URL: https://github.com/apache/flink/pull/17873#issuecomment-1000935339 @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 #17873: [FLINK-25009][CLI] Output slotSharingGroup as part of JsonGraph

flinkbot edited a comment on pull request #17873: URL: https://github.com/apache/flink/pull/17873#issuecomment-975923151 ## CI report: * Unknown: [CANCELED](TBD) * 7a5e46abcb427fbec0eb93842085f8d4d45bc561 UNKNOWN Bot commands The @flinkbot bot supports the

[jira] [Comment Edited] (FLINK-25423) Enable loading state backend via configuration in state processor api

[ https://issues.apache.org/jira/browse/FLINK-25423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465074#comment-17465074 ] Seth Wiesman edited comment on FLINK-25423 at 12/24/21, 7:52 PM: - Hi

[jira] [Commented] (FLINK-25423) Enable loading state backend via configuration in state processor api

[ https://issues.apache.org/jira/browse/FLINK-25423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465074#comment-17465074 ] Seth Wiesman commented on FLINK-25423: -- Hi Yuan,    we can get this into 1.15 without any

[GitHub] [flink] flinkbot edited a comment on pull request #18145: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient when getting offsets

flinkbot edited a comment on pull request #18145: URL: https://github.com/apache/flink/pull/18145#issuecomment-997131565 ## CI report: * b5804c8b8810086275acfa3272aab1d2d981fd80 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18145: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient when getting offsets

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

[GitHub] [flink] flinkbot edited a comment on pull request #18145: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient when getting offsets

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

[GitHub] [flink-statefun-playground] igalshilman merged pull request #16: Upgrade playground 3.1.x to version to 3.1.1

igalshilman merged pull request #16: URL: https://github.com/apache/flink-statefun-playground/pull/16 -- 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,

[GitHub] [flink] flinkbot edited a comment on pull request #18184: [hotfix][quickstarts] Fix misprints in DataStreamJob.java and DataStreamJob.scala

flinkbot edited a comment on pull request #18184: URL: https://github.com/apache/flink/pull/18184#issuecomment-42453 ## CI report: * 118bdcb21779306dbc10125fff3882952d42c5b7 Azure:

[GitHub] [flink] shouweikun commented on pull request #18199: [FLINK-25183] Optimize changelog normalize for the managed table upse…

shouweikun commented on pull request #18199: URL: https://github.com/apache/flink/pull/18199#issuecomment-1000863930 @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-ml] lindong28 commented on pull request #45: [hotfix] Add the NOTICE file

lindong28 commented on pull request #45: URL: https://github.com/apache/flink-ml/pull/45#issuecomment-1000852081 @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 #45: [hotfix] Add the NOTICE file

lindong28 opened a new pull request #45: URL: https://github.com/apache/flink-ml/pull/45 ## What is the purpose of the change Add the NOTICE file. ## Brief change log Added the NOTICE file. ## Verifying this change N/A ## Does this pull request

[GitHub] [flink] flinkbot edited a comment on pull request #18165: [FLINK-24904][docs] Updated docs to reflect new KDS Sink and deprecat…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17907: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

flinkbot edited a comment on pull request #17907: URL: https://github.com/apache/flink/pull/17907#issuecomment-979080179 ## CI report: * 683c8e4796bb01ba4789a1edc1cb465fae8b0547 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18184: [hotfix][quickstarts] Fix misprints in DataStreamJob.java and DataStreamJob.scala

flinkbot edited a comment on pull request #18184: URL: https://github.com/apache/flink/pull/18184#issuecomment-42453 ## CI report: * 118bdcb21779306dbc10125fff3882952d42c5b7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18184: [hotfix][quickstarts] Fix misprints in DataStreamJob.java and DataStreamJob.scala

flinkbot edited a comment on pull request #18184: URL: https://github.com/apache/flink/pull/18184#issuecomment-42453 ## CI report: * 118bdcb21779306dbc10125fff3882952d42c5b7 Azure:

[GitHub] [flink] snuyanzin commented on pull request #18116: [hotfix][docs] Fix type name for INTERVAL in Data Type Extraction section of types.md

snuyanzin commented on pull request #18116: URL: https://github.com/apache/flink/pull/18116#issuecomment-1000842007 Thanks for you feedback. I improved the title, description and commit message. Please let me know in case I missed anything. -- This is an automated message from the

[GitHub] [flink] snuyanzin commented on pull request #18184: [hotfix][quickstarts] Fix misprints in DataStreamJob.java and DataStreamJob.scala

snuyanzin commented on pull request #18184: URL: https://github.com/apache/flink/pull/18184#issuecomment-1000841738 @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 #18199: [FLINK-25183] Optimize changelog normalize for the managed table upse…

flinkbot edited a comment on pull request #18199: URL: https://github.com/apache/flink/pull/18199#issuecomment-1000699581 ## CI report: * 151689d6a8214edc38eae822b0f54c1b23922fe5 Azure:

[GitHub] [flink] wsry commented on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

wsry commented on pull request #17814: URL: https://github.com/apache/flink/pull/17814#issuecomment-1000828829 Hi, thanks a lot for the PR and review. I will take look after finishing this discussion: https://lists.apache.org/thread/pt2b1f17x2l5rlvggwxs6m265lo4ly7p. -- This is an

[GitHub] [flink] flinkbot edited a comment on pull request #18184: [hotfix][quickstarts] Fix misprints in DataStreamJob.java and DataStreamJob.scala

flinkbot edited a comment on pull request #18184: URL: https://github.com/apache/flink/pull/18184#issuecomment-42453 ## CI report: * 118bdcb21779306dbc10125fff3882952d42c5b7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18116: [hotfix][docs] Fix type name for INTERVAL in Data Type Extraction section of types.md

flinkbot edited a comment on pull request #18116: URL: https://github.com/apache/flink/pull/18116#issuecomment-994626650 ## CI report: * 3de2d7d7e66b4e94827c35c29f18be8e838603aa Azure:

[GitHub] [flink] SteNicholas commented on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

SteNicholas commented on pull request #17814: URL: https://github.com/apache/flink/pull/17814#issuecomment-1000826210 @hililiwei, thanks for your detailed review and I have addressed the above comment. IMO, the boolean type option has no the definition in NettyShuffleEnvironmentOptions

[GitHub] [flink] SteNicholas removed a comment on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

SteNicholas removed a comment on pull request #17814: URL: https://github.com/apache/flink/pull/17814#issuecomment-985186694 @hililiwei, thanks for your detailed review and I have addressed the above comment. IMO, the boolean type option has no the definition in

[GitHub] [flink] SteNicholas edited a comment on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

SteNicholas edited a comment on pull request #17814: URL: https://github.com/apache/flink/pull/17814#issuecomment-1000826210 @hililiwei, thanks for your detailed review and I have addressed the above comment. IMO, the boolean type option has no the definition in

[GitHub] [flink] SteNicholas edited a comment on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

SteNicholas edited a comment on pull request #17814: URL: https://github.com/apache/flink/pull/17814#issuecomment-985186694 @hililiwei, thanks for your detailed review and I have addressed the above comment. IMO, the boolean type option has no the definition in

[GitHub] [flink] flinkbot edited a comment on pull request #18201: [FLINK-25167][API / DataStream]Expose StreamOperatorFactory in Connec…

flinkbot edited a comment on pull request #18201: URL: https://github.com/apache/flink/pull/18201#issuecomment-1000767373 ## CI report: * b106d3f7ba04cd518efbb4552de331e80ff9be57 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18184: [hotfix][quickstarts] Fix misprints in DataStreamJob.java and DataStreamJob.scala

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

[GitHub] [flink] shouweikun commented on pull request #18114: [FLINK-25173][table][hive] Introduce CatalogLock and implement HiveCatalogLock

shouweikun commented on pull request #18114: URL: https://github.com/apache/flink/pull/18114#issuecomment-1000806049 Hi @JingsongLi , still I have some questions. Would you mind explaining it a little bit more? thx~ -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] shouweikun commented on a change in pull request #18114: [FLINK-25173][table][hive] Introduce CatalogLock and implement HiveCatalogLock

shouweikun commented on a change in pull request #18114: URL: https://github.com/apache/flink/pull/18114#discussion_r774987762 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogLock.java ## @@ -0,0 +1,40 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #18165: [FLINK-24904][docs] Updated docs to reflect new KDS Sink and deprecat…

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

[GitHub] [flink] shouweikun commented on a change in pull request #18114: [FLINK-25173][table][hive] Introduce CatalogLock and implement HiveCatalogLock

shouweikun commented on a change in pull request #18114: URL: https://github.com/apache/flink/pull/18114#discussion_r774988544 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveDynamicTableFactory.java ## @@ -70,13 +72,18

[GitHub] [flink] flinkbot edited a comment on pull request #18165: [FLINK-24904][docs] Updated docs to reflect new KDS Sink and deprecat…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17907: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

flinkbot edited a comment on pull request #17907: URL: https://github.com/apache/flink/pull/17907#issuecomment-979080179 ## CI report: * 47adbd8e9553d1532f9ef8eb9a51c07e498a5899 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17907: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

flinkbot edited a comment on pull request #17907: URL: https://github.com/apache/flink/pull/17907#issuecomment-979080179 ## CI report: * 47adbd8e9553d1532f9ef8eb9a51c07e498a5899 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18158: [FLINK-25398] Show complete stacktrace when requesting thread dump

flinkbot edited a comment on pull request #18158: URL: https://github.com/apache/flink/pull/18158#issuecomment-998496692 ## CI report: * c510d63b1d0b22542cef930d3d13a2fead70289d 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_r774982745 ## 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_r774982745 ## 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 #18133: [FLINK-24718][avro] update AVRO dependency to latest version

flinkbot edited a comment on pull request #18133: URL: https://github.com/apache/flink/pull/18133#issuecomment-995786550 ## CI report: * 635596e288832ab3df3434b7d6b153415f2711a0 Azure:

[jira] [Resolved] (FLINK-25437) Build wheels failed

[ https://issues.apache.org/jira/browse/FLINK-25437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-25437. -- Fix Version/s: 1.12.8 1.13.6 Resolution: Fixed Merged into

[GitHub] [flink] HuangXingBo closed pull request #18198: [FLINK-25437][python] Correct grpcio dependency version in dev-requirenment.txt

HuangXingBo closed pull request #18198: URL: https://github.com/apache/flink/pull/18198 -- 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] HuangXingBo closed pull request #18197: [FLINK-25437][python] Correct grpcio dependency version in dev-requirenment.txt

HuangXingBo closed pull request #18197: URL: https://github.com/apache/flink/pull/18197 -- 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 #18180: [hotfix][doc] fix typo of 'note that' and 'now that'

flinkbot edited a comment on pull request #18180: URL: https://github.com/apache/flink/pull/18180#issuecomment-999581101 ## CI report: * b3736ea54f18c499c3c4d8bbf24bbce17e02adbc Azure:

[GitHub] [flink] HuangXingBo commented on pull request #18197: [FLINK-25437][python] Correct grpcio dependency version in dev-requirenment.txt

HuangXingBo commented on pull request #18197: URL: https://github.com/apache/flink/pull/18197#issuecomment-1000789125 https://dev.azure.com/hxbks2ks/FLINK-TEST/_build/results?buildId=1692=results -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] HuangXingBo removed a comment on pull request #18198: [FLINK-25437][python] Correct grpcio dependency version in dev-requirenment.txt

HuangXingBo removed a comment on pull request #18198: URL: https://github.com/apache/flink/pull/18198#issuecomment-1000788561 https://dev.azure.com/hxbks2ks/FLINK-TEST/_build/results?buildId=1692=results -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] HuangXingBo commented on pull request #18198: [FLINK-25437][python] Correct grpcio dependency version in dev-requirenment.txt

HuangXingBo commented on pull request #18198: URL: https://github.com/apache/flink/pull/18198#issuecomment-1000788561 https://dev.azure.com/hxbks2ks/FLINK-TEST/_build/results?buildId=1692=results -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #18197: [FLINK-25437][python] Correct grpcio dependency version in dev-requirenment.txt

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

  1   2   3   >