[GitHub] [flink-kubernetes-operator] gyfora opened a new pull request, #437: [FLINK-29609] Shut down JM for terminated applications after configured duration

2022-11-11 Thread GitBox
gyfora opened a new pull request, #437: URL: https://github.com/apache/flink-kubernetes-operator/pull/437 ## What is the purpose of the change Currently Flink 1.15+ application JMs are never shut down after termination. This is not necessary as we only rely on them for one

[GitHub] [flink] zentol commented on pull request #21128: [FLINK-29710] Bump minimum supported Hadoop version to 2.10.2

2022-11-11 Thread GitBox
zentol commented on PR #21128: URL: https://github.com/apache/flink/pull/21128#issuecomment-1311748429 This needs an update: https://github.com/apache/flink/blob/master/flink-yarn-tests/README.md -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-29037) Flink Histogram not emitting sum while using Metrics Reporter

2022-11-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632373#comment-17632373 ] Chesnay Schepler commented on FLINK-29037: -- (and it doesn't make sense to change that because

[jira] [Closed] (FLINK-29037) Flink Histogram not emitting sum while using Metrics Reporter

2022-11-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29037. Resolution: Won't Fix We don't calculate sums for histograms. > Flink Histogram not

[jira] [Commented] (FLINK-29934) maven-assembly-plugin 2.4 make assemble plugin could find xml in flink clients module

2022-11-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632370#comment-17632370 ] Chesnay Schepler commented on FLINK-29934: -- files from other branches that are covered by

[jira] [Updated] (FLINK-27753) Scala suffix checks should check for maven errors

2022-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27753: --- Labels: pull-request-available (was: ) > Scala suffix checks should check for maven errors

[GitHub] [flink] flinkbot commented on pull request #21301: [FLINK-27753][ci] Fail suffix check early if maven failed

2022-11-11 Thread GitBox
flinkbot commented on PR #21301: URL: https://github.com/apache/flink/pull/21301#issuecomment-1311736810 ## CI report: * c0c3c7cd81b86068165ace2bdb8cf1930515bb26 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #357: [FLINK-29922] Support create external table for hive catalog

2022-11-11 Thread GitBox
JingsongLi commented on code in PR #357: URL: https://github.com/apache/flink-table-store/pull/357#discussion_r1020246545 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/TableType.java: ## @@ -0,0 +1,25 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #357: [FLINK-29922] Support create external table for hive catalog

2022-11-11 Thread GitBox
JingsongLi commented on code in PR #357: URL: https://github.com/apache/flink-table-store/pull/357#discussion_r1020246545 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/TableType.java: ## @@ -0,0 +1,25 @@ +/* + * Licensed to the Apache Software

[jira] [Assigned] (FLINK-29977) Kafka connector not compatible with kafka-clients 3.3x

2022-11-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-29977: Assignee: Chesnay Schepler > Kafka connector not compatible with kafka-clients

[GitHub] [flink] zentol commented on pull request #21298: [FLINK-28165][yarn] Inline 'include_hadoop_aws' profile

2022-11-11 Thread GitBox
zentol commented on PR #21298: URL: https://github.com/apache/flink/pull/21298#issuecomment-1311720698 > Can we already do this while https://github.com/apache/flink/pull/21128 is still open? yes; from the pom: > We can add the (test) dependency per default once 2.6 is the

[jira] [Commented] (FLINK-29962) Exclude Jamon 2.3.1

2022-11-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632353#comment-17632353 ] Jingsong Lee commented on FLINK-29962: -- Merged in Flink Table Store master:

[GitHub] [flink-table-store] JingsongLi merged pull request #372: [FLINK-29962] Exclude jamon 2.3.1 from dependencies

2022-11-11 Thread GitBox
JingsongLi merged PR #372: URL: https://github.com/apache/flink-table-store/pull/372 -- 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] [Closed] (FLINK-29994) Update official document about Lookup Join.

2022-11-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29994. Fix Version/s: table-store-0.3.0 Assignee: Hang HOU Resolution: Fixed master:

