[
https://issues.apache.org/jira/browse/FLINK-26123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-26123:
-
Component/s: Connectors / Kafka
> The data of the upsert-kafka source cannot be written to HBase under sql
> wh
[
https://issues.apache.org/jira/browse/FLINK-26123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-26123:
-
Affects Version/s: 1.13.1
(was: 1.12.1)
> The data of the upsert-kafka source cannot
[
https://issues.apache.org/jira/browse/FLINK-26123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-26123:
-
Description:
*1. source table :*
*(1) kafka topic :*
./kafka-topics.sh -create -zookeeper kafka01:2181,kafka02
[
https://issues.apache.org/jira/browse/FLINK-26123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-26123:
-
Component/s: Table SQL / Planner
> The data of the upsert-kafka source cannot be written to HBase under sql
> w
Carl created FLINK-26123:
Summary: The data of the upsert-kafka source cannot be written to
HBase under sql where conditions
Key: FLINK-26123
URL: https://issues.apache.org/jira/browse/FLINK-26123
Project: Fl
[
https://issues.apache.org/jira/browse/FLINK-24836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-24836:
-
Description:
1. When i use tumble window in month, it throw an exception:
_Window aggregate only SECOND, MINUTE
[
https://issues.apache.org/jira/browse/FLINK-24836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-24836:
-
Description:
1. When i use tumble window in month, it throw an exception:
_Window aggregate only SECOND, MINUTE
[
https://issues.apache.org/jira/browse/FLINK-24836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-24836:
-
Attachment: image-2021-11-09-12-32-04-053.png
> Over window in month time calculated an incorrect aggregation re
[
https://issues.apache.org/jira/browse/FLINK-24836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-24836:
-
Description:
1. When i use tumble window in month, it throw an exception:
_Window aggregate only SECOND, MINUTE
Carl created FLINK-24836:
Summary: Over window in month time calculated an incorrect
aggregation result.
Key: FLINK-24836
URL: https://issues.apache.org/jira/browse/FLINK-24836
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-23730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17404838#comment-17404838
]
Carl edited comment on FLINK-23730 at 8/26/21, 2:07 AM:
[~luoyux
[
https://issues.apache.org/jira/browse/FLINK-23730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17404838#comment-17404838
]
Carl commented on FLINK-23730:
--
[~luoyuxia] Thanks for you replay. I have update the descri
[
https://issues.apache.org/jira/browse/FLINK-23730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-23730:
-
Attachment: image-2021-08-26-10-05-23-289.png
> Source from hive sink hbase lost data
>
[
https://issues.apache.org/jira/browse/FLINK-23730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-23730:
-
Description:
Our use case is as follows,
# hive source: create hive table which meta data is in HMS
# create h
[
https://issues.apache.org/jira/browse/FLINK-23730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-23730:
-
Attachment: image-2021-08-26-09-52-35-808.png
> Source from hive sink hbase lost data
>
[
https://issues.apache.org/jira/browse/FLINK-23730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-23730:
-
Attachment: image-2021-08-26-09-51-38-899.png
> Source from hive sink hbase lost data
>
[
https://issues.apache.org/jira/browse/FLINK-23730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-23730:
-
Attachment: image-2021-08-26-09-50-35-061.png
> Source from hive sink hbase lost data
>
[
https://issues.apache.org/jira/browse/FLINK-23730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-23730:
-
Attachment: image-2021-08-26-09-44-20-390.png
> Source from hive sink hbase lost data
>
[
https://issues.apache.org/jira/browse/FLINK-23730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-23730:
-
Attachment: image-2021-08-26-09-43-39-055.png
> Source from hive sink hbase lost data
>
[
https://issues.apache.org/jira/browse/FLINK-23939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-23939:
-
Description:
*table options as follows,*
!image-2021-08-24-16-12-48-465.png!
*kafka source table ddl as follow
Carl created FLINK-23939:
Summary: The result of validation and parsing failure does not
match the document description
Key: FLINK-23939
URL: https://issues.apache.org/jira/browse/FLINK-23939
Project: Flink
Carl created FLINK-23730:
Summary: Source from hive sink hbase lost data
Key: FLINK-23730
URL: https://issues.apache.org/jira/browse/FLINK-23730
Project: Flink
Issue Type: Bug
Components: C
[
https://issues.apache.org/jira/browse/FLINK-23719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-23719:
-
Comment: was deleted
(was: I think there is no problem with what you described above. May I ask
which version c
[
https://issues.apache.org/jira/browse/FLINK-23719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17397134#comment-17397134
]
Carl commented on FLINK-23719:
--
I think there is no problem with what you described above.
[
https://issues.apache.org/jira/browse/FLINK-23719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-23719:
-
Description:
My application scenario is like this:
Use Flink SQL to write the batch data of hive table to a new
Carl created FLINK-23719:
Summary: Support switch WAL in Flink SQL DDL options
Key: FLINK-23719
URL: https://issues.apache.org/jira/browse/FLINK-23719
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-23198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-23198:
-
Labels: pull-request-available (was: pull-request-available stale-assigned)
> An old interface method is used i
[
https://issues.apache.org/jira/browse/FLINK-23198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17374701#comment-17374701
]
Carl commented on FLINK-23198:
--
[~yunta], i have create two PRs, one is target for release-
[
https://issues.apache.org/jira/browse/FLINK-23198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17373136#comment-17373136
]
Carl commented on FLINK-23198:
--
[~yunta], Thank you for your reply! I have create two PRs,
Carl created FLINK-23211:
Summary: An old interface method is used in this section of
[Passing Options Factory to RocksDB].
Key: FLINK-23211
URL: https://issues.apache.org/jira/browse/FLINK-23211
Project: Fli
Carl created FLINK-23198:
Summary: An old interface method is used in this section of
[Passing Options Factory to RocksDB].
Key: FLINK-23198
URL: https://issues.apache.org/jira/browse/FLINK-23198
Project: Fli
[
https://issues.apache.org/jira/browse/FLINK-23176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl closed FLINK-23176.
Resolution: Not A Problem
> flink application has failed when i executed an savepoint
> --
[
https://issues.apache.org/jira/browse/FLINK-23176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-23176:
-
Priority: Blocker (was: Major)
> flink application has failed when i executed an savepoint
> --
[
https://issues.apache.org/jira/browse/FLINK-23176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-23176:
-
Description:
*some exceptions it throws as follows*
!image-2021-06-29-14-44-18-005.png!
!image-2021-06-29-1
[
https://issues.apache.org/jira/browse/FLINK-23176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-23176:
-
Description:
*some exceptions it throws as follows*
!image-2021-06-29-14-44-18-005.png!
!image-2021-06-29-1
[
https://issues.apache.org/jira/browse/FLINK-23176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-23176:
-
Attachment: image-2021-06-29-14-54-21-627.png
> flink application has failed when i executed an savepoint
>
[
https://issues.apache.org/jira/browse/FLINK-23176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated FLINK-23176:
-
Summary: flink application has failed when i executed an savepoint (was:
my flink application has failed when i
Carl created FLINK-23176:
Summary: my flink application has failed when i executed an
savepoint
Key: FLINK-23176
URL: https://issues.apache.org/jira/browse/FLINK-23176
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-23051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366943#comment-17366943
]
Carl commented on FLINK-23051:
--
[~hiscat] thanks a lot!
> Savepoint an application for sou
[
https://issues.apache.org/jira/browse/FLINK-23051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl closed FLINK-23051.
Fix Version/s: (was: 1.14.0)
Resolution: Not A Bug
-s appear in the wrong place
> Savepoint an applica
[
https://issues.apache.org/jira/browse/FLINK-23051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366549#comment-17366549
]
Carl commented on FLINK-23051:
--
[~twalthr] it is a demo program, flink version stays const
Carl created FLINK-23051:
Summary: Savepoint an application for source of cdc-kafka, then
restart the application from the savepoint, offset not be recovered.
Key: FLINK-23051
URL: https://issues.apache.org/jira/browse/
Carl created FLINK-22498:
Summary: cast the primary key for source table that has a decimal
primary key as string, and then insert into a kudu table that has a string
primary key throw the exception : UpsertStreamTableSink requires that Table has
a full
[
https://issues.apache.org/jira/browse/FLINK-22267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321929#comment-17321929
]
Carl commented on FLINK-22267:
--
Thank you for your reply! If I don't delete the data, is th
Carl created FLINK-22267:
Summary: Savepoint an application for source of upsert-kafka, then
restart the application from the savepoint, state not be recovered.
Key: FLINK-22267
URL: https://issues.apache.org/jira/brows
[
https://issues.apache.org/jira/browse/FLINK-21889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl closed FLINK-21889.
Resolution: Not A Problem
> source:canal-cdc , sink:upsert-kafka, print "select * from sinkTable", throw
> NullEx
Carl created FLINK-21889:
Summary: source:canal-cdc , sink:upsert-kafka, print "select *
from sinkTable", throw NullException
Key: FLINK-21889
URL: https://issues.apache.org/jira/browse/FLINK-21889
Project: F
47 matches
Mail list logo
