[jira] [Commented] (FLINK-25858) Remove ArchUnit rules for JUnit 4 in ITCaseRules after the JUnit 4->5 migration is closed

2022-10-05 Thread Duncan Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613308#comment-17613308 ] Duncan Chan commented on FLINK-25858: - which task is blocking this one? Please assign it to me. >

[jira] [Commented] (FLINK-28049) Introduce FLIP-208 functionality to stop Source based on consumed records

2022-10-05 Thread Sergey Troshkov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613297#comment-17613297 ] Sergey Troshkov commented on FLINK-28049: - Hi [~afedulov]! I am interested in this issue. I

[jira] [Updated] (FLINK-29513) Update Kafka version to 3.2.3

2022-10-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29513: --- Labels: pull-request-available (was: ) > Update Kafka version to 3.2.3 >

[GitHub] [flink] MartijnVisser commented on pull request #20973: [FLINK-29514][Deployment/YARN] Bump Minikdc to v3.2.4

2022-10-05 Thread GitBox
MartijnVisser commented on PR #20973: URL: https://github.com/apache/flink/pull/20973#issuecomment-1269245937 @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 specific

[GitHub] [flink] MartijnVisser commented on pull request #20972: [FLINK-29513][Connector/Kafka] Update Kafka to version 3.2.3

2022-10-05 Thread GitBox
MartijnVisser commented on PR #20972: URL: https://github.com/apache/flink/pull/20972#issuecomment-1269245496 @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 specific

[GitHub] [flink] MartijnVisser commented on pull request #20170: [FLINK-28405][Connector/Kafka] Update Confluent Platform images used for testing to v7.2.2

2022-10-05 Thread GitBox
MartijnVisser commented on PR #20170: URL: https://github.com/apache/flink/pull/20170#issuecomment-1269244849 @zentol Seems I've finally fixed this so would be great if you could have a final look -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot commented on pull request #20975: [FLINK-29526][state/changelog] fix java doc mistake in SequenceNumber…

2022-10-05 Thread GitBox
flinkbot commented on PR #20975: URL: https://github.com/apache/flink/pull/20975#issuecomment-1269242781 ## CI report: * c66a24b69aeef3692996da9066099f0c6d610a5e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29526) Java doc mistake in SequenceNumberRange#contains()

2022-10-05 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-29526: Description: !image-2022-10-06-10-50-16-927.png|width=554,height=106! Hi [~masteryhx] , It seems

[jira] [Updated] (FLINK-29526) Java doc mistake in SequenceNumberRange#contains()

2022-10-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29526: --- Labels: pull-request-available (was: ) > Java doc mistake in

[GitHub] [flink] zoltar9264 opened a new pull request, #20975: [FLINK-29526][state/changelog] fix java doc mistake in SequenceNumber…

2022-10-05 Thread GitBox
zoltar9264 opened a new pull request, #20975: URL: https://github.com/apache/flink/pull/20975 …Range#contains() ## What is the purpose of the change fix java doc mistake in SequenceNumberRange#contains(), described in

[jira] [Assigned] (FLINK-29523) Support STR_TO_MAP、SUBSTR built-in function in Table API

2022-10-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-29523: --- Assignee: zhangjingcun > Support STR_TO_MAP、SUBSTR built-in function in Table API >

[jira] [Assigned] (FLINK-29522) Support SPLIT_INDEX built-in function in Table API

2022-10-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-29522: --- Assignee: zhangjingcun > Support SPLIT_INDEX built-in function in Table API >

[jira] [Assigned] (FLINK-29525) Support INSTR、LEFT、RIGHT built-in function in Table API

2022-10-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-29525: --- Assignee: zhangjingcun > Support INSTR、LEFT、RIGHT built-in function in Table API >

[jira] [Assigned] (FLINK-29524) Support DECODE、ENCODE built-in function in Table API

2022-10-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-29524: --- Assignee: zhangjingcun > Support DECODE、ENCODE built-in function in Table API >

[jira] [Assigned] (FLINK-29518) Support YEAR、QUARTER、MONTH、WEEK、HOUR、MINUTE、SECOND built-in function in Table API

2022-10-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-29518: --- Assignee: zhangjingcun > Support YEAR、QUARTER、MONTH、WEEK、HOUR、MINUTE、SECOND built-in function in

