[
https://issues.apache.org/jira/browse/FLINK-33935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33935:
---
Labels: pull-request-available (was: )
> Improve the default value doc and logic for some s
1996fanrui opened a new pull request, #23987:
URL: https://github.com/apache/flink/pull/23987
## What is the purpose of the change
Some state backend and checkpoint related options don't set the default
value directly, but but they implement default value based on code. Such as:
[
https://issues.apache.org/jira/browse/FLINK-33932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800258#comment-17800258
]
xiangyu feng commented on FLINK-33932:
--
Hi [~dianer17], thanks for creating this.
[
https://issues.apache.org/jira/browse/FLINK-33935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33935:
Description:
Some state backend and checkpoint related options don't set the default value
directly, but
Rui Fan created FLINK-33935:
---
Summary: Improve the default value doc and logic for some state
backend and checkpoint related options
Key: FLINK-33935
URL: https://issues.apache.org/jira/browse/FLINK-33935
P
flinkbot commented on PR #23986:
URL: https://github.com/apache/flink/pull/23986#issuecomment-1868812174
## CI report:
* 4f3d0851c216a7178ac673ca72b6b6fd031baf49 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33932:
---
Labels: pull-request-available (was: )
> Support retry mechanism for rocksdb uploader
> ---
xiangyuf opened a new pull request, #23986:
URL: https://github.com/apache/flink/pull/23986
## What is the purpose of the change
Add retry mechanism in RocksDBStateUploader
## Brief change log
- Introduce RetryStrategy in RocksDBStateUploader when
uploadFilesToChec
[
https://issues.apache.org/jira/browse/FLINK-33934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cai Liuyang updated FLINK-33934:
Description:
In our product we encounter a case that lead to data lost, the job info:
1. using
[
https://issues.apache.org/jira/browse/FLINK-33934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cai Liuyang updated FLINK-33934:
Description:
In our product we encounter a case that lead to data lost, the job info:
1. using
[
https://issues.apache.org/jira/browse/FLINK-33934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cai Liuyang updated FLINK-33934:
Description:
In our product we encounter a case that lead to data lost, the job info:
1. using
[
https://issues.apache.org/jira/browse/FLINK-33934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cai Liuyang updated FLINK-33934:
Description:
In our product we encounter a case that lead to data lost, the job info:
1. using
Cai Liuyang created FLINK-33934:
---
Summary: Flink SQL Source use raw format maybe lead to data lost
Key: FLINK-33934
URL: https://issues.apache.org/jira/browse/FLINK-33934
Project: Flink
Issue T
gt; Components: Runtime / Metrics
>Affects Versions: 1.18.0, 1.17.2
>Reporter: Zhanghao Chen
>Priority: Major
> Attachments: screenshot-20231224-195605-1.png,
> screenshot-20231225-120421.png
>
>
> Currently, the numRecordsIn &
[
https://issues.apache.org/jira/browse/FLINK-33865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33865:
Parent: FLINK-33735
Issue Type: Sub-task (was: Bug)
> exponential-delay.attempts-before-reset-bac
omponents: Runtime / Metrics
>Affects Versions: 1.18.0, 1.17.2
>Reporter: Zhanghao Chen
>Priority: Major
> Attachments: screenshot-20231224-195605-1.png,
> screenshot-20231225-120421.png
>
>
> Currently, the numRecordsIn & numBytesIn me
ntime / Metrics
>Affects Versions: 1.18.0, 1.17.2
>Reporter: Zhanghao Chen
>Priority: Major
> Attachments: screenshot-20231224-195605-1.png,
> screenshot-20231225-120421-1.png, screenshot-20231225-120421.png
>
>
> Currently, the n
1
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Metrics
>Affects Versions: 1.18.0, 1.17.2
>Reporter: Zhanghao Chen
>Priority: Major
> Attachments: screenshot-20231224-195605-1.png,
> screenshot-20
ntime / Metrics
>Affects Versions: 1.18.0, 1.17.2
>Reporter: Zhanghao Chen
>Priority: Major
> Attachments: screenshot-20231224-195605-1.png,
> screenshot-20231225-120421.png
>
>
> Currently, the numRecordsIn & numBytesIn metrics for sources
yunfengzhou-hub commented on code in PR #23927:
URL: https://github.com/apache/flink/pull/23927#discussion_r1435935387
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java:
##
@@ -1736,7 +1738,8 @@ private RemoteInputC
ink
> Issue Type: Bug
> Components: Runtime / Metrics
>Affects Versions: 1.18.0, 1.17.2
>Reporter: Zhanghao Chen
>Priority: Major
> Attachments: screenshot-20231224-195605-1.png
>
>
> Currently, the numRecordsIn & numBytes
cs. As a result, even
though new connectors supporting FLIP-33 metrics will report operator-level I/O
metrics, we still cannot see the metrics on dashboard.
This ticket serves as an umbrella issue to integrate standard source/sink I/O
metrics with the corresponding task I/O metrics.
!screenshot-
[
https://issues.apache.org/jira/browse/FLINK-33681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-33681:
--
Attachment: screenshot-20231224-195605-1.png
Description:
Currently, the numRecordsIn
omponents: Runtime / Metrics
>Affects Versions: 1.18.0, 1.17.2
>Reporter: Zhanghao Chen
>Priority: Major
> Attachments: screenshot-20231224-195605-1.png
>
>
> Currently, the numRecordsIn & numBytesIn metrics for sources and the
> numRecord
[
https://issues.apache.org/jira/browse/FLINK-33933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
KarlManong updated FLINK-33933:
---
Description:
Here is a simple example
{code:java}
// example
public class TableA implements LookupT
[
https://issues.apache.org/jira/browse/FLINK-33933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800230#comment-17800230
]
KarlManong commented on FLINK-33933:
`SerializedThrowable` method `addAllSuppressed`
KarlManong created FLINK-33933:
--
Summary: SerializedThrowable will be java.lang.StackOverflowError
when AsyncLookupFunction throw an exception
Key: FLINK-33933
URL: https://issues.apache.org/jira/browse/FLINK-33933
Guojun Li created FLINK-33932:
-
Summary: Support retry mechanism for rocksdb uploader
Key: FLINK-33932
URL: https://issues.apache.org/jira/browse/FLINK-33932
Project: Flink
Issue Type: Improvemen
zoudan commented on PR #23984:
URL: https://github.com/apache/flink/pull/23984#issuecomment-1868679111
@libenchao Thanks for reviewing, I have remove the configuration, please
take a look when you have time.
--
This is an automated message from the Apache Git Service.
To respond to the me
TanYuxin-tyx commented on code in PR #23927:
URL: https://github.com/apache/flink/pull/23927#discussion_r1435920016
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/NettyConnectionWriterImpl.java:
##
@@ -30,24 +30,33 @@ public clas
TanYuxin-tyx commented on code in PR #23957:
URL: https://github.com/apache/flink/pull/23957#discussion_r1435909606
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageMemoryManagerImpl.java:
##
@@ -244,6 +282,39 @@ pub
[
https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-33635.
--
Resolution: Fixed
> 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=17800229#comment-17800229
]
Weijie Guo commented on FLINK-33635:
Yep, I have checked the nightly CI of ElasticSe
[
https://issues.apache.org/jira/browse/FLINK-31830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800227#comment-17800227
]
Jane Chan edited comment on FLINK-31830 at 12/25/23 2:06 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-31830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800227#comment-17800227
]
Jane Chan commented on FLINK-31830:
---
I've already responded above, please see the "Beh
hunter-cloud09 commented on PR #740:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/740#issuecomment-1868659512
> Please add a proper PR description and a test. I am pretty sure that
existing tests do not cover this as you changed the behaviour.
Please see [issue](http
[
https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800225#comment-17800225
]
lincoln lee commented on FLINK-33635:
-
[~Weijie Guo] Could you have a check on this？
adipolak commented on code in PR #23903:
URL: https://github.com/apache/flink/pull/23903#discussion_r1435898859
##
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-31830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800216#comment-17800216
]
Sergey Nuyanzin commented on FLINK-31830:
-
[~qingyue] thanks for the response
j
snuyanzin commented on PR #23981:
URL: https://github.com/apache/flink/pull/23981#issuecomment-1868594128
1. the PR is incomplete: removal requirement for maven is not enough since
to make it reproducible there is no info how to enable it in IDE. In that case
in terminal there will be wrapp
asafm commented on PR #23981:
URL: https://github.com/apache/flink/pull/23981#issuecomment-1868536450
@snuyanzin Why would you want users, to run with their installed Maven? If
you want all users to have reproducible builds, they should only use the maven
wrapper, pinned to a specific versi
[ https://issues.apache.org/jira/browse/FLINK-33681 ]
Zhanghao Chen deleted comment on FLINK-33681:
---
was (Author: zhanghao chen):
After further investigation, it turned out to be a bug introduced by
FLINK-30536, which changed the way to count
[
https://issues.apache.org/jira/browse/FLINK-33681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800174#comment-17800174
]
Zhanghao Chen edited comment on FLINK-33681 at 12/24/23 12:24 PM:
[
https://issues.apache.org/jira/browse/FLINK-33681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-33681:
--
Affects Version/s: 1.17.2
1.18.0
Issue Type: Bug (was: Impro
[
https://issues.apache.org/jira/browse/FLINK-33681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800174#comment-17800174
]
Zhanghao Chen commented on FLINK-33681:
---
After further investigation, it turned ou
curcur commented on PR #23514:
URL: https://github.com/apache/flink/pull/23514#issuecomment-1868496305
CI seems Failed with
"[99d7b97](https://github.com/apache/flink/pull/23514/commits/99d7b97cd5844ec6362b30d8f9134509b72cb647)"
--
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/FLINK-33450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33450:
---
Labels: pull-request-available (was: )
> Implement JdbcAutoScalerStateStore
> -
1996fanrui opened a new pull request, #741:
URL: https://github.com/apache/flink-kubernetes-operator/pull/741
It's still developing, this is a draft 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 above to
48 matches
Mail list logo
