[jira] [Updated] (FLINK-33528) Externalize Python connector code

[ https://issues.apache.org/jira/browse/FLINK-33528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-33528: --- Description: During the connector externalization effort end to end tests for the python

[jira] [Created] (FLINK-33561) Externalize Pulsar Python connector code

Márton Balassi created FLINK-33561: -- Summary: Externalize Pulsar Python connector code Key: FLINK-33561 URL: https://issues.apache.org/jira/browse/FLINK-33561 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-33562) Externalize RabbitMQ Python connector code

Márton Balassi created FLINK-33562: -- Summary: Externalize RabbitMQ Python connector code Key: FLINK-33562 URL: https://issues.apache.org/jira/browse/FLINK-33562 Project: Flink Issue Type

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805495#comment-17805495 ] David Morávek commented on FLINK-34007: --- If there would have been a contin

[jira] [Updated] (FLINK-34063) When snapshot compression is enabled, rescaling of a source operator leads to some splits getting lost

[ https://issues.apache.org/jira/browse/FLINK-34063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-34063: -- Affects Version/s: 1.18.0 > When snapshot compression is enabled, rescaling of a sou

[jira] [Updated] (FLINK-34063) When snapshot compression is enabled, rescaling of a source operator leads to some splits getting lost

[ https://issues.apache.org/jira/browse/FLINK-34063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-34063: -- Priority: Blocker (was: Critical) > When snapshot compression is enabled, rescaling o

[jira] [Assigned] (FLINK-34063) When snapshot compression is enabled, rescaling of a source operator leads to some splits getting lost

[ https://issues.apache.org/jira/browse/FLINK-34063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek reassigned FLINK-34063: - Assignee: David Morávek > When snapshot compression is enabled, rescaling of a sou

[jira] [Updated] (FLINK-34063) When snapshot compression is enabled, rescaling of a source operator leads to some splits getting lost

[ https://issues.apache.org/jira/browse/FLINK-34063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-34063: -- Affects Version/s: 1.18.1 > When snapshot compression is enabled, rescaling of a sou

[jira] [Commented] (FLINK-34063) When snapshot compression is enabled, rescaling of a source operator leads to some splits getting lost

[ https://issues.apache.org/jira/browse/FLINK-34063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806131#comment-17806131 ] David Morávek commented on FLINK-34063: --- Hi [~yang], it would be great if

[jira] [Commented] (FLINK-34096) Upscale of kafka source operator leads to some splits getting lost

[ https://issues.apache.org/jira/browse/FLINK-34096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806932#comment-17806932 ] David Morávek commented on FLINK-34096: --- If you can share the whole log

[jira] [Commented] (FLINK-34096) Upscale of kafka source operator leads to some splits getting lost

[ https://issues.apache.org/jira/browse/FLINK-34096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807365#comment-17807365 ] David Morávek commented on FLINK-34096: --- What version of the Kafka connector

[jira] [Commented] (FLINK-34096) Upscale of kafka source operator leads to some splits getting lost

[ https://issues.apache.org/jira/browse/FLINK-34096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807384#comment-17807384 ] David Morávek commented on FLINK-34096: --- > It feels to me that s

[jira] [Resolved] (FLINK-34096) Upscale of kafka source operator leads to some splits getting lost

[ https://issues.apache.org/jira/browse/FLINK-34096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek resolved FLINK-34096. --- Resolution: Duplicate > Upscale of kafka source operator leads to some splits getting l

[jira] [Assigned] (FLINK-33123) Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek reassigned FLINK-33123: - Assignee: David Morávek > Wrong dynamic replacement of partitioner from FORWARD

[jira] [Assigned] (FLINK-33557) Externalize Cassandra Python connector code

[ https://issues.apache.org/jira/browse/FLINK-33557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-33557: -- Assignee: Ferenc Csaky > Externalize Cassandra Python connector c

[jira] [Assigned] (FLINK-33558) Externalize Elasticsearch Python connector code

[ https://issues.apache.org/jira/browse/FLINK-33558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-33558: -- Assignee: Ferenc Csaky > Externalize Elasticsearch Python connector c

[jira] [Commented] (FLINK-34063) When snapshot compression is enabled, rescaling of a source operator leads to some splits getting lost

[ https://issues.apache.org/jira/browse/FLINK-34063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808603#comment-17808603 ] David Morávek commented on FLINK-34063: --- ma

[jira] [Updated] (FLINK-34063) When snapshot compression is enabled, rescaling of a source operator leads to some splits getting lost

[ https://issues.apache.org/jira/browse/FLINK-34063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-34063: -- Release Note: Fixes a regression introduced in 1.18.0, where operator state couldn'

[jira] [Updated] (FLINK-34063) When snapshot compression is enabled, rescaling of a source operator leads to some splits getting lost

[ https://issues.apache.org/jira/browse/FLINK-34063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-34063: -- Release Note: Fixes a regression introduced in 1.18.0, where operator state couldn'

[jira] [Resolved] (FLINK-34063) When snapshot compression is enabled, rescaling of a source operator leads to some splits getting lost

[ https://issues.apache.org/jira/browse/FLINK-34063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek resolved FLINK-34063. --- Resolution: Fixed > When snapshot compression is enabled, rescaling of a source opera

[jira] [Comment Edited] (FLINK-34063) When snapshot compression is enabled, rescaling of a source operator leads to some splits getting lost

[ https://issues.apache.org/jira/browse/FLINK-34063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808603#comment-17808603 ] David Morávek edited comment on FLINK-34063 at 1/19/24 2:2

[jira] [Created] (FLINK-34201) Datadog name resolution fails and do not retry causing metrics to not get exported

Pedro Mázala created FLINK-34201: Summary: Datadog name resolution fails and do not retry causing metrics to not get exported Key: FLINK-34201 URL: https://issues.apache.org/jira/browse/FLINK-34201

[jira] [Updated] (FLINK-34201) Datadog name resolution fails and do not retry causing metrics to not get exported

[ https://issues.apache.org/jira/browse/FLINK-34201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pedro Mázala updated FLINK-34201: - Description: When node restarts happens on k8s, some deployments fail to report metrics to

[jira] [Commented] (FLINK-32315) Support local file upload in K8s mode

[ https://issues.apache.org/jira/browse/FLINK-32315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810733#comment-17810733 ] Márton Balassi commented on FLINK-32315: [~Paul Lin] I would assign thi

[jira] [Assigned] (FLINK-28915) Make application mode could support remote DFS schema(e.g. S3, OSS, HDFS, etc.)

[ https://issues.apache.org/jira/browse/FLINK-28915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-28915: -- Assignee: Ferenc Csaky (was: hjw) > Make application mode could support remote

[jira] [Commented] (FLINK-28915) Make application mode could support remote DFS schema(e.g. S3, OSS, HDFS, etc.)

[ https://issues.apache.org/jira/browse/FLINK-28915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810757#comment-17810757 ] Márton Balassi commented on FLINK-28915: [e63aa12|https://github.com/ap

[jira] [Closed] (FLINK-28915) Make application mode could support remote DFS schema(e.g. S3, OSS, HDFS, etc.)

[ https://issues.apache.org/jira/browse/FLINK-28915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-28915. -- Fix Version/s: 1.19.0 Resolution: Implemented > Make application mode could supp

[jira] [Assigned] (FLINK-32315) Support local file upload in K8s mode

[ https://issues.apache.org/jira/browse/FLINK-32315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-32315: -- Assignee: Ferenc Csaky > Support local file upload in K8s m

[jira] [Commented] (FLINK-33976) AdaptiveScheduler cooldown period is taken from a wrong configuration

[ https://issues.apache.org/jira/browse/FLINK-33976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811939#comment-17811939 ] David Morávek commented on FLINK-33976: --- ma

[jira] [Resolved] (FLINK-33976) AdaptiveScheduler cooldown period is taken from a wrong configuration

[ https://issues.apache.org/jira/browse/FLINK-33976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek resolved FLINK-33976. --- Fix Version/s: 1.19.0 Resolution: Fixed > AdaptiveScheduler cooldown period is ta

[jira] [Assigned] (FLINK-34272) AdaptiveSchedulerClusterITCase failure due to MiniCluster not running

[ https://issues.apache.org/jira/browse/FLINK-34272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek reassigned FLINK-34272: - Assignee: David Morávek > AdaptiveSchedulerClusterITCase failure due to MiniClus

[jira] [Commented] (FLINK-34272) AdaptiveSchedulerClusterITCase failure due to MiniCluster not running

[ https://issues.apache.org/jira/browse/FLINK-34272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812461#comment-17812461 ] David Morávek commented on FLINK-34272: --- The bug is quite critical and can

[jira] [Updated] (FLINK-34272) AdaptiveSchedulerClusterITCase failure due to MiniCluster not running

[ https://issues.apache.org/jira/browse/FLINK-34272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-34272: -- Priority: Blocker (was: Critical) > AdaptiveSchedulerClusterITCase failure due

[jira] [Commented] (FLINK-34272) AdaptiveSchedulerClusterITCase failure due to MiniCluster not running

[ https://issues.apache.org/jira/browse/FLINK-34272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812483#comment-17812483 ] David Morávek commented on FLINK-34272: --- The root cause of FLINK-3427

[jira] [Commented] (FLINK-34274) AdaptiveSchedulerTest.testRequirementLowerBoundDecreaseAfterResourceScarcityBelowAvailableSlots times out

[ https://issues.apache.org/jira/browse/FLINK-34274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812484#comment-17812484 ] David Morávek commented on FLINK-34274: --- It's possible to hit the reso

[jira] [Assigned] (FLINK-34274) AdaptiveSchedulerTest.testRequirementLowerBoundDecreaseAfterResourceScarcityBelowAvailableSlots times out

[ https://issues.apache.org/jira/browse/FLINK-34274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek reassigned FLINK-34274: - Assignee: David Morávek

[jira] [Commented] (FLINK-33092) Improve the resource-stabilization-timeout mechanism when rescale a job for Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-33092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812796#comment-17812796 ] David Morávek commented on FLINK-33092: --- This is something we've

[jira] [Commented] (FLINK-33092) Improve the resource-stabilization-timeout mechanism when rescale a job for Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-33092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812797#comment-17812797 ] David Morávek commented on FLINK-33092: --- I've attached some notes I had

[jira] [Updated] (FLINK-33092) Improve the resource-stabilization-timeout mechanism when rescale a job for Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-33092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-33092: -- Attachment: FLINK-FLIP-XXX_ Refining AdaptiveScheduler timeouts and rescale triggering-310124

[jira] [Resolved] (FLINK-34272) AdaptiveSchedulerClusterITCase failure due to MiniCluster not running

[ https://issues.apache.org/jira/browse/FLINK-34272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek resolved FLINK-34272. --- Fix Version/s: 1.19.0 Resolution: Fixed > AdaptiveSchedulerClusterITCase failure

[jira] [Commented] (FLINK-34272) AdaptiveSchedulerClusterITCase failure due to MiniCluster not running

[ https://issues.apache.org/jira/browse/FLINK-34272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813004#comment-17813004 ] David Morávek commented on FLINK-34272: --- [~xuyangzhong] the CI run doesn&#x

[jira] [Commented] (FLINK-34272) AdaptiveSchedulerClusterITCase failure due to MiniCluster not running

[ https://issues.apache.org/jira/browse/FLINK-34272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813005#comment-17813005 ] David Morávek commented on FLINK-34272: --- ma

[jira] [Created] (FLINK-34398) Validation Error in FlinkSessionJob Savepoint UpgradeMode Configuration

Dominik Dębowczyk created FLINK-34398: - Summary: Validation Error in FlinkSessionJob Savepoint UpgradeMode Configuration Key: FLINK-34398 URL: https://issues.apache.org/jira/browse/FLINK-34398

[jira] [Commented] (FLINK-25857) Add committer metrics to track the status of committables

[ https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790007#comment-17790007 ] Márton Balassi commented on FLINK-25857: Hi team, Thanks for looking into

[jira] [Created] (FLINK-33722) MATCH_RECOGNIZE in batch mode ignores events order

Grzegorz Kołakowski created FLINK-33722: --- Summary: MATCH_RECOGNIZE in batch mode ignores events order Key: FLINK-33722 URL: https://issues.apache.org/jira/browse/FLINK-33722 Project: Flink

[jira] [Updated] (FLINK-33722) MATCH_RECOGNIZE in batch mode ignores events order

[ https://issues.apache.org/jira/browse/FLINK-33722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grzegorz Kołakowski updated FLINK-33722: Description: MATCH_RECOGNIZE in batch mode seems to ignore ORDER BY clause. Let&#

[jira] [Updated] (FLINK-33722) MATCH_RECOGNIZE in batch mode ignores events order

[ https://issues.apache.org/jira/browse/FLINK-33722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grzegorz Kołakowski updated FLINK-33722: Description: MATCH_RECOGNIZE in batch mode seems to ignore ORDER BY clause. Let&#

[jira] [Created] (FLINK-33729) Events are getting lost when an exception occurs within a processing function

Rafał Trójczak created FLINK-33729: -- Summary: Events are getting lost when an exception occurs within a processing function Key: FLINK-33729 URL: https://issues.apache.org/jira/browse/FLINK-33729

[jira] [Commented] (FLINK-33722) MATCH_RECOGNIZE in batch mode ignores events order

[ https://issues.apache.org/jira/browse/FLINK-33722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17792680#comment-17792680 ] Grzegorz Kołakowski commented on FLINK-33722: - Please assign me to the

[jira] [Commented] (FLINK-27291) Translate the "List of Data Types" section of "Data Types" in to Chinese

[ https://issues.apache.org/jira/browse/FLINK-27291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17793496#comment-17793496 ] 韩宏旭 commented on FLINK-27291: - Hey Chengkai Yang,Cason I am experienced in flink. I

[jira] (FLINK-27291) Translate the "List of Data Types" section of "Data Types" in to Chinese

[ https://issues.apache.org/jira/browse/FLINK-27291 ] 韩宏旭 deleted comment on FLINK-27291: - was (Author: maomao): Hey Chengkai Yang,Cason I am experienced in flink. I have seen this issue is created at 18/Apr/22 19:51 and Updated at 27/Mar/23 11:34

[jira] (FLINK-33722) MATCH_RECOGNIZE in batch mode ignores events order

[ https://issues.apache.org/jira/browse/FLINK-33722 ] Grzegorz Kołakowski deleted comment on FLINK-33722: - was (Author: grzegorz.kolakowski): Please assign me to the task. > MATCH_RECOGNIZE in batch mode ignores events or

[jira] [Commented] (FLINK-24865) Support MATCH_RECOGNIZE in Batch mode

[ https://issues.apache.org/jira/browse/FLINK-24865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17795323#comment-17795323 ] Grzegorz Kołakowski commented on FLINK-24865: - Hi [~nicholasjiang]

[jira] [Comment Edited] (FLINK-24865) Support MATCH_RECOGNIZE in Batch mode

[ https://issues.apache.org/jira/browse/FLINK-24865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17795323#comment-17795323 ] Grzegorz Kołakowski edited comment on FLINK-24865 at 12/11/23 12:4

[jira] [Resolved] (FLINK-25857) Add committer metrics to track the status of committables

[ https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-25857. Resolution: Fixed [59c42d9|https://github.com/apache/flink/commit

[jira] [Commented] (FLINK-33635) Some connectors can not compile in 1.19-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17795755#comment-17795755 ] Márton Balassi commented on FLINK-33635: I just merged [https://github

[jira] [Closed] (FLINK-33812) Autoscale not working properly for standalone application deployment

[ https://issues.apache.org/jira/browse/FLINK-33812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-33812. -- Fix Version/s: kubernetes-operator-1.8.0 Resolution: Fixed   [{{f01f8ec}}|https

[jira] [Created] (FLINK-33955) UnsupportedFileSystemException when trying to save data to Azure's abfss File System

Alek Łańduch created FLINK-33955: Summary: UnsupportedFileSystemException when trying to save data to Azure's abfss File System Key: FLINK-33955 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Commented] (FLINK-33955) UnsupportedFileSystemException when trying to save data to Azure's abfss File System

[ https://issues.apache.org/jira/browse/FLINK-33955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17801001#comment-17801001 ] Alek Łańduch commented on FLINK-33955: -- [~martijnvisser] Thanks for pointin

[jira] [Updated] (FLINK-33955) UnsupportedFileSystemException when trying to save data to Azure's abfss File System

[ https://issues.apache.org/jira/browse/FLINK-33955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alek Łańduch updated FLINK-33955: - Priority: Minor (was: Major) > UnsupportedFileSystemException when trying to save data

[jira] [Created] (FLINK-33976) AdaptiveScheduler cooldown period is taken from a wrong configuration

David Morávek created FLINK-33976: - Summary: AdaptiveScheduler cooldown period is taken from a wrong configuration Key: FLINK-33976 URL: https://issues.apache.org/jira/browse/FLINK-33976 Project

[jira] [Assigned] (FLINK-33976) AdaptiveScheduler cooldown period is taken from a wrong configuration

[ https://issues.apache.org/jira/browse/FLINK-33976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek reassigned FLINK-33976: - Assignee: David Morávek > AdaptiveScheduler cooldown period is taken from a wr

[jira] [Assigned] (FLINK-33997) Typo in the doc `classloader.parent-first-patterns-additional`

[ https://issues.apache.org/jira/browse/FLINK-33997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-33997: -- Assignee: Rodrigo Meneses > Typo in the doc `classloader.parent-first-patte

[jira] [Commented] (FLINK-31896) Extend web interface to support failure labels

[ https://issues.apache.org/jira/browse/FLINK-31896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803310#comment-17803310 ] David Morávek commented on FLINK-31896: --- ma

[jira] [Resolved] (FLINK-31896) Extend web interface to support failure labels

[ https://issues.apache.org/jira/browse/FLINK-31896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek resolved FLINK-31896. --- Fix Version/s: 1.19.0 Resolution: Fixed > Extend web interface to support fail

[jira] [Commented] (FLINK-28915) Make application mode could support remote DFS schema(e.g. S3, OSS, HDFS, etc.)

[ https://issues.apache.org/jira/browse/FLINK-28915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803501#comment-17803501 ] Márton Balassi commented on FLINK-28915: Due to the [inactivity|h

[jira] [Commented] (FLINK-24865) Support MATCH_RECOGNIZE in Batch mode

[ https://issues.apache.org/jira/browse/FLINK-24865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804628#comment-17804628 ] Grzegorz Kołakowski commented on FLINK-24865: - Hi [~martijnvisser], m

[jira] [Created] (FLINK-34925) flinkCDC 抽取SQLSERVER 报错

宇宙先生 created FLINK-34925: Summary: flinkCDC 抽取SQLSERVER 报错 Key: FLINK-34925 URL: https://issues.apache.org/jira/browse/FLINK-34925 Project: Flink Issue Type: Bug Components: Flink CDC

[jira] [Updated] (FLINK-34925) FlinkCDC 3.0 for extracting data from sqlserver, errors occur

[ https://issues.apache.org/jira/browse/FLINK-34925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 宇宙先生 updated FLINK-34925: - Summary: FlinkCDC 3.0 for extracting data from sqlserver, errors occur (was: flinkCDC 抽取SQLSERVER 报错

[jira] [Commented] (FLINK-34925) FlinkCDC 3.0 for extracting data from sqlserver, errors occur

[ https://issues.apache.org/jira/browse/FLINK-34925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830356#comment-17830356 ] 宇宙先生 commented on FLINK-34925: -- [~loserwang1024]   thanks for ur replay,  may I have

[jira] [Comment Edited] (FLINK-34925) FlinkCDC 3.0 for extracting data from sqlserver, errors occur

[ https://issues.apache.org/jira/browse/FLINK-34925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830356#comment-17830356 ] 宇宙先生 edited comment on FLINK-34925 at 3/25/24 6:3

[jira] [Commented] (FLINK-34925) FlinkCDC 3.0 for extracting data from sqlserver, errors occur

[ https://issues.apache.org/jira/browse/FLINK-34925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830750#comment-17830750 ] 宇宙先生 commented on FLINK-34925: --   thanks for ur replay again.  my table  DDL sq

[jira] [Commented] (FLINK-34925) FlinkCDC 3.0 for extracting data from sqlserver, errors occur

[ https://issues.apache.org/jira/browse/FLINK-34925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830794#comment-17830794 ] 宇宙先生 commented on FLINK-34925: -- [~loserwang1024] Maybe,I dont konw how to resolve it,

[jira] [Commented] (FLINK-34955) Upgrade commons-compress to 1.26.0

[ https://issues.apache.org/jira/browse/FLINK-34955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17831639#comment-17831639 ] Márton Balassi commented on FLINK-34955: Thanks! Let us get this in quick

[jira] [Updated] (FLINK-7151) Support function DDL

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-7151: -- Fix Version/s: 1.10.0 > Support function DDL > > >

[jira] [Updated] (FLINK-7151) Support function DDL

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-7151: -- Priority: Major (was: Not a Priority) > Support function

[jira] [Assigned] (FLINK-7151) Support function DDL

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-7151: - Assignee: Zhenqiu Huang > Support function

[jira] [Closed] (FLINK-7151) Support function DDL

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-7151. - Resolution: Fixed Already implemented as discussed in [FLIP-79.|https://cwiki.apache.org

[jira] [Assigned] (FLINK-34955) Upgrade commons-compress to 1.26.0

[ https://issues.apache.org/jira/browse/FLINK-34955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-34955: -- Assignee: Shilun Fan > Upgrade commons-compress to 1.2

[jira] [Updated] (FLINK-34955) Upgrade commons-compress to 1.26.0

[ https://issues.apache.org/jira/browse/FLINK-34955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-34955: --- Fix Version/s: 1.18.2 1.20.0 1.19.1 > Upgrade comm

[jira] [Commented] (FLINK-34955) Upgrade commons-compress to 1.26.0

[ https://issues.apache.org/jira/browse/FLINK-34955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833201#comment-17833201 ] Márton Balassi commented on FLINK-34955: [163b9cc|https://github.com/ap

[jira] [Commented] (FLINK-34955) Upgrade commons-compress to 1.26.0

[ https://issues.apache.org/jira/browse/FLINK-34955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833561#comment-17833561 ] Márton Balassi commented on FLINK-34955: [{{f172171}}|https://github.com/ap

[jira] [Closed] (FLINK-34955) Upgrade commons-compress to 1.26.0

[ https://issues.apache.org/jira/browse/FLINK-34955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-34955. -- Resolution: Fixed > Upgrade commons-compress to 1.2

[jira] [Assigned] (FLINK-34657) Implement Lineage Graph for streaming API use cases

[ https://issues.apache.org/jira/browse/FLINK-34657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-34657: -- Assignee: Zhenqiu Huang > Implement Lineage Graph for streaming API use ca

[jira] [Updated] (FLINK-34657) Implement Lineage Graph for streaming API use cases

[ https://issues.apache.org/jira/browse/FLINK-34657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-34657: --- Fix Version/s: 1.20.0 > Implement Lineage Graph for streaming API use ca

[jira] [Assigned] (FLINK-35015) Flink Parquet Reader doesn't honor parquet configuration

[ https://issues.apache.org/jira/browse/FLINK-35015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-35015: -- Assignee: Zhenqiu Huang > Flink Parquet Reader doesn't honor parquet confi

[jira] [Closed] (FLINK-34657) Implement Lineage Graph for streaming API use cases

[ https://issues.apache.org/jira/browse/FLINK-34657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-34657. -- Resolution: Fixed [{{d3d8ae4}}|https://github.com/apache/flink/commit

[jira] [Closed] (FLINK-35015) Flink Parquet Reader doesn't honor parquet configuration

[ https://issues.apache.org/jira/browse/FLINK-35015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-35015. -- Resolution: Fixed > Flink Parquet Reader doesn't honor parquet confi

[jira] [Commented] (FLINK-35015) Flink Parquet Reader doesn't honor parquet configuration

[ https://issues.apache.org/jira/browse/FLINK-35015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835687#comment-17835687 ] Márton Balassi commented on FLINK-35015: [{{c0891cf}}|https://github.com/ap

[jira] [Updated] (FLINK-35080) Allow to specify additional pushdown filter in table properties

[ https://issues.apache.org/jira/browse/FLINK-35080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grzegorz Kołakowski updated FLINK-35080: Description: Currently, flink-connector-jdbc supports filter pushdown only for

[jira] [Created] (FLINK-35080) Allow to specify additional pushdown filter in table properties

Grzegorz Kołakowski created FLINK-35080: --- Summary: Allow to specify additional pushdown filter in table properties Key: FLINK-35080 URL: https://issues.apache.org/jira/browse/FLINK-35080

[jira] [Updated] (FLINK-35080) Allow to specify additional pushdown filter in table properties

[ https://issues.apache.org/jira/browse/FLINK-35080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grzegorz Kołakowski updated FLINK-35080: Description: Currently, flink-connector-jdbc supports filter pushdown only for

[jira] [Created] (FLINK-35081) CompileException when watermark definition contains coalesce and to_timestamp built-in functions

Grzegorz Kołakowski created FLINK-35081: --- Summary: CompileException when watermark definition contains coalesce and to_timestamp built-in functions Key: FLINK-35081 URL: https://issues.apache.org/jira

[jira] [Created] (FLINK-35116) Upgrade JOSDK dependency to 4.8.3

Márton Balassi created FLINK-35116: -- Summary: Upgrade JOSDK dependency to 4.8.3 Key: FLINK-35116 URL: https://issues.apache.org/jira/browse/FLINK-35116 Project: Flink Issue Type

[jira] [Commented] (FLINK-34735) "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837571#comment-17837571 ] 牛一凡 commented on FLINK-34735: - I am willing to do this.Can it be assigned t

[jira] [Commented] (FLINK-34747) "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837575#comment-17837575 ] 牛一凡 commented on FLINK-34747: - I am willing to do this.Can it be assigned t

[jira] [Commented] (FLINK-34748) "legacy-flink-cdc-sources" Page of Oracle for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837576#comment-17837576 ] 牛一凡 commented on FLINK-34748: - I am willing to do this.Can it be assigned t

[jira] [Commented] (FLINK-34749) "legacy-flink-cdc-sources" Page of SQLServer for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837578#comment-17837578 ] 牛一凡 commented on FLINK-34749: - I am willing to do this.Can it be assigned t

[jira] [Commented] (FLINK-34752) "legacy-flink-cdc-sources" Page of TIDB for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837579#comment-17837579 ] 牛一凡 commented on FLINK-34752: - I am willing to do this.Can it be assigned t

[jira] [Comment Edited] (FLINK-34748) "legacy-flink-cdc-sources" Page of Oracle for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837576#comment-17837576 ] 牛一凡 edited comment on FLINK-34748 at 4/16/24 8:10 AM: -- Hi [~k

<    1   2   3   4   5   6   7   8   9   10   >