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

2021-12-26 Thread GitBox
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:

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

2021-12-26 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

2021-12-26 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-25453: --- Summary: LocalFileSystem#listStatus throws FileNotFoundException when a file is deleted concurrently in the directory Key: FLINK-25453 URL:

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

2021-12-26 Thread Hang Ruan (Jira)
[ 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

2021-12-26 Thread GitBox
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[])

2021-12-26 Thread GitBox
flinkbot edited a comment on pull request #18202: URL: https://github.com/apache/flink/pull/18202#issuecomment-1001318347 ## CI report: * eb875e44857ad74a51da9d19facf5147d0947dd9 Azure:

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

2021-12-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465557#comment-17465557 ] Yun Gao commented on FLINK-25426: -

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

2021-12-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465558#comment-17465558 ] Yun Gao commented on FLINK-25427: -

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

2021-12-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465556#comment-17465556 ] Yun Gao commented on FLINK-18356: - Table test on master:

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

2021-12-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1746#comment-1746 ] Yun Gao commented on FLINK-25374: - A lot of failures in 

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

2021-12-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465553#comment-17465553 ] Yun Gao edited comment on FLINK-24801 at 12/27/21, 7:00 AM: The issue seems

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

2021-12-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465553#comment-17465553 ] Yun Gao commented on FLINK-24801: -

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