[jira] [Assigned] (FLINK-29519) Support DAYOFYEAR、DAYOFMONTH built-in function in Table API

2022-10-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-29519: --- Assignee: zhangjingcun > Support DAYOFYEAR、DAYOFMONTH built-in function in Table API >

[jira] [Assigned] (FLINK-29521) Support REVERSE built-in function in Table API

2022-10-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-29521: --- Assignee: zhangjingcun > Support REVERSE built-in function in Table API >

[jira] [Assigned] (FLINK-29520) Support PARSE_URL built-in function in Table API

2022-10-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-29520: --- Assignee: zhangjingcun > Support PARSE_URL built-in function in Table API >

[jira] [Updated] (FLINK-29526) Java doc mistake in SequenceNumberRange#contains()

2022-10-05 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-29526: Priority: Not a Priority (was: Major) > Java doc mistake in SequenceNumberRange#contains() >

[jira] [Created] (FLINK-29526) Java doc mistake in SequenceNumberRange#contains()

2022-10-05 Thread Feifan Wang (Jira)
Feifan Wang created FLINK-29526: --- Summary: Java doc mistake in SequenceNumberRange#contains() Key: FLINK-29526 URL: https://issues.apache.org/jira/browse/FLINK-29526 Project: Flink Issue Type:

[jira] [Commented] (FLINK-29244) Add metric lastMaterializationDuration to ChangelogMaterializationMetricGroup

2022-10-05 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613284#comment-17613284 ] Feifan Wang commented on FLINK-29244: - Thanks [~masteryhx] , I have submit a

[jira] [Created] (FLINK-29525) Support INSTR、LEFT、RIGHT built-in function in Table API

2022-10-05 Thread zhangjingcun (Jira)
zhangjingcun created FLINK-29525: Summary: Support INSTR、LEFT、RIGHT built-in function in Table API Key: FLINK-29525 URL: https://issues.apache.org/jira/browse/FLINK-29525 Project: Flink

[jira] [Created] (FLINK-29524) Support DECODE、ENCODE built-in function in Table API

2022-10-05 Thread zhangjingcun (Jira)
zhangjingcun created FLINK-29524: Summary: Support DECODE、ENCODE built-in function in Table API Key: FLINK-29524 URL: https://issues.apache.org/jira/browse/FLINK-29524 Project: Flink Issue

[jira] [Created] (FLINK-29523) Support STR_TO_MAP、SUBSTR built-in function in Table API

2022-10-05 Thread zhangjingcun (Jira)
zhangjingcun created FLINK-29523: Summary: Support STR_TO_MAP、SUBSTR built-in function in Table API Key: FLINK-29523 URL: https://issues.apache.org/jira/browse/FLINK-29523 Project: Flink

[jira] [Created] (FLINK-29522) Support SPLIT_INDEX built-in function in Table API

2022-10-05 Thread zhangjingcun (Jira)
zhangjingcun created FLINK-29522: Summary: Support SPLIT_INDEX built-in function in Table API Key: FLINK-29522 URL: https://issues.apache.org/jira/browse/FLINK-29522 Project: Flink Issue

[jira] [Created] (FLINK-29521) Support REVERSE built-in function in Table API

2022-10-05 Thread zhangjingcun (Jira)
zhangjingcun created FLINK-29521: Summary: Support REVERSE built-in function in Table API Key: FLINK-29521 URL: https://issues.apache.org/jira/browse/FLINK-29521 Project: Flink Issue Type:

[jira] [Created] (FLINK-29520) Support PARSE_URL built-in function in Table API

2022-10-05 Thread zhangjingcun (Jira)
zhangjingcun created FLINK-29520: Summary: Support PARSE_URL built-in function in Table API Key: FLINK-29520 URL: https://issues.apache.org/jira/browse/FLINK-29520 Project: Flink Issue Type:

[jira] [Created] (FLINK-29519) Support DAYOFYEAR、DAYOFMONTH built-in function in Table API

2022-10-05 Thread zhangjingcun (Jira)
zhangjingcun created FLINK-29519: Summary: Support DAYOFYEAR、DAYOFMONTH built-in function in Table API Key: FLINK-29519 URL: https://issues.apache.org/jira/browse/FLINK-29519 Project: Flink

[jira] [Created] (FLINK-29518) Support YEAR、QUARTER、MONTH、WEEK、HOUR、MINUTE、SECOND built-in function in Table API