[GitHub] [flink-table-store] JingsongLi merged pull request #374: [FLINK-29994][Table Store]Fix missing a period in description of Lookup Join.

2022-11-11 Thread GitBox
JingsongLi merged PR #374: URL: https://github.com/apache/flink-table-store/pull/374 -- 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-table-store] JingsongLi commented on pull request #369: [FLINK-29964] Support Spark/Hive with OSS

2022-11-11 Thread GitBox
JingsongLi commented on PR #369: URL: https://github.com/apache/flink-table-store/pull/369#issuecomment-1311702365 https://issues.apache.org/jira/browse/FLINK-3 We can evaluate the difficulty of this solution. If it can be solved, it will be much more elegant than calling

[GitHub] [flink-table-store] JingsongLi commented on pull request #369: [FLINK-29964] Support Spark/Hive with OSS

2022-11-11 Thread GitBox
JingsongLi commented on PR #369: URL: https://github.com/apache/flink-table-store/pull/369#issuecomment-1311698953 > We don't have `admin` access too. There is no `settings`... And I don't think we should add Aliyun remote service dependency for our testing... Other maintainers

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #373: [FLINK-29983] Fix Table Store with Hive3 lacking hive-standalone-metastore dependency

2022-11-11 Thread GitBox
JingsongLi commented on code in PR #373: URL: https://github.com/apache/flink-table-store/pull/373#discussion_r1020216429 ## flink-table-store-hive/pom.xml: ## @@ -83,7 +83,50 @@ under the License. 3 3.1.2 + +

[GitHub] [flink-table-store] JingsongLi commented on pull request #373: [FLINK-29983] Fix Table Store with Hive3 lacking hive-standalone-metastore dependency

2022-11-11 Thread GitBox
JingsongLi commented on PR #373: URL: https://github.com/apache/flink-table-store/pull/373#issuecomment-1311691417 Currently, we are using Hive2.3 Catalog (metastore client) for Hive 3.1, you can see it in `hive.md`: | |Jar| |---|---| |Hive 2.3+|[flink-table-store-hive-catalog-{{<

[jira] [Created] (FLINK-30000) Introduce FileSystemFactory to create FileSystem from custom configuration

2022-11-11 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-3: Summary: Introduce FileSystemFactory to create FileSystem from custom configuration Key: FLINK-3 URL: https://issues.apache.org/jira/browse/FLINK-3 Project:

[jira] [Assigned] (FLINK-29528) Check if core-default-shaded is still required

2022-11-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-29528: Assignee: Chesnay Schepler > Check if core-default-shaded is still required >

[jira] [Closed] (FLINK-26027) Add FLIP-33 metrics to Pulsar connector

2022-11-11 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-26027. - Resolution: Fixed master via 9c970b917bf26beba352e0fa6fa5725debb13e0a > Add FLIP-33 metrics to Pulsar

[GitHub] [flink] tisonkun merged pull request #21249: [FLINK-26027][Connector/Pulsar] Expose Pulsar metrics

2022-11-11 Thread GitBox
tisonkun merged PR #21249: URL: https://github.com/apache/flink/pull/21249 -- 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] tisonkun commented on pull request #21249: [FLINK-26027][Connector/Pulsar] Expose Pulsar metrics

2022-11-11 Thread GitBox
tisonkun commented on PR #21249: URL: https://github.com/apache/flink/pull/21249#issuecomment-1311679395 Merging... @syhily the next time you can push a separate commit so that it can be reviewed easily. Otherwise, it's hard to find the diff by the reviewer. -- This is an

[GitHub] [flink] flinkbot commented on pull request #21300: [FLINK-29423][rest] Remove custom JobDetails serializer

2022-11-11 Thread GitBox
flinkbot commented on PR #21300: URL: https://github.com/apache/flink/pull/21300#issuecomment-1311678241 ## CI report: * 124b0ca84f6359094558ad9fb51e866bb7170125 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] zentol commented on a diff in pull request #21300: [FLINK-29423][rest] Remove custom JobDetails serializer

