FangYongs closed pull request #313: [FLINK-27958] Compare batch maxKey to
reduce comparisons in SortMergeReader
URL: https://github.com/apache/flink-table-store/pull/313
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-30979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30979:
---
Labels: pull-request-available (was: )
> The buckets of the secondary partition should
FangYongs opened a new pull request, #522:
URL: https://github.com/apache/flink-table-store/pull/522
Currently sink operator in flink will shuffle data by bucket id, which cause
data skew when there is only 1 bucket with multiple partitions in the table.
This PR aims to support shuffling
[
https://issues.apache.org/jira/browse/FLINK-31021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687368#comment-17687368
]
Krzysztof Chmielewski commented on FLINK-31021:
---
Hi, i have few questions.
1. Could you
syhily commented on code in PR #24:
URL:
https://github.com/apache/flink-connector-pulsar/pull/24#discussion_r1103520528
##
flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarPartitionSplitReader.java:
##
@@ -231,7 +232,11 @@ public void
syhily commented on code in PR #24:
URL:
https://github.com/apache/flink-connector-pulsar/pull/24#discussion_r1103523033
##
flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumerator.java:
##
@@ -220,11 +223,14 @@ private
syhily commented on code in PR #24:
URL:
https://github.com/apache/flink-connector-pulsar/pull/24#discussion_r1103523033
##
flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumerator.java:
##
@@ -220,11 +223,14 @@ private
syhily commented on code in PR #24:
URL:
https://github.com/apache/flink-connector-pulsar/pull/24#discussion_r1103522744
##
flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumerator.java:
##
@@ -220,11 +223,14 @@ private
syhily commented on code in PR #24:
URL:
https://github.com/apache/flink-connector-pulsar/pull/24#discussion_r1103522426
##
flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceBuilder.java:
##
@@ -619,7 +619,7 @@ private void
syhily commented on code in PR #24:
URL:
https://github.com/apache/flink-connector-pulsar/pull/24#discussion_r1103520528
##
flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarPartitionSplitReader.java:
##
@@ -231,7 +232,11 @@ public void
syhily commented on code in PR #24:
URL:
https://github.com/apache/flink-connector-pulsar/pull/24#discussion_r1103520528
##
flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarPartitionSplitReader.java:
##
@@ -231,7 +232,11 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-30993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30993.
Assignee: Feng Wang
Resolution: Fixed
master: c62992cef568274ec777c2d6e264a12f077b0925
>
[
https://issues.apache.org/jira/browse/FLINK-30992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30992.
Assignee: Feng Wang
Resolution: Fixed
master: f285db56b8a440ef4ef08d15b5a48d58b7c10e01
>
JingsongLi merged PR #511:
URL: https://github.com/apache/flink-table-store/pull/511
--
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:
[
https://issues.apache.org/jira/browse/FLINK-30991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30991.
Resolution: Fixed
master: 430df6c595c229a7128a43c5a1dc831d3f91f905
> Introduce LongSerializer
JingsongLi merged PR #510:
URL: https://github.com/apache/flink-table-store/pull/510
--
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:
JingsongLi merged PR #509:
URL: https://github.com/apache/flink-table-store/pull/509
--
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:
[
https://issues.apache.org/jira/browse/FLINK-31021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui updated FLINK-31021:
Affects Version/s: 1.15.3
> JavaCodeSplitter doesn't split static method properly
>
Xingcan Cui created FLINK-31021:
---
Summary: JavaCodeSplitter doesn't split static method properly
Key: FLINK-31021
URL: https://issues.apache.org/jira/browse/FLINK-31021
Project: Flink
Issue
shuiqiangchen commented on PR #21897:
URL: https://github.com/apache/flink/pull/21897#issuecomment-1426584980
@MartijnVisser Thank you for reminding. It worked after rebasing.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-31003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687347#comment-17687347
]
Shuiqiang Chen edited comment on FLINK-31003 at 2/11/23 2:51 AM:
-
Hi
[
https://issues.apache.org/jira/browse/FLINK-31003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687347#comment-17687347
]
Shuiqiang Chen commented on FLINK-31003:
Hi [~martijnvisser][~weiqinpan], I think it is the same
[
https://issues.apache.org/jira/browse/FLINK-30998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687346#comment-17687346
]
Andriy Redko commented on FLINK-30998:
--
[~lilyevsky] thanks, you could send the pull request to
[
https://issues.apache.org/jira/browse/FLINK-30998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687343#comment-17687343
]
Leonid Ilyevsky commented on FLINK-30998:
-
[~reta] Thanks, please let me know how to submit my
syhily commented on code in PR #24:
URL:
https://github.com/apache/flink-connector-pulsar/pull/24#discussion_r1103481149
##
flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/utils/PulsarTransactionUtils.java:
##
@@ -46,17 +45,18 @@ private
syhily commented on code in PR #24:
URL:
https://github.com/apache/flink-connector-pulsar/pull/24#discussion_r1103481149
##
flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/utils/PulsarTransactionUtils.java:
##
@@ -46,17 +45,18 @@ private
[
https://issues.apache.org/jira/browse/FLINK-31020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omkar Deshpande updated FLINK-31020:
Summary: Read-only mode for Rest API (was: Provide read-only mode for
flink web UI)
>
Omkar Deshpande created FLINK-31020:
---
Summary: Provide read-only mode for flink web UI
Key: FLINK-31020
URL: https://issues.apache.org/jira/browse/FLINK-31020
Project: Flink
Issue Type:
leeoo commented on PR #13081:
URL: https://github.com/apache/flink/pull/13081#issuecomment-1426566305
@libenchao Okay, but I don't have experience in improving Flink framework,
it's better to review it by Flink framework contributors. I will keep an eye on
it and test it with my kafka JSON
[
https://issues.apache.org/jira/browse/FLINK-28283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-28283.
Resolution: Won't Do
[~zlzhang0122], thanks for your reply. Closing this as won't do.
>
syhily commented on code in PR #24:
URL:
https://github.com/apache/flink-connector-pulsar/pull/24#discussion_r1103451369
##
flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/source/cases/MultipleTopicsConsumingContext.java:
##
@@ -56,7 +57,11 @@
syhily commented on code in PR #24:
URL:
https://github.com/apache/flink-connector-pulsar/pull/24#discussion_r1103449916
##
flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/runtime/PulsarRuntimeOperator.java:
##
@@ -80,7 +72,7 @@
import static
libenchao commented on PR #13081:
URL: https://github.com/apache/flink/pull/13081#issuecomment-1426536898
@leeoo Thanks for your interest, I'll rebase the PR the latest master branch
lately, would you please help to review it?
--
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/FLINK-30757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687321#comment-17687321
]
Shipeng Xie edited comment on FLINK-30757 at 2/11/23 12:16 AM:
---
The e2e
[
https://issues.apache.org/jira/browse/FLINK-30757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687321#comment-17687321
]
Shipeng Xie commented on FLINK-30757:
-
The e2e
xshipeng commented on PR #530:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/530#issuecomment-1426506352
It looks like busybox latest (1.36.0) is unstable ->
https://github.com/docker-library/busybox/issues/162
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-30998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687289#comment-17687289
]
Andriy Redko commented on FLINK-30998:
--
[~martijnvisser] [~lilyevsky] sure, happy to help here
>
[
https://issues.apache.org/jira/browse/FLINK-30627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687287#comment-17687287
]
Martijn Visser commented on FLINK-30627:
[~tanyuxin] Could you elaborate on how you would like
[
https://issues.apache.org/jira/browse/FLINK-30757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687284#comment-17687284
]
Shipeng Xie commented on FLINK-30757:
-
Hi [~gyfora] [~gaborgsomogyi], I added the code to print init
[
https://issues.apache.org/jira/browse/FLINK-30757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30757:
---
Labels: pull-request-available starter (was: starter)
> Ugrade busybox version to a pinned
xshipeng opened a new pull request, #530:
URL: https://github.com/apache/flink-kubernetes-operator/pull/530
## What is the purpose of the change
Since [e2e
test](https://github.com/apache/flink-kubernetes-operator/actions/runs/389690/jobs/6662337363)
is flaky with latest
MartijnVisser commented on PR #21897:
URL: https://github.com/apache/flink/pull/21897#issuecomment-1426325867
@shuiqiangchen You need to rebase your PR on the latest changes in `master`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/FLINK-30998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687276#comment-17687276
]
Martijn Visser commented on FLINK-30998:
[~reta] WDYT?
> Add optional exception handler to
[
https://issues.apache.org/jira/browse/FLINK-30971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-30971:
--
Assignee: Yunhong Zheng
> Modify the default value of parameter
>
[
https://issues.apache.org/jira/browse/FLINK-30971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-30971:
---
Fix Version/s: 1.17.0
> Modify the default value of parameter
>
[
https://issues.apache.org/jira/browse/FLINK-30971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-30971:
---
Fix Version/s: (was: 1.17.0)
> Modify the default value of parameter
>
[
https://issues.apache.org/jira/browse/FLINK-31006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687275#comment-17687275
]
Martijn Visser commented on FLINK-31006:
[~renqs] WDYT?
> job is not finished when using
[
https://issues.apache.org/jira/browse/FLINK-31007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687274#comment-17687274
]
Martijn Visser commented on FLINK-31007:
[~lincoln.86xy] WDYT?
> The code generated by the IF
MartijnVisser commented on PR #21630:
URL: https://github.com/apache/flink/pull/21630#issuecomment-1426319887
@gaoyunhaii Can you take one more look? You've already reviewed the original
PR, which missed one thing that is now addressed in this PR.
--
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-30627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-30627:
---
Description:
{{FileSystemTableSink}} currently depends on most of the capabilities from
[
https://issues.apache.org/jira/browse/FLINK-31019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-31019.
--
Resolution: Duplicate
> Migrate FileSystemTableSink to FileSink
>
Martijn Visser created FLINK-31019:
--
Summary: Migrate FileSystemTableSink to FileSink
Key: FLINK-31019
URL: https://issues.apache.org/jira/browse/FLINK-31019
Project: Flink
Issue Type:
reta commented on code in PR #5:
URL:
https://github.com/apache/flink-connector-opensearch/pull/5#discussion_r1103191251
##
.github/workflows/push_pr.yml:
##
@@ -25,6 +25,6 @@ jobs:
compile_and_test:
uses:
reta commented on PR #5:
URL:
https://github.com/apache/flink-connector-opensearch/pull/5#issuecomment-1426283511
Thanks @dannycranmer , I think I went through all your comments, thanks a
lot, really appreciate it.
--
This is an automated message from the Apache Git Service.
To respond
dannycranmer commented on PR #7:
URL:
https://github.com/apache/flink-connector-opensearch/pull/7#issuecomment-1426268450
Thanks @reta
--
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
dannycranmer merged PR #7:
URL: https://github.com/apache/flink-connector-opensearch/pull/7
--
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:
flinkbot commented on PR #21911:
URL: https://github.com/apache/flink/pull/21911#issuecomment-1426267913
## CI report:
* cee862b208cfd3674f6cbcd64d07e7f7c871253b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-19065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19065:
---
Labels: auto-deprioritized-major auto-deprioritized-minor
pull-request-available (was:
hmit opened a new pull request, #21911:
URL: https://github.com/apache/flink/pull/21911
## What is the purpose of the change
This fixes issue when flink job using join/cogroup is run with
autoGenerateUid disabled. With uid generation disabled, the input ->
map-for-union
mxm commented on code in PR #21908:
URL: https://github.com/apache/flink/pull/21908#discussion_r1103096757
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotSharingSlotAllocator.java:
##
@@ -133,7 +138,56 @@ public Optional
mxm commented on code in PR #21908:
URL: https://github.com/apache/flink/pull/21908#discussion_r1103092025
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotSharingSlotAllocator.java:
##
@@ -133,7 +138,56 @@ public Optional
mxm commented on code in PR #21908:
URL: https://github.com/apache/flink/pull/21908#discussion_r1103091640
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotSharingSlotAllocator.java:
##
@@ -133,7 +138,56 @@ public Optional
reta commented on code in PR #5:
URL:
https://github.com/apache/flink-connector-opensearch/pull/5#discussion_r1103088811
##
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchAsyncWriter.java:
##
@@ -0,0 +1,308 @@
+/*
+ * Licensed to
reta commented on code in PR #5:
URL:
https://github.com/apache/flink-connector-opensearch/pull/5#discussion_r1103068913
##
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/DocSerdeRequest.java:
##
@@ -0,0 +1,107 @@
+/*
+ * Licensed to the
mxm commented on code in PR #529:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/529#discussion_r1103083946
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/JobAutoscalerFactoryImpl.java:
##
@@ -0,0 +1,41 @@
mxm commented on code in PR #529:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/529#discussion_r1103083946
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/JobAutoscalerFactoryImpl.java:
##
@@ -0,0 +1,41 @@
reta commented on code in PR #5:
URL:
https://github.com/apache/flink-connector-opensearch/pull/5#discussion_r1103068913
##
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/DocSerdeRequest.java:
##
@@ -0,0 +1,107 @@
+/*
+ * Licensed to the
reta commented on code in PR #5:
URL:
https://github.com/apache/flink-connector-opensearch/pull/5#discussion_r1103066160
##
.github/workflows/push_pr.yml:
##
@@ -25,4 +25,4 @@ jobs:
compile_and_test:
uses:
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1101701294
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/CassandraSplitState.java:
##
@@ -0,0 +1,66 @@
+/*
+ *
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1101601871
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/SplitsGenerator.java:
##
@@ -0,0 +1,110 @@
+/*
+ * Licensed
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1100252874
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/reader/CassandraSplitReader.java:
##
@@ -0,0 +1,309 @@
+/*
+ *
reta opened a new pull request, #7:
URL: https://github.com/apache/flink-connector-opensearch/pull/7
Update Apache Flink to 1.16.1
--
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
[
https://issues.apache.org/jira/browse/FLINK-31018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687220#comment-17687220
]
Martijn Visser commented on FLINK-31018:
Great to hear that fixes it, thanks for updating it!
>
[
https://issues.apache.org/jira/browse/FLINK-31018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687218#comment-17687218
]
Krzysztof Chmielewski edited comment on FLINK-31018 at 2/10/23 5:39 PM:
[
https://issues.apache.org/jira/browse/FLINK-31018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krzysztof Chmielewski closed FLINK-31018.
-
Resolution: Not A Bug
> SQL Client -j option does not load user jars to
[
https://issues.apache.org/jira/browse/FLINK-31018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687218#comment-17687218
]
Krzysztof Chmielewski commented on FLINK-31018:
---
[~martijnvisser] yes it seemt that this
dannycranmer commented on code in PR #5:
URL:
https://github.com/apache/flink-connector-opensearch/pull/5#discussion_r1102989699
##
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/DocSerdeRequest.java:
##
@@ -0,0 +1,107 @@
+/*
+ * Licensed
wanglijie95 commented on PR #21813:
URL: https://github.com/apache/flink/pull/21813#issuecomment-1426056540
Thanks @noahshpak @reswqa, 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 to the
[
https://issues.apache.org/jira/browse/FLINK-31003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687149#comment-17687149
]
weiqinpan edited comment on FLINK-31003 at 2/10/23 4:20 PM:
The value of
wanglijie95 merged PR #21813:
URL: https://github.com/apache/flink/pull/21813
--
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:
[
https://issues.apache.org/jira/browse/FLINK-31003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687149#comment-17687149
]
weiqinpan commented on FLINK-31003:
---
The field of marketing_flow_id is not null, but the result of
zekai-li commented on PR #21675:
URL: https://github.com/apache/flink/pull/21675#issuecomment-1426034122
--
This is an automated message from the Apache Git Service.
To
zekai-li commented on PR #21675:
URL: https://github.com/apache/flink/pull/21675#issuecomment-1426032058
> The compile build failed. Could you fix it first?
The compilation error has been fixed
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687143#comment-17687143
]
Piotr Nowojski commented on FLINK-29825:
Yes, that's a good idea :)
> Improve benchmark
[
https://issues.apache.org/jira/browse/FLINK-31003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687120#comment-17687120
]
Martijn Visser commented on FLINK-31003:
[~lincoln.86xy] WDYT?
> Flink SQL IF / CASE WHEN
[
https://issues.apache.org/jira/browse/FLINK-31017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687118#comment-17687118
]
Martijn Visser commented on FLINK-31017:
[~Juntao Hu] Are you committing to fixing this in 1.18?
[
https://issues.apache.org/jira/browse/FLINK-31018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687117#comment-17687117
]
Martijn Visser commented on FLINK-31018:
[~KristoffSC] Could this be related to FLINK-15635 ?
>
[
https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687116#comment-17687116
]
Dong Lin commented on FLINK-29825:
--
Thanks [~Yanfei Lei] for the detailed evaluation results! Maybe we
Krzysztof Chmielewski created FLINK-31018:
-
Summary: SQL Client -j option does not load user jars to classpath.
Key: FLINK-31018
URL: https://issues.apache.org/jira/browse/FLINK-31018
Project:
[
https://issues.apache.org/jira/browse/FLINK-30998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687111#comment-17687111
]
Leonid Ilyevsky commented on FLINK-30998:
-
This morning I successfully tested my solution. The
[
https://issues.apache.org/jira/browse/FLINK-28911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes closed FLINK-28911.
Resolution: Won't Fix
> Elasticsearch connector fails build
> ---
[
https://issues.apache.org/jira/browse/FLINK-18235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-18235:
--
Assignee: (was: Dian Fu)
> Improve the checkpoint strategy for Python UDF
[
https://issues.apache.org/jira/browse/FLINK-18235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-18235:
---
Priority: Not a Priority (was: Major)
> Improve the checkpoint strategy for Python UDF
[
https://issues.apache.org/jira/browse/FLINK-18235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687102#comment-17687102
]
Piotr Nowojski commented on FLINK-18235:
[~dianfu], may I ask if you have considered
[
https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687098#comment-17687098
]
Piotr Nowojski commented on FLINK-29825:
Thanks a lot for the very detailed comparison [~Yanfei
XComp commented on code in PR #19970:
URL: https://github.com/apache/flink/pull/19970#discussion_r1102841851
##
flink-formats/flink-hadoop-bulk/archunit-violations/db4de53e-d09e-4fb0-bdbc-429c1b64686f:
##
@@ -0,0 +1,12 @@
Juntao Hu created FLINK-31017:
-
Summary: Early-started partial match timeout not yield completed
matches
Key: FLINK-31017
URL: https://issues.apache.org/jira/browse/FLINK-31017
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-23016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687090#comment-17687090
]
Krzysztof Chmielewski commented on FLINK-23016:
---
FYI,
got the same error on Flink 1.16.1
wanglijie95 commented on PR #21813:
URL: https://github.com/apache/flink/pull/21813#issuecomment-1425854545
@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
[
https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687082#comment-17687082
]
Yanfei Lei commented on FLINK-29825:
[~pnowojski] I tried to use hunter to detect regression, and
1 - 100 of 220 matches
Mail list logo