2021-12-26 Thread Yun Gao (Jira)
[ 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

2021-12-26 Thread GitBox
flinkbot edited a comment on pull request #18148: URL: https://github.com/apache/flink/pull/18148#issuecomment-997327937 ## CI report: * 0ece7b12868a4b123dcc69a11fd0efd65b076f6e Azure:

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

2021-12-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465552#comment-17465552 ] Yun Gao commented on FLINK-25181: -

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

2021-12-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465551#comment-17465551 ] Yun Gao commented on FLINK-23493: -

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

2021-12-26 Thread Yun Gao (Jira)
Yun Gao created FLINK-25452: --- Summary: FlinkKafkaProducerITCase.testRestoreUsingDifferentTransactionalIdPrefix failed on azure Key: FLINK-25452 URL: https://issues.apache.org/jira/browse/FLINK-25452

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

2021-12-26 Thread Yun Gao (Jira)
[ 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

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

2021-12-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465549#comment-17465549 ] Yun Gao commented on FLINK-24970: -

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

2021-12-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465548#comment-17465548 ] Yun Gao commented on FLINK-23493: -

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

2021-12-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465541#comment-17465541 ] Yun Gao edited comment on FLINK-25292 at 12/27/21, 6:38 AM: A lot of

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

2021-12-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465542#comment-17465542 ] Yun Gao edited comment on FLINK-25374 at 12/27/21, 6:38 AM: A lot of

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

2021-12-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465545#comment-17465545 ] Yun Gao commented on FLINK-25427: -

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

2021-12-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465547#comment-17465547 ] Yun Gao commented on FLINK-18356: - Table test on master:

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

2021-12-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465546#comment-17465546 ] Yun Gao commented on FLINK-25426: -

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

2021-12-26 Thread GitBox
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

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

2021-12-26 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465544#comment-17465544 ] Dong Lin commented on FLINK-25368: -- Thanks for the creating the ticket to improve Flink! I think the

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

2021-12-26 Thread Yun Gao (Jira)
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

2021-12-26 Thread Yun Gao (Jira)
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:

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

2021-12-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465541#comment-17465541 ] Yun Gao commented on FLINK-25292: - A lot of failures in

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

2021-12-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465542#comment-17465542 ] Yun Gao commented on FLINK-25374: - A lot of failures in

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

2021-12-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465540#comment-17465540 ] Yun Gao commented on FLINK-25181: -

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

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

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

2021-12-26 Thread Yun Gao (Jira)
[ 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

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

2021-12-26 Thread Yun Gao (Jira)
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

2021-12-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465537#comment-17465537 ] Yun Gao commented on FLINK-23493: -

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

2021-12-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465535#comment-17465535 ] Yun Gao commented on FLINK-25374: -

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

2021-12-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465536#comment-17465536 ] Yun Gao commented on FLINK-25292: -

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

2021-12-26 Thread Yun Gao (Jira)
Yun Gao created FLINK-25448: --- Summary: TaskManagerRunnerTest.testShouldShutdownIfRegistrationWithJobManagerFails failed on azure Key: FLINK-25448 URL: https://issues.apache.org/jira/browse/FLINK-25448

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

2021-12-26 Thread Yun Gao (Jira)
[ 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[])

2021-12-26 Thread GitBox
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

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

2021-12-26 Thread rerorero (Jira)
[ 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

2021-12-26 Thread lincoln lee (Jira)
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…

2021-12-26 Thread GitBox
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 #18202: [FLINK-25446][state] Avoid improper sanity check on read bytes on DataInputStream#read(byte[])

2021-12-26 Thread GitBox
flinkbot edited a comment on pull request #18202: URL: https://github.com/apache/flink/pull/18202#issuecomment-1001318347 ## CI report: * eb875e44857ad74a51da9d19facf5147d0947dd9 Azure:

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

2021-12-26 Thread GitBox
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[])

2021-12-26 Thread ASF GitHub Bot (Jira)
[ 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

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

2021-12-26 Thread GitBox
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

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

2021-12-26 Thread GitBox
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

2021-12-26 Thread GitBox
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

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

2021-12-26 Thread Yun Tang (Jira)
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

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

2021-12-26 Thread Shammon (Jira)
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

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

2021-12-26 Thread Jingsong Lee (Jira)
[ 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

2021-12-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465516#comment-17465516 ] Jingsong Lee commented on FLINK-25177: -- [~nicholasjiang] Thanks > Support "DESCRIBE TABLE

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

2021-12-26 Thread GitBox
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 #18201: [FLINK-25167][API / DataStream]Expose StreamOperatorFactory in Connec…

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

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

2021-12-26 Thread GitBox
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

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

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

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

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

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

2021-12-26 Thread GitBox
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…

2021-12-26 Thread GitBox
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

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

2021-12-26 Thread Qingsheng Ren (Jira)
[ 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:

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

2021-12-26 Thread GitBox
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

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

2021-12-26 Thread GitBox
flinkbot edited a comment on pull request #18148: URL: https://github.com/apache/flink/pull/18148#issuecomment-997327937 ## CI report: * 92bcfd7a84d150a3d5f7d9d60ba17405368a34b1 Azure:

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

2021-12-26 Thread GitBox
flinkbot edited a comment on pull request #18148: URL: https://github.com/apache/flink/pull/18148#issuecomment-997327937 ## CI report: * 92bcfd7a84d150a3d5f7d9d60ba17405368a34b1 Azure:

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

2021-12-26 Thread Wen Zhou (Jira)
[ 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

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

2021-12-26 Thread Wen Zhou (Jira)
[ 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

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

2021-12-26 Thread Wen Zhou (Jira)
[ 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

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

2021-12-26 Thread Wen Zhou (Jira)
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

2021-12-26 Thread GitBox
flinkbot edited a comment on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-818947931 ## CI report: * c7ad1cfa43fc77dbb8b58be8c35abb314b638678 Azure:

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

2021-12-26 Thread Flink Jira Bot (Jira)
[ 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

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

2021-12-26 Thread Flink Jira Bot (Jira)
[ 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:

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

2021-12-26 Thread Flink Jira Bot (Jira)
[ 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:

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

2021-12-26 Thread Flink Jira Bot (Jira)
[ 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:

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

2021-12-26 Thread Flink Jira Bot (Jira)
[ 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:

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

2021-12-26 Thread Flink Jira Bot (Jira)
[ 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

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

2021-12-26 Thread Flink Jira Bot (Jira)
[ 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

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

2021-12-26 Thread Flink Jira Bot (Jira)
[ 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:

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

2021-12-26 Thread Flink Jira Bot (Jira)
[ 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

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

2021-12-26 Thread Flink Jira Bot (Jira)
[ 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

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

2021-12-26 Thread Flink Jira Bot (Jira)
[ 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:

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

2021-12-26 Thread Flink Jira Bot (Jira)
[ 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

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

2021-12-26 Thread Flink Jira Bot (Jira)
[ 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

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

2021-12-26 Thread Flink Jira Bot (Jira)
[ 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

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

2021-12-26 Thread Flink Jira Bot (Jira)
[ 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

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

2021-12-26 Thread Flink Jira Bot (Jira)
[ 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:

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

2021-12-26 Thread Flink Jira Bot (Jira)
[ 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:

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

2021-12-26 Thread Flink Jira Bot (Jira)
[ 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:

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

2021-12-26 Thread Flink Jira Bot (Jira)
[ 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:

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

2021-12-26 Thread Flink Jira Bot (Jira)
[ 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

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

2021-12-26 Thread Flink Jira Bot (Jira)
[ 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:

[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

2021-12-26 Thread GitBox
flinkbot edited a comment on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-818947931 ## CI report: * f90389b51e59a8632d786a20475ea866132b334b Azure:

[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

2021-12-26 Thread GitBox
flinkbot edited a comment on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-818947931 ## CI report: * f90389b51e59a8632d786a20475ea866132b334b Azure:

[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

2021-12-26 Thread Galen Warren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465402#comment-17465402 ] Galen Warren commented on FLINK-25197: -- PR created:

[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

2021-12-26 Thread Galen Warren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465400#comment-17465400 ] Galen Warren commented on FLINK-25197: -- PR created:

[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

2021-12-26 Thread ASF GitHub Bot (Jira)
[ 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

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

2021-12-26 Thread GitBox
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

2021-12-26 Thread GitBox
flinkbot edited a comment on pull request #17996: URL: https://github.com/apache/flink/pull/17996#issuecomment-984710569 ## CI report: * b2892f91a74e5ce2682a00cc6d5bebaa151e09a8 Azure:

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

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

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

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

  1   2   >