2022-11-11 Thread GitBox
zentol commented on code in PR #21300: URL: https://github.com/apache/flink/pull/21300#discussion_r1020203806 ## docs/layouts/shortcodes/generated/rest_v1_dispatcher.html: ## @@ -1084,7 +1084,38 @@ "jobs" : { "type" : "array", "items" : { -"type" :

[GitHub] [flink] zentol commented on a diff in pull request #21300: [FLINK-29423][rest] Remove custom JobDetails serializer

2022-11-11 Thread GitBox
zentol commented on code in PR #21300: URL: https://github.com/apache/flink/pull/21300#discussion_r1020202889 ## docs/layouts/shortcodes/generated/rest_v1_dispatcher.html: ## @@ -1084,7 +1084,38 @@ "jobs" : { "type" : "array", "items" : { -"type" :

[GitHub] [flink] syhily commented on pull request #21249: [FLINK-26027][Connector/Pulsar] Expose Pulsar metrics

2022-11-11 Thread GitBox
syhily commented on PR #21249: URL: https://github.com/apache/flink/pull/21249#issuecomment-1311675493 @tisonkun The ci passed. -- 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

[jira] [Updated] (FLINK-29423) JobDetails is incorrect OpenAPI spec

2022-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29423: --- Labels: pull-request-available (was: ) > JobDetails is incorrect OpenAPI spec >

[GitHub] [flink] zentol opened a new pull request, #21300: [FLINK-29423][rest] Remove custom JobDetails serializer

2022-11-11 Thread GitBox
zentol opened a new pull request, #21300: URL: https://github.com/apache/flink/pull/21300 Remove custom serializer so we can properly document the `JobDetails` response. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Comment Edited] (FLINK-29992) Join execution plan parsing error

2022-11-11 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632335#comment-17632335 ] luoyuxia edited comment on FLINK-29992 at 11/11/22 1:00 PM: [~HunterHunter]

[jira] [Commented] (FLINK-29992) Join execution plan parsing error

2022-11-11 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632335#comment-17632335 ] luoyuxia commented on FLINK-29992: -- [~HunterHunter] Thanks for raising it. I'll fix is asap > Join

[GitHub] [flink] MartijnVisser commented on pull request #21298: [FLINK-28165][yarn] Inline 'include_hadoop_aws' profile

2022-11-11 Thread GitBox
MartijnVisser commented on PR #21298: URL: https://github.com/apache/flink/pull/21298#issuecomment-1311661953 Can we already do this while https://github.com/apache/flink/pull/21128 is still open? -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Created] (FLINK-29999) Improve documentation on how a user should migrate from FlinkKafkaConsumer to KafkaSource

2022-11-11 Thread Jing Ge (Jira)
Jing Ge created FLINK-2: --- Summary: Improve documentation on how a user should migrate from FlinkKafkaConsumer to KafkaSource Key: FLINK-2 URL: https://issues.apache.org/jira/browse/FLINK-2

[jira] [Assigned] (FLINK-29999) Improve documentation on how a user should migrate from FlinkKafkaConsumer to KafkaSource

2022-11-11 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-2: --- Assignee: Jing Ge > Improve documentation on how a user should migrate from FlinkKafkaConsumer to

[GitHub] [flink] flinkbot commented on pull request #21299: [FLINK-28427][tests] MiniClusterResource respect explicit rest port configurations

2022-11-11 Thread GitBox
flinkbot commented on PR #21299: URL: https://github.com/apache/flink/pull/21299#issuecomment-1311645194 ## CI report: * 737a70c47b64ffe3d1449e0415610463b691f1c9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-28427) MiniClusterResource should not override rest port settings

2022-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28427: --- Labels: pull-request-available (was: ) > MiniClusterResource should not override rest port

[jira] [Assigned] (FLINK-28427) MiniClusterResource should not override rest port settings

2022-11-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-28427: Assignee: Chesnay Schepler > MiniClusterResource should not override rest port

[GitHub] [flink] zentol opened a new pull request, #21299: [FLINK-28427][tests] MiniClusterResource respect explicit rest port configurations

