[jira] [Reopened] (FLINK-26681) Support sql statement end with ";" for Hive dialect

2022-04-12 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang reopened FLINK-26681: > Support sql statement end with ";" for Hive dialect > --

[jira] [Commented] (FLINK-26681) Support sql statement end with ";" for Hive dialect

2022-04-12 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521055#comment-17521055 ] Jing Zhang commented on FLINK-26681: I'm sorry to merge it late. > Support sql stat

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on pull request #165: [FLINK-26140] Support rollback strategies

2022-04-12 Thread GitBox
wangyang0918 commented on PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#issuecomment-1096485474 I agree we could have the rollback related configs in `flinkConfiguration`. If it is really necessary, it could be added to the CRD in the future. -- This is an a

[GitHub] [flink] XComp commented on a diff in pull request #19427: [FLINK-27140][coordination] Write job result in ioExecutor

2022-04-12 Thread GitBox
XComp commented on code in PR #19427: URL: https://github.com/apache/flink/pull/19427#discussion_r848244397 ## flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java: ## @@ -420,7 +420,7 @@ public void testCancellationOfCanceledTerminalDoesNotThrowE

[jira] [Comment Edited] (FLINK-26681) Support sql statement end with ";" for Hive dialect

2022-04-12 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521055#comment-17521055 ] Jing Zhang edited comment on FLINK-26681 at 4/12/22 10:04 AM:

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #165: [FLINK-26140] Support rollback strategies

2022-04-12 Thread GitBox
gyfora commented on PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#issuecomment-1096490074 @Aitozi @wangyang0918 I think at this point most new configs/features should probably go straight to `flinkConfiguration` We should aim to keep the CRD slim and only kee

[jira] [Assigned] (FLINK-27023) Merge default flink and operator configuration settings for the operator

2022-04-12 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-27023: -- Assignee: (was: Nicholas Jiang) > Merge default flink and operator configuration settings

[jira] [Commented] (FLINK-27121) Translate "Configuration#overview" paragraph and the code example in "Application Development > Table API & SQL" to Chinese

2022-04-12 Thread Marios Trivyzas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521057#comment-17521057 ] Marios Trivyzas commented on FLINK-27121: - [~MartijnVisser] Could you please tak

[jira] [Commented] (FLINK-27023) Merge default flink and operator configuration settings for the operator

2022-04-12 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521059#comment-17521059 ] Gyula Fora commented on FLINK-27023: [~nicholasjiang] I unassigned the ticket from y

[GitHub] [flink-kubernetes-operator] Aitozi commented on pull request #164: [FLINK-26871] Handle session job spec change

2022-04-12 Thread GitBox
Aitozi commented on PR #164: URL: https://github.com/apache/flink-kubernetes-operator/pull/164#issuecomment-1096518676 Force pushed to resolve conflicts -- 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 t

[GitHub] [flink] zentol commented on a diff in pull request #19427: [FLINK-27140][coordination] Write job result in ioExecutor

2022-04-12 Thread GitBox
zentol commented on code in PR #19427: URL: https://github.com/apache/flink/pull/19427#discussion_r848287320 ## flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java: ## @@ -420,7 +420,7 @@ public void testCancellationOfCanceledTerminalDoesNotThrow

[GitHub] [flink] zentol commented on a diff in pull request #19427: [FLINK-27140][coordination] Write job result in ioExecutor

2022-04-12 Thread GitBox
zentol commented on code in PR #19427: URL: https://github.com/apache/flink/pull/19427#discussion_r848295455 ## flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java: ## @@ -1215,15 +1241,10 @@ private CompletableFuture waitForTerminatingJob(

[jira] [Updated] (FLINK-26681) Support sql statement end with ";" for Hive dialect

2022-04-12 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-26681: --- Priority: Blocker (was: Major) > Support sql statement end with ";" for Hive dialect >

[jira] [Commented] (FLINK-26811) Document CRD upgrade process

