[GitHub] [flink] gaoyunhaii closed pull request #18642: [FLINK-25572][connectors/filesystem] Update File Sink to use decomposed interfaces.

gaoyunhaii closed pull request #18642: URL: https://github.com/apache/flink/pull/18642 -- 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-unsu

[jira] [Commented] (FLINK-26033) In KafkaConnector, when 'sink.partitioner' is configured as 'round-robin', it does not take effect

[ https://issues.apache.org/jira/browse/FLINK-26033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489345#comment-17489345 ] shizhengchao commented on FLINK-26033: -- [~MartijnVisser] This is not a problem, but

[GitHub] [flink] flinkbot edited a comment on pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

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

[GitHub] [flink] flinkbot edited a comment on pull request #18664: [FLINK-25907][runtime][security] Add pluggable delegation token manager

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

[GitHub] [flink] flinkbot edited a comment on pull request #18657: [FLINK-26001][avro] Implement ProjectableDecodingFormat for avro BulkDecodingFormat

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

[jira] [Commented] (FLINK-26033) In KafkaConnector, when 'sink.partitioner' is configured as 'round-robin', it does not take effect

[ https://issues.apache.org/jira/browse/FLINK-26033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489342#comment-17489342 ] shizhengchao commented on FLINK-26033: -- [~MartijnVisser] I made a mistake,I re-chec

[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable application mode on YARN to use usrlib

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

[jira] [Commented] (FLINK-25585) JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure failed on the azure

[ https://issues.apache.org/jira/browse/FLINK-25585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489343#comment-17489343 ] Konstantin Knauf commented on FLINK-25585: -- https://dev.azure.com/apache-flink/

[GitHub] [flink] flinkbot edited a comment on pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe

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

[jira] [Updated] (FLINK-26039) Incorrect value getter in map unnest table function

[ https://issues.apache.org/jira/browse/FLINK-26039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26039: --- Labels: pull-request-available (was: ) > Incorrect value getter in map unnest table functio

[GitHub] [flink] fornaix opened a new pull request #18679: [FLINK-26039][table-runtime] Fix the incorrect value getter in map unnest table function

fornaix opened a new pull request #18679: URL: https://github.com/apache/flink/pull/18679 ## What is the purpose of the change Suppose we have a map field that needs to be expanded. ```sql CREATE TABLE t ( id INT, map_field MAP ) WITH ( -- ... )

[jira] [Closed] (FLINK-25706) Add idleness to Kafka Source documentation

[ https://issues.apache.org/jira/browse/FLINK-25706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25706. -- Resolution: Duplicate > Add idleness to Kafka Source documentation > -

[GitHub] [flink] tsreaper commented on pull request #18657: [FLINK-26001][avro] Implement ProjectableDecodingFormat for avro BulkDecodingFormat

tsreaper commented on pull request #18657: URL: https://github.com/apache/flink/pull/18657#issuecomment-1033468869 @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 specifi

[jira] [Assigned] (FLINK-25852) Annotate SourceFunction and SinkFunction as deprecated

[ https://issues.apache.org/jira/browse/FLINK-25852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25852: -- Assignee: (was: Martijn Visser) > Annotate SourceFunction and SinkFunction as dep

[jira] [Commented] (FLINK-25937) SQL Client end-to-end test e2e fails on AZP

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

[jira] [Assigned] (FLINK-25852) Annotate SourceFunction and SinkFunction as deprecated

[ https://issues.apache.org/jira/browse/FLINK-25852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25852: -- Assignee: Martijn Visser > Annotate SourceFunction and SinkFunction as deprecated > -

[jira] [Assigned] (FLINK-25852) Annotate SourceFunction and SinkFunction as deprecated

[ https://issues.apache.org/jira/browse/FLINK-25852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25852: -- Assignee: (was: Martijn Visser) > Annotate SourceFunction and SinkFunction as dep

[GitHub] [flink] flinkbot commented on pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

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

[jira] [Commented] (FLINK-25825) MySqlCatalogITCase fails on azure

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

[GitHub] [flink] flinkbot commented on pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

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

[jira] [Commented] (FLINK-25884) PulsarSourceITCase.testTaskManagerFailure failed on azure

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

[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable application mode on YARN to use usrlib

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

[jira] [Closed] (FLINK-25329) Improvement of execution graph store in flink session cluster for jobs

[ https://issues.apache.org/jira/browse/FLINK-25329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-25329. -- Resolution: Fixed > Improvement of execution graph store in flink session cluster for jobs > -

[jira] [Commented] (FLINK-25329) Improvement of execution graph store in flink session cluster for jobs

[ https://issues.apache.org/jira/browse/FLINK-25329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489334#comment-17489334 ] Yangze Guo commented on FLINK-25329: master: b7984705c45185df171a67392e3177f47086564

[jira] [Commented] (FLINK-25937) SQL Client end-to-end test e2e fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489335#comment-17489335 ] Yun Gao commented on FLINK-25937: - SQL Client end-to-end test: https://dev.azure.com/ap

[jira] [Comment Edited] (FLINK-25329) Improvement of execution graph store in flink session cluster for jobs

[ https://issues.apache.org/jira/browse/FLINK-25329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489334#comment-17489334 ] Yangze Guo edited comment on FLINK-25329 at 2/9/22, 8:05 AM: -

[jira] [Updated] (FLINK-25329) Improvement of execution graph store in flink session cluster for jobs

[ https://issues.apache.org/jira/browse/FLINK-25329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-25329: --- Fix Version/s: 1.15.0 > Improvement of execution graph store in flink session cluster for jobs > ---

[jira] [Updated] (FLINK-26042) PyFlinkEmbeddedSubInterpreterTests. test_udf_without_arguments failed on azure

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

[jira] [Commented] (FLINK-26018) Unnecessary late events when using the new KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-26018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489333#comment-17489333 ] Martijn Visser commented on FLINK-26018: [~qinjunjerry] Just to double check, is

[jira] [Created] (FLINK-26042) PyFlinkEmbeddedSubInterpreterTests. test_udf_without_arguments failed on azure

Yun Gao created FLINK-26042: --- Summary: PyFlinkEmbeddedSubInterpreterTests. test_udf_without_arguments failed on azure Key: FLINK-26042 URL: https://issues.apache.org/jira/browse/FLINK-26042 Project: Flink

[GitHub] [flink] KarmaGYZ closed pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

KarmaGYZ closed pull request #18360: URL: https://github.com/apache/flink/pull/18360 -- 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-unsubs

[jira] [Commented] (FLINK-18575) Failed to send data to Kafka

[ https://issues.apache.org/jira/browse/FLINK-18575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489332#comment-17489332 ] Fangliang Liu commented on FLINK-18575: --- [~mzz_q]  I also encountered this problem

[jira] [Updated] (FLINK-26018) Unnecessary late events when using the new KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-26018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26018: --- Priority: Critical (was: Major) > Unnecessary late events when using the new KafkaSource >

[jira] [Updated] (FLINK-26018) Unnecessary late events when using the new KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-26018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26018: --- Affects Version/s: 1.14.3 > Unnecessary late events when using the new KafkaSource > ---

[jira] [Updated] (FLINK-26018) Unnecessary late events when using the new KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-26018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26018: --- Component/s: Connectors / Kafka > Unnecessary late events when using the new KafkaSource > -

[GitHub] [flink] autophagy opened a new pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

autophagy opened a new pull request #18678: URL: https://github.com/apache/flink/pull/18678 ## What is the purpose of the change The purpose of this change is to configure Flink, by default, to bind the web/REST endpoint to localhost rather than an externally facing network interfac

[jira] [Comment Edited] (FLINK-26036) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489320#comment-17489320 ] Yun Gao edited comment on FLINK-26036 at 2/9/22, 8:02 AM: -- http

[jira] [Created] (FLINK-26041) AbstractTaskManagerProcessFailureRecoveryTest.testTaskManagerProcessFailure hang on azure

Yun Gao created FLINK-26041: --- Summary: AbstractTaskManagerProcessFailureRecoveryTest.testTaskManagerProcessFailure hang on azure Key: FLINK-26041 URL: https://issues.apache.org/jira/browse/FLINK-26041 Proj

[jira] [Commented] (FLINK-25566) Fail to cancel task if disk is bad for java.lang.NoClassDefFoundError

[ https://issues.apache.org/jira/browse/FLINK-25566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489330#comment-17489330 ] Liu commented on FLINK-25566: - [~pnowojski] Thanks for the reply. I agree with you that the

[GitHub] [flink] flinkbot edited a comment on pull request #18677: [FLINK-26032][client] add log info for the status of job submission and execution result.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable application mode on YARN to use usrlib

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

[jira] [Commented] (FLINK-26033) In KafkaConnector, when 'sink.partitioner' is configured as 'round-robin', it does not take effect

[ https://issues.apache.org/jira/browse/FLINK-26033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489329#comment-17489329 ] Martijn Visser commented on FLINK-26033: [~tinny] When reading up in the documen

<    5   6   7   8   9   10