2022-11-11 Thread GitBox
zentol opened a new pull request, #21299: URL: https://github.com/apache/flink/pull/21299 Allow the user to hard-code a specific port. This can for example be useful for demos. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] flinkbot commented on pull request #21298: [FLINK-28165][yarn] Inline 'include_hadoop_aws' profile

2022-11-11 Thread GitBox
flinkbot commented on PR #21298: URL: https://github.com/apache/flink/pull/21298#issuecomment-1311638973 ## CI report: * 3c3545d5d1bc33855031c4437a511e60e062797c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #21297: [FLINK-24679][conf] Hide secret values from parser error messages

2022-11-11 Thread GitBox
flinkbot commented on PR #21297: URL: https://github.com/apache/flink/pull/21297#issuecomment-1311631690 ## CI report: * aefc2c0247b5996d21c585d5726b9ffb042d46a0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-28165) Remove include_hadoop_aws profile

2022-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28165: --- Labels: pull-request-available (was: ) > Remove include_hadoop_aws profile >

[GitHub] [flink] zentol opened a new pull request, #21298: [FLINK-28165][yarn] Inline 'include_hadoop_aws' profile

2022-11-11 Thread GitBox
zentol opened a new pull request, #21298: URL: https://github.com/apache/flink/pull/21298 With the minimum hadoop version being raised we no longer need to make the dependency on hadoop-aws conditional. -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Assigned] (FLINK-28165) Remove include_hadoop_aws profile

2022-11-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-28165: Assignee: Chesnay Schepler > Remove include_hadoop_aws profile >

[jira] [Updated] (FLINK-24679) Configuration parsing exceptions may leak sensitive data

2022-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24679: --- Labels: pull-request-available (was: ) > Configuration parsing exceptions may leak

[GitHub] [flink] zentol opened a new pull request, #21297: [FLINK-24679][conf] Hide secret values from parser error messages

2022-11-11 Thread GitBox
zentol opened a new pull request, #21297: URL: https://github.com/apache/flink/pull/21297 * if a map/list was malformed we logged the entire value * if a line in the config was malformed we logged the entire line -- This is an automated message from the Apache Git Service. To respond

[jira] [Updated] (FLINK-24679) Configuration parsing exceptions may leak sensitive data

2022-11-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24679: - Fix Version/s: 1.17.0 > Configuration parsing exceptions may leak sensitive data >

[jira] [Assigned] (FLINK-24679) Configuration parsing exceptions may leak sensitive data

2022-11-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-24679: Assignee: Chesnay Schepler > Configuration parsing exceptions may leak sensitive

[jira] [Comment Edited] (FLINK-27962) KafkaSourceReader fails to commit consumer offsets for checkpoints

2022-11-11 Thread Eui Heo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632277#comment-17632277 ] Eui Heo edited comment on FLINK-27962 at 11/11/22 11:56 AM: Hi, [~renqs]. 

[jira] [Commented] (FLINK-27962) KafkaSourceReader fails to commit consumer offsets for checkpoints

2022-11-11 Thread Eui Heo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632277#comment-17632277 ] Eui Heo commented on FLINK-27962: - Hi, [~renqs].  I've had this problem for a long time with 1.14.4 and

[jira] [Assigned] (FLINK-29998) Make the backpressure tab could be sort by the busy percent

2022-11-11 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-29998: Assignee: Yu Chen > Make the backpressure tab could be sort by the busy percent >

[jira] [Created] (FLINK-29998) Make the backpressure tab could be sort by the busy percent

2022-11-11 Thread Yun Tang (Jira)
Yun Tang created FLINK-29998: Summary: Make the backpressure tab could be sort by the busy percent Key: FLINK-29998 URL: https://issues.apache.org/jira/browse/FLINK-29998 Project: Flink Issue

[jira] [Commented] (FLINK-29987) PartialUpdateITCase.testForeignKeyJo is unstable

2022-11-11 Thread Alex Sorokoumov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632274#comment-17632274 ] Alex Sorokoumov commented on FLINK-29987: - As far I understand the flakiness is caused by

[jira] [Created] (FLINK-29997) Link to the taskmanager page in the expired sub-task of checkpoint tab