2022-04-12 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521076#comment-17521076 ] Gyula Fora commented on FLINK-26811: Hi [~tedhtchang]  I think what you are looking

[jira] [Updated] (FLINK-26681) Support sql statement end with ";" for Hive dialect

2022-04-12 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26681: Fix Version/s: 1.15.0 (was: 1.15.1) > Support sql statement end with ";" for Hive d

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #165: [FLINK-26140] Support rollback strategies

2022-04-12 Thread GitBox
gyfora commented on PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#issuecomment-1096579979 @Aitozi I actually also introduced a two step rollback logic here, first marking with `ROLLING_BACK` in order to allow dealing with errors during the rollback process.

[jira] [Commented] (FLINK-26822) Add Source implementation for Cassandra connector

2022-04-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521080#comment-17521080 ] Chesnay Schepler commented on FLINK-26822: -- Could we first upgrade the sink to

[GitHub] [flink] XComp commented on a diff in pull request #19427: [FLINK-27140][coordination] Write job result in ioExecutor

2022-04-12 Thread GitBox
XComp commented on code in PR #19427: URL: https://github.com/apache/flink/pull/19427#discussion_r848312679 ## flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java: ## @@ -1215,15 +1241,10 @@ private CompletableFuture waitForTerminatingJob(

[jira] [Commented] (FLINK-26977) JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithRestartsShouldSimplyRestartInTerminate failed on azure

2022-04-12 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521081#comment-17521081 ] Dawid Wysakowicz commented on FLINK-26977: -- I'll take over as I missed this tes

[jira] [Comment Edited] (FLINK-26783) Restore from a stop-with-savepoint if failed during committing

2022-04-12 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513448#comment-17513448 ] Dawid Wysakowicz edited comment on FLINK-26783 at 4/12/22 11:13 AM: --

[GitHub] [flink] slinkydeveloper commented on pull request #19025: [FLINK-26553][build] Configure scalafmt

2022-04-12 Thread GitBox
slinkydeveloper commented on PR #19025: URL: https://github.com/apache/flink/pull/19025#issuecomment-1096591741 @twalthr I checked a bit and I couldn't find for both of the two problems you raised a solution in the configuraiton https://scalameta.org/scalafmt/docs/configuration.html. About

[jira] [Assigned] (FLINK-25806) Remove legacy high availability services

2022-04-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-25806: Assignee: Chesnay Schepler > Remove legacy high availability services > -

[jira] [Assigned] (FLINK-26977) JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithRestartsShouldSimplyRestartInTerminate failed on azure

2022-04-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-26977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek reassigned FLINK-26977: - Assignee: Dawid Wysakowicz (was: David Morávek) > JobMasterStopWithSavepointITCase.thr

[jira] [Updated] (FLINK-27127) Local recovery is not triggered on task manager process restart

2022-04-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-27127: - Description: Hey, I am experimenting with the support of local recovery after process r

[GitHub] [flink] flinkbot commented on pull request #19438: [FLINK-25806][ha] Remove legacy HA services

2022-04-12 Thread GitBox
flinkbot commented on PR #19438: URL: https://github.com/apache/flink/pull/19438#issuecomment-1096601088 ## CI report: * 248c0b5d5c429cb3ca4b99f3f8f90a046b58d01d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-25806) Remove legacy high availability services

2022-04-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25806: --- Labels: pull-request-available (was: ) > Remove legacy high availability services > ---

[jira] [Assigned] (FLINK-27155) Reduce multiple reads to the same Changelog file in the same taskmanager during restore

2022-04-12 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-27155: - Assignee: Feifan Wang > Reduce multiple reads to the same Changelog file in the

[jira] [Updated] (FLINK-27155) Reduce multiple reads to the same Changelog file in the same taskmanager during restore

2022-04-12 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-27155: -- Component/s: (was: Runtime / Checkpointing) > Reduce multiple reads to the same Ch

