[jira] [Updated] (FLINK-30781) Add completed checkpoint check to cluster health check

2023-01-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30781: --- Labels: pull-request-available (was: ) > Add completed checkpoint check to cluster health c

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on pull request #513: [FLINK-30781] Add completed checkpoint check to cluster health check

2023-01-25 Thread via GitHub
gaborgsomogyi commented on PR #513: URL: https://github.com/apache/flink-kubernetes-operator/pull/513#issuecomment-1404658254 cc @gyfora -- 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

[GitHub] [flink-kubernetes-operator] gaborgsomogyi opened a new pull request, #513: [FLINK-30781] Add completed checkpoint check to cluster health check

2023-01-25 Thread via GitHub
gaborgsomogyi opened a new pull request, #513: URL: https://github.com/apache/flink-kubernetes-operator/pull/513 ## What is the purpose of the change There are workloads which stuck in such a way that they're in RUNNING state most of the time but not able to proceed and make checkpoin

[jira] [Commented] (FLINK-29405) InputFormatCacheLoaderTest is unstable

2023-01-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680917#comment-17680917 ] Matthias Pohl commented on FLINK-29405: --- 1 build, 2 failures: * https://dev.azure

[jira] [Commented] (FLINK-30727) JoinReorderITCase.testBushyTreeJoinReorder failed due to IOException

2023-01-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680916#comment-17680916 ] Matthias Pohl commented on FLINK-30727: --- https://dev.azure.com/apache-flink/apache

[jira] [Commented] (FLINK-30793) PyFlink YARN per-job on Docker test fails on Azure due to permission issues

2023-01-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680915#comment-17680915 ] Matthias Pohl commented on FLINK-30793: --- I'm linking FLINK-24434 because it has th

[jira] [Created] (FLINK-30793) PyFlink YARN per-job on Docker test fails on Azure due to permission issues

2023-01-25 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-30793: - Summary: PyFlink YARN per-job on Docker test fails on Azure due to permission issues Key: FLINK-30793 URL: https://issues.apache.org/jira/browse/FLINK-30793 Project

[jira] [Reopened] (FLINK-30328) TaskManagerWideRocksDbMemorySharingITCase.testBlockCache failed

2023-01-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reopened FLINK-30328: --- I'm reopening this issue because we still see test failures on {{master}}. The following build

[jira] [Resolved] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

2023-01-25 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved FLINK-30623. -- Resolution: Fixed > Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023 >

[GitHub] [flink] lindong28 closed pull request #21690: [FLINK-30623][runtime][bug] The canEmitBatchOfRecords should check recordWriter and changelogWriterAvailabilityProvider are available

2023-01-25 Thread via GitHub
lindong28 closed pull request #21690: [FLINK-30623][runtime][bug] The canEmitBatchOfRecords should check recordWriter and changelogWriterAvailabilityProvider are available URL: https://github.com/apache/flink/pull/21690 -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] 1996fanrui commented on pull request #21690: [FLINK-30623][runtime][bug] The canEmitBatchOfRecords should check recordWriter and changelogWriterAvailabilityProvider are available

2023-01-25 Thread via GitHub
1996fanrui commented on PR #21690: URL: https://github.com/apache/flink/pull/21690#issuecomment-1404523024 There are some unit tests fail due to the first commit, and I have updated. The `Supplier mailboxHasMail;` should be true in the `TestingSourceOperator` by default, however the `

[GitHub] [flink] libenchao commented on pull request #21746: [FLINK-30499][SQL/Table] Fix over window codegen error when member code incorrectly used in method body

2023-01-25 Thread via GitHub
libenchao commented on PR #21746: URL: https://github.com/apache/flink/pull/21746#issuecomment-1404504193 @herunkang2018 Thanks for your contribution. It would be great if you add a test case for this. Besides, the CI fails now due to the spotless checking, could you also fix that? -

[jira] [Created] (FLINK-30792) clean up not uploaded state changes after materialization complete

