[
https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-29852:
---
Fix Version/s: (was: 1.16.0)
> The operator is repeatedly displayed on the Flink Web UI
snuyanzin commented on PR #21150:
URL: https://github.com/apache/flink/pull/21150#issuecomment-1301715846
@flinkbot run azure
--
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 go to the speci
MartijnVisser commented on PR #21176:
URL: https://github.com/apache/flink/pull/21176#issuecomment-1301715942
@flinkbot run azure
--
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 go to the specific comm
Noel O'Connor created FLINK-29860:
-
Summary: Pulsar connector bug when using Hybrid.Builder
Key: FLINK-29860
URL: https://issues.apache.org/jira/browse/FLINK-29860
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628149#comment-17628149
]
Yun Gao commented on FLINK-29852:
-
Hi [~JasonLee] thanks for reporting the issue! Could
[
https://issues.apache.org/jira/browse/FLINK-29860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Noel O'Connor updated FLINK-29860:
--
Description:
When using a HybridSource with a set of pulsar sources submitting a job to a
fli
[
https://issues.apache.org/jira/browse/FLINK-29809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628150#comment-17628150
]
Zhu Zhu commented on FLINK-29809:
-
Flink already supports submitting a job using REST AP
gaoyunhaii commented on code in PR #21174:
URL: https://github.com/apache/flink/pull/21174#discussion_r1012522367
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SinkFunctionOperator.java:
##
@@ -0,0 +1,37 @@
+/*
+ * Licensed to the Apache Softwar
[
https://issues.apache.org/jira/browse/FLINK-29437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang updated FLINK-29437:
---
Component/s: Connectors / Kafka
> The partition of data before and after the Kafka Shuffle are not a
[
https://issues.apache.org/jira/browse/FLINK-29573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628157#comment-17628157
]
Yingjie Cao commented on FLINK-29573:
-
[~kriswang] Thanks for reporting this issue,
[
https://issues.apache.org/jira/browse/FLINK-29322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628159#comment-17628159
]
Xintong Song commented on FLINK-29322:
--
Any updates for this ticket?
> Expose save
[
https://issues.apache.org/jira/browse/FLINK-29095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan reassigned FLINK-29095:
-
Assignee: Yanfei Lei
> Improve logging in SharedStateRegistry
> --
[
https://issues.apache.org/jira/browse/FLINK-29095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan reassigned FLINK-29095:
-
Assignee: (was: Roman Khachatryan)
> Improve logging in SharedStateRegistry
[
https://issues.apache.org/jira/browse/FLINK-29095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628161#comment-17628161
]
Roman Khachatryan commented on FLINK-29095:
---
Sure, assigned to you. Thanks for
wsry commented on code in PR #21217:
URL: https://github.com/apache/flink/pull/21217#discussion_r1012572311
##
flink-runtime/src/main/java/org/apache/flink/runtime/util/EnvironmentInformation.java:
##
@@ -469,7 +469,9 @@ public static void logEnvironmentInfo(
}
[
https://issues.apache.org/jira/browse/FLINK-29364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628164#comment-17628164
]
Yun Gao commented on FLINK-29364:
-
Thanks [~wanglijie] for the checking, and [~afedulov]
[
https://issues.apache.org/jira/browse/FLINK-28697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-28697:
-
Issue Type: Technical Debt (was: Bug)
> MapDataSerializer doesn't declare a serialVersionUID
>
[
https://issues.apache.org/jira/browse/FLINK-28697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-28697:
Assignee: Josh Mahonin
> MapDataSerializer doesn't declare a serialVersionUID
> -
[
https://issues.apache.org/jira/browse/FLINK-28561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-28561:
Fix Version/s: (was: 1.17.0)
> Merge subpartition shuffle data read request for better sequent
[
https://issues.apache.org/jira/browse/FLINK-28561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-28561:
Priority: Minor (was: Major)
> Merge subpartition shuffle data read request for better sequential
[
https://issues.apache.org/jira/browse/FLINK-28697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-28697:
Assignee: (was: Josh Mahonin)
> MapDataSerializer doesn't declare a serialVersionUID
[
https://issues.apache.org/jira/browse/FLINK-28598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628167#comment-17628167
]
Yun Gao commented on FLINK-28598:
-
[~zlzhang0122] May I have a double confirmation of th
[
https://issues.apache.org/jira/browse/FLINK-28455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-28455:
Component/s: API / Python
(was: API / Core)
> pyflink tableResult collect result to l
[
https://issues.apache.org/jira/browse/FLINK-28455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628168#comment-17628168
]
Yun Gao commented on FLINK-28455:
-
[~hxb] could you help to have a look at this issue?
luoyuxia created FLINK-29861:
Summary: Optimize logic of enumerateSplits in HiveSource
Key: FLINK-29861
URL: https://issues.apache.org/jira/browse/FLINK-29861
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-29861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29861:
-
Description: Currently, Hive source will call to emu
> Optimize logic of enumerateSplits in HiveSource
[
https://issues.apache.org/jira/browse/FLINK-29208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628170#comment-17628170
]
Lijie Wang commented on FLINK-29208:
I found that "{*}{{logs"}}{*} already exists in
[
https://issues.apache.org/jira/browse/FLINK-29208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628170#comment-17628170
]
Lijie Wang edited comment on FLINK-29208 at 11/3/22 7:57 AM:
-
pnowojski commented on code in PR #21131:
URL: https://github.com/apache/flink/pull/21131#discussion_r1012587547
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestDispatcherImpl.java:
##
@@ -73,11 +79,27 @@ public void dispatch(Ch
[
https://issues.apache.org/jira/browse/FLINK-28469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628176#comment-17628176
]
Yun Gao commented on FLINK-28469:
-
Hi [~Sandys-Lumsdaine] logically it is a bit hard to
czy006 commented on PR #21012:
URL: https://github.com/apache/flink/pull/21012#issuecomment-1301753419
@flinkbot run azure
--
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 go to the specific comment.
T
[
https://issues.apache.org/jira/browse/FLINK-29861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29861:
-
Description:
Currently, Hive source will call ` InputFormat#getSplits(JobConf conf, int
minNumSplits)`
czy006 commented on code in PR #21012:
URL: https://github.com/apache/flink/pull/21012#discussion_r1012593836
##
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarHandlerParameterTest.java:
##
@@ -69,6 +71,11 @@ enum ProgramArgsParType {
static
reswqa commented on PR #21137:
URL: https://github.com/apache/flink/pull/21137#issuecomment-1301765413
@flinkbot run azure
--
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 go to the specific comment.
T
zentol merged PR #43:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/43
--
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 go to the specific comment.
To unsubscribe, e-mail: issues-unsubs
[
https://issues.apache.org/jira/browse/FLINK-29468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29468:
-
Fix Version/s: elasticsearch-3.0.0
> Update jackson-bom to 2.13.4
>
[
https://issues.apache.org/jira/browse/FLINK-29468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29468:
-
Fix Version/s: (was: 1.17.0)
> Update jackson-bom to 2.13.4
> --
[
https://issues.apache.org/jira/browse/FLINK-29468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620527#comment-17620527
]
Chesnay Schepler edited comment on FLINK-29468 at 11/3/22 8:15 AM:
---
wangshiwei13363 commented on code in PR #21217:
URL: https://github.com/apache/flink/pull/21217#discussion_r1012599684
##
flink-runtime/src/main/java/org/apache/flink/runtime/util/EnvironmentInformation.java:
##
@@ -469,7 +469,9 @@ public static void logEnvironmentInfo(
dangshazi commented on code in PR #21185:
URL: https://github.com/apache/flink/pull/21185#discussion_r1012599965
##
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerStaticFileServerHandler.java:
##
@@ -166,10 +194,40 @@ private void respon
[
https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628182#comment-17628182
]
JasonLee commented on FLINK-29852:
--
Hi [~gaoyunhaii] yes,Stably repeated, I tested two
Chesnay Schepler created FLINK-29862:
Summary: Upgrade to flink-shaded 16.0
Key: FLINK-29862
URL: https://issues.apache.org/jira/browse/FLINK-29862
Project: Flink
Issue Type: Improvement
snuyanzin commented on PR #21150:
URL: https://github.com/apache/flink/pull/21150#issuecomment-1301775092
@flinkbot run azure
--
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 go to the speci
zentol commented on code in PR #21227:
URL: https://github.com/apache/flink/pull/21227#discussion_r1012607697
##
docs/layouts/shortcodes/generated/rest_v1_dispatcher.html:
##
@@ -1368,7 +1368,8 @@
"job-accumulators" : {
"type" : "array",
"items" : {
-"
[
https://issues.apache.org/jira/browse/FLINK-29862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29862:
---
Labels: pull-request-available (was: )
> Upgrade to flink-shaded 16.0
> ---
zentol commented on code in PR #21227:
URL: https://github.com/apache/flink/pull/21227#discussion_r1012608382
##
flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/CompatibilityRoutines.java:
##
@@ -230,6 +230,7 @@ private static void assertCompatible(final
zentol commented on code in PR #21227:
URL: https://github.com/apache/flink/pull/21227#discussion_r1012608847
##
pom.xml:
##
@@ -348,10 +347,16 @@ under the License.
-->
+
+ org.apache.flink
zentol commented on code in PR #21227:
URL: https://github.com/apache/flink/pull/21227#discussion_r1012609311
##
pom.xml:
##
@@ -139,7 +139,7 @@ under the License.
2.12
0.7.6
- 3.5.9
+ 3.5.10
Review Co
flinkbot commented on PR #21227:
URL: https://github.com/apache/flink/pull/21227#issuecomment-1301780919
## CI report:
* 549533a740f4acce34d021f8b9a83c8b553e2b65 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Jiabao-Sun commented on PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#issuecomment-1301782871
Hi @zentol.
Sorry to bother you again.
Please help to see if there is anything else that needs to be modified.
Thanks.
--
This is an automated message from the
yangjf2019 opened a new pull request, #425:
URL: https://github.com/apache/flink-kubernetes-operator/pull/425
## What is the purpose of the change
* Remove the extra space separator.
## Brief change log
* I have modified some files in the _docs/content/docs_
RyanSkraba commented on PR #20805:
URL: https://github.com/apache/flink/pull/20805#issuecomment-1301800271
Rebased and changed the commit messages to the suggested text. Thanks for
your attention!
In fact, for testing correctness, I would suggest that all three commits be
cherry-pic
dannycranmer commented on code in PR #21224:
URL: https://github.com/apache/flink/pull/21224#discussion_r1012630966
##
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java:
##
@@ -503,6 +503,10 @@ private void
init
zentol commented on PR #21137:
URL: https://github.com/apache/flink/pull/21137#issuecomment-1301815374
I don't see how this is supposed to be good from a maintenance perspective.
If you look at the code without context you now have 2 arbitrary calls go
through an executor and you make
zentol commented on PR #21137:
URL: https://github.com/apache/flink/pull/21137#issuecomment-1301817458
> In that case, the entire callback will be executed in the synchronized
block rightaway, which is not what we want.
Which implies that the future calls should never run under the lo
[
https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628218#comment-17628218
]
Krzysztof Chmielewski commented on FLINK-27246:
---
[~TsReaper]
I see why my
zentol commented on code in PR #21201:
URL: https://github.com/apache/flink/pull/21201#discussion_r1012657729
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/metainfo/StateMetaInfoSnapshotReadersWriters.java:
##
@@ -123,10 +116,10 @@ private static StateMetaInfoRea
zentol commented on code in PR #21201:
URL: https://github.com/apache/flink/pull/21201#discussion_r1012590358
##
flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSerializationUtil.java:
##
@@ -36,8 +32,6 @@
import java.io.ByteArrayInputStream;
impor
Chesnay Schepler created FLINK-29863:
Summary: Properly handle NaN/Infinity in OpenAPI spec
Key: FLINK-29863
URL: https://issues.apache.org/jira/browse/FLINK-29863
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628218#comment-17628218
]
Krzysztof Chmielewski edited comment on FLINK-27246 at 11/3/22 9:31 AM:
--
liyubin117 commented on PR #21182:
URL: https://github.com/apache/flink/pull/21182#issuecomment-1301843584
@flinkbot run azure
--
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 go to the specific comment
czy006 commented on PR #21012:
URL: https://github.com/apache/flink/pull/21012#issuecomment-1301845113
@flinkbot run azure
--
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 go to the specific comment.
T
weibozhao commented on code in PR #160:
URL: https://github.com/apache/flink-ml/pull/160#discussion_r1012675109
##
flink-ml-python/pyflink/ml/lib/feature/randomsplitter.py:
##
@@ -0,0 +1,77 @@
+
+#
[
https://issues.apache.org/jira/browse/FLINK-29558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628222#comment-17628222
]
Hang HOU commented on FLINK-29558:
--
I tried flink 1.16.0 with the same env,now in sql-c
zhuzhurk commented on code in PR #21197:
URL: https://github.com/apache/flink/pull/21197#discussion_r1012616825
##
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java:
##
@@ -175,6 +176,11 @@ public OperatorID operatorId() {
[
https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628226#comment-17628226
]
luoyuxia commented on FLINK-29855:
--
How do you know some of the data have been processe
zhipeng93 commented on code in PR #160:
URL: https://github.com/apache/flink-ml/pull/160#discussion_r1012681894
##
docs/content/docs/operators/feature/randomsplitter.md:
##
@@ -0,0 +1,148 @@
+---
+title: "RandomSplitter"
+weight: 1
+type: docs
+aliases:
+- /operators/feature/ran
Aitozi commented on code in PR #21174:
URL: https://github.com/apache/flink/pull/21174#discussion_r1012711061
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SinkFunctionOperator.java:
##
@@ -0,0 +1,37 @@
+/*
+ * Licensed to the Apache Software Fo
pnowojski commented on PR #21056:
URL: https://github.com/apache/flink/pull/21056#issuecomment-1301887623
@zentol / @twalthr , could you take a look again? (ignoring FLINK-29807
commits). I've migrated most of the fields, except of those that are
problematic.
--
This is an automated mes
[
https://issues.apache.org/jira/browse/FLINK-29420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29420:
-
Summary: Upgrade Zookeeper to 3.7 / 3.8 (was: Add support for Zookeeper
3.7 / 3.8)
> U
[
https://issues.apache.org/jira/browse/FLINK-29558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628222#comment-17628222
]
Hang HOU edited comment on FLINK-29558 at 11/3/22 10:17 AM:
[
https://issues.apache.org/jira/browse/FLINK-29379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628233#comment-17628233
]
Piotr Nowojski commented on FLINK-29379:
We can not refactor ExecutionConfig as
[
https://issues.apache.org/jira/browse/FLINK-29379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628233#comment-17628233
]
Piotr Nowojski edited comment on FLINK-29379 at 11/3/22 10:18 AM:
[
https://issues.apache.org/jira/browse/FLINK-29379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628233#comment-17628233
]
Piotr Nowojski edited comment on FLINK-29379 at 11/3/22 10:19 AM:
xintongsong commented on PR #21137:
URL: https://github.com/apache/flink/pull/21137#issuecomment-1301899690
> If you look at the code without context you now have 2 arbitrary calls go
through an executor and you make similar decisions as with locking ("what
operations should run in the exec
christofe lintermans created FLINK-29864:
Summary: AvroDeserializationSchema.forSpecific still generates
genericdata.record
Key: FLINK-29864
URL: https://issues.apache.org/jira/browse/FLINK-29864
1996fanrui commented on code in PR #21131:
URL: https://github.com/apache/flink/pull/21131#discussion_r1012728556
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestDispatcherImpl.java:
##
@@ -73,11 +79,27 @@ public void dispatch(C
[
https://issues.apache.org/jira/browse/FLINK-15633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber reassigned FLINK-15633:
---
Assignee: Nico Kruber
> Javadocs cannot be built on Java 11
> -
Nico Kruber created FLINK-29865:
---
Summary: Allow configuring the JDK in build-nightly-dist.yml
Key: FLINK-29865
URL: https://issues.apache.org/jira/browse/FLINK-29865
Project: Flink
Issue Type:
Aitozi commented on code in PR #21174:
URL: https://github.com/apache/flink/pull/21174#discussion_r1012761649
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SinkFunctionOperator.java:
##
@@ -0,0 +1,37 @@
+/*
+ * Licensed to the Apache Software Fo
pnowojski commented on code in PR #21131:
URL: https://github.com/apache/flink/pull/21131#discussion_r1012777571
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestDispatcherImpl.java:
##
@@ -73,11 +79,27 @@ public void dispatch(Ch
pnowojski commented on PR #21131:
URL: https://github.com/apache/flink/pull/21131#issuecomment-1301962892
Maybe we should rename the ticket/pr/commit. This doesn't simplify the class
anymore 😓 Maybe
> Do not support concurrent unaligned checkpoints in the
ChannelStateWriteRequestDispatc
dawidwys commented on code in PR #21201:
URL: https://github.com/apache/flink/pull/21201#discussion_r1012785767
##
flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSerializationUtil.java:
##
@@ -36,8 +32,6 @@
import java.io.ByteArrayInputStream;
imp
pnowojski commented on code in PR #21201:
URL: https://github.com/apache/flink/pull/21201#discussion_r1012793476
##
flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSerializationUtil.java:
##
@@ -36,8 +32,6 @@
import java.io.ByteArrayInputStream;
im
Chesnay Schepler created FLINK-29866:
Summary: Split flink-dist
Key: FLINK-29866
URL: https://issues.apache.org/jira/browse/FLINK-29866
Project: Flink
Issue Type: New Feature
Co
zentol opened a new pull request, #21228:
URL: https://github.com/apache/flink/pull/21228
This proposal extracts the core Flink dependencies of `flink-dist` into a
new `flink-dist-pub` module.
(Still looking for a better name! Don't want to use `flink-dist` to not
break dev workflows)
[
https://issues.apache.org/jira/browse/FLINK-29866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29866:
---
Labels: pull-request-available (was: )
> Split flink-dist
>
>
>
zentol merged PR #21227:
URL: https://github.com/apache/flink/pull/21227
--
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 go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache
pnowojski commented on code in PR #21201:
URL: https://github.com/apache/flink/pull/21201#discussion_r1012802125
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/metainfo/StateMetaInfoSnapshotReadersWriters.java:
##
@@ -139,10 +132,10 @@ private static StateMetaInfo
[
https://issues.apache.org/jira/browse/FLINK-29862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-29862.
Resolution: Fixed
master: 9e1ff648f18286628649a83aeaead6cbdca85259
> Upgrade to flink-sha
flinkbot commented on PR #21228:
URL: https://github.com/apache/flink/pull/21228#issuecomment-1301991570
## CI report:
* 219d79fb12f012149f40d9db47026cccbc25cb52 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yuzelin opened a new pull request, #21229:
URL: https://github.com/apache/flink/pull/21229
## 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 on
Nico Kruber created FLINK-29867:
---
Summary: Update maven-enforcer-plugin to 3.1.0
Key: FLINK-29867
URL: https://issues.apache.org/jira/browse/FLINK-29867
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-29866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628289#comment-17628289
]
Chesnay Schepler commented on FLINK-29866:
--
Note that this would also solve the
snuyanzin commented on PR #21150:
URL: https://github.com/apache/flink/pull/21150#issuecomment-1302005842
@flinkbot run azure
--
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 go to the speci
flinkbot commented on PR #21229:
URL: https://github.com/apache/flink/pull/21229#issuecomment-1302008075
## CI report:
* d3470826fef6a088d9b1a34a0e262b669832d49b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
jeesmon commented on PR #407:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/407#issuecomment-1302013578
@pvary Can this be configured per FlinkDeployment or is it global config for
all Deployments managed by the operator? Thanks!
--
This is an automated message from the A
zentol commented on PR #21221:
URL: https://github.com/apache/flink/pull/21221#issuecomment-1302016120
Looks like it finds more violations now.
```
Nov 03 07:53:12 [ERROR] Tests run: 1, Failures: 0, Errors: 1, Skipped: 0,
Time elapsed: 0.362 s <<< FAILURE! - in
org.apache.flink.ar
1996fanrui commented on PR #21131:
URL: https://github.com/apache/flink/pull/21131#issuecomment-1302018254
> Maybe we should rename the ticket/pr/commit. This doesn't simplify the
class anymore 😓 Maybe
>
> > Do not support concurrent unaligned checkpoints in the
ChannelStateWriteRequ
[
https://issues.apache.org/jira/browse/FLINK-29730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-29730:
Summary: Do not support concurrent unaligned checkpoints in the
ChannelStateWriteRequestDispatcherImpl (w
1 - 100 of 306 matches
Mail list logo
