XComp commented on PR #22829:
URL: https://github.com/apache/flink/pull/22829#issuecomment-1598216745
I had to change the order of the PRs because I realized that I did assign a
few commits to the wrong branch/PR. But I didn't want to touch the already
approved PR FLINK-30344. I updated the
XComp commented on PR #22830:
URL: https://github.com/apache/flink/pull/22830#issuecomment-1598216870
I had to change the order of the PRs because I realized that I did assign a
few commits to the wrong branch/PR. But I didn't want to touch the already
approved PR FLINK-30344. I updated the
[
https://issues.apache.org/jira/browse/FLINK-31923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17733002#comment-17733002
]
Martijn Visser edited comment on FLINK-31923 at 6/20/23 6:54 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17735160#comment-17735160
]
Martijn Visser commented on FLINK-20628:
[~RocMarshal] I've assigned the ticket
[
https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-20628:
--
Assignee: RocMarshal
> Port RabbitMQ Sources to FLIP-27 API
> ---
XComp commented on PR #22829:
URL: https://github.com/apache/flink/pull/22829#issuecomment-1598180313
Force-pushed rebase to master (no additional changes)
--
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
[
https://issues.apache.org/jira/browse/FLINK-32180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-32180.
---
Fix Version/s: 1.18.0
Resolution: Fixed
master: 6a410899e2c57059f9944e8dd35742efa1358
XComp merged PR #22656:
URL: https://github.com/apache/flink/pull/22656
--
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.
[
https://issues.apache.org/jira/browse/FLINK-32371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-32371.
---
Fix Version/s: 1.16.3
1.17.2
Resolution: Fixed
> Bump snappy-java
[
https://issues.apache.org/jira/browse/FLINK-32371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17734063#comment-17734063
]
Matthias Pohl edited comment on FLINK-32371 at 6/20/23 6:03 AM:
--
XComp merged PR #22823:
URL: https://github.com/apache/flink/pull/22823
--
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.
XComp merged PR #22822:
URL: https://github.com/apache/flink/pull/22822
--
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 #22733:
URL: https://github.com/apache/flink/pull/22733#discussion_r1234767876
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/TieredStorageConsumerClientTest.java:
##
@@ -0,0 +1,74 @@
+/*
+ * Licens
snuyanzin commented on PR #17867:
URL: https://github.com/apache/flink/pull/17867#issuecomment-1598142720
Thanks for having a look @reswqa , @fsk119
I've rebased, tests are passed
will merge soon
--
This is an automated message from the Apache Git Service.
To respond to the mes
[
https://issues.apache.org/jira/browse/FLINK-32137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17735128#comment-17735128
]
Rui Fan commented on FLINK-32137:
-
A mistake has just occurred about assignee.
Hi [~net
[
https://issues.apache.org/jira/browse/FLINK-32137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-32137:
---
Assignee: Vladimir Matveev (was: Rui Fan)
> Flame graph is hard to use with many task managers
> -
[
https://issues.apache.org/jira/browse/FLINK-32137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-32137:
---
Assignee: Rui Fan (was: Vladimir Matveev)
> Flame graph is hard to use with many task managers
> -
curcur commented on PR #22590:
URL: https://github.com/apache/flink/pull/22590#issuecomment-1598107276
@Zakelly Thanks for the efforts! I've gone through another pass, LGTM.
A couple of things left:
1. squash the commits (address comments e.t.c)
2. run the bot again (the pip
FangYongs commented on PR #22768:
URL: https://github.com/apache/flink/pull/22768#issuecomment-1598082695
Hi @fsk119 Please help to review this PR when you are free, thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
[
https://issues.apache.org/jira/browse/FLINK-32310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17735108#comment-17735108
]
luoyuxia commented on FLINK-32310:
--
[~lemonjing] Sorry to bother you. I'm wondering the
Weihua Hu created FLINK-32387:
-
Summary: InputGateDeploymentDescriptor uses cache to avoid
deserializing shuffle descriptors multiple times
Key: FLINK-32387
URL: https://issues.apache.org/jira/browse/FLINK-32387
[
https://issues.apache.org/jira/browse/FLINK-32383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-32383:
Priority: Blocker (was: Major)
> 2.0 Breaking configuration changes
> --
Weihua Hu created FLINK-32386:
-
Summary: Add ShuffleDescriptorsCache in TaskExecutor to cache
ShuffleDescriptors
Key: FLINK-32386
URL: https://issues.apache.org/jira/browse/FLINK-32386
Project: Flink
luoyuxia commented on code in PR #22721:
URL: https://github.com/apache/flink/pull/22721#discussion_r1234691322
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowPartitionsOperation.java:
##
@@ -66,10 +66,6 @@ public CatalogPartitionSpec get
WencongLiu commented on PR #22733:
URL: https://github.com/apache/flink/pull/22733#issuecomment-1598052498
Thanks for the review from @TanYuxin-tyx and @reswqa ! I've made a round of
changes. 🎉
--
This is an automated message from the Apache Git Service.
To respond to the message, please
WencongLiu commented on code in PR #22733:
URL: https://github.com/apache/flink/pull/22733#discussion_r1234687955
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java:
##
@@ -813,6 +813,11 @@ private void checkPartitionReq
WencongLiu commented on code in PR #22733:
URL: https://github.com/apache/flink/pull/22733#discussion_r1234687042
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java:
##
@@ -217,6 +222,12 @@ public class SingleInputGate exte
WencongLiu commented on code in PR #22733:
URL: https://github.com/apache/flink/pull/22733#discussion_r1234687515
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/benchmark/StreamNetworkBenchmarkEnvironment.java:
##
@@ -280,7 +281,8 @@ private IndexedI
WencongLiu commented on code in PR #22733:
URL: https://github.com/apache/flink/pull/22733#discussion_r1234687374
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateFactory.java:
##
@@ -158,9 +166,34 @@ public SingleInputGate cre
[
https://issues.apache.org/jira/browse/FLINK-32370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li updated FLINK-32370:
---
Component/s: Tests
> JDBC SQl gateway e2e test is unstable
> -
>
Weihua Hu created FLINK-32385:
-
Summary: Introduce a struct SerializedShuffleDescriptorAndIndices
to identify a group of ShuffleDescriptorAndIndex
Key: FLINK-32385
URL: https://issues.apache.org/jira/browse/FLINK-3238
[
https://issues.apache.org/jira/browse/FLINK-32370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li closed FLINK-32370.
--
Assignee: Fang Yong
Resolution: Fixed
Fixed via
https://github.com/apache/flink/commit/8119411a
[
https://issues.apache.org/jira/browse/FLINK-32288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-32288.
---
Resolution: Done
done via b462d0ec4d1d421a369e45f8dca33284b5be6bc2
> Improve the scheduling performance of
libenchao closed pull request #22819: [FLINK-32370][client] Fix warn log in
result fetcher when job is finished
URL: https://github.com/apache/flink/pull/22819
--
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
zhuzhurk closed pull request #22798: [FLINK-32288][runtime] Improve the
scheduling performance of AdaptiveBatchScheduler
URL: https://github.com/apache/flink/pull/22798
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
Samrat002 commented on PR #83:
URL:
https://github.com/apache/flink-connector-aws/pull/83#issuecomment-1598036360
Hi @dannycranmer , @hlteoh37 !
Please validate if we want to add newly released minor version of flink
(1.16.2 and 1.17.1) in the PR build pipeline.
Thank you
LoveHeat commented on code in PR #22806:
URL: https://github.com/apache/flink/pull/22806#discussion_r1234672707
##
flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java:
##
@@ -195,9 +195,19 @@ void announceCombinedWatermark() {
LoveHeat commented on code in PR #22806:
URL: https://github.com/apache/flink/pull/22806#discussion_r1234672707
##
flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java:
##
@@ -195,9 +195,19 @@ void announceCombinedWatermark() {
Zhu Zhu created FLINK-32384:
---
Summary: Remove deprecated configuration keys which violate YAML
spec
Key: FLINK-32384
URL: https://issues.apache.org/jira/browse/FLINK-32384
Project: Flink
Issue Typ
LoveHeat commented on PR #22808:
URL: https://github.com/apache/flink/pull/22808#issuecomment-1598030633
The first path is(just simple call stack not full):
[create JobMaster for each recovered job, and will init a scheduler object
in jobmaster construct
function](https://github.com/apac
TanYuxin-tyx commented on code in PR #22733:
URL: https://github.com/apache/flink/pull/22733#discussion_r1234664689
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TestingTierFactory.java:
##
@@ -0,0 +1,128 @@
+/*
+ * Licensed t
TanYuxin-tyx commented on code in PR #22733:
URL: https://github.com/apache/flink/pull/22733#discussion_r1234664689
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TestingTierFactory.java:
##
@@ -0,0 +1,128 @@
+/*
+ * Licensed t
Zhu Zhu created FLINK-32383:
---
Summary: 2.0 Breaking configuration changes
Key: FLINK-32383
URL: https://issues.apache.org/jira/browse/FLINK-32383
Project: Flink
Issue Type: Technical Debt
[
https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17734964#comment-17734964
]
RocMarshal commented on FLINK-20628:
[~martijnvisser] Thank you for your reply.
Yes,
[
https://issues.apache.org/jira/browse/FLINK-32374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17734087#comment-17734087
]
luoyuxia edited comment on FLINK-32374 at 6/20/23 1:49 AM:
---
ma
[
https://issues.apache.org/jira/browse/FLINK-32374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia closed FLINK-32374.
Resolution: Fixed
> ExecNodeGraphInternalPlan#writeToFile should support TRUNCATE_EXISTING for
> overwrit
luoyuxia merged PR #22825:
URL: https://github.com/apache/flink/pull/22825
--
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.apac
luoyuxia merged PR #22826:
URL: https://github.com/apache/flink/pull/22826
--
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.apac
[
https://issues.apache.org/jira/browse/FLINK-27240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17734637#comment-17734637
]
luoyuxia commented on FLINK-27240:
--
master: 4586bcbe6627ad91001838507b9e1e68ddfc7cdf
>
[
https://issues.apache.org/jira/browse/FLINK-27240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia closed FLINK-27240.
Resolution: Fixed
> Support ADD PARTITION statement for partitioned table
> --
luoyuxia merged PR #22711:
URL: https://github.com/apache/flink/pull/22711
--
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.apac
luoyuxia commented on PR #22711:
URL: https://github.com/apache/flink/pull/22711#issuecomment-1597923994
@ruanhang1993 Thanks for review. Merging
--
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
rkhachatryan commented on code in PR #22669:
URL: https://github.com/apache/flink/pull/22669#discussion_r1234528219
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -122,37 +121,20 @@ public StreamStateHandle registerReference(
rkhachatryan commented on PR #22669:
URL: https://github.com/apache/flink/pull/22669#issuecomment-1597828851
Good find @zoltar9264!
> Don't trigger a new materialization until the previous one has either
confirmed or failed
That makes perfect sense to me.
Would you be able
XComp commented on code in PR #22828:
URL: https://github.com/apache/flink/pull/22828#discussion_r1234298207
##
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesLeaderRetrievalDriverTest.java:
##
@@ -62,14 +62,13 @@ void testKubernetesLeaderR
zentol commented on code in PR #22828:
URL: https://github.com/apache/flink/pull/22828#discussion_r1234288121
##
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesLeaderRetrievalDriverTest.java:
##
@@ -62,14 +62,13 @@ void testKubernetesLeader
flinkbot commented on PR #22830:
URL: https://github.com/apache/flink/pull/22830#issuecomment-1597491143
## CI report:
* 2ebfc9a83f4fc6a438e280d5463da8ca702dc1e8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30343:
---
Labels: pull-request-available (was: )
> Migrate KubernetesLeaderElectionAndRetrievalITCase
flinkbot commented on PR #22829:
URL: https://github.com/apache/flink/pull/22829#issuecomment-1597485705
## CI report:
* cf666395bd0ca5e4f1b3114313b118a346fcb485 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #22828:
URL: https://github.com/apache/flink/pull/22828#issuecomment-1597485614
## CI report:
* f981327bb48ba92b93d68e1a95964960d7dbd9f9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
XComp opened a new pull request, #22830:
URL: https://github.com/apache/flink/pull/22830
* https://github.com/apache/flink/pull/21742
* https://github.com/apache/flink/pull/22379
* https://github.com/apache/flink/pull/22422
* https://github.com/apache/flink/pull/22380
* https://gi
[
https://issues.apache.org/jira/browse/FLINK-30342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30342:
---
Labels: pull-request-available (was: )
> Migrate ZooKeeperLeaderElectionTest
>
XComp opened a new pull request, #22829:
URL: https://github.com/apache/flink/pull/22829
* https://github.com/apache/flink/pull/21742
* https://github.com/apache/flink/pull/22379
* https://github.com/apache/flink/pull/22422
* https://github.com/apache/flink/pull/22380
* https://gi
[
https://issues.apache.org/jira/browse/FLINK-30344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30344:
---
Labels: pull-request-available (was: )
> Migrate KubernetesHighAvailabilityTestBase and imp
XComp opened a new pull request, #22828:
URL: https://github.com/apache/flink/pull/22828
* https://github.com/apache/flink/pull/21742
* https://github.com/apache/flink/pull/22379
* https://github.com/apache/flink/pull/22422
* https://github.com/apache/flink/pull/22380
* https://gi
afedulov commented on PR #22816:
URL: https://github.com/apache/flink/pull/22816#issuecomment-1597458830
Flaky test failure. Passed in a private pipeline
https://dev.azure.com/alexanderfedulov/Flink/_build/results?buildId=484&view=results
--
This is an automated message from the Apache Gi
afedulov commented on PR #22816:
URL: https://github.com/apache/flink/pull/22816#issuecomment-1597457675
@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-32382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-32382.
---
Resolution: Duplicate
> SQL JDBC e2e test failed with FlinkJobNotFoundException
> --
XComp commented on PR #22656:
URL: https://github.com/apache/flink/pull/22656#issuecomment-1597399978
@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.
To
XComp commented on PR #22656:
URL: https://github.com/apache/flink/pull/22656#issuecomment-1597399847
I created FLINK-32382 to cover the test instability. It doesn't look like
it's related to the refactoring
--
This is an automated message from the Apache Git Service.
To respond to the me
[
https://issues.apache.org/jira/browse/FLINK-32382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32382:
--
Description:
I ran into a test instability in [this CI
build|https://dev.azure.com/apache-fli
[
https://issues.apache.org/jira/browse/FLINK-32382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32382:
--
Attachment: logs-ci-e2e_2_ci-1687181689.zip
> SQL JDBC e2e test failed with FlinkJobNotFoundEx
Matthias Pohl created FLINK-32382:
-
Summary: SQL JDBC e2e test failed with FlinkJobNotFoundException
Key: FLINK-32382
URL: https://issues.apache.org/jira/browse/FLINK-32382
Project: Flink
Iss
flinkbot commented on PR #22827:
URL: https://github.com/apache/flink/pull/22827#issuecomment-1597364046
## CI report:
* 0f1b59cb40de5f2e4763578c56e763e8f4e9cb2f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-20887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20887:
---
Labels: auto-deprioritized-major auto-unassigned pull-request-available
(was: auto-depriori
[
https://issues.apache.org/jira/browse/FLINK-32379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17734207#comment-17734207
]
Chesnay Schepler commented on FLINK-32379:
--
There seem to be some differences i
ferenc-csaky commented on PR #5:
URL:
https://github.com/apache/flink-connector-hbase/pull/5#issuecomment-1597249499
@MartijnVisser @zentol opened #12 with the dockerized E2E tests. The
workflow runs currently seems to fail, I'm not sure why.
--
This is an automated message from the Apac
[
https://issues.apache.org/jira/browse/FLINK-32379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17734203#comment-17734203
]
Chesnay Schepler commented on FLINK-32379:
--
{code}
maven clean install -DskipTe
[
https://issues.apache.org/jira/browse/FLINK-20887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-20887:
Fix Version/s: 1.18.0
> Non-deterministic functions return different values even if it is referred
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17734183#comment-17734183
]
Stefan Richter commented on FLINK-31238:
[~mayuehappy] Thanks for working on thi
[
https://issues.apache.org/jira/browse/FLINK-32379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17734179#comment-17734179
]
Chesnay Schepler commented on FLINK-32379:
--
Nope, I also couldn't reproduce it.
WencongLiu commented on code in PR #22733:
URL: https://github.com/apache/flink/pull/22733#discussion_r1234040994
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/tier/memory/MemoryTierConsumerAgent.java:
##
@@ -0,0 +1,82 @@
+/*
+ * Lice
reswqa commented on code in PR #22733:
URL: https://github.com/apache/flink/pull/22733#discussion_r1233995628
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java:
##
@@ -217,6 +222,12 @@ public class SingleInputGate extends
[
https://issues.apache.org/jira/browse/FLINK-32097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-32097:
Summary: Implement support for Kinesis deaggregation (was: Implement
support for Kinesis
[
https://issues.apache.org/jira/browse/FLINK-31990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer closed FLINK-31990.
-
Resolution: Done
> Use Flink Configuration to specify KDS Source configuration object
>
[
https://issues.apache.org/jira/browse/FLINK-31990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17734168#comment-17734168
]
Danny Cranmer commented on FLINK-31990:
---
ok thanks [~liangtl]Â
Â
> Use Flink Con
carp84 commented on code in PR #22788:
URL: https://github.com/apache/flink/pull/22788#discussion_r1231969461
##
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateDownloaderTest.java:
##
@@ -165,4 +192,48 @@ public
[
https://issues.apache.org/jira/browse/FLINK-31956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17734166#comment-17734166
]
Jane Chan commented on FLINK-31956:
---
Hi, [~xu_shuai_] Thanks for your contribution! We
[
https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17734163#comment-17734163
]
Martijn Visser commented on FLINK-20628:
[~RocMarshal] Do you want to continue o
[
https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-20628:
---
Fix Version/s: (was: 1.12.0)
> Port RabbitMQ Sources to FLIP-27 API
> --
LadyForest commented on code in PR #22539:
URL: https://github.com/apache/flink/pull/22539#discussion_r1230722665
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/ExecNodeGraphInternalPlan.java:
##
@@ -75,6 +75,9 @@ public void writeToFile(Fil
XComp commented on PR #22656:
URL: https://github.com/apache/flink/pull/22656#issuecomment-1597107794
@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.
To
[
https://issues.apache.org/jira/browse/FLINK-26656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-26656.
--
Resolution: Later
> Change/remove mentions of "mode" in Source and Sink documentation
> --
[
https://issues.apache.org/jira/browse/FLINK-28119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-28119.
--
Resolution: Fixed
> Update the document for Contribute Documentation
> ---
[
https://issues.apache.org/jira/browse/FLINK-31801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-31801.
--
Resolution: Fixed
> Missing elasticsearch connector on maven central repository
> ---
[
https://issues.apache.org/jira/browse/FLINK-32198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-32198:
-
Parent: FLINK-32377
Issue Type: Sub-task (was: Bug)
> Enforce single maxExcepti
zentol commented on code in PR #22718:
URL: https://github.com/apache/flink/pull/22718#discussion_r1233971542
##
flink-runtime/src/main/java/org/apache/flink/runtime/execution/librarycache/BlobLibraryCacheManager.java:
##
@@ -391,6 +407,7 @@ private ResolvedClassLoader(
TanYuxin-tyx commented on code in PR #22733:
URL: https://github.com/apache/flink/pull/22733#discussion_r1233875486
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/tier/memory/MemoryTierFactory.java:
##
@@ -28,7 +30,9 @@
import
org.ap
FangYongs commented on code in PR #22718:
URL: https://github.com/apache/flink/pull/22718#discussion_r1233966178
##
flink-runtime/src/main/java/org/apache/flink/runtime/execution/librarycache/LibraryCacheManager.java:
##
@@ -43,9 +43,11 @@ public interface LibraryCacheManager {
[
https://issues.apache.org/jira/browse/FLINK-32357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-32357.
-
Fix Version/s: elasticsearch-3.0.2
Resolution: Fixed
> Elasticsearch v3.0 won't c
1 - 100 of 195 matches
Mail list logo