2022-11-11 Thread Yun Tang (Jira)
Yun Tang created FLINK-29997: Summary: Link to the taskmanager page in the expired sub-task of checkpoint tab Key: FLINK-29997 URL: https://issues.apache.org/jira/browse/FLINK-29997 Project: Flink

[jira] [Assigned] (FLINK-29997) Link to the taskmanager page in the expired sub-task of checkpoint tab

2022-11-11 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-29997: Assignee: Yu Chen > Link to the taskmanager page in the expired sub-task of checkpoint tab >

[jira] [Commented] (FLINK-29986) How to persist flink catalogs configuration?

2022-11-11 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632269#comment-17632269 ] luoyuxia commented on FLINK-29986: -- The short answer is no.  But as a work around, you can prepare a

[jira] [Created] (FLINK-29996) Link to the task manager's thread dump page in the backpressure tab

2022-11-11 Thread Yun Tang (Jira)
Yun Tang created FLINK-29996: Summary: Link to the task manager's thread dump page in the backpressure tab Key: FLINK-29996 URL: https://issues.apache.org/jira/browse/FLINK-29996 Project: Flink

[jira] [Assigned] (FLINK-29996) Link to the task manager's thread dump page in the backpressure tab

2022-11-11 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-29996: Assignee: Yu Chen > Link to the task manager's thread dump page in the backpressure tab >

[jira] [Created] (FLINK-29995) Improve the usability of job analysis for backpressure, expired checkpoints and exceptions

2022-11-11 Thread Yun Tang (Jira)
Yun Tang created FLINK-29995: Summary: Improve the usability of job analysis for backpressure, expired checkpoints and exceptions Key: FLINK-29995 URL: https://issues.apache.org/jira/browse/FLINK-29995

[jira] [Updated] (FLINK-29994) Update official document about Lookup Join.

2022-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29994: --- Labels: pull-request-available (was: ) > Update official document about Lookup Join. >

[GitHub] [flink-table-store] houhang1005 opened a new pull request, #374: [FLINK-29994][Table Store]Fix missing a period in description of Lookup Join.

2022-11-11 Thread GitBox
houhang1005 opened a new pull request, #374: URL: https://github.com/apache/flink-table-store/pull/374 Need to add a period to the description of "lookup.cache-rows". -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink-kubernetes-operator] tisonkun commented on pull request #431: [hotfix] Prevent release branches from deleted and force pushes

2022-11-11 Thread GitBox
tisonkun commented on PR #431: URL: https://github.com/apache/flink-kubernetes-operator/pull/431#issuecomment-1311542914 @gyfora Updated: https://cwiki.apache.org/confluence/pages/diffpagesbyversion.action?pageId=199540570=16=15 -- This is an automated message from the Apache Git

[GitHub] [flink] zentol commented on a diff in pull request #21296: [FLINK-24235][metrics] Only support reporters via factories

2022-11-11 Thread GitBox
zentol commented on code in PR #21296: URL: https://github.com/apache/flink/pull/21296#discussion_r1020105044 ## flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/reporter/InstantiateViaFactory.java: ## @@ -26,14 +26,7 @@ import

[GitHub] [flink] flinkbot commented on pull request #21296: [FLINK-24235][metrics] Only support reporters via factories

2022-11-11 Thread GitBox
flinkbot commented on PR #21296: URL: https://github.com/apache/flink/pull/21296#issuecomment-1311538985 ## CI report: * 97c90cf38fdad8e9cf4763fb84156d874658e465 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] zentol commented on a diff in pull request #21296: [FLINK-24235][metrics] Only support reporters via factories

2022-11-11 Thread GitBox
zentol commented on code in PR #21296: URL: https://github.com/apache/flink/pull/21296#discussion_r1020105044 ## flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/reporter/InstantiateViaFactory.java: ## @@ -26,14 +26,7 @@ import

[jira] [Updated] (FLINK-24235) Only support reporter factories for instantiation

2022-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24235: --- Labels: pull-request-available (was: ) > Only support reporter factories for instantiation

[GitHub] [flink] zentol opened a new pull request, #21296: [FLINK-24235][metrics] Only support reporters via factories