2022-10-05 Thread zhangjingcun (Jira)
zhangjingcun created FLINK-29518: Summary: Support YEAR、QUARTER、MONTH、WEEK、HOUR、MINUTE、SECOND built-in function in Table API Key: FLINK-29518 URL: https://issues.apache.org/jira/browse/FLINK-29518

[jira] [Assigned] (FLINK-29517) Support DATE_FORMAT built-in function in Table API

2022-10-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-29517: --- Assignee: zhangjingcun > Support DATE_FORMAT built-in function in Table API >

[jira] [Assigned] (FLINK-29516) Support TIMESTAMPADD built-in function in Table API

2022-10-05 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-29516: --- Assignee: zhangjingcun > Support TIMESTAMPADD built-in function in Table API >

[jira] [Created] (FLINK-29517) Support DATE_FORMAT built-in function in Table API

2022-10-05 Thread zhangjingcun (Jira)
zhangjingcun created FLINK-29517: Summary: Support DATE_FORMAT built-in function in Table API Key: FLINK-29517 URL: https://issues.apache.org/jira/browse/FLINK-29517 Project: Flink Issue

[jira] [Created] (FLINK-29516) Support TIMESTAMPADD built-in function in Table API

2022-10-05 Thread zhangjingcun (Jira)
zhangjingcun created FLINK-29516: Summary: Support TIMESTAMPADD built-in function in Table API Key: FLINK-29516 URL: https://issues.apache.org/jira/browse/FLINK-29516 Project: Flink Issue

[GitHub] [flink] flinkbot commented on pull request #20974: [FLINK-29352]Support CONVERT_TZ built-in function in Table API

2022-10-05 Thread GitBox
flinkbot commented on PR #20974: URL: https://github.com/apache/flink/pull/20974#issuecomment-1269188146 ## CI report: * e9749eb63f7486bb37f5b0ba7286123c21aae9a5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] cun8cun8 opened a new pull request, #20974: [FLINK-29352]Support CONVERT_TZ built-in function in Table API

2022-10-05 Thread GitBox
cun8cun8 opened a new pull request, #20974: URL: https://github.com/apache/flink/pull/20974 ## 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] [Updated] (FLINK-29352) Support CONVERT_TZ built-in function in Table API

2022-10-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29352: --- Labels: pull-request-available (was: ) > Support CONVERT_TZ built-in function in Table API

[GitHub] [flink] cun8cun8 closed pull request #20944: [FLINK-29352]Support CONVERT_TZ built-in function in Table API

2022-10-05 Thread GitBox
cun8cun8 closed pull request #20944: [FLINK-29352]Support CONVERT_TZ built-in function in Table API URL: https://github.com/apache/flink/pull/20944 -- 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

[jira] [Created] (FLINK-29515) Document KafkaSource behavior with deleted topics

2022-10-05 Thread Mason Chen (Jira)
Mason Chen created FLINK-29515: -- Summary: Document KafkaSource behavior with deleted topics Key: FLINK-29515 URL: https://issues.apache.org/jira/browse/FLINK-29515 Project: Flink Issue Type:

[GitHub] [flink] leletan commented on a diff in pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-10-05 Thread GitBox
leletan commented on code in PR #20852: URL: https://github.com/apache/flink/pull/20852#discussion_r988446731 ## flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointTriggerInfo.java: ## @@ -0,0 +1,78 @@ +/* + * Licensed to the Apache

[GitHub] [flink] leletan commented on a diff in pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-10-05 Thread GitBox
leletan commented on code in PR #20852: URL: https://github.com/apache/flink/pull/20852#discussion_r988441596 ## flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointTriggerInfo.java: ## @@ -0,0 +1,78 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot commented on pull request #20973: [FLINK-29514][Deployment/YARN] Bump Minikdc to v3.2.4

2022-10-05 Thread GitBox
flinkbot commented on PR #20973: URL: https://github.com/apache/flink/pull/20973#issuecomment-1269046874 ## CI report: * 133d24a675cc24dc6aab61d50165f96f469c4daa UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29514) Bump Minikdc to v3.2.4

2022-10-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29514: --- Labels: pull-request-available (was: ) > Bump Minikdc to v3.2.4 > -- >

[GitHub] [flink] MartijnVisser opened a new pull request, #20973: [FLINK-29514][Deployment/YARN] Bump Minikdc to v3.2.4

