[GitHub] [flink-ml] gaoyunhaii closed pull request #45: [hotfix] Add the NOTICE file

gaoyunhaii closed pull request #45: URL: https://github.com/apache/flink-ml/pull/45 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubsc

[jira] [Commented] (FLINK-25453) LocalFileSystem#listStatus throws FileNotFoundException when a file is deleted concurrently in the directory

[ https://issues.apache.org/jira/browse/FLINK-25453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465569#comment-17465569 ] Mingliang Liu commented on FLINK-25453: --- I think it makes sense to ignore the FNFE

[jira] [Created] (FLINK-25453) LocalFileSystem#listStatus throws FileNotFoundException when a file is deleted concurrently in the directory

Caizhi Weng created FLINK-25453: --- Summary: LocalFileSystem#listStatus throws FileNotFoundException when a file is deleted concurrently in the directory Key: FLINK-25453 URL: https://issues.apache.org/jira/browse/FLI

[jira] [Closed] (FLINK-25342) DataStream.sinkTo will not add sink to the sinks field in the StreamGraph

[ https://issues.apache.org/jira/browse/FLINK-25342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang Ruan closed FLINK-25342. - Resolution: Won't Fix > DataStream.sinkTo will not add sink to the sinks field in the StreamGraph >

[GitHub] [flink] deadwind4 commented on pull request #18186: [FLINK-25418][python] install dependencies completely offline

deadwind4 commented on pull request #18186: URL: https://github.com/apache/flink/pull/18186#issuecomment-1001380034 @dianfu please review 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 above to go

[GitHub] [flink] flinkbot edited a comment on pull request #18202: [FLINK-25446][state] Avoid improper sanity check on read bytes on DataInputStream#read(byte[])

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

[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&focusedCommentId=17465557#comment-17465557 ] Yun Gao commented on FLINK-25426: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[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&focusedCommentId=17465558#comment-17465558 ] Yun Gao commented on FLINK-25427: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[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&focusedCommentId=17465556#comment-17465556 ] Yun Gao commented on FLINK-18356: - Table test on master: [https://dev.azure.com/apache-

[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&focusedCommentId=1746#comment-1746 ] Yun Gao commented on FLINK-25374: - A lot of failures in  [https://dev.azure.com/apache-

[jira] [Comment Edited] (FLINK-24801) "Post-job: Cache Maven local repo" failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465553#comment-17465553 ] Yun Gao edited comment on FLINK-24801 at 12/27/21, 7:00 AM:

[jira] [Commented] (FLINK-24801) "Post-job: Cache Maven local repo" failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465553#comment-17465553 ] Yun Gao commented on FLINK-24801: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Reopened] (FLINK-24801) "Post-job: Cache Maven local repo" failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reopened FLINK-24801: - > "Post-job: Cache Maven local repo" failed on Azure > -- >

[GitHub] [flink] flinkbot edited a comment on pull request #18148: [FLINK-25372] Add thread dump feature for jobmanager

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

[jira] [Commented] (FLINK-25181) KafkaSourceITCase.testValueOnlyDeserializer fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465552#comment-17465552 ] Yun Gao commented on FLINK-25181: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-23493) python tests hang on Azure

[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465551#comment-17465551 ] Yun Gao commented on FLINK-23493: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Created] (FLINK-25452) FlinkKafkaProducerITCase.testRestoreUsingDifferentTransactionalIdPrefix failed on azure

Yun Gao created FLINK-25452: --- Summary: FlinkKafkaProducerITCase.testRestoreUsingDifferentTransactionalIdPrefix failed on azure Key: FLINK-25452 URL: https://issues.apache.org/jira/browse/FLINK-25452 Projec

[jira] [Updated] (FLINK-24970) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired after 60000 milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/FLINK-24970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24970: Priority: Critical (was: Major) > FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired af

[jira] [Commented] (FLINK-24970) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired after 60000 milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/FLINK-24970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465549#comment-17465549 ] Yun Gao commented on FLINK-24970: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Commented] (FLINK-23493) python tests hang on Azure

[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465548#comment-17465548 ] Yun Gao commented on FLINK-23493: - https://dev.azure.com/apache-flink/apache-flink/_buil

[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&focusedCommentId=17465541#comment-17465541 ] Yun Gao edited comment on FLINK-25292 at 12/27/21, 6:38 AM:

[jira] [Comment Edited] (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&focusedCommentId=17465542#comment-17465542 ] Yun Gao edited comment on FLINK-25374 at 12/27/21, 6:38 AM:

[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&focusedCommentId=17465545#comment-17465545 ] Yun Gao commented on FLINK-25427: - https://dev.azure.com/apache-flink/apache-flink/_buil

[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&focusedCommentId=17465547#comment-17465547 ] Yun Gao commented on FLINK-18356: - Table test on master: [https://dev.azure.com/apache-

[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&focusedCommentId=17465546#comment-17465546 ] Yun Gao commented on FLINK-25426: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[GitHub] [flink] lindong28 commented on pull request #18145: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient when getting offsets

lindong28 commented on pull request #18145: URL: https://github.com/apache/flink/pull/18145#issuecomment-1001365705 Thanks for the creating the ticket to improve Flink! I think the overall motivation makes sense. But the PR changed OffsetsInitializer::PartitionOffsetsRetriever and Of

[jira] [Commented] (FLINK-25368) Use AdminClient to get offsets rather than KafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-25368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465544#comment-17465544 ] Dong Lin commented on FLINK-25368: -- Thanks for the creating the ticket to improve Flink

[jira] [Created] (FLINK-25451) KafkaEnumeratorTest.testDiscoverPartitionsPeriodically failed on azure

Yun Gao created FLINK-25451: --- Summary: KafkaEnumeratorTest.testDiscoverPartitionsPeriodically failed on azure Key: FLINK-25451 URL: https://issues.apache.org/jira/browse/FLINK-25451 Project: Flink

[jira] [Created] (FLINK-25450) JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout is unstable on azure

Yun Gao created FLINK-25450: --- Summary: JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout is unstable on azure Key: FLINK-25450 URL: https://issues.apache.org/jira/browse/FLINK-25450 Project: Fli

[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&focusedCommentId=17465541#comment-17465541 ] Yun Gao commented on FLINK-25292: - A lot of failures in https://dev.azure.com/apache-fl

[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&focusedCommentId=17465542#comment-17465542 ] Yun Gao commented on FLINK-25374: - A lot of failures in https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-25181) KafkaSourceITCase.testValueOnlyDeserializer fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465540#comment-17465540 ] Yun Gao commented on FLINK-25181: - https://dev.azure.com/apache-flink/apache-flink/_buil

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-25449) KafkaSourceITCase.testRedundantParallelism failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25449: Description: {code:java} Dec 25 00:51:07 at akka.dispatch.Mailbox.run(Mailbox.scala:225) Dec 25 00

[jira] [Created] (FLINK-25449) KafkaSourceITCase.testRedundantParallelism failed on azure

Yun Gao created FLINK-25449: --- Summary: KafkaSourceITCase.testRedundantParallelism failed on azure Key: FLINK-25449 URL: https://issues.apache.org/jira/browse/FLINK-25449 Project: Flink Issue Type:

[jira] [Commented] (FLINK-23493) python tests hang on Azure

[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465537#comment-17465537 ] Yun Gao commented on FLINK-23493: - https://dev.azure.com/apache-flink/apache-flink/_buil

[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&focusedCommentId=17465535#comment-17465535 ] Yun Gao commented on FLINK-25374: - https://dev.azure.com/apache-flink/apache-flink/_buil

[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&focusedCommentId=17465536#comment-17465536 ] Yun Gao commented on FLINK-25292: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Created] (FLINK-25448) TaskManagerRunnerTest.testShouldShutdownIfRegistrationWithJobManagerFails failed on azure

Yun Gao created FLINK-25448: --- Summary: TaskManagerRunnerTest.testShouldShutdownIfRegistrationWithJobManagerFails failed on azure Key: FLINK-25448 URL: https://issues.apache.org/jira/browse/FLINK-25448 Proj

[jira] [Reopened] (FLINK-23493) python tests hang on Azure

[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reopened FLINK-23493: - > python tests hang on Azure > -- > > Key: FLINK-23493 >

[GitHub] [flink] curcur commented on pull request #18202: [FLINK-25446][state] Avoid improper sanity check on read bytes on DataInputStream#read(byte[])

curcur commented on pull request #18202: URL: https://github.com/apache/flink/pull/18202#issuecomment-1001352110 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 un

[jira] [Closed] (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:all-tabpanel ] rerorero closed FLINK-25293. Resolution: Won't Fix > Option to let fail if KafkaSource keeps failing to commit offset > ---

[jira] [Created] (FLINK-25447) batch query cannot generate plan when a sorted view into multi sinks

lincoln lee created FLINK-25447: --- Summary: batch query cannot generate plan when a sorted view into multi sinks Key: FLINK-25447 URL: https://issues.apache.org/jira/browse/FLINK-25447 Project: Flink

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18202: [FLINK-25446][state] Avoid improper sanity check on read bytes on DataInputStream#read(byte[])

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

[GitHub] [flink] flinkbot commented on pull request #18202: [FLINK-25446][state] Avoid improper sanity check on read bytes on DataInputStream#read(byte[])

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

[jira] [Updated] (FLINK-25446) Avoid sanity check on read bytes on DataInputStream#read(byte[])

[ https://issues.apache.org/jira/browse/FLINK-25446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25446: --- Labels: pull-request-available (was: ) > Avoid sanity check on read bytes on DataInputStrea

[GitHub] [flink] flinkbot commented on pull request #18202: [FLINK-25446][state] Avoid improper sanity check on read bytes on DataInputStream#read(byte[])

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

[GitHub] [flink] SteNicholas commented on pull request #15140: [FLINK-20628][connectors/rabbitmq2] RabbitMQ connector using new connector API

SteNicholas commented on pull request #15140: URL: https://github.com/apache/flink/pull/15140#issuecomment-1001316884 @pscls , thanks for your updates. In general the changes look good to me and I have still left certain comments. Please take a look. -- This is an automated message from

[GitHub] [flink] SteNicholas commented on a change in pull request #15140: [FLINK-20628][connectors/rabbitmq2] RabbitMQ connector using new connector API

SteNicholas commented on a change in pull request #15140: URL: https://github.com/apache/flink/pull/15140#discussion_r775324812 ## File path: flink-connectors/flink-connector-rabbitmq2/README.md ## @@ -19,6 +19,143 @@ and the Sink API specified in [FLIP-143](https://cwiki.apac

[jira] [Created] (FLINK-25446) Avoid sanity check on read bytes on DataInputStream#read(byte[])

Yun Tang created FLINK-25446: Summary: Avoid sanity check on read bytes on DataInputStream#read(byte[]) Key: FLINK-25446 URL: https://issues.apache.org/jira/browse/FLINK-25446 Project: Flink Iss

[jira] [Created] (FLINK-25445) TaskExecutor always creates local file for task even when local state store is not used

Shammon created FLINK-25445: --- Summary: TaskExecutor always creates local file for task even when local state store is not used Key: FLINK-25445 URL: https://issues.apache.org/jira/browse/FLINK-25445 Project

[jira] [Assigned] (FLINK-25177) Support "DESCRIBE TABLE EXTENDED" with managed table

[ https://issues.apache.org/jira/browse/FLINK-25177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-25177: Assignee: Nicholas Jiang > Support "DESCRIBE TABLE EXTENDED" with managed table > ---

[jira] [Commented] (FLINK-25177) Support "DESCRIBE TABLE EXTENDED" with managed table

[ https://issues.apache.org/jira/browse/FLINK-25177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465516#comment-17465516 ] Jingsong Lee commented on FLINK-25177: -- [~nicholasjiang] Thanks > Support "DESCRIB

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] shouweikun commented on pull request #18201: [FLINK-25167][API / DataStream]Expose StreamOperatorFactory in Connec…

shouweikun commented on pull request #18201: URL: https://github.com/apache/flink/pull/18201#issuecomment-1001299363 @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 speci

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

shouweikun removed a comment 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

[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-1001295713 @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 s

[jira] [Resolved] (FLINK-25132) KafkaSource cannot work with object-reusing DeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-25132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-25132. --- Resolution: Fixed Merged to master: 2b1a9dea74a334adb1fe890f024f4153ad11a985 release-1.14: e

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

KarmaGYZ commented on pull request #17873: URL: https://github.com/apache/flink/pull/17873#issuecomment-1001291359 @xinbinhuang Just a kindly reminder, please rebase your PR to the latest master instead of merging it. -- This is an automated message from the Apache Git Service. To respon

[GitHub] [flink] flinkbot edited a comment on pull request #18148: [FLINK-25372] Add thread dump feature for jobmanager

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

[GitHub] [flink] flinkbot edited a comment on pull request #18148: [FLINK-25372] Add thread dump feature for jobmanager

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

[jira] [Updated] (FLINK-25444) ExecutionConfig can not be Serializable due to TextElement used in side

[ https://issues.apache.org/jira/browse/FLINK-25444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wen Zhou updated FLINK-25444: - Description: This should be a bug introduced by the latest flink commit of file [flink-core/src/main/ja

[jira] [Updated] (FLINK-25444) ExecutionConfig can not be Serializable due to TextElement used in side

[ https://issues.apache.org/jira/browse/FLINK-25444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wen Zhou updated FLINK-25444: - Description: This should be a bug introduced by the latest flink commit of file [flink-core/src/main/ja

[jira] [Updated] (FLINK-25444) ExecutionConfig can not be Serializable due to TextElement used in side

[ https://issues.apache.org/jira/browse/FLINK-25444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wen Zhou updated FLINK-25444: - Description: This should be a bug introduced by the latest flink commit of file [flink-core/src/main/ja

[jira] [Created] (FLINK-25444) ExecutionConfig can not be Serializable due to TextElement used in side

Wen Zhou created FLINK-25444: Summary: ExecutionConfig can not be Serializable due to TextElement used in side Key: FLINK-25444 URL: https://issues.apache.org/jira/browse/FLINK-25444 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

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

[jira] [Updated] (FLINK-5177) Improve nullability handling

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

[jira] [Updated] (FLINK-10476) Change related ProcessFunction to KeyedProcessFunction in Sql/Table-api

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

[jira] [Updated] (FLINK-16165) NestedLoopJoin fallback to HashJoin when build records number is very large

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

[jira] [Updated] (FLINK-5047) Add sliding group-windows for batch tables

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

[jira] [Updated] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

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

[jira] [Updated] (FLINK-4942) Improve processing performance of HeapInternalTimerService with key groups

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

[jira] [Updated] (FLINK-4965) AllPairsShortestPaths

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

[jira] [Updated] (FLINK-10515) Improve tokenisation of program args passed as string

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

[jira] [Updated] (FLINK-5105) Improve ReduceState: value put into ReducingState should always be a copy

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

[jira] [Updated] (FLINK-5078) Introduce annotations for classes copied from Calcite

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

[jira] [Updated] (FLINK-10568) Show correct time attributes when calling Table.getSchema()

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

[jira] [Updated] (FLINK-5089) Introduce Loop functions and Enforce Nesting on Data Streams

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

[jira] [Updated] (FLINK-4966) BetweennessCentrality

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

[jira] [Updated] (FLINK-10518) Inefficient design in ContinuousFileMonitoringFunction

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

[jira] [Updated] (FLINK-5127) Reduce the amount of intermediate data in vertex-centric iterations

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

[jira] [Updated] (FLINK-10576) Introduce Machine/Node/TM health management

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

[jira] [Updated] (FLINK-10489) Inconsistent window information for streams with EventTime characteristic

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

[jira] [Updated] (FLINK-10448) VALUES clause is translated into a separate operator per value

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

[jira] [Updated] (FLINK-10667) Clean up Scala 2.10 remnants

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

[jira] [Updated] (FLINK-10684) Improve the CSV reading process

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

[jira] [Updated] (FLINK-10688) Remove flink-table dependencies from flink-connectors

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

[GitHub] [flink] flinkbot edited a comment on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

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

[GitHub] [flink] flinkbot edited a comment on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

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

[jira] [Commented] (FLINK-25197) Using Statefun RequestReplyFunctionBuilder fails with Java 8 date/time type `java.time.Duration` not supported by default: add Module "org.apache.flink.shaded.jackson2

[ https://issues.apache.org/jira/browse/FLINK-25197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465402#comment-17465402 ] Galen Warren commented on FLINK-25197: -- PR created: https://github.com/apache/flink

[jira] [Commented] (FLINK-25197) Using Statefun RequestReplyFunctionBuilder fails with Java 8 date/time type `java.time.Duration` not supported by default: add Module "org.apache.flink.shaded.jackson2

[ https://issues.apache.org/jira/browse/FLINK-25197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465400#comment-17465400 ] Galen Warren commented on FLINK-25197: -- PR created: https://github.com/apache/flink

[jira] [Updated] (FLINK-25197) Using Statefun RequestReplyFunctionBuilder fails with Java 8 date/time type `java.time.Duration` not supported by default: add Module "org.apache.flink.shaded.jackson2.c

[ https://issues.apache.org/jira/browse/FLINK-25197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25197: --- Labels: pull-request-available (was: ) > Using Statefun RequestReplyFunctionBuilder fails w

[GitHub] [flink-statefun] galenwarren opened a new pull request #282: [FLINK-25197] Fix serialization issue in RequestReplyFunctionBuilder

galenwarren opened a new pull request #282: URL: https://github.com/apache/flink-statefun/pull/282 This fixes the issue described in [FLINK-25197](https://issues.apache.org/jira/browse/FLINK-25197), where this error occurs when using RequestReplyFunctionBuilder to build Statefun jobs:

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

[jira] [Comment Edited] (FLINK-25380) Introduce DynamicTableSink & DynamicTableSource for RabbitMQ

[ https://issues.apache.org/jira/browse/FLINK-25380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465389#comment-17465389 ] RocMarshal edited comment on FLINK-25380 at 12/26/21, 2:29 PM: ---

[jira] [Comment Edited] (FLINK-25380) Introduce DynamicTableSink & DynamicTableSource for RabbitMQ

[ https://issues.apache.org/jira/browse/FLINK-25380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465389#comment-17465389 ] RocMarshal edited comment on FLINK-25380 at 12/26/21, 2:28 PM: ---

  1   2   >