[GitHub] [flink] gaborgsomogyi commented on pull request #23329: [FLINK-32989][python] Fix version parsing issue

gaborgsomogyi commented on PR #23329: URL: https://github.com/apache/flink/pull/23329#issuecomment-1700460894 @dianfu thanks for your efforts by double checking it manually, appreciate it! 👍 -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[jira] [Assigned] (FLINK-27491) Support env replacement in flink-kubernetes-operator CR

[ https://issues.apache.org/jira/browse/FLINK-27491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-27491: -- Assignee: Matyas Orhidi > Support env replacement in flink-kubernetes-operator CR > -

[jira] [Closed] (FLINK-27448) Enable standalone mode for old Flink versions

[ https://issues.apache.org/jira/browse/FLINK-27448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-27448. -- Resolution: Won't Fix It probably make sense to limit the number of supported Flink versions with the

[jira] [Commented] (FLINK-32963) Make the test "testKeyedMapStateStateMigration" stable

[ https://issues.apache.org/jira/browse/FLINK-32963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760746#comment-17760746 ] Matthias Pohl commented on FLINK-32963: --- Ok, thanks for the clarification :) > Ma

[jira] [Closed] (FLINK-27281) Improve stability conditions for rollback logic

[ https://issues.apache.org/jira/browse/FLINK-27281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-27281. -- Resolution: Won't Fix > Improve stability conditions for rollback logic >

[jira] [Resolved] (FLINK-32989) PyFlink wheel package build failed

[ https://issues.apache.org/jira/browse/FLINK-32989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-32989. --- Fix Version/s: 1.19.0 Resolution: Fixed 3975dd0 on master > PyFlink wheel package bu

[jira] [Closed] (FLINK-32989) PyFlink wheel package build failed

[ https://issues.apache.org/jira/browse/FLINK-32989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-32989. - > PyFlink wheel package build failed > -- > > Key: F

[jira] [Commented] (FLINK-32731) SqlGatewayE2ECase.testHiveServer2ExecuteStatement failed due to MetaException

[ https://issues.apache.org/jira/browse/FLINK-32731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760744#comment-17760744 ] Matthias Pohl commented on FLINK-32731: --- Yeah, the Pipeline overview went away. We

[GitHub] [flink] gaborgsomogyi merged pull request #23329: [FLINK-32989][python] Fix version parsing issue

gaborgsomogyi merged PR #23329: URL: https://github.com/apache/flink/pull/23329 -- 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

[jira] [Commented] (FLINK-30519) Add e2e tests for operator dynamic config

[ https://issues.apache.org/jira/browse/FLINK-30519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760743#comment-17760743 ] Gyula Fora commented on FLINK-30519: [~haiqingchen] are you still working on this by

[jira] [Assigned] (FLINK-30519) Add e2e tests for operator dynamic config

[ https://issues.apache.org/jira/browse/FLINK-30519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30519: -- Assignee: (was: haiqingchen) > Add e2e tests for operator dynamic config > --

[jira] [Comment Edited] (FLINK-30530) Flink configuration from user-provided ConfigMap

[ https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760742#comment-17760742 ] Gyula Fora edited comment on FLINK-30530 at 8/31/23 6:43 AM: -

[jira] [Commented] (FLINK-30530) Flink configuration from user-provided ConfigMap

[ https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760742#comment-17760742 ] Gyula Fora commented on FLINK-30530: We now have operator, namespace and flink versi

[jira] [Assigned] (FLINK-32987) BlobClientSslTest>BlobClientTest.testSocketTimeout expected SocketTimeoutException but identified SSLException

[ https://issues.apache.org/jira/browse/FLINK-32987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-32987: - Assignee: Ferenc Csaky > BlobClientSslTest>BlobClientTest.testSocketTimeout expected >

[jira] [Closed] (FLINK-30851) flink-kubernetes-operator - operator image should provide s3 support for jarUri

[ https://issues.apache.org/jira/browse/FLINK-30851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30851. -- Resolution: Not A Problem > flink-kubernetes-operator - operator image should provide s3 support for

[jira] [Commented] (FLINK-31509) REST Service missing sessionAffinity causes job run failure with HA cluster

[ https://issues.apache.org/jira/browse/FLINK-31509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760739#comment-17760739 ] Gyula Fora commented on FLINK-31509: I think this is a problem in the Flink Kubernet

[jira] [Updated] (FLINK-31509) REST Service missing sessionAffinity causes job run failure with HA cluster

[ https://issues.apache.org/jira/browse/FLINK-31509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-31509: --- Component/s: Deployment / Kubernetes > REST Service missing sessionAffinity causes job run failure w

[jira] [Closed] (FLINK-32143) Automatic cleanup of terminated flinkdeployments

[ https://issues.apache.org/jira/browse/FLINK-32143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-32143. -- Resolution: Fixed This is already covered by the `kubernetes.operator.jm-deployment.shutdown-ttl` opt

[jira] [Closed] (FLINK-32255) Pre-deployed idle Task Managers

[ https://issues.apache.org/jira/browse/FLINK-32255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-32255. -- Resolution: Duplicate > Pre-deployed idle Task Managers > --- > >

[jira] [Closed] (FLINK-32318) [flink-operator] missing s3 plugin in folder plugins

[ https://issues.apache.org/jira/browse/FLINK-32318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-32318. -- Resolution: Not A Problem > [flink-operator] missing s3 plugin in folder plugins > ---

[jira] [Closed] (FLINK-32423) Flink-sql-runner-example application fails if multiple execute() called in one sql file

[ https://issues.apache.org/jira/browse/FLINK-32423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-32423. -- Resolution: Won't Fix The SQL runner is intended to be an example and not really a proper all encompa

[jira] [Closed] (FLINK-32531) "Recovery of missing job deployments" feature not working as described

[ https://issues.apache.org/jira/browse/FLINK-32531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-32531. -- Resolution: Not A Problem > "Recovery of missing job deployments" feature not working as described > -

[jira] [Commented] (FLINK-31998) Flink Operator Deadlock on run job Failure

[ https://issues.apache.org/jira/browse/FLINK-31998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760730#comment-17760730 ] Gyula Fora commented on FLINK-31998: [~chalixar] is this still an issue? > Flink Op

[jira] [Closed] (FLINK-31941) Not backwards compatible naming for some kubernetes resources

[ https://issues.apache.org/jira/browse/FLINK-31941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-31941. -- Resolution: Not A Problem > Not backwards compatible naming for some kubernetes resources > --

[jira] [Resolved] (FLINK-31964) Improve the document of Autoscaler as 1.17.0 is released

[ https://issues.apache.org/jira/browse/FLINK-31964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-31964. Resolution: Fixed > Improve the document of Autoscaler as 1.17.0 is released > ---

[jira] [Closed] (FLINK-31850) Fix args in JobSpec not being passed through to Flink in Standalone mode - 1.4.0

[ https://issues.apache.org/jira/browse/FLINK-31850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-31850. -- Resolution: Not A Problem > Fix args in JobSpec not being passed through to Flink in Standalone mode -

[jira] [Closed] (FLINK-31613) Some default operator config values are overwritten by values.yaml

[ https://issues.apache.org/jira/browse/FLINK-31613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-31613. -- Resolution: Won't Fix > Some default operator config values are overwritten by values.yaml > -

[jira] [Resolved] (FLINK-31203) Application upgrade rollbacks failed in Flink Kubernetes Operator

[ https://issues.apache.org/jira/browse/FLINK-31203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-31203. Resolution: Fixed I think this is fixed in 1.6.0 > Application upgrade rollbacks failed in Flink

[jira] [Commented] (FLINK-31064) Error while retrieving the leader gateway

[ https://issues.apache.org/jira/browse/FLINK-31064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760726#comment-17760726 ] Gyula Fora commented on FLINK-31064: [~tshofer] is still still an issue? > Error wh

[GitHub] [flink] gaborgsomogyi commented on pull request #23329: [FLINK-32989][python] Fix version parsing issue

gaborgsomogyi commented on PR #23329: URL: https://github.com/apache/flink/pull/23329#issuecomment-1700428297 Unless there are any objections I will merge this to unblock things. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #661: [FLINK-32700] Support job drain for Savepoint upgrade mode

gyfora commented on PR #661: URL: https://github.com/apache/flink-kubernetes-operator/pull/661#issuecomment-1700427568 Regenerate the docs pls: `mvn clean install -DskipTests -Pgenerate-docs` -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [flink] jiangxin369 commented on pull request #23332: [FLINK-32996][Tests] Fix the CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished fails

jiangxin369 commented on PR #23332: URL: https://github.com/apache/flink/pull/23332#issuecomment-1700419715 @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 commen

[GitHub] [flink] jiangxin369 commented on pull request #23331: [FLINK-32996][Tests] Fix the CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished fails

jiangxin369 commented on PR #23331: URL: https://github.com/apache/flink/pull/23331#issuecomment-1700419231 @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 commen

[jira] [Commented] (FLINK-29359) Pulsar Table Connector pom config and packaging

[ https://issues.apache.org/jira/browse/FLINK-29359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760716#comment-17760716 ] Yufei Zhang commented on FLINK-29359: - [~tison] Yeah I think when the ticket is crea

[jira] [Comment Edited] (FLINK-29359) Pulsar Table Connector pom config and packaging

[ https://issues.apache.org/jira/browse/FLINK-29359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760716#comment-17760716 ] Yufei Zhang edited comment on FLINK-29359 at 8/31/23 4:56 AM:

[jira] [Updated] (FLINK-32122) Update the Azure Blob Storage document to assist in configuring the MSI provider with a shaded class name

[ https://issues.apache.org/jira/browse/FLINK-32122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32122: --- Labels: pull-request-available (was: ) > Update the Azure Blob Storage document to assist i

[GitHub] [flink] surendralilhore commented on pull request #22602: [FLINK-32122] Update the Azure Blob Storage document to assist in configuring the MSI provider with a shaded class name

surendralilhore commented on PR #22602: URL: https://github.com/apache/flink/pull/22602#issuecomment-1700360398 @MartijnVisser , Thanks for review. Updated Chinese document. Sorry for late reply. -- This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] masteryhx commented on a diff in pull request #23239: [FLINK-26585][state-processor-api] replace implementation of MultiStateKeyIterator with Stream-free implementation

masteryhx commented on code in PR #23239: URL: https://github.com/apache/flink/pull/23239#discussion_r1311067683 ## flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/input/MultiStateKeyIterator.java: ## @@ -46,47 +55,59 @@ public final class Mul

[GitHub] [flink] JunRuiLee commented on pull request #23181: W.I.P only used to run ci.

JunRuiLee commented on PR #23181: URL: https://github.com/apache/flink/pull/23181#issuecomment-1700345704 @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] dianfu commented on pull request #23329: [FLINK-32989][python] Fix version parsing issue

dianfu commented on PR #23329: URL: https://github.com/apache/flink/pull/23329#issuecomment-1700340731 Verified that the broken CI could pass with this PR. 👍 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

[jira] [Commented] (FLINK-29199) Support blue-green deployment type

[ https://issues.apache.org/jira/browse/FLINK-29199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760707#comment-17760707 ] Matt Wang commented on FLINK-29199: --- [~nfraison.datadog] I think [double data output]

[GitHub] [flink] flinkbot commented on pull request #23341: Dev flink 6912 test6

flinkbot commented on PR #23341: URL: https://github.com/apache/flink/pull/23341#issuecomment-1700332505 ## CI report: * d5dc0f956e46340210165aa55c11ae92bfad84ed UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-32731) SqlGatewayE2ECase.testHiveServer2ExecuteStatement failed due to MetaException

[ https://issues.apache.org/jira/browse/FLINK-32731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760705#comment-17760705 ] Shengkai Fang commented on FLINK-32731: --- > How do you find out whether "it works"?

[GitHub] [flink] WencongLiu commented on pull request #21184: [FLINK-29787][ci] fix ci METHOD_NEW_DEFAULT issue

WencongLiu commented on PR #21184: URL: https://github.com/apache/flink/pull/21184#issuecomment-1700319487 Hello @XComp @liyubin117 , currently I meet a same problem when I'm trying to add a new default method to a class with @Public annotation. Should I just need to add an @PublicEvolving

[jira] [Resolved] (FLINK-32975) Enhance equal() for all MapState's iterator

[ https://issues.apache.org/jira/browse/FLINK-32975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-32975. -- Fix Version/s: 1.19.0 Resolution: Fixed merge [aa8d93ea|https://github.com/apache/flin

[jira] [Commented] (FLINK-32963) Make the test "testKeyedMapStateStateMigration" stable

[ https://issues.apache.org/jira/browse/FLINK-32963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760699#comment-17760699 ] Hangxiang Yu commented on FLINK-32963: -- This is just a simple improvement to make t

[jira] [Updated] (FLINK-29390) Pulsar SQL Connector: SQLClient E2E testing

[ https://issues.apache.org/jira/browse/FLINK-29390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29390: --- Labels: pull-request-available (was: ) > Pulsar SQL Connector: SQLClient E2E testing >

[GitHub] [flink-connector-pulsar] tisonkun opened a new pull request, #58: [FLINK-29390] SQLClient E2E testing

tisonkun opened a new pull request, #58: URL: https://github.com/apache/flink-connector-pulsar/pull/58 Run tests. ## Significant changes *(Please check any boxes [x] if the answer is "yes". You can first publish the PR and check them afterwards, for convenience.)* - [

[jira] [Commented] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP

[ https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760695#comment-17760695 ] Hangxiang Yu commented on FLINK-32523: -- [~mapohl] Thanks for the reminder. I will m

[jira] [Resolved] (FLINK-32781) Release Testing: Add a metric for back-pressure from the ChangelogStateBackend

[ https://issues.apache.org/jira/browse/FLINK-32781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-32781. -- Resolution: Fixed Verified the metric in UI, just as [~Yanfei Lei] shows. > Release Testing:

[jira] [Comment Edited] (FLINK-32785) Release Testing: Verify FLIP-292: Enhance COMPILED PLAN to support operator-level state TTL configuration

[ https://issues.apache.org/jira/browse/FLINK-32785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1775#comment-1775 ] Jane Chan edited comment on FLINK-32785 at 8/31/23 3:09 AM:

[jira] [Commented] (FLINK-32785) Release Testing: Verify FLIP-292: Enhance COMPILED PLAN to support operator-level state TTL configuration

[ https://issues.apache.org/jira/browse/FLINK-32785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760693#comment-17760693 ] Jane Chan commented on FLINK-32785: --- Hi, [~snuyanzin],  This issue is because the test

[GitHub] [flink] masteryhx merged pull request #23334: [FLINK-32523][test] Guarantee all operators triggering decline checkpoint together for NotifyCheckpointAbortedITCase#testNotifyCheckpointAborted

masteryhx merged PR #23334: URL: https://github.com/apache/flink/pull/23334 -- 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.apa

[GitHub] [flink] masteryhx commented on pull request #23333: [FLINK-32523][test] Guarantee all operators triggering decline checkpoint together for NotifyCheckpointAbortedITCase#testNotifyCheckpointAb

masteryhx commented on PR #2: URL: https://github.com/apache/flink/pull/2#issuecomment-1700302031 @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-kubernetes-operator] mananmangal closed pull request #648: [FLINK-32700] Support job drain for Savepoint upgrade mode

mananmangal closed pull request #648: [FLINK-32700] Support job drain for Savepoint upgrade mode URL: https://github.com/apache/flink-kubernetes-operator/pull/648 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

[GitHub] [flink-kubernetes-operator] mananmangal commented on pull request #648: [FLINK-32700] Support job drain for Savepoint upgrade mode

mananmangal commented on PR #648: URL: https://github.com/apache/flink-kubernetes-operator/pull/648#issuecomment-1700300622 #661 Created. Closing this one due to incorrect rebase. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Assigned] (FLINK-29390) Pulsar SQL Connector: SQLClient E2E testing

[ https://issues.apache.org/jira/browse/FLINK-29390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-29390: - Assignee: Zili Chen > Pulsar SQL Connector: SQLClient E2E testing > ---

[jira] [Closed] (FLINK-31427) Pulsar Catalog support with Schema translation

[ https://issues.apache.org/jira/browse/FLINK-31427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-31427. - Fix Version/s: (was: pulsar-4.0.1) Resolution: Later It's rare that users would use Pulsar as

[GitHub] [flink-kubernetes-operator] mananmangal opened a new pull request, #661: FLINK-32700

mananmangal opened a new pull request, #661: URL: https://github.com/apache/flink-kubernetes-operator/pull/661 ## What is the purpose of the change This pull request adds an option called `kubernetes.operator.job.drain-on-savepoint-deletion` to indicate whether a job should b

[jira] [Assigned] (FLINK-29360) Pulsar Table Connector Documentation

[ https://issues.apache.org/jira/browse/FLINK-29360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-29360: - Assignee: Zili Chen > Pulsar Table Connector Documentation > --

[jira] [Commented] (FLINK-29359) Pulsar Table Connector pom config and packaging

[ https://issues.apache.org/jira/browse/FLINK-29359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760687#comment-17760687 ] Zili Chen commented on FLINK-29359: --- [~affe] [~syhily] [~leonard] I'm unsure if this t

[jira] [Resolved] (FLINK-29357) Pulsar Table Sink code: implementation

[ https://issues.apache.org/jira/browse/FLINK-29357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen resolved FLINK-29357. --- Fix Version/s: pulsar-4.1.0 Resolution: Fixed master via c71fc862e0d4a782c19f361d3bf581da836c

[jira] [Assigned] (FLINK-29357) Pulsar Table Sink code: implementation

[ https://issues.apache.org/jira/browse/FLINK-29357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-29357: - Assignee: Zili Chen > Pulsar Table Sink code: implementation >

[jira] [Resolved] (FLINK-29358) Pulsar Table Connector testing

[ https://issues.apache.org/jira/browse/FLINK-29358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen resolved FLINK-29358. --- Fix Version/s: pulsar-4.1.0 Assignee: Zili Chen Resolution: Fixed master via c71fc86

[jira] [Resolved] (FLINK-29356) Pulsar Table Source code :implementation

[ https://issues.apache.org/jira/browse/FLINK-29356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen resolved FLINK-29356. --- Fix Version/s: pulsar-4.1.0 Resolution: Fixed master via c71fc862e0d4a782c19f361d3bf581da836c

[jira] [Assigned] (FLINK-29356) Pulsar Table Source code :implementation

[ https://issues.apache.org/jira/browse/FLINK-29356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-29356: - Assignee: Zili Chen > Pulsar Table Source code :implementation > --

[GitHub] [flink-connector-pulsar] tisonkun commented on pull request #56: [FLINK-26203] Basic table factory for Pulsar connector

tisonkun commented on PR #56: URL: https://github.com/apache/flink-connector-pulsar/pull/56#issuecomment-1700296791 @leonardBang Thank you! Merged. > sql jar and task for docs can start as well next Yep. Let me create the related JIRA tickets.. -- This is an automated messag

[GitHub] [flink-kubernetes-operator] mananmangal commented on pull request #648: [FLINK-32700] Support job drain for Savepoint upgrade mode

mananmangal commented on PR #648: URL: https://github.com/apache/flink-kubernetes-operator/pull/648#issuecomment-1700295844 Looks like something went wrong during rebase, let me create another request and we can close this one. -- This is an automated message from the Apache Git Service.

[GitHub] [flink] flinkbot commented on pull request #23340: Dev flink 6912 test5

flinkbot commented on PR #23340: URL: https://github.com/apache/flink/pull/23340#issuecomment-1700294924 ## CI report: * 100cdf50addeb89ca565cc2d9e2f864b9b1787fb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #23339: [BP-1.18][FLINK-32821][examples] Include flink-connector-datagen for streaming examples

flinkbot commented on PR #23339: URL: https://github.com/apache/flink/pull/23339#issuecomment-1700294811 ## CI report: * 8b7483b80352548191ca15517e08a5dbeacc8334 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-connector-pulsar] tisonkun merged pull request #56: [FLINK-26203] Basic table factory for Pulsar connector

tisonkun merged PR #56: URL: https://github.com/apache/flink-connector-pulsar/pull/56 -- 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] X-czh commented on pull request #23339: [BP-1.18][FLINK-32821][examples] Include flink-connector-datagen for streaming examples

X-czh commented on PR #23339: URL: https://github.com/apache/flink/pull/23339#issuecomment-1700293301 @huwh Could you help take a look? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specifi

[jira] [Commented] (FLINK-26203) Support Table API in Pulsar Connector

[ https://issues.apache.org/jira/browse/FLINK-26203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760680#comment-17760680 ] Zili Chen commented on FLINK-26203: --- Yeah. I'm updating the tickets here now. > Suppo

[jira] [Resolved] (FLINK-32798) Release Testing: Verify FLIP-294: Support Customized Catalog Modification Listener

[ https://issues.apache.org/jira/browse/FLINK-32798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-32798. --- Resolution: Done > Release Testing: Verify FLIP-294: Support Customized Catalog Modification

[jira] [Assigned] (FLINK-32755) Add quick start guide for Flink OLAP

[ https://issues.apache.org/jira/browse/FLINK-32755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-32755: -- Assignee: xiangyu feng > Add quick start guide for Flink OLAP > -

[jira] [Commented] (FLINK-33004) Decoupling topology and network memory to support complex job topologies

[ https://issues.apache.org/jira/browse/FLINK-33004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760673#comment-17760673 ] dalongliu commented on FLINK-33004: --- cc [~guoweijie]  > Decoupling topology and netwo

[jira] [Created] (FLINK-33004) Decoupling topology and network memory to support complex job topologies

dalongliu created FLINK-33004: - Summary: Decoupling topology and network memory to support complex job topologies Key: FLINK-33004 URL: https://issues.apache.org/jira/browse/FLINK-33004 Project: Flink

[jira] [Created] (FLINK-33003) Flink ML add isolationForest algorithm

zhaozijun created FLINK-33003: - Summary: Flink ML add isolationForest algorithm Key: FLINK-33003 URL: https://issues.apache.org/jira/browse/FLINK-33003 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-32798) Release Testing: Verify FLIP-294: Support Customized Catalog Modification Listener

[ https://issues.apache.org/jira/browse/FLINK-32798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760670#comment-17760670 ] Hang Ruan commented on FLINK-32798: --- [~renqs] [~zjureel] , I think we could complete t

[GitHub] [flink] flinkbot commented on pull request #23338: [FLINK-32952][table-planner] Fix scan reuse with readable metadata and watermark push down get wrong watermark error

flinkbot commented on PR #23338: URL: https://github.com/apache/flink/pull/23338#issuecomment-1700235442 ## CI report: * aa90d3540a792e72dea020a15b7cb67d35962aad UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] wangyang0918 commented on a diff in pull request #23327: [FLINK-32994][runtime] Adds human-readable toString implementations to the LeaderElectionDriver classes

wangyang0918 commented on code in PR #23327: URL: https://github.com/apache/flink/pull/23327#discussion_r1311008016 ## flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java: ## @@ -610,12 +611,41 @@ FileSystemStateStorageHelper createFileSystemStateStora

[GitHub] [flink] swuferhong opened a new pull request, #23338: [FLINK-32952][table-planner] Fix scan reuse with readable metadata and watermark push down get wrong watermark error

swuferhong opened a new pull request, #23338: URL: https://github.com/apache/flink/pull/23338 ## What is the purpose of the change cherry-pick to releae-1.18 ## Brief change log ## Verifying this change ## Does this pull request potentially affe

[GitHub] [flink] liuyongvs commented on pull request #22745: [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function.

liuyongvs commented on PR #22745: URL: https://github.com/apache/flink/pull/22745#issuecomment-1700223225 hi @snuyanzin do you have time to look again? -- 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 g

[jira] [Updated] (FLINK-32990) when execute Plan#translate function with CREATE TABLE AS statement, the CreateTableASOperation as Plan.translate function parameter exception

[ https://issues.apache.org/jira/browse/FLINK-32990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Licho Sun updated FLINK-32990: -- Description: The `translate` function comment description `ModifyOperation` could be a parameter, but

[GitHub] [flink] swuferhong commented on pull request #23285: [FLINK-32952][table-planner] Fix scan reuse with readable metadata and watermark push down get wrong watermark error

swuferhong commented on PR #23285: URL: https://github.com/apache/flink/pull/23285#issuecomment-1700165210 > @swuferhong could you open a cherry-pick pull request for release-1.18 branch? Sure. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Closed] (FLINK-18445) Short circuit join condition for lookup join

[ https://issues.apache.org/jira/browse/FLINK-18445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-18445. --- Resolution: Fixed fixed in master: 360b97a710a9711bffbf320db2806c17557bb334 > Short circuit join co

[GitHub] [flink] lincoln-lil merged pull request #23316: [FLINK-18445][table] Add pre-filter optimization for lookup join

lincoln-lil merged PR #23316: URL: https://github.com/apache/flink/pull/23316 -- 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.a

[jira] [Updated] (FLINK-11526) Support Chinese Website for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-11526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11526: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned pull-request-ava

[jira] [Updated] (FLINK-15012) Checkpoint directory not cleaned up

[ https://issues.apache.org/jira/browse/FLINK-15012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15012: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned pull-request-ava

[jira] [Updated] (FLINK-18822) [umbrella] Improve and complete Change Data Capture formats

[ https://issues.apache.org/jira/browse/FLINK-18822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18822: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was: auto-depr

[jira] [Updated] (FLINK-32509) avoid using skip in InputStreamFSInputWrapper.seek

[ https://issues.apache.org/jira/browse/FLINK-32509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32509: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-32264) Add FIELD support in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-32264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32264: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

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

[ https://issues.apache.org/jira/browse/FLINK-29459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760626#comment-17760626 ] Martijn Visser commented on FLINK-29459: [~gaoyunhaii] Sorry for the late reply,

[jira] [Updated] (FLINK-32962) Failure to install python dependencies from requirements file

[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksandr Pilipenko updated FLINK-32962: Affects Version/s: 1.18.0 > Failure to install python dependencies from requiremen

[jira] [Closed] (FLINK-33002) Bump snappy-java from 1.1.4 to 1.1.10.1

[ https://issues.apache.org/jira/browse/FLINK-33002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-33002. -- Fix Version/s: statefun-3.3.0 Resolution: Fixed Fixed in: apache/flink-statefun 4b1e0f

[jira] [Updated] (FLINK-33002) Bump snappy-java from 1.1.4 to 1.1.10.1

[ https://issues.apache.org/jira/browse/FLINK-33002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33002: --- Labels: pull-request-available (was: ) > Bump snappy-java from 1.1.4 to 1.1.10.1 >

[GitHub] [flink-statefun] MartijnVisser merged pull request #330: [FLINK-33002] Bump snappy-java from 1.1.4 to 1.1.10.1 in /statefun-flink

MartijnVisser merged PR #330: URL: https://github.com/apache/flink-statefun/pull/330 -- 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] flinkbot commented on pull request #23337: [FLINK-32962][python] Remove pip version check on installing dependencies.

flinkbot commented on PR #23337: URL: https://github.com/apache/flink/pull/23337#issuecomment-1699727538 ## CI report: * c6a8c746e52ec4ca81671f32b19bebccb23a1600 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-statefun] dependabot[bot] commented on pull request #327: Bump jackson-databind from 2.13.2.2 to 2.13.4.2

dependabot[bot] commented on PR #327: URL: https://github.com/apache/flink-statefun/pull/327#issuecomment-1699759947 Looks like this PR is already up-to-date with master! If you'd still like to recreate it from scratch, overwriting any edits, you can request `@dependabot recreate`. -- Th

[jira] [Created] (FLINK-33002) Bump snappy-java from 1.1.4 to 1.1.10.1

Martijn Visser created FLINK-33002: -- Summary: Bump snappy-java from 1.1.4 to 1.1.10.1 Key: FLINK-33002 URL: https://issues.apache.org/jira/browse/FLINK-33002 Project: Flink Issue Type: Techn

  1   2   3   >