[jira] [Commented] (FLINK-27155) Reduce multiple reads to the same Changelog file in the same taskmanager during restore

2022-04-12 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521085#comment-17521085 ] Roman Khachatryan commented on FLINK-27155: --- Thanks a lot [~Feifan Wang]! I'v

[jira] [Updated] (FLINK-27155) Reduce multiple reads to the same Changelog file in the same taskmanager during restore

2022-04-12 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-27155: -- Fix Version/s: 1.16.0 > Reduce multiple reads to the same Changelog file in the same t

[jira] [Updated] (FLINK-27186) support ElasticSearch 8

2022-04-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27186: --- Priority: Major (was: Critical) > support ElasticSearch 8 > --- > >

[jira] [Updated] (FLINK-27186) support ElasticSearch 8

2022-04-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27186: --- Issue Type: New Feature (was: Improvement) > support ElasticSearch 8 >

[jira] [Commented] (FLINK-27186) support ElasticSearch 8

2022-04-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521088#comment-17521088 ] Martijn Visser commented on FLINK-27186: [~macdoor615] The Elasticsearch upgrade

[GitHub] [flink] Thesharing commented on a diff in pull request #19275: [FLINK-24491][runtime] Make the job termination wait until the archiving of ExecutionGraphInfo finishes

2022-04-12 Thread GitBox
Thesharing commented on code in PR #19275: URL: https://github.com/apache/flink/pull/19275#discussion_r848274651 ## flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java: ## @@ -421,6 +421,8 @@ public void testCancellationOfCanceledTerminalDoesNotT

[GitHub] [flink] RyanSkraba commented on pull request #18823: [FLINK-20625][pubsub,e2e] Add PubSubSource connector using FLIP-27

2022-04-12 Thread GitBox
RyanSkraba commented on PR #18823: URL: https://github.com/apache/flink/pull/18823#issuecomment-1096626684 Hello! I **have** been working on two specific Pub/Sub things (1) updating unit tests here and (2) the FLIP-143 unified sink API version. I'm currently on vacation :beach_umbrella:

[GitHub] [flink] XComp commented on a diff in pull request #19427: [FLINK-27140][coordination] Write job result in ioExecutor

2022-04-12 Thread GitBox
XComp commented on code in PR #19427: URL: https://github.com/apache/flink/pull/19427#discussion_r848349135 ## flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java: ## @@ -420,7 +420,7 @@ public void testCancellationOfCanceledTerminalDoesNotThrowE

[jira] [Closed] (FLINK-26681) Support sql statement end with ";" for Hive dialect

2022-04-12 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang closed FLINK-26681. -- Resolution: Fixed > Support sql statement end with ";" for Hive dialect >

[GitHub] [flink] dawidwys opened a new pull request, #19439: [FLINK-26977] Remove no longer valid tests in JobMasterStopWithSavepointITCase

2022-04-12 Thread GitBox
dawidwys opened a new pull request, #19439: URL: https://github.com/apache/flink/pull/19439 ## What is the purpose of the change Tests in JobMasterStopWithSavepointITCase are no longer valid. In particular the way number of restarts is calculated is wrong. Moreover cases that

[jira] [Updated] (FLINK-26977) JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithRestartsShouldSimplyRestartInTerminate failed on azure

2022-04-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26977: --- Labels: pull-request-available test-stability (was: test-stability) > JobMasterStopWithSave

[GitHub] [flink] flinkbot commented on pull request #19439: [FLINK-26977] Remove no longer valid tests in JobMasterStopWithSavepointITCase

2022-04-12 Thread GitBox
flinkbot commented on PR #19439: URL: https://github.com/apache/flink/pull/19439#issuecomment-1096646782 ## CI report: * 074f6c3279b9d355e3bd11e96f313f232109f69c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] zentol commented on a diff in pull request #19275: [FLINK-24491][runtime] Make the job termination wait until the archiving of ExecutionGraphInfo finishes