2022-11-11 Thread GitBox
zentol opened a new pull request, #21296: URL: https://github.com/apache/flink/pull/21296 Following the deprecation in 1.16 this PR removes the reflection-based code path for instantiating reporters. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Created] (FLINK-29994) Update official document about Lookup Join.

2022-11-11 Thread Hang HOU (Jira)
Hang HOU created FLINK-29994: Summary: Update official document about Lookup Join. Key: FLINK-29994 URL: https://issues.apache.org/jira/browse/FLINK-29994 Project: Flink Issue Type: Improvement

[GitHub] [flink] alpinegizmo commented on pull request #20070: [FLINK-28202][ci] Generalize utils around shade plugin

2022-11-11 Thread GitBox
alpinegizmo commented on PR #20070: URL: https://github.com/apache/flink/pull/20070#issuecomment-1311513217 I see that the build failed on the spotless check. -- 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-table-store] zjureel commented on pull request #351: [FLINK-28812] Support to read compacted snapshot only

2022-11-11 Thread GitBox
zjureel commented on PR #351: URL: https://github.com/apache/flink-table-store/pull/351#issuecomment-1311506738 Thanks @tsreaper I have updated the codes -- 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

[jira] [Commented] (FLINK-29235) Update SnakeYAML to 1.31

2022-11-11 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632228#comment-17632228 ] Martijn Visser commented on FLINK-29235: [~sergiosp] I've changed the description of the ticket

[jira] [Closed] (FLINK-29235) Update SnakeYAML to 1.31

2022-11-11 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-29235. -- Assignee: Martijn Visser (was: Chesnay Schepler) Resolution: Fixed > Update SnakeYAML

[jira] [Updated] (FLINK-29235) Update SnakeYAML to 1.31

2022-11-11 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29235: --- Description: Flink uses snakeyaml v1.27. flink-shaded uses Jackson 2.12.4, which used

[jira] [Updated] (FLINK-29235) Update SnakeYAML to 1.31

2022-11-11 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29235: --- Description: Flink uses snakeyaml v1.27. flink-shaded uses Jackson 2.12.4, which used

[jira] [Updated] (FLINK-29235) Update SnakeYAML to 1.31

2022-11-11 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29235: --- Summary: Update SnakeYAML to 1.31 (was: CVE-2022-25857 (snakeyaml 1.29)) > Update

[jira] [Comment Edited] (FLINK-29235) Update SnakeYAML to 1.31

2022-11-11 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627076#comment-17627076 ] Martijn Visser edited comment on FLINK-29235 at 11/11/22 9:59 AM: --

[jira] [Created] (FLINK-29993) Provide more convenient way to programmatically configure reporters

2022-11-11 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29993: Summary: Provide more convenient way to programmatically configure reporters Key: FLINK-29993 URL: https://issues.apache.org/jira/browse/FLINK-29993 Project:

[GitHub] [flink] flinkbot commented on pull request #21295: [Typo] Fix the typo 'retriable', which means 'retryable'.

2022-11-11 Thread GitBox
flinkbot commented on PR #21295: URL: https://github.com/apache/flink/pull/21295#issuecomment-1311468867 ## CI report: * 83a726906c327a6824b4913f84fe54fa2bdddf27 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-29992) Join execution plan parsing error

2022-11-11 Thread HunterXHunter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632217#comment-17632217 ] HunterXHunter commented on FLINK-29992: --- This use case is normal in 1.15. > Join execution plan

[jira] [Created] (FLINK-29992) Join execution plan parsing error

2022-11-11 Thread HunterXHunter (Jira)
HunterXHunter created FLINK-29992: - Summary: Join execution plan parsing error Key: FLINK-29992 URL: https://issues.apache.org/jira/browse/FLINK-29992 Project: Flink Issue Type: Bug

[GitHub] [flink] FlechazoW opened a new pull request, #21295: [Typo] Fix the typo 'retriable', which means 'retryable'.

2022-11-11 Thread GitBox
FlechazoW opened a new pull request, #21295: URL: https://github.com/apache/flink/pull/21295 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[jira] [Assigned] (FLINK-29991) KinesisFirehoseSinkTest#firehoseSinkFailsWhenUnableToConnectToRemoteService failed