2022-10-05 Thread GitBox
MartijnVisser opened a new pull request, #20973: URL: https://github.com/apache/flink/pull/20973 ## What is the purpose of the change * Bump Minikdc to v3.2.4 to avoid getting falsely flagged as vulnerable for CVEs which don't impact Flink ## Brief change log * Updated

[jira] [Created] (FLINK-29514) Bump Minikdc to v3.2.4

2022-10-05 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-29514: -- Summary: Bump Minikdc to v3.2.4 Key: FLINK-29514 URL: https://issues.apache.org/jira/browse/FLINK-29514 Project: Flink Issue Type: Technical Debt

[jira] [Updated] (FLINK-28405) Update Confluent Platform images to v7.2.2

2022-10-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-28405: --- Description: We have updated the used Kafka Clients to v3.1.1 via FLINK-28060 and then to

[jira] [Updated] (FLINK-28405) Update Confluent Platform images to v7.2.2

2022-10-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-28405: --- Summary: Update Confluent Platform images to v7.2.2 (was: Update Confluent Platform images

[GitHub] [flink] MartijnVisser commented on pull request #20343: [FLINK-25916][connector-kafka] Using upsert-kafka with a flush buffer…

2022-10-05 Thread GitBox
MartijnVisser commented on PR #20343: URL: https://github.com/apache/flink/pull/20343#issuecomment-1265807076 @PatrickRen WDYT? -- 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

[GitHub] [flink] leletan commented on pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-10-05 Thread GitBox
leletan commented on PR #20852: URL: https://github.com/apache/flink/pull/20852#issuecomment-1265689101 Thanks, @pnowojski and @stevenzwu! Combing the feedbacks and here is my plan: 1. fix the build 2. rebase all the changes so far into one commit. 3. do a follow up commit for

[GitHub] [flink] fsk119 commented on a diff in pull request #20931: [FLINK-29486][sql-client] Implement ClientParser for implementing remote SQL client later

2022-10-05 Thread GitBox
fsk119 commented on code in PR #20931: URL: https://github.com/apache/flink/pull/20931#discussion_r985739642 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/parser/ClientParser.java: ## @@ -0,0 +1,137 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] leletan commented on pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-10-05 Thread GitBox
leletan commented on PR #20852: URL: https://github.com/apache/flink/pull/20852#issuecomment-1265618274 @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 specific comment.

[GitHub] [flink] m8719-github commented on pull request #20936: [FLINK-13703][flink-formats/flink-avro] AvroTypeInfo requires objects to be strict POJOs (mutable, with setters)

2022-10-05 Thread GitBox
m8719-github commented on PR #20936: URL: https://github.com/apache/flink/pull/20936#issuecomment-1265589920 @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 specific

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #388: [FLINK-29413] Make it possible to associate triggered and completed savepoints

2022-10-05 Thread GitBox
gyfora merged PR #388: URL: https://github.com/apache/flink-kubernetes-operator/pull/388 -- 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] [Updated] (FLINK-22243) Reactive Mode parallelism changes are not shown in the job graph visualization in the UI

2022-10-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22243: --- Labels: pull-request-available (was: ) > Reactive Mode parallelism changes are not shown

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #388: [FLINK-29413] Make it possible to associate triggered and completed savepoints

2022-10-05 Thread GitBox
morhidi commented on code in PR #388: URL: https://github.com/apache/flink-kubernetes-operator/pull/388#discussion_r985735711 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/Savepoint.java: ## @@ -38,7 +36,42 @@ public class Savepoint

[GitHub] [flink] flinkbot commented on pull request #20941: [FLINK-22243] Sync parallelism in JobGraph with VertexParallelismStore

2022-10-05 Thread GitBox
flinkbot commented on PR #20941: URL: https://github.com/apache/flink/pull/20941#issuecomment-1265412264 ## CI report: * 41b6416c2d22ccd89ec8fafce56fc97a1d4c289a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] dawidwys opened a new pull request, #20941: [FLINK-22243] Sync parallelism in JobGraph with VertexParallelismStore

2022-10-05 Thread GitBox
dawidwys opened a new pull request, #20941: URL: https://github.com/apache/flink/pull/20941 ## What is the purpose of the change In adaptive scheduler the actual parallelism is encoded in the VertexParallelismStore. This has two consequences: 1. The Web UI does not show

[GitHub] [flink-connector-opensearch] reta commented on pull request #1: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors

2022-10-05 Thread GitBox
reta commented on PR #1: URL: https://github.com/apache/flink-connector-opensearch/pull/1#issuecomment-1265396809 @MartijnVisser could you please take a look? thank you :-) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #388: [FLINK-29413] Make it possible to associate triggered and completed savepoints

2022-10-05 Thread GitBox
gyfora commented on code in PR #388: URL: https://github.com/apache/flink-kubernetes-operator/pull/388#discussion_r985699753 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/Savepoint.java: ## @@ -38,7 +36,42 @@ public class Savepoint

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #377: [FLINK-28979] Add owner reference to flink deployment object

2022-10-05 Thread GitBox
gyfora commented on code in PR #377: URL: https://github.com/apache/flink-kubernetes-operator/pull/377#discussion_r985697814 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java: ## @@ -97,6

[GitHub] [flink] yuzelin commented on a diff in pull request #20931: [FLINK-29486][sql-client] Implement ClientParser for implementing remote SQL client later

2022-10-05 Thread GitBox
yuzelin commented on code in PR #20931: URL: https://github.com/apache/flink/pull/20931#discussion_r985673122 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/parser/ClientParser.java: ## @@ -0,0 +1,104 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink-ml] jiangxin369 commented on pull request #158: [FLINK-29409] Add Transformer and Estimator for VarianceThresholdSelector

2022-10-05 Thread GitBox
jiangxin369 commented on PR #158: URL: https://github.com/apache/flink-ml/pull/158#issuecomment-1265316166 > Thanks for the update. Looks good overall. Left just some minor comments. Thanks for your review, the above comments are updated. -- This is an automated message from the

[GitHub] [flink] grzegorz8 commented on a diff in pull request #20140: [Flink 16024][Connector][JDBC] Support FilterPushdown

2022-10-05 Thread GitBox
grzegorz8 commented on code in PR #20140: URL: https://github.com/apache/flink/pull/20140#discussion_r985666582 ## flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownPreparedStatementVisitor.java: ## @@ -0,0 +1,178 @@ +/*

[GitHub] [flink] liuzhuang2017 commented on pull request #20939: [hotfix][docs]Fixed some typos of docs.

2022-10-05 Thread GitBox
liuzhuang2017 commented on PR #20939: URL: https://github.com/apache/flink/pull/20939#issuecomment-1265152795 @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 specific

[GitHub] [flink] dianfu closed pull request #20742: [FLINK-29156]Support LISTAGG in the Table API

2022-10-05 Thread GitBox
dianfu closed pull request #20742: [FLINK-29156]Support LISTAGG in the Table API URL: https://github.com/apache/flink/pull/20742 -- 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.

[GitHub] [flink] yuzelin commented on a diff in pull request #20931: [FLINK-29486][sql-client] Implement ClientParser for implementing remote SQL client later

2022-10-05 Thread GitBox
yuzelin commented on code in PR #20931: URL: https://github.com/apache/flink/pull/20931#discussion_r985409681 ## flink-table/flink-sql-client/pom.xml: ## @@ -511,6 +511,12 @@ under the License. provided + +

[GitHub] [flink] liuzhuang2017 commented on pull request #20940: [hotfix][docs] Fix inaccessible ES links.

2022-10-05 Thread GitBox
liuzhuang2017 commented on PR #20940: URL: https://github.com/apache/flink/pull/20940#issuecomment-1264868739 @MartijnVisser , Sorry to bother you again, can you help me review this pr? Thank you. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot commented on pull request #20940: [hotfix][docs] Fix inaccessible ES links.

2022-10-05 Thread GitBox
flinkbot commented on PR #20940: URL: https://github.com/apache/flink/pull/20940#issuecomment-1264870593 ## CI report: * 87dd4d3845e5f1ce4c3f1da7badf4a6036137f2d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] liuzhuang2017 opened a new pull request, #20940: [hotfix][docs] Fix inaccessible ES links.

2022-10-05 Thread GitBox
liuzhuang2017 opened a new pull request, #20940: URL: https://github.com/apache/flink/pull/20940 ## What is the purpose of the change - Fix inaccessible ES links. ## Brief change log - Fix inaccessible ES links. ## Verifying this change - This

[GitHub] [flink] flinkbot commented on pull request #20939: [hotfix][docs]Fixed some typos of docs.

2022-10-05 Thread GitBox
flinkbot commented on PR #20939: URL: https://github.com/apache/flink/pull/20939#issuecomment-1264814652 ## CI report: * b5f403ceb76893a5e477159d87a11bbf56f6a04b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] liuzhuang2017 opened a new pull request, #20939: [hotfix][docs]Fixed some typos of docs.

2022-10-05 Thread GitBox
liuzhuang2017 opened a new pull request, #20939: URL: https://github.com/apache/flink/pull/20939 ## What is the purpose of the change - Fixed some typos of docs. ## Brief change log - Fixed some typos of docs. ## Verifying this change - This

[GitHub] [flink] liuzhuang2017 commented on pull request #20939: [hotfix][docs]Fixed some typos of docs.

2022-10-05 Thread GitBox
liuzhuang2017 commented on PR #20939: URL: https://github.com/apache/flink/pull/20939#issuecomment-1264811207 @MartijnVisser , Sorry to bother you again, can you help me review this pr? Thank you. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] liuzhuang2017 commented on pull request #20938: [hotfix][table] Add the `dayofweek` function description.

2022-10-05 Thread GitBox
liuzhuang2017 commented on PR #20938: URL: https://github.com/apache/flink/pull/20938#issuecomment-1264770996 @wuchong ,Can you help me review this pr?Thank you very much. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] yuzelin commented on a diff in pull request #20931: [FLINK-29486][sql-client] Implement ClientParser for implementing remote SQL client later

2022-10-05 Thread GitBox
yuzelin commented on code in PR #20931: URL: https://github.com/apache/flink/pull/20931#discussion_r985271871 ## flink-table/flink-sql-client/pom.xml: ## @@ -511,6 +511,12 @@ under the License. provided + +

[GitHub] [flink] fsk119 commented on a diff in pull request #20931: [FLINK-29486][sql-client] Implement ClientParser for implementing remote SQL client later

2022-10-05 Thread GitBox
fsk119 commented on code in PR #20931: URL: https://github.com/apache/flink/pull/20931#discussion_r985252646 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/parser/StatementType.java: ## @@ -0,0 +1,30 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] flinkbot commented on pull request #20938: [hotfix][table] Add the `dayofweek` function description.

2022-10-05 Thread GitBox
flinkbot commented on PR #20938: URL: https://github.com/apache/flink/pull/20938#issuecomment-1264670040 ## CI report: * 1415776206501369c0bf1ca29fc2d430aabb916f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] liuzhuang2017 opened a new pull request, #20938: [hotfix][table] Add the `dayofweek` function description.

2022-10-05 Thread GitBox
liuzhuang2017 opened a new pull request, #20938: URL: https://github.com/apache/flink/pull/20938 ## What is the purpose of the change - Add the `dayofweek` function description. ## Brief change log - Add the `dayofweek` function description. ##

[jira] [Created] (FLINK-29513) Update Kafka version to 3.2.3

2022-10-05 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-29513: -- Summary: Update Kafka version to 3.2.3 Key: FLINK-29513 URL: https://issues.apache.org/jira/browse/FLINK-29513 Project: Flink Issue Type: Technical Debt

[jira] [Commented] (FLINK-25916) Using upsert-kafka with a flush buffer results in Null Pointer Exception

2022-10-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613117#comment-17613117 ] Martijn Visser commented on FLINK-25916: [~jjimenezMM] [~mhv] That's because no maintainers has

[jira] [Commented] (FLINK-29501) Allow overriding JobVertex parallelisms during job submission

2022-10-05 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613080#comment-17613080 ] Maximilian Michels commented on FLINK-29501: {quote}I don't really follow. Will you suspend

[jira] [Commented] (FLINK-9171) Flink HCatolog integration

2022-10-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613068#comment-17613068 ] Martijn Visser commented on FLINK-9171: --- I've opened a discussion thread to remove the HCatalog

[jira] [Closed] (FLINK-26622) Azure failed due to Connection timed out

2022-10-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-26622. -- Resolution: Cannot Reproduce > Azure failed due to Connection timed out >

[jira] [Updated] (FLINK-29511) Sort properties/schemas in OpenAPI spec

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29511: - Description: The properties/schema order is currently based on whatever order they were

[jira] [Updated] (FLINK-29511) Sort properties/schemas in OpenAPI spec

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29511: - Summary: Sort properties/schemas in OpenAPI spec (was: Sort properties in OpenAPI

[jira] [Created] (FLINK-29512) Align SubtaskCommittableManager checkpointId with CheckpointCommittableManagerImpl checkpointId during recovery

2022-10-05 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-29512: --- Summary: Align SubtaskCommittableManager checkpointId with CheckpointCommittableManagerImpl checkpointId during recovery Key: FLINK-29512 URL:

[jira] [Updated] (FLINK-29511) Sort properties in OpenAPI spec

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29511: - Description: The properties order is currently based on whatever order properties were

[jira] [Created] (FLINK-29511) Sort properties in OpenAPI spec

2022-10-05 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29511: Summary: Sort properties in OpenAPI spec Key: FLINK-29511 URL: https://issues.apache.org/jira/browse/FLINK-29511 Project: Flink Issue Type:

[jira] [Closed] (FLINK-29456) Add methods that accept OperatorIdentifier

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29456. Resolution: Fixed master: 8d72490377551a35851a3319c0f49b408d31a566 > Add methods that

[jira] [Updated] (FLINK-25916) Using upsert-kafka with a flush buffer results in Null Pointer Exception

2022-10-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25916: --- Priority: Critical (was: Major) > Using upsert-kafka with a flush buffer results in Null

[jira] [Closed] (FLINK-29499) DispatcherOperationCaches should implement AutoCloseableAsync

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29499. Resolution: Fixed master: 3730e24cc4283f877ac35b189dff355579d1de68 >

[jira] [Closed] (FLINK-26469) Adaptive job shows error in WebUI when not enough resource are available

2022-10-05 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-26469. Fix Version/s: 1.17.0 1.15.3 1.16.1

[jira] [Created] (FLINK-29510) Add NoticeFileChecker tests

2022-10-05 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29510: Summary: Add NoticeFileChecker tests Key: FLINK-29510 URL: https://issues.apache.org/jira/browse/FLINK-29510 Project: Flink Issue Type: Technical

[jira] [Commented] (FLINK-29459) Sink v2 has bugs in supporting legacy v1 implementations with global committer

2022-10-05 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612982#comment-17612982 ] Fabian Paul commented on FLINK-29459: - It also looks like the first and second point are the same

[jira] [Commented] (FLINK-29459) Sink v2 has bugs in supporting legacy v1 implementations with global committer

2022-10-05 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612980#comment-17612980 ] Fabian Paul commented on FLINK-29459: - [~gaoyunhaii] thanks for your analysis. I am currently

[jira] [Resolved] (FLINK-27938) [JUnit5 Migration] Module: flink-connector-hbase-base

2022-10-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-27938. --- Fix Version/s: 1.17.0 Resolution: Fixed master:

[jira] [Assigned] (FLINK-27938) [JUnit5 Migration] Module: flink-connector-hbase-base

2022-10-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-27938: - Assignee: Sergey Nuyanzin > [JUnit5 Migration] Module: flink-connector-hbase-base >

[jira] [Created] (FLINK-29509) Set correct subtaskId during recovery of committables

2022-10-05 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-29509: --- Summary: Set correct subtaskId during recovery of committables Key: FLINK-29509 URL: https://issues.apache.org/jira/browse/FLINK-29509 Project: Flink Issue

[jira] [Updated] (FLINK-27942) [JUnit5 Migration] Module: flink-connector-rabbitmq

2022-10-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-27942: -- Fix Version/s: 1.17.0 > [JUnit5 Migration] Module: flink-connector-rabbitmq >

[jira] [Resolved] (FLINK-27942) [JUnit5 Migration] Module: flink-connector-rabbitmq

2022-10-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-27942. --- Resolution: Fixed master: d191bda7e63a2c12416cba56090e5cd75426079b > [JUnit5 Migration]

[jira] [Commented] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs

2022-10-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612972#comment-17612972 ] Matthias Pohl commented on FLINK-29419: ---

[jira] [Created] (FLINK-29508) Some NOTICE files are not checked for correctness

2022-10-05 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29508: Summary: Some NOTICE files are not checked for correctness Key: FLINK-29508 URL: https://issues.apache.org/jira/browse/FLINK-29508 Project: Flink

  1   2   >