2022-04-12 Thread GitBox
zentol commented on code in PR #19275: URL: https://github.com/apache/flink/pull/19275#discussion_r848367225 ## flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java: ## @@ -1103,23 +1095,60 @@ private void archiveExecutionGraph(ExecutionGraphInfo exec

[GitHub] [flink] XComp commented on pull request #19427: [FLINK-27140][coordination] Write job result in ioExecutor

2022-04-12 Thread GitBox
XComp commented on PR #19427: URL: https://github.com/apache/flink/pull/19427#issuecomment-1096667718 Ah, one more thing, I just remembered: We could also make the marking `markJobAsClean` call in [Dispatcher#removeJob:991](https://github.com/apache/flink/blob/5aaa075d585d0d71e15067ee91f846

[jira] [Commented] (FLINK-26822) Add Source implementation for Cassandra connector

2022-04-12 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521126#comment-17521126 ] Etienne Chauchot commented on FLINK-26822: -- [~chesnay] sure 4.x is indeed a nee

[GitHub] [flink] zentol commented on a diff in pull request #19427: [FLINK-27140][coordination] Write job result in ioExecutor

2022-04-12 Thread GitBox
zentol commented on code in PR #19427: URL: https://github.com/apache/flink/pull/19427#discussion_r848401132 ## flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java: ## @@ -420,7 +420,7 @@ public void testCancellationOfCanceledTerminalDoesNotThrow

[GitHub] [flink] zentol commented on a diff in pull request #19427: [FLINK-27140][coordination] Write job result in ioExecutor

2022-04-12 Thread GitBox
zentol commented on code in PR #19427: URL: https://github.com/apache/flink/pull/19427#discussion_r848401132 ## flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java: ## @@ -420,7 +420,7 @@ public void testCancellationOfCanceledTerminalDoesNotThrow

[GitHub] [flink] slinkydeveloper commented on a diff in pull request #19190: [FLINK-13785][table] Port time functions to new type inference

2022-04-12 Thread GitBox
slinkydeveloper commented on code in PR #19190: URL: https://github.com/apache/flink/pull/19190#discussion_r848403874 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/TemporalOverlapsInputTypeStrategy.java: ## @@ -0,0 +1,118 @@ +/

[GitHub] [flink] zentol commented on pull request #19427: [FLINK-27140][coordination] Write job result in ioExecutor

2022-04-12 Thread GitBox
zentol commented on PR #19427: URL: https://github.com/apache/flink/pull/19427#issuecomment-1096698931 > Ah, one more thing, I just remembered: We could also make the marking markJobAsClean call [...] be executed by the ioExecutor, couldn't we? Done. Although I am wondering whe

[GitHub] [flink] hehuiyuan commented on a diff in pull request #19423: [FLINK-27175][hive] Support to call Hive UDAF when the UDAF accepts one parameter with array type

2022-04-12 Thread GitBox
hehuiyuan commented on code in PR #19423: URL: https://github.com/apache/flink/pull/19423#discussion_r848413211 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDAF.java: ## @@ -105,6 +108,8 @@ private void init() throws Hi

[GitHub] [flink] hehuiyuan commented on a diff in pull request #19423: [FLINK-27175][hive] Support to call Hive UDAF when the UDAF accepts one parameter with array type

2022-04-12 Thread GitBox
hehuiyuan commented on code in PR #19423: URL: https://github.com/apache/flink/pull/19423#discussion_r848413211 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDAF.java: ## @@ -105,6 +108,8 @@ private void init() throws Hi

[GitHub] [flink] hehuiyuan commented on a diff in pull request #19423: [FLINK-27175][hive] Support to call Hive UDAF when the UDAF accepts one parameter with array type

2022-04-12 Thread GitBox
hehuiyuan commented on code in PR #19423: URL: https://github.com/apache/flink/pull/19423#discussion_r848413211 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDAF.java: ## @@ -105,6 +108,8 @@ private void init() throws Hi