2022-11-11 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-29991: -- Assignee: Ahmed Hamdy >

[jira] [Closed] (FLINK-23887) Check thread pollution for 1.14

2022-11-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-23887. Resolution: Won't Fix > Check thread pollution for 1.14 > ---

[jira] [Updated] (FLINK-23887) Check thread pollution for 1.14

2022-11-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23887: - Fix Version/s: (was: 1.17.0) > Check thread pollution for 1.14 >

[jira] [Closed] (FLINK-16388) Bump orc-core to 1.4.5

2022-11-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-16388. Fix Version/s: (was: 1.17.0) Resolution: Fixed > Bump orc-core to 1.4.5 >

[jira] [Closed] (FLINK-16958) Bump Hive 2.0.X to 2.0.1

2022-11-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-16958. Resolution: Won't Fix 2.0.x is no longer supported. > Bump Hive 2.0.X to 2.0.1 >

[jira] [Closed] (FLINK-10294) Split MiniClusterResource to be usable in runtime/streaming-java/clients

2022-11-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10294. Resolution: Fixed Got fixed somewhere along the way. > Split MiniClusterResource to be

[jira] [Closed] (FLINK-9667) Scala docs are only generated for flink-scala

2022-11-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9667. --- Resolution: Won't Fix > Scala docs are only generated for flink-scala >

[jira] [Updated] (FLINK-29899) flink-runtime tests fail with exit code 137 returned from Docker

2022-11-11 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29899: --- Affects Version/s: 1.16.0 > flink-runtime tests fail with exit code 137 returned from

[jira] [Updated] (FLINK-29899) flink-runtime tests fail with exit code 137 returned from Docker

2022-11-11 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29899: --- Priority: Critical (was: Major) > flink-runtime tests fail with exit code 137 returned

[jira] [Closed] (FLINK-6490) Explicitly support dynamic defaults in ConfigOption

2022-11-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6490. --- Resolution: Won't Fix > Explicitly support dynamic defaults in ConfigOption >

[jira] [Commented] (FLINK-29899) flink-runtime tests fail with exit code 137 returned from Docker

2022-11-11 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632197#comment-17632197 ] Martijn Visser commented on FLINK-29899:

[jira] [Commented] (FLINK-29899) flink-runtime tests fail with exit code 137 returned from Docker

2022-11-11 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632196#comment-17632196 ] Martijn Visser commented on FLINK-29899:

[jira] [Updated] (FLINK-29862) Upgrade to flink-shaded 16.1

2022-11-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29862: - Summary: Upgrade to flink-shaded 16.1 (was: Upgrade to flink-shaded 16.0) > Upgrade to

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21197: [FLINK-29801] OperatorCoordinator need open the way to operate metric…

2022-11-11 Thread GitBox
zhuzhurk commented on code in PR #21197: URL: https://github.com/apache/flink/pull/21197#discussion_r1020004748 ## flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java: ## @@ -192,10 +193,13 @@ public int

[jira] [Commented] (FLINK-29884) Flaky test failure in finegrained_resource_management/SortMergeResultPartitionTest.testRelease

2022-11-11 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632193#comment-17632193 ] Martijn Visser commented on FLINK-29884:

[jira] [Commented] (FLINK-29991) KinesisFirehoseSinkTest#firehoseSinkFailsWhenUnableToConnectToRemoteService failed

2022-11-11 Thread Ahmed Hamdy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632192#comment-17632192 ] Ahmed Hamdy commented on FLINK-29991: - Hi [~martijnvisser]  Can you assign this to me, I will have a

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

2022-11-11 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632191#comment-17632191 ] Martijn Visser commented on FLINK-18356:

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

2022-11-11 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632190#comment-17632190 ] Martijn Visser commented on FLINK-18356:

[jira] [Commented] (FLINK-29461) ProcessDataStreamStreamingTests.test_process_function unstable

2022-11-11 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632189#comment-17632189 ] Martijn Visser commented on FLINK-29461:

<    1   2   3   4   >