Sergei Morozov created FLINK-38065:
--
Summary: Mismatching bracket in PostgresOffset#toString
Key: FLINK-38065
URL: https://issues.apache.org/jira/browse/FLINK-38065
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-37979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergei Morozov updated FLINK-37979:
---
Description:
There is a redundant condition and a misleading comment in
{{MySqlSnapshotSpli
[
https://issues.apache.org/jira/browse/FLINK-37979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17985220#comment-17985220
]
Sergei Morozov commented on FLINK-37979:
I've already submitted a PR for this on
Sergei Morozov created FLINK-37979:
--
Summary: Obsolete MySQL CDC snapshot split assigner code
Key: FLINK-37979
URL: https://issues.apache.org/jira/browse/FLINK-37979
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-37891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergei Morozov updated FLINK-37891:
---
Summary: SQL Server CDC mistakenly documents scan.startup.mode=initial-only
as supported (w
Sergei Morozov created FLINK-37891:
--
Summary: SQL Server CDC mistakenly document
scan.startup.mode=initial-only as supported
Key: FLINK-37891
URL: https://issues.apache.org/jira/browse/FLINK-37891
Pr
Sergei Morozov created FLINK-37852:
--
Summary: SQL Server CDC cannot capture changes from tables with
special characters
Key: FLINK-37852
URL: https://issues.apache.org/jira/browse/FLINK-37852
Project
[
https://issues.apache.org/jira/browse/FLINK-37774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergei Morozov updated FLINK-37774:
---
Description:
If a SQL Server database name contains special characters (e.g. a space), the
Sergei Morozov created FLINK-37774:
--
Summary: SQL Server CDC connector incorrectly handles special
characters in database and table names
Key: FLINK-37774
URL: https://issues.apache.org/jira/browse/FLINK-37774
Sergei Morozov created FLINK-37710:
--
Summary: Schema operator relies on data sources re-emitting
CreateTableEvents during startup
Key: FLINK-37710
URL: https://issues.apache.org/jira/browse/FLINK-37710
Sergei Morozov created FLINK-37604:
--
Summary: Flink CDC pipeline composer doesn't assign UIDs to
operators
Key: FLINK-37604
URL: https://issues.apache.org/jira/browse/FLINK-37604
Project: Flink
Sergei Morozov created FLINK-37371:
--
Summary: Postgres CDC incremental source fails to handle
upper-case table and column names
Key: FLINK-37371
URL: https://issues.apache.org/jira/browse/FLINK-37371
[
https://issues.apache.org/jira/browse/FLINK-36406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergei Morozov updated FLINK-36406:
---
Fix Version/s: cdc-3.3.0
> MetadataApplier should be closed when the job stop
>
[
https://issues.apache.org/jira/browse/FLINK-36891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergei Morozov updated FLINK-36891:
---
Description:
PendingSplitsStateSerializer maintains a {{DataOutputSerializer}} instance
sto
Sergei Morozov created FLINK-36891:
--
Summary: MySQL CDC connector produces corrupted state in case of
serialization failure
Key: FLINK-36891
URL: https://issues.apache.org/jira/browse/FLINK-36891
Pro
[
https://issues.apache.org/jira/browse/FLINK-36546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergei Morozov updated FLINK-36546:
---
Fix Version/s: cdc-3.3.0
> Handle batch sources in DataSinkTranslator
>
[
https://issues.apache.org/jira/browse/FLINK-36546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergei Morozov updated FLINK-36546:
---
Description:
Currently, there is hard-coded {{boolean isBatchMode = false}} in
{{DataSinkTr
[
https://issues.apache.org/jira/browse/FLINK-36546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergei Morozov updated FLINK-36546:
---
Description:
Currently, there is hard-coded {{boolean isBatchMode = false}} in
{{DataSinkTr
Sergei Morozov created FLINK-36546:
--
Summary: Handle batch sources in DataSinkTranslator
Key: FLINK-36546
URL: https://issues.apache.org/jira/browse/FLINK-36546
Project: Flink
Issue Type: Im
[
https://issues.apache.org/jira/browse/FLINK-36407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergei Morozov updated FLINK-36407:
---
Attachment: Flink36407Reproducer.java
> SchemaRegistry doesn't shutdown its underlying Execu
[
https://issues.apache.org/jira/browse/FLINK-36407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergei Morozov updated FLINK-36407:
---
Description:
The {{SchemaRegistry}} class exclusively uses an {{ExecutorService}} referenced
Sergei Morozov created FLINK-36407:
--
Summary: SchemaRegistry doesn't shutdown its underlying
ExecutorService upon closing
Key: FLINK-36407
URL: https://issues.apache.org/jira/browse/FLINK-36407
Proje
Sergei Morozov created FLINK-36406:
--
Summary: MetadataApplier should be closed when the job stop
Key: FLINK-36406
URL: https://issues.apache.org/jira/browse/FLINK-36406
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-35056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875604#comment-17875604
]
Sergei Morozov commented on FLINK-35056:
I submitted a pull request with a test
[
https://issues.apache.org/jira/browse/FLINK-35056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875320#comment-17875320
]
Sergei Morozov commented on FLINK-35056:
Here's a source table example that will
Sergei Morozov created FLINK-36086:
--
Summary: SQL Server source connector skips changes if restarted
mid transaction
Key: FLINK-36086
URL: https://issues.apache.org/jira/browse/FLINK-36086
Project: F
[
https://issues.apache.org/jira/browse/FLINK-36051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergei Morozov updated FLINK-36051:
---
Description:
An SQL Server sink connector may fail with the following exception:
{code}
jav
Sergei Morozov created FLINK-36051:
--
Summary: JDBC sink doesn't re-prepare invalidated prepared
statements
Key: FLINK-36051
URL: https://issues.apache.org/jira/browse/FLINK-36051
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergei Morozov updated FLINK-35177:
---
Description:
Currently, the
[examples|https://nightlies.apache.org/flink/flink-docs-release
Sergei Morozov created FLINK-35177:
--
Summary: Datagen examples in documentation do not compile
Key: FLINK-35177
URL: https://issues.apache.org/jira/browse/FLINK-35177
Project: Flink
Issue Ty
30 matches
Mail list logo