[GitHub] [flink] XComp commented on pull request #19427: [FLINK-27140][coordination] Write job result in ioExecutor

2022-04-12 Thread GitBox
XComp commented on PR #19427: URL: https://github.com/apache/flink/pull/19427#issuecomment-1096706765 Valid point. I created FLINK-27204 to cover this topic. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abov

[jira] [Created] (FLINK-27204) FileSystemJobResultStore should operator on the ioExecutor

2022-04-12 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-27204: - Summary: FileSystemJobResultStore should operator on the ioExecutor Key: FLINK-27204 URL: https://issues.apache.org/jira/browse/FLINK-27204 Project: Flink

[GitHub] [flink] zoltar9264 opened a new pull request, #19441: [FLINK-27187][state/changelog] Add changelog storage metric totalAttemptsPerUpload

2022-04-12 Thread GitBox
zoltar9264 opened a new pull request, #19441: URL: https://github.com/apache/flink/pull/19441 ## What is the purpose of the change As [FLINK-27187](https://issues.apache.org/jira/browse/FLINK-27187) discussed, add changelog storage metric "totalAttemptsPerUpload" representing the tot

[jira] [Updated] (FLINK-27187) The attemptsPerUpload metric may be lower than it actually is

2022-04-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27187: --- Labels: pull-request-available (was: ) > The attemptsPerUpload metric may be lower than it

[GitHub] [flink] flinkbot commented on pull request #19440: [1.15][FLINK-26616][tests] Remove deadlines from CommonTestUtils

2022-04-12 Thread GitBox
flinkbot commented on PR #19440: URL: https://github.com/apache/flink/pull/19440#issuecomment-1096717246 ## CI report: * 4773b61b7c9cd9882ccad22b72a09afe3f5eb8f1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #19441: [FLINK-27187][state/changelog] Add changelog storage metric totalAttemptsPerUpload

2022-04-12 Thread GitBox
flinkbot commented on PR #19441: URL: https://github.com/apache/flink/pull/19441#issuecomment-1096717465 ## CI report: * eec54f3f0d7c6eb33d0bc1d22910e1857bf1ee23 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-27187) The attemptsPerUpload metric may be lower than it actually is

2022-04-12 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521140#comment-17521140 ] Feifan Wang commented on FLINK-27187: - Thanks [~roman] , I've opened a pr to address

[jira] [Comment Edited] (FLINK-27101) Periodically break the chain of incremental checkpoint

2022-04-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521141#comment-17521141 ] Piotr Nowojski edited comment on FLINK-27101 at 4/12/22 1:18 PM: -

[jira] [Commented] (FLINK-27101) Periodically break the chain of incremental checkpoint

2022-04-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521141#comment-17521141 ] Piotr Nowojski commented on FLINK-27101: What do you have in mind to be pluggabl

[jira] [Created] (FLINK-27205) Translate "Concepts -> Glossary" page into Chinese

2022-04-12 Thread Zhuang Liu (Jira)
Zhuang Liu created FLINK-27205: --- Summary: Translate "Concepts -> Glossary" page into Chinese Key: FLINK-27205 URL: https://issues.apache.org/jira/browse/FLINK-27205 Project: Flink Issue Type:

[GitHub] [flink] slinkydeveloper commented on a diff in pull request #19190: [FLINK-13785][table] Port time functions to new type inference

2022-04-12 Thread GitBox
slinkydeveloper commented on code in PR #19190: URL: https://github.com/apache/flink/pull/19190#discussion_r848435418 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ExtractInputTypeStrategy.java: ## @@ -0,0 +1,102 @@ +/* + * Lic

[jira] [Commented] (FLINK-27205) Translate "Concepts -> Glossary" page into Chinese

2022-04-12 Thread Zhuang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521149#comment-17521149 ] Zhuang Liu commented on FLINK-27205: - [~yunta],[~jark],Hi,I think I could help to t

[jira] [Updated] (FLINK-26446) Update Feature Radar in Apache Flink Roadmap

