JunRuiLee commented on PR #21963:
URL: https://github.com/apache/flink/pull/21963#issuecomment-1443025904
LGTM.
--
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 unsub
gaborgsomogyi commented on PR #22009:
URL: https://github.com/apache/flink/pull/22009#issuecomment-1443023755
e2e tests are still running so most probably it's going to pass.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
gaborgsomogyi commented on code in PR #22009:
URL: https://github.com/apache/flink/pull/22009#discussion_r1116617650
##
flink-runtime/src/main/java/org/apache/flink/runtime/security/modules/HadoopModule.java:
##
@@ -70,10 +71,22 @@ public void install() throws SecurityInstallExc
flinkbot commented on PR #22010:
URL: https://github.com/apache/flink/pull/22010#issuecomment-1443013003
## CI report:
* 5f4a9ee58a62b1b2e4d540ea6293554638722e53 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
xuzhiwen1255 commented on PR #22010:
URL: https://github.com/apache/flink/pull/22010#issuecomment-1442997250
@reswqa Can you review it for me, Thank you.
--
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
[
https://issues.apache.org/jira/browse/FLINK-30583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17693055#comment-17693055
]
Piotr Nowojski commented on FLINK-30583:
Thanks for this improvement! I've just
[
https://issues.apache.org/jira/browse/FLINK-27115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-27115.
--
Resolution: Fixed
master(1.18) via 67bd4ba7f300749c4831b37df525b82a76d3c36c
release-1.17 via 6170615ed
[
https://issues.apache.org/jira/browse/FLINK-31192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31192:
---
Labels: pull-request-available (was: )
> dataGen takes too long to initialize under sequenc
xuzhiwen1255 opened a new pull request, #22010:
URL: https://github.com/apache/flink/pull/22010
## What is the purpose of the change
In the sequence mode, the dataGen field will preload all the sequence values
when it is initialized, and it will take a long time during this period
[
https://issues.apache.org/jira/browse/FLINK-27115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-27115:
---
Affects Version/s: 1.17.0
> Error while executing BLOB connection. java.io.IOException: Unknown oper
[
https://issues.apache.org/jira/browse/FLINK-27115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-27115:
---
Fix Version/s: 1.17.0
> Error while executing BLOB connection. java.io.IOException: Unknown operatio
[
https://issues.apache.org/jira/browse/FLINK-27115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-27115:
--
Assignee: Weihua Hu
> Error while executing BLOB connection. java.io.IOException: Unknown ope
reswqa merged PR #22004:
URL: https://github.com/apache/flink/pull/22004
--
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
reswqa commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1116565034
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java:
##
@@ -362,30 +357,28 @@ private void testSyncSavepointWithEndInput(
[
https://issues.apache.org/jira/browse/FLINK-31089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17693022#comment-17693022
]
Yanfei Lei commented on FLINK-31089:
Let me try to summarize this issue:
# Enable P
reswqa commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1116563643
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java:
##
@@ -368,17 +368,19 @@ void testCleanUpExceptionSuppressing() throw
jhkkhtd commented on PR #21998:
URL: https://github.com/apache/flink/pull/21998#issuecomment-1442874077
> Thanks @jhkkhtd. Firstly, You should open a [jira
ticket](https://issues.apache.org/jira/projects/FLINK/issues) and describe
clearly why you need this change and how you plan to change
[
https://issues.apache.org/jira/browse/FLINK-31208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-31208:
--
Description:
KafkaSourceReader overrides meaninglessly a method(pauseOrResumeSplits) ，which
i
Hongshun Wang created FLINK-31208:
-
Summary: KafkaSourceReader overrides meaninglessly a
method(pauseOrResumeSplits)
Key: FLINK-31208
URL: https://issues.apache.org/jira/browse/FLINK-31208
Project: Fl
RocMarshal commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1116556431
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java:
##
@@ -1085,27 +1081,27 @@ public void testNotifyCheckpointOnClos
RocMarshal commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1116556097
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java:
##
@@ -1121,13 +1117,14 @@ private void
testFailToConfirmCheckpo
RocMarshal commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1116555777
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java:
##
@@ -362,30 +357,28 @@ private void testSyncSavepointWithEndInp
RocMarshal commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1116555051
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java:
##
@@ -362,30 +357,28 @@ private void testSyncSavepointWithEndInp
[
https://issues.apache.org/jira/browse/FLINK-22484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17693015#comment-17693015
]
jackylau commented on FLINK-22484:
--
hi [~Sergey Nuyanzin] how aboult add
map_entries/m
reswqa commented on code in PR #21999:
URL: https://github.com/apache/flink/pull/21999#discussion_r1116492529
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java:
##
@@ -362,30 +357,28 @@ private void testSyncSavepointWithEndInput(
[
https://issues.apache.org/jira/browse/FLINK-31207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau updated FLINK-31207:
-
Description:
spark [https://spark.apache.org/docs/latest/api/sql/index.html#transform]
transform/transf
zhuangchong opened a new pull request, #556:
URL: https://github.com/apache/flink-table-store/pull/556
Add version reference of `kafka` dependent package
--
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
[
https://issues.apache.org/jira/browse/FLINK-22091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17693008#comment-17693008
]
Samrat Deb commented on FLINK-22091:
i would like to work on this issue.
> env.java
[
https://issues.apache.org/jira/browse/FLINK-31207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau updated FLINK-31207:
-
Summary: Supports high order function like other engine (was: supports
high order function like other e
jackylau created FLINK-31207:
Summary: supports high order function like other engine
Key: FLINK-31207
URL: https://issues.apache.org/jira/browse/FLINK-31207
Project: Flink
Issue Type: Sub-task
1996fanrui commented on PR #21999:
URL: https://github.com/apache/flink/pull/21999#issuecomment-1442822176
Please squish these commits, and follow the rules that @reswqa mentioned
before.
> This PR will eventually have two commits in the following order:
> 1.[hotfix] Migrate S
[
https://issues.apache.org/jira/browse/FLINK-31196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prabhu Joseph updated FLINK-31196:
--
Description:
Flink on YARN, honor env.java.home, and launch JobManager and TaskMananger
conta
[
https://issues.apache.org/jira/browse/FLINK-31196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prabhu Joseph resolved FLINK-31196.
---
Resolution: Duplicate
> Flink on YARN honors env.java.home
> ---
[
https://issues.apache.org/jira/browse/FLINK-31196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17693003#comment-17693003
]
Prabhu Joseph commented on FLINK-31196:
---
Thanks [~zlzhang0122] for the update. Ha
[
https://issues.apache.org/jira/browse/FLINK-20395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-20395:
--
Assignee: Weijie Guo
> Migrate test_netty_shuffle_memory_control.sh
> ---
Zili Chen created FLINK-31206:
-
Summary: Broken links on flink.apache.org
Key: FLINK-31206
URL: https://issues.apache.org/jira/browse/FLINK-31206
Project: Flink
Issue Type: Bug
Report
[
https://issues.apache.org/jira/browse/FLINK-31204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31204.
Fix Version/s: table-store-0.4.0
Assignee: Shammon
Resolution: Fixed
master: 306a9
wanglijie95 commented on PR #20006:
URL: https://github.com/apache/flink/pull/20006#issuecomment-1442775810
@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 commen
JingsongLi merged PR #555:
URL: https://github.com/apache/flink-table-store/pull/555
--
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...@
wanglijie95 commented on PR #21963:
URL: https://github.com/apache/flink/pull/21963#issuecomment-1442773339
Thanks for review @JunRuiLee @zhuzhurk . I 've addressed all comments,
please take a look.
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
wanglijie95 commented on code in PR #21963:
URL: https://github.com/apache/flink/pull/21963#discussion_r1116480439
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java:
##
@@ -1060,14 +,97 @@ private void setVertexConfig(
[
https://issues.apache.org/jira/browse/FLINK-31107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yufan Sheng updated FLINK-31107:
Description:
This is a ticket for tracking [the known
issue|https://github.com/apache/pulsar/issu
wanglijie95 commented on code in PR #21963:
URL: https://github.com/apache/flink/pull/21963#discussion_r1116477683
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java:
##
@@ -568,12 +592,7 @@ && isChainableInput(sourceOutEdg
wanglijie95 commented on code in PR #21963:
URL: https://github.com/apache/flink/pull/21963#discussion_r1116477303
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/forwardgroup/ForwardGroup.java:
##
@@ -53,9 +55,22 @@ public ForwardGroup(final Set jobVertices) {
venkata91 commented on PR #22009:
URL: https://github.com/apache/flink/pull/22009#issuecomment-1442766757
Looking into the test failure, somehow it worked locally but failing in the
pipeline.
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
wanglijie95 commented on code in PR #21963:
URL: https://github.com/apache/flink/pull/21963#discussion_r1116476622
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java:
##
@@ -928,14 +1011,8 @@ private StreamConfig createJobV
wanglijie95 commented on code in PR #21963:
URL: https://github.com/apache/flink/pull/21963#discussion_r1116476465
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java:
##
@@ -1060,14 +,97 @@ private void setVertexConfig(
wuchong commented on PR #21966:
URL: https://github.com/apache/flink/pull/21966#issuecomment-1442759082
@stayrascal thank you for helping to verifying it.
--
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
lsyldliu commented on PR #21966:
URL: https://github.com/apache/flink/pull/21966#issuecomment-1442750732
@stayrascal Very thanks you can make double-check. I think it works well
because it works on JM side.
--
This is an automated message from the Apache Git Service.
To respond to the mes
[
https://issues.apache.org/jira/browse/FLINK-31117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31117.
Resolution: Fixed
master: 37f75a85091697b75c6968293edfb060595adae3
> Split flink connector to eac
JingsongLi merged PR #545:
URL: https://github.com/apache/flink-table-store/pull/545
--
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...@
stayrascal commented on PR #21966:
URL: https://github.com/apache/flink/pull/21966#issuecomment-1442721215
@lsyldliu thanks a lot for looking at this issue, may I check that if we use
flink filesytem instead of hadoop filesytem to open parquet file, so that flink
fs can retrieve the configu
FangYongs commented on code in PR #555:
URL: https://github.com/apache/flink-table-store/pull/555#discussion_r1116445519
##
flink-table-store-hive/flink-table-store-hive-catalog/pom.xml:
##
@@ -535,6 +535,65 @@ under the License.
org.jamon
[
https://issues.apache.org/jira/browse/FLINK-22922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692982#comment-17692982
]
Zili Chen commented on FLINK-22922:
---
Hi [~martijnvisser]! I see now we use `asf-site`
Mulavar commented on PR #21545:
URL: https://github.com/apache/flink/pull/21545#issuecomment-1442717916
@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.
[
https://issues.apache.org/jira/browse/FLINK-31204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31204:
---
Labels: pull-request-available (was: )
> HiveCatalogITCase fails due to avro conflict in ta
JingsongLi commented on code in PR #555:
URL: https://github.com/apache/flink-table-store/pull/555#discussion_r111644
##
flink-table-store-hive/flink-table-store-hive-catalog/pom.xml:
##
@@ -535,6 +535,65 @@ under the License.
org.jamon
[
https://issues.apache.org/jira/browse/FLINK-12450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692979#comment-17692979
]
Ran Tao commented on FLINK-12450:
-
[~jark] Hi, Jark. can you assign this ticket to me? i
[
https://issues.apache.org/jira/browse/FLINK-12449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692978#comment-17692978
]
Ran Tao commented on FLINK-12449:
-
[~lzljs3620320] hi,Jingsong, can you assign this tick
JingsongLi merged PR #553:
URL: https://github.com/apache/flink-table-store/pull/553
--
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...@
flinkbot commented on PR #22009:
URL: https://github.com/apache/flink/pull/22009#issuecomment-1442699380
## CI report:
* c7e58124ab18ef98248a279359ee9014071847dc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lsyldliu commented on PR #21966:
URL: https://github.com/apache/flink/pull/21966#issuecomment-1442697375
@wuchong Thanks for reviewing. Regarding your question, we can't verify the
configuration in ParquetReader now because the `ParquetFileReader` doesn't
contain the credential info. The cr
[
https://issues.apache.org/jira/browse/FLINK-31109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692973#comment-17692973
]
Venkata krishnan Sowrirajan commented on FLINK-31109:
-
[~martijnviss
venkata91 commented on PR #22009:
URL: https://github.com/apache/flink/pull/22009#issuecomment-1442696039
Please review. cc @MartijnVisser @gaborgsomogyi @becketqin
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
[
https://issues.apache.org/jira/browse/FLINK-31109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31109:
---
Labels: pull-request-available (was: )
> Fails with proxy user not supported even when
> s
venkata91 opened a new pull request, #22009:
URL: https://github.com/apache/flink/pull/22009
…etch is disabled
## What is the purpose of the change
FLINK-28330 removed old delegation token framework code as part of it
removed the existing support for delegation tokens t
Aitozi created FLINK-31205:
--
Summary: do optimize for multi sink in a single relNode tree
Key: FLINK-31205
URL: https://issues.apache.org/jira/browse/FLINK-31205
Project: Flink
Issue Type: Improvem
zlzhang0122 commented on PR #20183:
URL: https://github.com/apache/flink/pull/20183#issuecomment-1442682491
@wuchong Could you pls help to confirm and review this?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
[
https://issues.apache.org/jira/browse/FLINK-31201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-31201:
Assignee: Jingsong Lee
> Provides option to sort partition for full stage in streaming re
[
https://issues.apache.org/jira/browse/FLINK-31196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692966#comment-17692966
]
zlzhang0122 commented on FLINK-31196:
-
Maybe duplicate with this?
[Flink-22091|http
[
https://issues.apache.org/jira/browse/FLINK-31201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31201:
---
Labels: pull-request-available (was: )
> Provides option to sort partition for full stage i
JingsongLi opened a new pull request, #554:
URL: https://github.com/apache/flink-table-store/pull/554
Currently, it is out of order for partitions. Because HashMap is used, we
may be able to use LinkedHashMap to make the order according to the creation
time of the first file.
--
This is
Shammon created FLINK-31204:
---
Summary: HiveCatalogITCase fails due to avro conflict in table
store
Key: FLINK-31204
URL: https://issues.apache.org/jira/browse/FLINK-31204
Project: Flink
Issue Type
rkhachatryan commented on PR #21981:
URL: https://github.com/apache/flink/pull/21981#issuecomment-1442587044
Thanks for the feedback, @zentol and @dmvk .
I've updated the PR, would you mind taking another look?
I've significantly restructured the code after the offline discussions.
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1116364006
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotAllocator.java:
##
@@ -54,6 +54,18 @@ public interface SlotAllocator {
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1116362299
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/StateLocalitySlotAssigner.java:
##
@@ -0,0 +1,209 @@
+/*
+ * Licensed to the A
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1116362006
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/StateLocalitySlotAssigner.java:
##
@@ -0,0 +1,209 @@
+/*
+ * Licensed to the A
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1116360889
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/StateLocalitySlotAssigner.java:
##
@@ -0,0 +1,209 @@
+/*
+ * Licensed to the A
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1116359613
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/StateLocalitySlotAssigner.java:
##
@@ -0,0 +1,209 @@
+/*
+ * Licensed to the A
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1116359318
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/StateLocalitySlotAssigner.java:
##
@@ -0,0 +1,209 @@
+/*
+ * Licensed to the A
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1116358878
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateTransitions.java:
##
@@ -163,7 +165,12 @@ CompletableFuture goToStopWithSavepoint(
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1116358657
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/StateLocalitySlotAssigner.java:
##
@@ -0,0 +1,209 @@
+/*
+ * Licensed to the A
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1116358477
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/StateLocalitySlotAssigner.java:
##
@@ -0,0 +1,209 @@
+/*
+ * Licensed to the A
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1116356436
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java:
##
@@ -794,7 +802,23 @@ public void goToWaitingForResources() {
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1116355057
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotSharingSlotAllocator.java:
##
@@ -121,16 +133,13 @@ public Optional
deter
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1116355057
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotSharingSlotAllocator.java:
##
@@ -121,16 +133,13 @@ public Optional
deter
gunnarmorling commented on PR #21648:
URL: https://github.com/apache/flink/pull/21648#issuecomment-1442297939
@rmetzger, could we get this one merged?
--
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
mxm merged PR #537:
URL: https://github.com/apache/flink-kubernetes-operator/pull/537
--
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...
dannycranmer commented on code in PR #611:
URL: https://github.com/apache/flink-web/pull/611#discussion_r1116091205
##
docs/content/posts/2023-02-23-release-1.15.4.md:
##
@@ -0,0 +1,152 @@
+---
+authors:
+- fapaul: null
+ name: Danny Cranmer
+date: "2023-02-23T17:00:00Z"
+excer
snuyanzin commented on code in PR #611:
URL: https://github.com/apache/flink-web/pull/611#discussion_r1116071377
##
docs/content/posts/2023-02-23-release-1.15.4.md:
##
@@ -0,0 +1,152 @@
+---
+authors:
+- fapaul: null
+ name: Danny Cranmer
+date: "2023-02-23T17:00:00Z"
+excerpt:
snuyanzin commented on code in PR #21993:
URL: https://github.com/apache/flink/pull/21993#discussion_r1116007389
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayElementArgumentTypeStrategy.java:
##
@@ -31,24 +31,28 @@
imp
[
https://issues.apache.org/jira/browse/FLINK-27954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-27954:
--
Assignee: Weijie Guo
> JobVertexFlameGraphHandler does not work on standby Dispatcher
> -
mxm opened a new pull request, #537:
URL: https://github.com/apache/flink-kubernetes-operator/pull/537
Using the reporter class directly is not supported anymore with Flink 1.16.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
[
https://issues.apache.org/jira/browse/FLINK-27954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692801#comment-17692801
]
Weijie Guo commented on FLINK-27954:
Thanks [~chesnay] for reporting this and giving
snuyanzin commented on code in PR #21993:
URL: https://github.com/apache/flink/pull/21993#discussion_r1116011807
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SpecificInputTypeStrategies.java:
##
@@ -71,7 +71,11 @@ public final
snuyanzin commented on code in PR #21993:
URL: https://github.com/apache/flink/pull/21993#discussion_r1116007389
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayElementArgumentTypeStrategy.java:
##
@@ -31,24 +31,28 @@
imp
[
https://issues.apache.org/jira/browse/FLINK-31183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-31183.
---
Resolution: Fixed
> Flink Kinesis EFO Consumer can fail to stop gracefully
> ---
[
https://issues.apache.org/jira/browse/FLINK-31183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692651#comment-17692651
]
Danny Cranmer edited comment on FLINK-31183 at 2/23/23 5:05 PM:
--
dannycranmer merged PR #22008:
URL: https://github.com/apache/flink/pull/22008
--
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.
zhuzhurk commented on code in PR #21963:
URL: https://github.com/apache/flink/pull/21963#discussion_r1115923261
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java:
##
@@ -928,14 +1011,8 @@ private StreamConfig createJobVert
1 - 100 of 316 matches
Mail list logo