2023-01-25 Thread Feifan Wang (Jira)
Feifan Wang created FLINK-30792: --- Summary: clean up not uploaded state changes after materialization complete Key: FLINK-30792 URL: https://issues.apache.org/jira/browse/FLINK-30792 Project: Flink

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

2023-01-25 Thread via GitHub
RyanSkraba closed pull request #18823: [FLINK-20625][pubsub,e2e] Add PubSubSource connector using FLIP-27 URL: https://github.com/apache/flink/pull/18823 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

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

2023-01-25 Thread via GitHub
RyanSkraba commented on PR #18823: URL: https://github.com/apache/flink/pull/18823#issuecomment-1404446166 @MartijnVisser I've moved this to https://github.com/apache/flink-connector-gcp-pubsub/pull/2! Thanks for the ping! @dchristle having some eyes check it out for validation would be t

[jira] [Commented] (FLINK-30561) ChangelogStreamHandleReaderWithCache cause FileNotFoundException

2023-01-25 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680850#comment-17680850 ] Feifan Wang commented on FLINK-30561: - Hi [~roman]  , I submitted a pr to fix this p

[GitHub] [flink-connector-gcp-pubsub] boring-cyborg[bot] commented on pull request #2: [FLINK-20625][pubsub,e2e] Add PubSubSource connector using FLIP-27

2023-01-25 Thread boring-cyborg
boring-cyborg[bot] commented on PR #2: URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/2#issuecomment-140557 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This i

[GitHub] [flink-connector-gcp-pubsub] RyanSkraba opened a new pull request, #2: [FLINK-20625][pubsub,e2e] Add PubSubSource connector using FLIP-27

2023-01-25 Thread via GitHub
RyanSkraba opened a new pull request, #2: URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/2 ## What is the purpose of the change * Originally from PR https://github.com/apache/flink/pull/15152, then https://github.com/apache/flink/pull/18823 to help finish the PR for a

[jira] [Comment Edited] (FLINK-17804) Follow the spec when decoding Parquet logical DECIMAL type