2022-04-12 Thread Joe Moser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Moser updated FLINK-26446: -- Attachment: flink_feature_radar_3.png > Update Feature Radar in Apache Flink Roadmap > --

[jira] [Commented] (FLINK-26446) Update Feature Radar in Apache Flink Roadmap

2022-04-12 Thread Joe Moser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521161#comment-17521161 ] Joe Moser commented on FLINK-26446: --- I'm just upgrading the graphics. Based on your c

[GitHub] [flink] whitecloud6688 opened a new pull request, #19442: NULL语法支持

2022-04-12 Thread GitBox
whitecloud6688 opened a new pull request, #19442: URL: https://github.com/apache/flink/pull/19442 ## What is the purpose of the change 请支持类似以下语法: select if(1>2,1,NULL) as col1; select NULL as col1; ## Brief change log 需要将 NULL 赋值给一个字段,然后写入表,但报语法错误。版本:FLINK-1.13.6。 Flink

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

2022-04-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24235: - Fix Version/s: 1.17.0 (was: 1.15.0) > Only support reporter facto

[jira] [Created] (FLINK-27206) Deprecate reflection-based reporter instantiation

2022-04-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-27206: Summary: Deprecate reflection-based reporter instantiation Key: FLINK-27206 URL: https://issues.apache.org/jira/browse/FLINK-27206 Project: Flink Iss

[GitHub] [flink] zentol opened a new pull request, #19444: [FLINK-27206][metrics] Deprecate reflection-based reporter instantiation

2022-04-12 Thread GitBox
zentol opened a new pull request, #19444: URL: https://github.com/apache/flink/pull/19444 Based on #17228. Metric reporters can currently be instantiated in one of 2 ways: a) the reporter class is loaded via reflection b) the reporter factory is loaded via reflection/ServiceLoade

[GitHub] [flink] flinkbot commented on pull request #19442: NULL语法支持

2022-04-12 Thread GitBox
flinkbot commented on PR #19442: URL: https://github.com/apache/flink/pull/19442#issuecomment-1096774398 ## CI report: * dbfe5da2a2bc4564a1cf715a918299d107758b6c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] zentol closed pull request #19442: NULL语法支持

2022-04-12 Thread GitBox
zentol closed pull request #19442: NULL语法支持 URL: https://github.com/apache/flink/pull/19442 -- 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-unsub

[jira] [Updated] (FLINK-27206) Deprecate reflection-based reporter instantiation

2022-04-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27206: --- Labels: pull-request-available (was: ) > Deprecate reflection-based reporter instantiation

[GitHub] [flink] flinkbot commented on pull request #19443: [FLINK-25269][rest] Return 503 if rpc endpoint is not started

2022-04-12 Thread GitBox
flinkbot commented on PR #19443: URL: https://github.com/apache/flink/pull/19443#issuecomment-1096782791 ## CI report: * 07c2f0d0beffd7545cae1dc8939a5367895f5362 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #19444: [FLINK-27206][metrics] Deprecate reflection-based reporter instantiation

2022-04-12 Thread GitBox
flinkbot commented on PR #19444: URL: https://github.com/apache/flink/pull/19444#issuecomment-1096783029 ## CI report: * af76914771ef4923660e43c30b1eef449776b544 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-25269) Return 503 Service Unavailable if endpoint is not ready yet

