[
https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795222#comment-17795222
]
Feifan Wang commented on FLINK-33734:
-
Thanks [~roman] , merge handle in JM in MetadataSerializer
Myasuka commented on code in PR #23903:
URL: https://github.com/apache/flink/pull/23903#discussion_r1422036625
##
docs/content/docs/flinkDev/ide_setup.md:
##
@@ -260,7 +260,7 @@ versions.
[Flake8](https://pypi.org/project/flake8/) is used to enforce some coding
guidelines.
[
https://issues.apache.org/jira/browse/FLINK-17972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Feifan Wang updated FLINK-17972:
Description:
(depends on rescaling for unaligned checkpoints (FLINK-17979))
Current structure
dependabot[bot] opened a new pull request, #65:
URL: https://github.com/apache/flink-connector-pulsar/pull/65
Bumps org.apache.commons:commons-compress from 1.22 to 1.24.0.
[![Dependabot compatibility
[
https://issues.apache.org/jira/browse/FLINK-28691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795194#comment-17795194
]
Dan Zou commented on FLINK-28691:
-
[~libenchao] Hi, I would like to take this ticket, could you please
[
https://issues.apache.org/jira/browse/FLINK-33792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795193#comment-17795193
]
Dan Zou commented on FLINK-33792:
-
[~libenchao] Hi, I would like to take this ticket, could you please
Dan Zou created FLINK-33792:
---
Summary: Generate the same code for the same logic
Key: FLINK-33792
URL: https://issues.apache.org/jira/browse/FLINK-33792
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-33780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795171#comment-17795171
]
Yubin Li edited comment on FLINK-33780 at 12/11/23 6:14 AM:
[~hackergin]
[
https://issues.apache.org/jira/browse/FLINK-33780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795171#comment-17795171
]
Yubin Li edited comment on FLINK-33780 at 12/11/23 6:13 AM:
[~hackergin]
[
https://issues.apache.org/jira/browse/FLINK-33780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795171#comment-17795171
]
Yubin Li edited comment on FLINK-33780 at 12/11/23 5:53 AM:
[~hackergin]
[
https://issues.apache.org/jira/browse/FLINK-33780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795171#comment-17795171
]
Yubin Li edited comment on FLINK-33780 at 12/11/23 5:52 AM:
[~hackergin] In
[
https://issues.apache.org/jira/browse/FLINK-33780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795171#comment-17795171
]
Yubin Li edited comment on FLINK-33780 at 12/11/23 5:51 AM:
[~hackergin] In
[
https://issues.apache.org/jira/browse/FLINK-33634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795170#comment-17795170
]
Gyula Fora commented on FLINK-33634:
I don't think the idea was to migrate from status to condition.
[
https://issues.apache.org/jira/browse/FLINK-33780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795171#comment-17795171
]
Yubin Li commented on FLINK-33780:
--
[~hackergin] In addition to the conceptual necessity (default
[
https://issues.apache.org/jira/browse/FLINK-33780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-33780:
-
Attachment: image-2023-12-11-13-47-29-623.png
> Support to store default catalog in CatalogStore
>
liuyongvs commented on PR #23894:
URL: https://github.com/apache/flink/pull/23894#issuecomment-1849338235
hi @snuyanzin @dawidwys could you help review 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
liuyongvs commented on PR #23895:
URL: https://github.com/apache/flink/pull/23895#issuecomment-1849337918
hi @snuyanzin @dawidwys could you help review 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
liuyongvs commented on PR #23897:
URL: https://github.com/apache/flink/pull/23897#issuecomment-1849337647
hi @snuyanzin @dawidwys could you help review 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
liuyongvs commented on PR #23898:
URL: https://github.com/apache/flink/pull/23898#issuecomment-1849337372
hi @snuyanzin @dawidwys could you help review 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
liyubin117 commented on code in PR #23678:
URL: https://github.com/apache/flink/pull/23678#discussion_r1421917082
##
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/connector/datagen/table/DataGenConnectorOptions.java:
##
@@ -118,10 +118,10 @@ public
liyubin117 commented on code in PR #23678:
URL: https://github.com/apache/flink/pull/23678#discussion_r1421917082
##
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/connector/datagen/table/DataGenConnectorOptions.java:
##
@@ -118,10 +118,10 @@ public
[
https://issues.apache.org/jira/browse/FLINK-33788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795152#comment-17795152
]
luoyuxia edited comment on FLINK-33788 at 12/11/23 3:43 AM:
[~shaoguang]
[
https://issues.apache.org/jira/browse/FLINK-33788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia reassigned FLINK-33788:
Assignee: lishaoguang
> Table not found for catalogname is capital
>
[
https://issues.apache.org/jira/browse/FLINK-33788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795152#comment-17795152
]
luoyuxia edited comment on FLINK-33788 at 12/11/23 3:42 AM:
[~shaoguang]
[
https://issues.apache.org/jira/browse/FLINK-33788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795152#comment-17795152
]
luoyuxia commented on FLINK-33788:
--
[~shaoguang] Cool! Thanks. One hint is that we may only need to
[
https://issues.apache.org/jira/browse/FLINK-33780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795151#comment-17795151
]
Feng Jin commented on FLINK-33780:
--
Hi, [~liyubin117] Thanks for pointing this . could you provide a
[
https://issues.apache.org/jira/browse/FLINK-33784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795149#comment-17795149
]
Feng Jin commented on FLINK-33784:
--
[~twalthr] Thank you for pointing out this issue, I would like
liyubin117 commented on code in PR #23678:
URL: https://github.com/apache/flink/pull/23678#discussion_r1421910481
##
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/connector/datagen/table/RandomGeneratorVisitor.java:
##
@@ -489,6 +465,16 @@ protected
JingWei Li created FLINK-33791:
--
Summary: Fix NPE when array is null in PostgresArrayConverter in
flink-connector-jdbc
Key: FLINK-33791
URL: https://issues.apache.org/jira/browse/FLINK-33791
Project:
JingWei Li created FLINK-33790:
--
Summary: Upsert statement filter unique key field colume in mysql
dielact
Key: FLINK-33790
URL: https://issues.apache.org/jira/browse/FLINK-33790
Project: Flink
LadyForest commented on code in PR #23678:
URL: https://github.com/apache/flink/pull/23678#discussion_r1421891193
##
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/connector/datagen/table/DataGenConnectorOptions.java:
##
@@ -118,10 +118,10 @@ public
Zakelly commented on PR #23253:
URL: https://github.com/apache/flink/pull/23253#issuecomment-1849238533
> > Hi @xiangforever2014 @masteryhx sorry for jumping in... And I'm
wondering if we could use the capital '-D' for short option? Or I suggest we do
not leave any short option for this,
flinkbot commented on PR #23904:
URL: https://github.com/apache/flink/pull/23904#issuecomment-1849236984
## CI report:
* 81eb39d1ed6d0129ca7548051210100af961ed32 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
ljw-hit commented on PR #23323:
URL: https://github.com/apache/flink/pull/23323#issuecomment-1849235718
@zhougit86 Thank you for your patience and contribution. I will complete the
review within the next two weeks and provide comments.
--
This is an automated message from the Apache Git
KarmaGYZ opened a new pull request, #23904:
URL: https://github.com/apache/flink/pull/23904
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
[
https://issues.apache.org/jira/browse/FLINK-33788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795144#comment-17795144
]
lishaoguang edited comment on FLINK-33788 at 12/11/23 2:32 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-33788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795144#comment-17795144
]
lishaoguang commented on FLINK-33788:
-
[~luoyuxia] I will try to fix it.But I find there are 11
[
https://issues.apache.org/jira/browse/FLINK-33741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795142#comment-17795142
]
Yun Tang commented on FLINK-33741:
--
[~zhoujira86] I think there exists valuable information in the
[
https://issues.apache.org/jira/browse/FLINK-33741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-33741:
Assignee: xiaogang zhou
> Exposed Rocksdb statistics in Flink metrics and introduce 2 Rocksdb
[
https://issues.apache.org/jira/browse/FLINK-33788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795137#comment-17795137
]
luoyuxia commented on FLINK-33788:
--
[~shaoguang] Thanks for reporting it. As Hive is case-insentive,
[
https://issues.apache.org/jira/browse/FLINK-33634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795126#comment-17795126
]
Ryan van Huuksloot edited comment on FLINK-33634 at 12/10/23 11:00 PM:
[
https://issues.apache.org/jira/browse/FLINK-33634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795126#comment-17795126
]
Ryan van Huuksloot edited comment on FLINK-33634 at 12/10/23 10:59 PM:
[
https://issues.apache.org/jira/browse/FLINK-33634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795126#comment-17795126
]
Ryan van Huuksloot edited comment on FLINK-33634 at 12/10/23 10:59 PM:
[
https://issues.apache.org/jira/browse/FLINK-33634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795126#comment-17795126
]
Ryan van Huuksloot edited comment on FLINK-33634 at 12/10/23 10:57 PM:
[
https://issues.apache.org/jira/browse/FLINK-33634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795126#comment-17795126
]
Ryan van Huuksloot edited comment on FLINK-33634 at 12/10/23 10:47 PM:
[
https://issues.apache.org/jira/browse/FLINK-33634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795126#comment-17795126
]
Ryan van Huuksloot commented on FLINK-33634:
Is the idea of this issue to migrate the
[ https://issues.apache.org/jira/browse/FLINK-33634 ]
Ryan van Huuksloot deleted comment on FLINK-33634:
was (Author: JIRAUSER285640):
Thoughts on converting the current Status representations to Conditions prior
to adding more
[
https://issues.apache.org/jira/browse/FLINK-33634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795121#comment-17795121
]
Ryan van Huuksloot commented on FLINK-33634:
Thoughts on converting the current Status
[ https://issues.apache.org/jira/browse/FLINK-33634 ]
Ryan van Huuksloot deleted comment on FLINK-33634:
was (Author: JIRAUSER285640):
Thoughts on converting the current Status representations to Conditions prior
to adding more
[
https://issues.apache.org/jira/browse/FLINK-33634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795120#comment-17795120
]
Ryan van Huuksloot commented on FLINK-33634:
Thoughts on converting the current Status
[
https://issues.apache.org/jira/browse/FLINK-33789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-33789:
--
Summary: Expose restart time as a metric (was: Expose restart time as
metric)
>
[
https://issues.apache.org/jira/browse/FLINK-33789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-33789:
--
Description: FLINK-30593 added restart time tracking. It would be
convenient to also
[
https://issues.apache.org/jira/browse/FLINK-33789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-33789:
--
Description: FLINK-30593 added restart time tracking. It would be
convenient to also
Alexander Fedulov created FLINK-33789:
-
Summary: Expose restart time as metric
Key: FLINK-33789
URL: https://issues.apache.org/jira/browse/FLINK-33789
Project: Flink
Issue Type: New
flinkbot commented on PR #23903:
URL: https://github.com/apache/flink/pull/23903#issuecomment-1849028559
## CI report:
* 4366e0adc981baefb7ca51e67799fd86317804a1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
adipolak opened a new pull request, #23903:
URL: https://github.com/apache/flink/pull/23903
## What is the purpose of the change
setting pycharm for pyflink project - fixing from going to reference (which
dosn't exist) to settings
## Brief change log
-
PrabhuJoseph commented on PR #23725:
URL: https://github.com/apache/flink/pull/23725#issuecomment-1849009696
@Samrat002 I have verified the patch with filesystem connector using both
csv and json format. The patch is working fine.
LGTM, +1 (non-binding)
--
This is an automated
flinkbot commented on PR #23902:
URL: https://github.com/apache/flink/pull/23902#issuecomment-1848984657
## CI report:
* 29f82bd2a211fc7dee9f636b7d11aed091e3c5b3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Gianzie opened a new pull request, #23902:
URL: https://github.com/apache/flink/pull/23902
…ields
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid
[
https://issues.apache.org/jira/browse/FLINK-33741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaogang zhou updated FLINK-33741:
--
Summary: Exposed Rocksdb statistics in Flink metrics and introduce 2
Rocksdb statistic
[
https://issues.apache.org/jira/browse/FLINK-33741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaogang zhou updated FLINK-33741:
--
Description:
I think we can also parse the multi-line string of the rocksdb statistics.
[
https://issues.apache.org/jira/browse/FLINK-33741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaogang zhou updated FLINK-33741:
--
Summary: Introduce stat dump period and statsLevel configuration (was:
introduce stat dump
kaori-seasons commented on PR #62:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/62#issuecomment-1848966405
> @kaori-seasons Are you still planning to work on this PR?
@MartijnVisser
Hello, I just saw your reply recently. Due to work, I did not continue this
Pull
63 matches
Mail list logo