2023-01-25 Thread Sergii Mikhtoniuk (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680849#comment-17680849 ] Sergii Mikhtoniuk edited comment on FLINK-17804 at 1/26/23 1:13 AM: --

[jira] [Commented] (FLINK-17804) Follow the spec when decoding Parquet logical DECIMAL type

2023-01-25 Thread Sergii Mikhtoniuk (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680849#comment-17680849 ] Sergii Mikhtoniuk commented on FLINK-17804: ---  I think this ticker can be close

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #509: [FLINK-30653] Trigger resource Events on autoscaler actions

2023-01-25 Thread via GitHub
morhidi commented on code in PR #509: URL: https://github.com/apache/flink-kubernetes-operator/pull/509#discussion_r1087187329 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ScalingExecutor.java: ## @@ -99,14 +103,27 @@ public boolean

[jira] [Closed] (FLINK-30791) Codespeed machine is not responding

2023-01-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-30791. -- Thanks! > Codespeed machine is not responding > --- > >

[jira] [Updated] (FLINK-30769) Use Operator SDK RuntimeInfo in Health Probe

2023-01-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30769: --- Labels: pull-request-available (was: ) > Use Operator SDK RuntimeInfo in Health Probe > ---

[GitHub] [flink-kubernetes-operator] gyfora opened a new pull request, #512: [FLINK-30769] Use Operator RuntimeInfo in health probe

2023-01-25 Thread via GitHub
gyfora opened a new pull request, #512: URL: https://github.com/apache/flink-kubernetes-operator/pull/512 ## What is the purpose of the change The operator health check endpoint currently only catches startup errors and does not react on the info now exposed by the Java operator sdk.

[jira] [Resolved] (FLINK-30791) Codespeed machine is not responding

2023-01-25 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge resolved FLINK-30791. - Resolution: Fixed > Codespeed machine is not responding > --- > >

[jira] [Commented] (FLINK-30791) Codespeed machine is not responding

2023-01-25 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680739#comment-17680739 ] Jing Ge commented on FLINK-30791: - fixed, the dns is back. > Codespeed machine is not r

[GitHub] [flink] snuyanzin commented on pull request #20922: [DRAFT] Apply changes for calcite 1.3x

2023-01-25 Thread via GitHub
snuyanzin commented on PR #20922: URL: https://github.com/apache/flink/pull/20922#issuecomment-1404050162 @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.

[jira] [Comment Edited] (FLINK-30791) Codespeed machine is not responding

2023-01-25 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680724#comment-17680724 ] Jing Ge edited comment on FLINK-30791 at 1/25/23 6:10 PM: -- the

[jira] [Assigned] (FLINK-30790) [Connectors/Jdbc] Refactor of testings

2023-01-25 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-30790: -- Assignee: João Boto > [Connectors/Jdbc] Refactor of testings > --

[jira] [Assigned] (FLINK-30791) Codespeed machine is not responding

2023-01-25 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-30791: -- Assignee: Jing Ge > Codespeed machine is not responding > ---

[jira] [Commented] (FLINK-30791) Codespeed machine is not responding

2023-01-25 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680724#comment-17680724 ] Jing Ge commented on FLINK-30791: - the machine is running with no issue, there are some

[jira] [Commented] (FLINK-30791) Codespeed machine is not responding

2023-01-25 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680700#comment-17680700 ] Jing Ge commented on FLINK-30791: - Thanks for creating this ticket. We are working on it

[jira] [Updated] (FLINK-30791) Codespeed machine is not responding

2023-01-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-30791: --- Description: Neither speedcenter: [http://codespeed.dak8s.net:8000/] nor jenkins: [http://c

[jira] [Created] (FLINK-30791) Codespeed machine is not responding

2023-01-25 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-30791: -- Summary: Codespeed machine is not responding Key: FLINK-30791 URL: https://issues.apache.org/jira/browse/FLINK-30791 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-30790) [Connectors/Jdbc] Refactor of testings

2023-01-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30790: --- Labels: pull-request-available (was: ) > [Connectors/Jdbc] Refactor of testings > -

[GitHub] [flink-connector-jdbc] eskabetxe opened a new pull request, #17: [FLINK-30790] Better performance on testing

2023-01-25 Thread via GitHub
eskabetxe opened a new pull request, #17: URL: https://github.com/apache/flink-connector-jdbc/pull/17 ## What is the purpose of the change Get better performance executing tests and set a easy way to extend a test to a new database ## Brief change log - Change parametriz

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #508: [hotfix] Minor logging and scaling execution improvements for autoscaler

2023-01-25 Thread via GitHub
gyfora merged PR #508: URL: https://github.com/apache/flink-kubernetes-operator/pull/508 -- 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] [Created] (FLINK-30789) Merge MultipleComponentsLeaderElectionDriver methods notifyAllKnownLeaderInformation and notifyLeaderInformationChange into a single method and

2023-01-25 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-30789: - Summary: Merge MultipleComponentsLeaderElectionDriver methods notifyAllKnownLeaderInformation and notifyLeaderInformationChange into a single method and Key: FLINK-30789 URL:

[jira] [Created] (FLINK-30790) [Connectors/Jdbc] Refactor of testings

2023-01-25 Thread Jira
João Boto created FLINK-30790: - Summary: [Connectors/Jdbc] Refactor of testings Key: FLINK-30790 URL: https://issues.apache.org/jira/browse/FLINK-30790 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

2023-01-25 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680680#comment-17680680 ] Roman Khachatryan commented on FLINK-28440: --- Should we disable randomization w

[jira] [Assigned] (FLINK-26082) CancelPartitionRequestTest.testDuplicateCancel failed on azure due to bind failed

2023-01-25 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-26082: - Assignee: Anton Kalashnikov > CancelPartitionRequestTest.testDuplicateCancel fa

[jira] [Updated] (FLINK-30377) CommonExecSink does not use ClientWrapperClassLoader while extracting Type from KeyedStream

2023-01-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-30377: -- Fix Version/s: 1.16.1 > CommonExecSink does not use ClientWrapperClassLoader while extracting

[GitHub] [flink] flinkbot commented on pull request #21758: [FLINK-30618][Python] Remove SNAPSHOT reference to Pulsar connector

2023-01-25 Thread via GitHub
flinkbot commented on PR #21758: URL: https://github.com/apache/flink/pull/21758#issuecomment-1403814051 ## CI report: * 3e69bd39eda55d840d9249f92af4a2a876303278 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #21757: [FLINK-30788][runtime] Refactors AbstractHaServices.createLeaderElectionService to return LeaderElectionDriverFactory

2023-01-25 Thread via GitHub
flinkbot commented on PR #21757: URL: https://github.com/apache/flink/pull/21757#issuecomment-1403813850 ## CI report: * 8b8076300bc534464a6501ac255f1659b06162ab UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-30618) flink-connector-pulsar not retrievable from Apache's Snapshot Maven repository

2023-01-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30618: --- Labels: pull-request-available test-stability (was: test-stability) > flink-connector-pulsa

[GitHub] [flink] MartijnVisser opened a new pull request, #21758: [FLINK-30618][Python] Remove SNAPSHOT reference to Pulsar connector

2023-01-25 Thread via GitHub
MartijnVisser opened a new pull request, #21758: URL: https://github.com/apache/flink/pull/21758 ## What is the purpose of the change * Since there are no SNAPSHOTs created for connectors, lookup to SNAPSHOT versions of connector in Flink itself should not be present ## Brief c

[GitHub] [flink] XComp opened a new pull request, #21757: [FLINK-30788][runtime] Refactors AbstractHaServices.createLeaderElectionService to return LeaderElectionDriverFactory

2023-01-25 Thread via GitHub
XComp opened a new pull request, #21757: URL: https://github.com/apache/flink/pull/21757 ## What is the purpose of the change The HA-backend-specific code is actually only the `LeaderElectionDriverFactory` creation rather than instantiating the `LeaderElectionService`. This is meant

[jira] [Updated] (FLINK-30788) Refactor redundant code in AbstractHaServices

2023-01-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30788: --- Labels: pull-request-available (was: ) > Refactor redundant code in AbstractHaServices > -

[GitHub] [flink] dannycranmer merged pull request #21689: [hotfix][javadocs]Fix javadoc in Catalog Interface

2023-01-25 Thread via GitHub
dannycranmer merged PR #21689: URL: https://github.com/apache/flink/pull/21689 -- 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...@flink.

[GitHub] [flink] dannycranmer commented on pull request #21689: [hotfix][javadocs]Fix javadoc in Catalog Interface

2023-01-25 Thread via GitHub
dannycranmer commented on PR #21689: URL: https://github.com/apache/flink/pull/21689#issuecomment-1403796850 Thanks for the contribution @Samrat002 -- 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 t

[GitHub] [flink] dannycranmer merged pull request #21754: [hotfix][docs][table] Fix typo in flink hive-dialect doc

2023-01-25 Thread via GitHub
dannycranmer merged PR #21754: URL: https://github.com/apache/flink/pull/21754 -- 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...@flink.

[GitHub] [flink] dannycranmer commented on pull request #21754: [hotfix][docs][table] Fix typo in flink hive-dialect doc

2023-01-25 Thread via GitHub
dannycranmer commented on PR #21754: URL: https://github.com/apache/flink/pull/21754#issuecomment-1403795786 Thanks for the contribution @Samrat002 -- 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 t

[GitHub] [flink-web] MartijnVisser commented on pull request #597: [FLINK-22922] Migrate project website from Jekyll to Hugo

2023-01-25 Thread via GitHub
MartijnVisser commented on PR #597: URL: https://github.com/apache/flink-web/pull/597#issuecomment-1403793418 This PR is ready for a first pass. What's left to do: * Convert the `material`, `roadmap`, `security` and `training` pages * Create 301 redirects from all the old URLs to the ne

[jira] [Assigned] (FLINK-30788) Refactor redundant code in AbstractHaServices

2023-01-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-30788: - Assignee: Matthias Pohl > Refactor redundant code in AbstractHaServices >

[jira] [Created] (FLINK-30788) Refactor redundant code in AbstractHaServices

2023-01-25 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-30788: - Summary: Refactor redundant code in AbstractHaServices Key: FLINK-30788 URL: https://issues.apache.org/jira/browse/FLINK-30788 Project: Flink Issue Type:

[GitHub] [flink] dannycranmer commented on a diff in pull request #21497: [FLINK-30377][table-planner] applySinkProvider use ClientWrapperClassLoader while extracting Type from KeyedStream

2023-01-25 Thread via GitHub
dannycranmer commented on code in PR #21497: URL: https://github.com/apache/flink/pull/21497#discussion_r1086767065 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSink.java: ## @@ -460,87 +461,95 @@ private Transf

[jira] [Updated] (FLINK-30377) CommonExecSink does not use ClientWrapperClassLoader while extracting Type from KeyedStream

2023-01-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-30377: -- Fix Version/s: 1.17.0 > CommonExecSink does not use ClientWrapperClassLoader while extracting

[jira] [Assigned] (FLINK-30377) CommonExecSink does not use ClientWrapperClassLoader while extracting Type from KeyedStream

2023-01-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-30377: - Assignee: Samrat Deb > CommonExecSink does not use ClientWrapperClassLoader while extra

[GitHub] [flink] Samrat002 commented on pull request #21754: [hotfix][docs][table] Fix typo in flink hive-dialect doc

2023-01-25 Thread via GitHub
Samrat002 commented on PR #21754: URL: https://github.com/apache/flink/pull/21754#issuecomment-1403759681 @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-connector-cassandra] echauchot commented on a diff in pull request #3: [FLINK-26822] Add Cassandra Source

2023-01-25 Thread via GitHub
echauchot commented on code in PR #3: URL: https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1085595610 ## flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraSplitReader.java: ## @@ -0,0 +1,280 @@ +/* + * Lic

[GitHub] [flink] XComp commented on pull request #21555: [FLINK-26522][draft] Cleanup of LeaderElectionService

2023-01-25 Thread via GitHub
XComp commented on PR #21555: URL: https://github.com/apache/flink/pull/21555#issuecomment-1403625528 I accidentally pushed the wrong branch after rebasing. I fixed that: 9cf28ae refers to the rebased work that excluded certain (previous hotfix) commits that were merged to `master` in separ

[jira] [Commented] (FLINK-24456) Support bounded offset in the Kafka table connector

2023-01-25 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680615#comment-17680615 ] Martijn Visser commented on FLINK-24456: +1, thanks [~twalthr] > Support bounde

[GitHub] [flink] dawidwys commented on a diff in pull request #21635: [FLINK-30613] Improve resolving schema compatibility -- Milestone one

2023-01-25 Thread via GitHub
dawidwys commented on code in PR #21635: URL: https://github.com/apache/flink/pull/21635#discussion_r1086628860 ## flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeTypeSerializerSnapshot.java: ## @@ -290,26 +332,26 @@ protected void readOuterSnapshot(

[GitHub] [flink] dawidwys commented on a diff in pull request #21635: [FLINK-30613] Improve resolving schema compatibility -- Milestone one

2023-01-25 Thread via GitHub
dawidwys commented on code in PR #21635: URL: https://github.com/apache/flink/pull/21635#discussion_r1086625857 ## flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshot.java: ## @@ -124,11 +124,40 @@ void readSnapshot(int readVersion, DataInputVie

[GitHub] [flink] rkhachatryan closed pull request #20523: [WIP][FLINK-26372][runtime][state] Allow to configure Changelog Storage per program

2023-01-25 Thread via GitHub
rkhachatryan closed pull request #20523: [WIP][FLINK-26372][runtime][state] Allow to configure Changelog Storage per program URL: https://github.com/apache/flink/pull/20523 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] dawidwys commented on a diff in pull request #21635: [FLINK-30613] Improve resolving schema compatibility -- Milestone one

2023-01-25 Thread via GitHub
dawidwys commented on code in PR #21635: URL: https://github.com/apache/flink/pull/21635#discussion_r1086625857 ## flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshot.java: ## @@ -124,11 +124,40 @@ void readSnapshot(int readVersion, DataInputVie

[GitHub] [flink] rkhachatryan commented on pull request #20523: [WIP][FLINK-26372][runtime][state] Allow to configure Changelog Storage per program

2023-01-25 Thread via GitHub
rkhachatryan commented on PR #20523: URL: https://github.com/apache/flink/pull/20523#issuecomment-1403591635 Superseded by 21637 -- 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 comme

[GitHub] [flink] dawidwys commented on a diff in pull request #21635: [FLINK-30613] Improve resolving schema compatibility -- Milestone one

2023-01-25 Thread via GitHub
dawidwys commented on code in PR #21635: URL: https://github.com/apache/flink/pull/21635#discussion_r1086625857 ## flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshot.java: ## @@ -124,11 +124,40 @@ void readSnapshot(int readVersion, DataInputVie

[jira] [Commented] (FLINK-24456) Support bounded offset in the Kafka table connector

2023-01-25 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680608#comment-17680608 ] Timo Walther commented on FLINK-24456: -- It seems there is no progress on this impor

[jira] [Resolved] (FLINK-30762) Add nightly builds for AWS connectors repo

2023-01-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-30762. --- Resolution: Fixed > Add nightly builds for AWS connectors repo > ---

[jira] [Commented] (FLINK-30762) Add nightly builds for AWS connectors repo

2023-01-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680607#comment-17680607 ] Danny Cranmer commented on FLINK-30762: --- Merged commit [{{e5f1362}}|https://githu

[GitHub] [flink-connector-aws] boring-cyborg[bot] commented on pull request #48: [FLINK-30762][ci] Add nightly build workflow

2023-01-25 Thread boring-cyborg
boring-cyborg[bot] commented on PR #48: URL: https://github.com/apache/flink-connector-aws/pull/48#issuecomment-1403569682 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink-connector-aws] dannycranmer merged pull request #48: [FLINK-30762][ci] Add nightly build workflow

2023-01-25 Thread via GitHub
dannycranmer merged PR #48: URL: https://github.com/apache/flink-connector-aws/pull/48 -- 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..

[GitHub] [flink] MartijnVisser commented on pull request #21690: [FLINK-30623][runtime][bug] The canEmitBatchOfRecords should check recordWriter and changelogWriterAvailabilityProvider are available

2023-01-25 Thread via GitHub
MartijnVisser commented on PR #21690: URL: https://github.com/apache/flink/pull/21690#issuecomment-1403568678 @1996fanrui It looks like you need to push an empty commit or rebase/force push again, CiBot doesn't seem to pick up your latest commits but I see it work for other PRs -- This i

[GitHub] [flink] kristoffSC commented on a diff in pull request #21393: [FLINK-27246][TableSQL/Runtime][master] - Include WHILE blocks in split generated java methods

2023-01-25 Thread via GitHub
kristoffSC commented on code in PR #21393: URL: https://github.com/apache/flink/pull/21393#discussion_r1085531144 ## flink-table/flink-table-code-splitter/src/main/java/org/apache/flink/table/codesplit/BlockStatementSplitter.java: ## @@ -0,0 +1,326 @@ +/* + * Licensed to the Apa

[GitHub] [flink] flinkbot commented on pull request #21756: [FLINK-30787][debug] Adds dmesg call to test_controller to check whether it would succeed on Alibaba instances.

2023-01-25 Thread via GitHub
flinkbot commented on PR #21756: URL: https://github.com/apache/flink/pull/21756#issuecomment-1403551203 ## CI report: * 95df77a3476ed067dd2ff8a6dc09b6be3da3b30a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-30787) dmesg fails to save data to file due to permissions

2023-01-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30787: --- Labels: pull-request-available (was: ) > dmesg fails to save data to file due to permission

[GitHub] [flink] XComp opened a new pull request, #21756: [FLINK-30787][debug] Adds dmesg call to test_controller to check whether it would succeed on Alibaba instances.

2023-01-25 Thread via GitHub
XComp opened a new pull request, #21756: URL: https://github.com/apache/flink/pull/21756 This draft adds dmesg to the `test_controller.sh` to check whether it would work on Alibaba instances to determine whether FLINK-13978 is the cause for the error in the e2e tests. -- This is an autom

[GitHub] [flink] tsreaper commented on a diff in pull request #21393: [FLINK-27246][TableSQL/Runtime][master] - Include WHILE blocks in split generated java methods

2023-01-25 Thread via GitHub
tsreaper commented on code in PR #21393: URL: https://github.com/apache/flink/pull/21393#discussion_r1086577308 ## flink-table/flink-table-code-splitter/src/main/java/org/apache/flink/table/codesplit/BlockStatementSplitter.java: ## @@ -0,0 +1,326 @@ +/* + * Licensed to the Apach

[GitHub] [flink] tsreaper commented on a diff in pull request #21393: [FLINK-27246][TableSQL/Runtime][master] - Include WHILE blocks in split generated java methods

2023-01-25 Thread via GitHub
tsreaper commented on code in PR #21393: URL: https://github.com/apache/flink/pull/21393#discussion_r1086577308 ## flink-table/flink-table-code-splitter/src/main/java/org/apache/flink/table/codesplit/BlockStatementSplitter.java: ## @@ -0,0 +1,326 @@ +/* + * Licensed to the Apach

[jira] [Commented] (FLINK-25343) HBaseConnectorITCase.testTableSourceSinkWithDDL fail on azure

2023-01-25 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680596#comment-17680596 ] Ferenc Csaky commented on FLINK-25343: -- Yep, that's a fair point too. I'll try to d

[jira] [Commented] (FLINK-30787) dmesg fails to save data to file due to permissions

2023-01-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680592#comment-17680592 ] Matthias Pohl commented on FLINK-30787: --- good point, I'm gonna double-check > dme

[jira] [Comment Edited] (FLINK-26803) Merge small ChannelState file for Unaligned Checkpoint

2023-01-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17679859#comment-17679859 ] Piotr Nowojski edited comment on FLINK-26803 at 1/25/23 12:11 PM:

[jira] [Comment Edited] (FLINK-26803) Merge small ChannelState file for Unaligned Checkpoint

2023-01-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17679859#comment-17679859 ] Piotr Nowojski edited comment on FLINK-26803 at 1/25/23 12:10 PM:

[jira] [Updated] (FLINK-30474) DefaultMultipleComponentLeaderElectionService triggers HA backend change even if it's not the leader

2023-01-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-30474: -- Parent: FLINK-26522 Issue Type: Sub-task (was: Bug) > DefaultMultipleComponentLeaderE

[jira] [Commented] (FLINK-30474) DefaultMultipleComponentLeaderElectionService triggers HA backend change even if it's not the leader

2023-01-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680586#comment-17680586 ] Matthias Pohl commented on FLINK-30474: --- Added PR #21537 which resolves this issue

[jira] [Updated] (FLINK-30462) DefaultMultipleComponentLeaderElectionService saves wrong leader session ID

2023-01-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-30462: -- Parent: FLINK-26522 Issue Type: Sub-task (was: Bug) > DefaultMultipleComponentLeaderE

[jira] [Commented] (FLINK-30787) dmesg fails to save data to file due to permissions

2023-01-25 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680583#comment-17680583 ] Robert Metzger commented on FLINK-30787: I'm pretty sure this worked before. May

[jira] [Updated] (FLINK-30649) Shutting down MiniCluster times out

2023-01-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-30649: -- Summary: Shutting down MiniCluster times out (was: Run kubernetes session test (default input

[jira] [Commented] (FLINK-30649) Run kubernetes session test (default input) failed with a timeout

2023-01-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680581#comment-17680581 ] Matthias Pohl commented on FLINK-30649: --- The test actually succeeds. The timeout r

[jira] [Assigned] (FLINK-30649) Run kubernetes session test (default input) failed with a timeout

2023-01-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-30649: - Assignee: Matthias Pohl > Run kubernetes session test (default input) failed with a tim

[GitHub] [flink] twalthr commented on pull request #21519: [FLINK-29932][table] Upgrade Calcite to 1.29.0

2023-01-25 Thread via GitHub
twalthr commented on PR #21519: URL: https://github.com/apache/flink/pull/21519#issuecomment-1403481316 A follow-up issue would not harm. At least to track that this could potentially cause problems, if it doesn't cause problems I don't see an immediate need to implement it right away. --

[jira] [Comment Edited] (FLINK-30787) dmesg fails to save data to file due to permissions

2023-01-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680580#comment-17680580 ] Matthias Pohl edited comment on FLINK-30787 at 1/25/23 11:42 AM: -

[jira] [Commented] (FLINK-30787) dmesg fails to save data to file due to permissions

2023-01-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680580#comment-17680580 ] Matthias Pohl commented on FLINK-30787: --- I linked the FLINK-19699 PR that introduc

[jira] (FLINK-30649) Run kubernetes session test (default input) failed with a timeout

2023-01-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30649 ] Matthias Pohl deleted comment on FLINK-30649: --- was (Author: mapohl): I linked the FLINK-19699 PR that introduced this feature in the CI pipeline. [~rmetzger] can you recall whether we chec

[jira] [Commented] (FLINK-30649) Run kubernetes session test (default input) failed with a timeout

2023-01-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680579#comment-17680579 ] Matthias Pohl commented on FLINK-30649: --- I linked the FLINK-19699 PR that introduc

[jira] [Created] (FLINK-30787) dmesg fails to save data to file due to permissions

2023-01-25 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-30787: - Summary: dmesg fails to save data to file due to permissions Key: FLINK-30787 URL: https://issues.apache.org/jira/browse/FLINK-30787 Project: Flink Issue T

[jira] [Updated] (FLINK-30649) Run kubernetes session test (default input) failed with a timeout

2023-01-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-30649: -- Component/s: Test Infrastructure > Run kubernetes session test (default input) failed with a t

[GitHub] [flink-benchmarks] XComp commented on pull request #63: [FLINK-27571][benchmark] Recognize 'less is better' benchmarks in regression detection script

2023-01-25 Thread via GitHub
XComp commented on PR #63: URL: https://github.com/apache/flink-benchmarks/pull/63#issuecomment-1403464195 @fredia what's the state on this PR? Looks like @rkhachatryan comments still wait for some reply? -- This is an automated message from the Apache Git Service. To respond to the messa

[GitHub] [flink] XComp commented on a diff in pull request #21736: [FLINK-27518][tests] Refactor migration tests to support version update automatically

2023-01-25 Thread via GitHub
XComp commented on code in PR #21736: URL: https://github.com/apache/flink/pull/21736#discussion_r1082750754 ## flink-test-utils-parent/flink-migration-test-utils/src/main/java/org/apache/flink/test/migration/MigrationTestsSnapshotGenerator.java: ## @@ -0,0 +1,152 @@ +/* + * Lic

  1   2   >