2022-04-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25269: --- Labels: pull-request-available stale-assigned test-stability (was: stale-assigned test-stab

[jira] [Assigned] (FLINK-26762) Add the overdraft buffer in BufferPool to reduce unaligned checkpoint being blocked

2022-04-12 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-26762: - Assignee: fanrui > Add the overdraft buffer in BufferPool to reduce unaligned c

[GitHub] [flink] hehuiyuan commented on a diff in pull request #19423: [FLINK-27175][hive] Support to call Hive UDAF when the UDAF accepts one parameter with array type

2022-04-12 Thread GitBox
hehuiyuan commented on code in PR #19423: URL: https://github.com/apache/flink/pull/19423#discussion_r848489334 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDAF.java: ## @@ -173,6 +178,14 @@ public GenericUDAFEvaluator.

[jira] [Commented] (FLINK-26762) Add the overdraft buffer in BufferPool to reduce unaligned checkpoint being blocked

2022-04-12 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521184#comment-17521184 ] Anton Kalashnikov commented on FLINK-26762: --- We definitely can ignore buffer d

[GitHub] [flink] snuyanzin commented on pull request #18109: [FLINK-25284][Table SQL / API] Add proportion of null values to generate with datagen

2022-04-12 Thread GitBox
snuyanzin commented on PR #18109: URL: https://github.com/apache/flink/pull/18109#issuecomment-1096799811 @slinkydeveloper sorry for the delay and thanks for your feedback, I rebased it since it was already moved to assertj -- This is an automated message from the Apache Git Service.

[GitHub] [flink] snuyanzin commented on a diff in pull request #18109: [FLINK-25284][Table SQL / API] Add proportion of null values to generate with datagen

2022-04-12 Thread GitBox
snuyanzin commented on code in PR #18109: URL: https://github.com/apache/flink/pull/18109#discussion_r848504683 ## flink-table/flink-table-api-java-bridge/src/test/java/org/apache/flink/table/factories/DataGenTableSourceFactoryTest.java: ## @@ -178,6 +192,10 @@ public void testS

[GitHub] [flink] snuyanzin commented on a diff in pull request #18109: [FLINK-25284][Table SQL / API] Add proportion of null values to generate with datagen

2022-04-12 Thread GitBox
snuyanzin commented on code in PR #18109: URL: https://github.com/apache/flink/pull/18109#discussion_r848504911 ## flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/connector/datagen/table/DataGenConnectorOptions.java: ## @@ -109,5 +110,12 @@

[jira] [Commented] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-04-12 Thread Yuan Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521188#comment-17521188 ] Yuan Zhu commented on FLINK-27191: -- But when job starts running, Hive source need to co

[jira] [Commented] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-04-12 Thread Yuan Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521189#comment-17521189 ] Yuan Zhu commented on FLINK-27191: -- I'm very happy to contribute. > Support multi kerb

[GitHub] [flink] XComp commented on a diff in pull request #19275: [FLINK-24491][runtime] Make the job termination wait until the archiving of ExecutionGraphInfo finishes

2022-04-12 Thread GitBox
XComp commented on code in PR #19275: URL: https://github.com/apache/flink/pull/19275#discussion_r848497903 ## flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java: ## @@ -992,6 +992,7 @@ public void testRequestMultipleJobDetails_returnsFinishedOv

[GitHub] [flink] David-N-Perkins commented on pull request #19428: [FLINK-25694] [file-system] Ugrade Presto

2022-04-12 Thread GitBox
David-N-Perkins commented on PR #19428: URL: https://github.com/apache/flink/pull/19428#issuecomment-1096822125 I updated the NOTICE file. -- 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 spec

[jira] [Comment Edited] (FLINK-25806) Remove legacy high availability services

2022-04-12 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17482344#comment-17482344 ] Matthias Pohl edited comment on FLINK-25806 at 4/12/22 2:43 PM: --

[GitHub] [flink] XComp commented on pull request #19353: [FLINK-27050][runtime] Removes default RpcSystem instance

2022-04-12 Thread GitBox
XComp commented on PR #19353: URL: https://github.com/apache/flink/pull/19353#issuecomment-1096826291 Force-pushed once more after the branch idle'd for 5 days to prepare the merge for tomorrow morning... -- This is an automated message from the Apache Git Service. To respond to the messa

[jira] [Assigned] (FLINK-23589) Support Avro Microsecond precision

2022-04-12 Thread Marios Trivyzas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marios Trivyzas reassigned FLINK-23589: --- Assignee: Marios Trivyzas > Support Avro Microsecond precision > --

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on a diff in pull request #160: [FLINK-27124] Flink Kubernetes operator prints starting logs with wrong version

2022-04-12 Thread GitBox
wangyang0918 commented on code in PR #160: URL: https://github.com/apache/flink-kubernetes-operator/pull/160#discussion_r848326257 ## flink-kubernetes-operator/pom.xml: ## @@ -282,6 +293,35 @@ under the License. +

[jira] [Commented] (FLINK-26522) Refactoring code for multiple component leader election

2022-04-12 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521195#comment-17521195 ] Matthias Pohl commented on FLINK-26522: --- We should look into this issue after FLIN

[jira] [Created] (FLINK-27207) Support built-in parquet format

2022-04-12 Thread Yubin Li (Jira)
Yubin Li created FLINK-27207: Summary: Support built-in parquet format Key: FLINK-27207 URL: https://issues.apache.org/jira/browse/FLINK-27207 Project: Flink Issue Type: Sub-task Compon

[jira] [Commented] (FLINK-26824) Upgrade Flink's supported Cassandra versions to match with the Cassandra community supported versions

2022-04-12 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521196#comment-17521196 ] Etienne Chauchot commented on FLINK-26824: -- [~martijnvisser] Can you assign me

[GitHub] [flink] twalthr closed pull request #19025: [FLINK-26553][build] Configure scalafmt

2022-04-12 Thread GitBox
twalthr closed pull request #19025: [FLINK-26553][build] Configure scalafmt URL: https://github.com/apache/flink/pull/19025 -- 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 u

[jira] [Commented] (FLINK-26824) Upgrade Flink's supported Cassandra versions to match with the Cassandra community supported versions

2022-04-12 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521203#comment-17521203 ] Etienne Chauchot commented on FLINK-26824: -- and by the way, there was a complet

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #87: [FLINK-27123] Introduce filter predicate for 'LIKE'

2022-04-12 Thread GitBox
JingsongLi commented on code in PR #87: URL: https://github.com/apache/flink-table-store/pull/87#discussion_r848472799 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/PredicateConverter.java: ## @@ -95,9 +107,45 @@ public Predicate visit(CallE

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #163: [FLINK-27154] Disable web.cancel.enable for application clusters

2022-04-12 Thread GitBox
gyfora merged PR #163: URL: https://github.com/apache/flink-kubernetes-operator/pull/163 -- 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-unsubscr

[jira] [Assigned] (FLINK-26824) Upgrade Flink's supported Cassandra versions to match with the Cassandra community supported versions

2022-04-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-26824: -- Assignee: Etienne Chauchot > Upgrade Flink's supported Cassandra versions to match wi

[jira] [Closed] (FLINK-27154) Disable web.cancel.enable for application clusters

2022-04-12 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-27154. -- Resolution: Fixed Merged to main: b87211168665a34dff15cd28e3a0c0bb34f9283e > Disable web.cancel.enabl

[jira] [Closed] (FLINK-26553) Enable scalafmt for scala codebase

2022-04-12 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-26553. Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master: commit bf342d2f67a46e5266c3595734

[jira] [Created] (FLINK-27208) Update the documentation to configure the IDE with scalafmt

2022-04-12 Thread Timo Walther (Jira)
Timo Walther created FLINK-27208: Summary: Update the documentation to configure the IDE with scalafmt Key: FLINK-27208 URL: https://issues.apache.org/jira/browse/FLINK-27208 Project: Flink

[GitHub] [flink-web] akalash commented on pull request #524: Add Buffer debloating blog post

2022-04-12 Thread GitBox
akalash commented on PR #524: URL: https://github.com/apache/flink-web/pull/524#issuecomment-1096864423 > "instabilities", do you mean "imbalances" or "varying conditions" (instabilities refer rather to failures than to stable conditions) Let's discuss it later but I think that `insta

<    1   2   3   4   5   6   7   8   >