MOBIN created FLINK-37132:
-
Summary: Add schema validation in Multi Transform
Key: FLINK-37132
URL: https://issues.apache.org/jira/browse/FLINK-37132
Project: Flink
Issue Type: Bug
Componen
MOBIN created FLINK-37012:
-
Summary: Fix exception caused by MetadataColumns causing argument
type mismatch
Key: FLINK-37012
URL: https://issues.apache.org/jira/browse/FLINK-37012
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-36958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908074#comment-17908074
]
MOBIN commented on FLINK-36958:
---
Please assign this to me, thanks~ [~kunni] [~Leonard]
>
[
https://issues.apache.org/jira/browse/FLINK-36958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-36958:
--
Description:
When using Format Options in pipeline, such as
debezium-json.encode.decimal-as-plain-number, an
MOBIN created FLINK-36958:
-
Summary: Support pipeline-connector-kafka to reuse csv, canal-json
and debezium-json Format Options
Key: FLINK-36958
URL: https://issues.apache.org/jira/browse/FLINK-36958
Project:
[
https://issues.apache.org/jira/browse/FLINK-36858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-36858:
--
Description:
I encountered this bug when I was working on MysqlToKafkaE2eITCase
minimum repetition step：
Flink
[
https://issues.apache.org/jira/browse/FLINK-36858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17903568#comment-17903568
]
MOBIN commented on FLINK-36858:
---
It seems that flink cdc has not yet fully adapted to flin
[
https://issues.apache.org/jira/browse/FLINK-36858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-36858:
--
Description:
minimum repetition step：
Flink 1.20
Flink cdc master
{code:java}
source:
type: mysql
name: My
MOBIN created FLINK-36858:
-
Summary: [pipeline-kafka] JsonRowDataSerializationSchema
compatibility bug
Key: FLINK-36858
URL: https://issues.apache.org/jira/browse/FLINK-36858
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-36754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-36754:
--
Description:
When projection is empty or NULL, the projection should be treated as an
asterisk. The following
[
https://issues.apache.org/jira/browse/FLINK-36754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-36754:
--
Description:
When projection is empty or NULL, the projection should be treated as an
asterisk. The following
MOBIN created FLINK-36754:
-
Summary: When projection is empty or null, it is treated as an
asterisk
Key: FLINK-36754
URL: https://issues.apache.org/jira/browse/FLINK-36754
Project: Flink
Issue Type:
MOBIN created FLINK-36632:
-
Summary: When scan.startup.mode is not initial and restart with
savepoint, newly add-table will not synchronize snapshot data
Key: FLINK-36632
URL: https://issues.apache.org/jira/browse/FLINK-3
MOBIN created FLINK-36597:
-
Summary: Optimize SnapshotSplitAssigner error log output
Key: FLINK-36597
URL: https://issues.apache.org/jira/browse/FLINK-36597
Project: Flink
Issue Type: Bug
C
MOBIN created FLINK-36580:
-
Summary: Using debezium.column.exclude.list causes job failure
Key: FLINK-36580
URL: https://issues.apache.org/jira/browse/FLINK-36580
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-23195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN closed FLINK-23195.
-
Resolution: Not A Problem
> No value for kafka metrics in Flink Web ui
> ---
[
https://issues.apache.org/jira/browse/FLINK-36188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-36188:
--
Description:
HBase table
||rowkey||col||
|1|1|
The user lookup joins the hbase table, adds 1 to the col value
MOBIN created FLINK-36188:
-
Summary: HBase disable buffer flush lose efficacy
Key: FLINK-36188
URL: https://issues.apache.org/jira/browse/FLINK-36188
Project: Flink
Issue Type: Bug
Componen
[
https://issues.apache.org/jira/browse/FLINK-36188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-36188:
--
Description:
HBase table
||rowkey||col||
|1|1|
The user lookup joins the hbase table, adds 1 to the col value
[
https://issues.apache.org/jira/browse/FLINK-36093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875393#comment-17875393
]
MOBIN commented on FLINK-36093:
---
Please assign this for me,I'd like to do it.[~xiqian_yu]
[
https://issues.apache.org/jira/browse/FLINK-36111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-36111:
--
Fix Version/s: cdc-3.2.0
Affects Version/s: cdc-3.2.0
Description:
module：flink-cdc-pipeline
MOBIN created FLINK-36111:
-
Summary: fix: adjust MultiTableCommittableChannelComputer Topology
name
Key: FLINK-36111
URL: https://issues.apache.org/jira/browse/FLINK-36111
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-35985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872832#comment-17872832
]
MOBIN commented on FLINK-35985:
---
Currently, flink-cdc only provides the substr function. A
[
https://issues.apache.org/jira/browse/FLINK-35981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871529#comment-17871529
]
MOBIN edited comment on FLINK-35981 at 8/7/24 4:10 AM:
---
Please ass
[
https://issues.apache.org/jira/browse/FLINK-35981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871529#comment-17871529
]
MOBIN commented on FLINK-35981:
---
Please assign this for me,I'd like to do it.[~xiqian_yu]
MOBIN created FLINK-35936:
-
Summary: paimon cdc schema evolution failure when restart job
Key: FLINK-35936
URL: https://issues.apache.org/jira/browse/FLINK-35936
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-35058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN closed FLINK-35058.
-
Resolution: Not A Bug
> Encountered change event for table db.table whose schema isn't known to this
> connecto
MOBIN created FLINK-35058:
-
Summary: Encountered change event for table db.table whose schema
isn't known to this connector
Key: FLINK-35058
URL: https://issues.apache.org/jira/browse/FLINK-35058
Project: Fli
[
https://issues.apache.org/jira/browse/FLINK-33971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-33971:
--
Description:
Specifies whether to use HBase table that supports dynamic columns.
Refer to the dynamic.table p
[
https://issues.apache.org/jira/browse/FLINK-33971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-33971:
--
Description:
Specifies whether to use HBase table that supports dynamic columns.
Refer to the dynamic.table p
[
https://issues.apache.org/jira/browse/FLINK-33971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17802045#comment-17802045
]
MOBIN commented on FLINK-33971:
---
https://github.com/apache/flink-connector-hbase/pull/36
[ https://issues.apache.org/jira/browse/FLINK-33971 ]
MOBIN deleted comment on FLINK-33971:
---
was (Author: mobin):
https://github.com/apache/flink-connector-hbase/pull/36
> Specifies whether to use HBase table that supports dynamic columns.
>
MOBIN created FLINK-33971:
-
Summary: Specifies whether to use HBase table that supports
dynamic columns.
Key: FLINK-33971
URL: https://issues.apache.org/jira/browse/FLINK-33971
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-29252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-29252:
--
Description:
Support create table-store table with 'connector'='table-store':
sink to table-store:
{code:jav
MOBIN created FLINK-29252:
-
Summary: Support create table-store table with
'connector'='table-store'
Key: FLINK-29252
URL: https://issues.apache.org/jira/browse/FLINK-29252
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-29213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-29213:
--
Description:
pretty schema/snapshot json file,easy to read
before improvement：
!before.jpeg|width=1669,hei
[
https://issues.apache.org/jira/browse/FLINK-29213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-29213:
--
Summary: Pretty schema/snapshot json file (was: Pretty schema json file)
> Pretty schema/snapshot json file
>
[
https://issues.apache.org/jira/browse/FLINK-29213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-29213:
--
Description:
pretty schema json file,easy to read
before improvement：
!before.jpeg|width=1669,height=115!
[
https://issues.apache.org/jira/browse/FLINK-29213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-29213:
--
Description:
pretty schema json file,easy to read
before improvement：
!before.jpeg|width=1669,height=115!
[
https://issues.apache.org/jira/browse/FLINK-29213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-29213:
--
Description:
pretty schema json file,Easy to read
before improvement：
!before.jpeg!
after improvement：
[
https://issues.apache.org/jira/browse/FLINK-29213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-29213:
--
Description:
pretty schema json file,Easy to read
before improvement：
!before.jpeg!
after improvement：
[
https://issues.apache.org/jira/browse/FLINK-29213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-29213:
--
Attachment: before.jpeg
> Pretty schema json file
> ---
>
> Key: FLINK-292
[
https://issues.apache.org/jira/browse/FLINK-29213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-29213:
--
Attachment: after.jpeg
> Pretty schema json file
> ---
>
> Key: FLINK-2921
[
https://issues.apache.org/jira/browse/FLINK-29213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-29213:
--
Description:
pretty schema json file,Easy to read
before improvement：
!before.jpeg|width=1669,height=115!
[
https://issues.apache.org/jira/browse/FLINK-29213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-29213:
--
Description:
pretty schema json file,Easy to read
before improvement：
after improvement：
was:
prett
[
https://issues.apache.org/jira/browse/FLINK-29213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-29213:
--
Description:
pretty schema json file,Easy to read
before improvement：
after improvement：
was:
pretty
MOBIN created FLINK-29213:
-
Summary: Pretty schema json file
Key: FLINK-29213
URL: https://issues.apache.org/jira/browse/FLINK-29213
Project: Flink
Issue Type: Improvement
Components: Table
[
https://issues.apache.org/jira/browse/FLINK-29213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-29213:
--
Description:
pretty schema json file,Easy to read
before improvement：
after improvement：
was:
prett
[
https://issues.apache.org/jira/browse/FLINK-23195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-23195:
--
Description:
The kafka metrics in the Flink Web ui have no value, but the other metrics are
displayed normall
MOBIN created FLINK-23195:
-
Summary: No value for kafka metrics in Flink Web ui
Key: FLINK-23195
URL: https://issues.apache.org/jira/browse/FLINK-23195
Project: Flink
Issue Type: Bug
Compon
[
https://issues.apache.org/jira/browse/FLINK-23026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-23026:
--
Description:
{code:java}
Flink SQL> CREATE TABLE tmall_item(
> itemID VARCHAR,
> itemType VARCHAR,
> eve
[
https://issues.apache.org/jira/browse/FLINK-23026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-23026:
--
Description:
{code:java}
Flink SQL> CREATE TABLE tmall_item(
> itemID VARCHAR,
> itemType VARCHAR,
> eve
[
https://issues.apache.org/jira/browse/FLINK-23026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-23026:
--
Description:
{code:java}
Flink SQL> CREATE TABLE tmall_item(
> itemID VARCHAR,
> itemType VARCHAR,
> eve
MOBIN created FLINK-23026:
-
Summary: OVER WINDOWS function lost data
Key: FLINK-23026
URL: https://issues.apache.org/jira/browse/FLINK-23026
Project: Flink
Issue Type: Bug
Components: Table
54 matches
Mail list logo
