senlizishi closed pull request #19800: [docs]update User-defined Sources &
Sinks document
URL: https://github.com/apache/flink/pull/19800
--
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 specifi
KinoMin commented on PR #22103:
URL: https://github.com/apache/flink/pull/22103#issuecomment-1499971995
We are still using flink1.12, what should I do for this pr I want to use in
1.12, I try to merge this pr in 1.12, and find that the difference is too big
and it is difficult to merge, if
[
https://issues.apache.org/jira/browse/FLINK-28528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709597#comment-17709597
]
Dian Fu commented on FLINK-28528:
-
The exception happens when converting TableSchema to
[
https://issues.apache.org/jira/browse/FLINK-28528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709595#comment-17709595
]
Dian Fu commented on FLINK-28528:
-
The root cause is that currently table.get_schema() o
[
https://issues.apache.org/jira/browse/FLINK-28528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709591#comment-17709591
]
Dian Fu commented on FLINK-28528:
-
A similar issue reported in slack channel:
https://a
nateab commented on code in PR #22359:
URL: https://github.com/apache/flink/pull/22359#discussion_r1160430061
##
flink-table/flink-table-planner/pom.xml:
##
@@ -301,6 +301,13 @@ under the License.
${project.version}
test
[
https://issues.apache.org/jira/browse/FLINK-31628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709583#comment-17709583
]
Lijie Wang commented on FLINK-31628:
This problem may occur when the source configur
[
https://issues.apache.org/jira/browse/FLINK-31628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709580#comment-17709580
]
Lijie Wang edited comment on FLINK-31628 at 4/7/23 4:32 AM:
[
https://issues.apache.org/jira/browse/FLINK-31628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang updated FLINK-31628:
---
Fix Version/s: 1.18.0
1.17.1
> ArrayIndexOutOfBoundsException in watermark proces
[
https://issues.apache.org/jira/browse/FLINK-31628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709581#comment-17709581
]
Lijie Wang commented on FLINK-31628:
We should check if the channel is in the heap b
[
https://issues.apache.org/jira/browse/FLINK-31628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang reassigned FLINK-31628:
--
Assignee: Lijie Wang
> ArrayIndexOutOfBoundsException in watermark processing
> -
[
https://issues.apache.org/jira/browse/FLINK-31628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709580#comment-17709580
]
Lijie Wang commented on FLINK-31628:
This is caused by FLINK-30544, in which we intr
[
https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709578#comment-17709578
]
Weijie Guo commented on FLINK-27925:
Hi [~huwh].
AFAIK, This PR is waiting for revi
[
https://issues.apache.org/jira/browse/FLINK-31447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31447:
---
Fix Version/s: 1.18.0
> Aligning unit tests of FineGrainedSlotManager with DeclarativeSlotManager
>
[
https://issues.apache.org/jira/browse/FLINK-31447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-31447.
Resolution: Fixed
master(1.18) via 69131d29497fadf5ca55532ff0f7ed55c5e72c73.
> Aligning unit test
[
https://issues.apache.org/jira/browse/FLINK-31447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-31447.
--
> Aligning unit tests of FineGrainedSlotManager with DeclarativeSlotManager
>
[
https://issues.apache.org/jira/browse/FLINK-31447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31447:
---
Affects Version/s: 1.18.0
> Aligning unit tests of FineGrainedSlotManager with DeclarativeSlotManage
reswqa closed pull request #22306: [FLINK-31447][runtime] Aligning unit tests
of FineGrainedSlotManager with DeclarativeSlotManager
URL: https://github.com/apache/flink/pull/22306
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
[
https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709567#comment-17709567
]
Weihua Hu commented on FLINK-27925:
---
Hi [~ouyangwulin] . Are you still working on this
haishui126 commented on code in PR #22291:
URL: https://github.com/apache/flink/pull/22291#discussion_r1160405755
##
flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java:
##
@@ -178,9 +178,16 @@ void announceCombinedWatermark() {
nateab commented on code in PR #22359:
URL: https://github.com/apache/flink/pull/22359#discussion_r1160403337
##
flink-table/flink-table-planner/pom.xml:
##
@@ -301,6 +301,13 @@ under the License.
${project.version}
test
[
https://issues.apache.org/jira/browse/FLINK-30989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708930#comment-17708930
]
Weijie Guo edited comment on FLINK-30989 at 4/7/23 3:05 AM:
[
https://issues.apache.org/jira/browse/FLINK-30989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-30989.
--
Resolution: Fixed
> Configuration table.exec.spill-compression.block-size not take effect in
> batch
pltbkd commented on code in PR #22291:
URL: https://github.com/apache/flink/pull/22291#discussion_r1160398514
##
flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java:
##
@@ -178,9 +178,16 @@ void announceCombinedWatermark() {
ZhengYi Weng created FLINK-31750:
Summary: Hash Keys are duplicate when join reorder happens in
stream mode
Key: FLINK-31750
URL: https://issues.apache.org/jira/browse/FLINK-31750
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-31593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709549#comment-17709549
]
Yanfei Lei commented on FLINK-31593:
[~roman]
> It was likely generated during chan
[
https://issues.apache.org/jira/browse/FLINK-31749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
junzhong qin updated FLINK-31749:
-
Description:
The following example shows how to use Hadoop’s {{TextOutputFormat from the
doc:
nateab commented on code in PR #22359:
URL: https://github.com/apache/flink/pull/22359#discussion_r1160394865
##
flink-table/flink-table-planner/pom.xml:
##
@@ -301,6 +301,13 @@ under the License.
${project.version}
test
junzhong qin created FLINK-31749:
Summary: The Using Hadoop OutputFormats example is not avaliable
for DataStream
Key: FLINK-31749
URL: https://issues.apache.org/jira/browse/FLINK-31749
Project: Flink
jiangxin369 commented on PR #229:
URL: https://github.com/apache/flink-ml/pull/229#issuecomment-1499866189
@zhipeng93 Could you help review this PR? And I have no idea why the
workflow needs additional approval to run in this PR, could you help approve
the workflow running?
--
This is a
Zili Chen created FLINK-31748:
-
Summary: Adapt SplitFetcherManager#removeSplit for
flink-connector-pulsar
Key: FLINK-31748
URL: https://issues.apache.org/jira/browse/FLINK-31748
Project: Flink
I
nateab commented on code in PR #22359:
URL: https://github.com/apache/flink/pull/22359#discussion_r1160388987
##
flink-table/flink-table-planner/pom.xml:
##
@@ -301,6 +301,13 @@ under the License.
${project.version}
test
haishui126 commented on code in PR #22291:
URL: https://github.com/apache/flink/pull/22291#discussion_r1160388130
##
flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java:
##
@@ -178,9 +178,16 @@ void announceCombinedWatermark() {
flinkbot commented on PR #22367:
URL: https://github.com/apache/flink/pull/22367#issuecomment-1499860845
## CI report:
* 5432ca4507169c8e39f19d7e7aa741002ab7fd7e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27144:
---
Labels: pull-request-available (was: )
> Provide timeout details when calling FutureUtils.o
wanglijie95 opened a new pull request, #22367:
URL: https://github.com/apache/flink/pull/22367
## What is the purpose of the change
Currently, there are two versions of FutureUtils.orTimeout() that use null
as an error message when the timeout happens. This makes it difficult to debug
boring-cyborg[bot] commented on PR #42:
URL:
https://github.com/apache/flink-connector-pulsar/pull/42#issuecomment-1499824593
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
tisonkun merged PR #42:
URL: https://github.com/apache/flink-connector-pulsar/pull/42
--
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...
tisonkun commented on PR #42:
URL:
https://github.com/apache/flink-connector-pulsar/pull/42#issuecomment-1499824519
Merging...
It seems the daily CI always failed on compilation now. Let me take a look..
--
This is an automated message from the Apache Git Service.
To respond to the
yangjf2019 commented on PR #22274:
URL: https://github.com/apache/flink/pull/22274#issuecomment-1499816668
@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
tzulitai closed pull request #16: [FLINK-30859] Externalize confluent avro
related code
URL: https://github.com/apache/flink-connector-kafka/pull/16
--
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 t
tzulitai commented on PR #9:
URL:
https://github.com/apache/flink-connector-kafka/pull/9#issuecomment-1499758433
I'm not so sure we should merge this.
I believe we want to always develop against the latest stable Flink version,
even in `main` branch.
For example in `main` right no
tzulitai commented on code in PR #16:
URL:
https://github.com/apache/flink-connector-kafka/pull/16#discussion_r1160329477
##
flink-confluent-schema-registry-e2e-tests/pom.xml:
##
@@ -0,0 +1,136 @@
+
+http://maven.apache.org/POM/4.0.0";
+xmlns:xsi="http://www.w3.
[
https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709522#comment-17709522
]
Tzu-Li (Gordon) Tai commented on FLINK-25916:
-
Merged to apache/flink-connec
[
https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-25916:
Fix Version/s: kafka-3.0.0
> Using upsert-kafka with a flush buffer results in Nul
tzulitai closed pull request #5: [FLINK-25916][connector-kafka] Using
upsert-kafka with a flush buffer…
URL: https://github.com/apache/flink-connector-kafka/pull/5
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
mas-chen commented on code in PR #16:
URL:
https://github.com/apache/flink-connector-kafka/pull/16#discussion_r1160320646
##
flink-formats-kafka/flink-json-debezium/pom.xml:
##
@@ -0,0 +1,141 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSche
mas-chen commented on code in PR #16:
URL:
https://github.com/apache/flink-connector-kafka/pull/16#discussion_r1160320646
##
flink-formats-kafka/flink-json-debezium/pom.xml:
##
@@ -0,0 +1,141 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSche
Mason Chen created FLINK-31747:
--
Summary: Externalize debezium from flink-json
Key: FLINK-31747
URL: https://issues.apache.org/jira/browse/FLINK-31747
Project: Flink
Issue Type: Improvement
RamanVerma commented on code in PR #20:
URL:
https://github.com/apache/flink-connector-kafka/pull/20#discussion_r1160275482
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReaderTest.java:
##
@@ -319,6 +321,51 @@ public v
RamanVerma commented on code in PR #20:
URL:
https://github.com/apache/flink-connector-kafka/pull/20#discussion_r1160264888
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java:
##
@@ -80,11 +80,20 @@ public KafkaP
tzulitai commented on code in PR #18:
URL:
https://github.com/apache/flink-connector-kafka/pull/18#discussion_r1160175017
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/HeaderProducer.java:
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache Softwar
[
https://issues.apache.org/jira/browse/FLINK-31746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709484#comment-17709484
]
Martijn Visser commented on FLINK-31746:
[~functioner] Please let us know what t
tzulitai commented on code in PR #16:
URL:
https://github.com/apache/flink-connector-kafka/pull/16#discussion_r1160139972
##
flink-formats-kafka/flink-json-debezium/pom.xml:
##
@@ -0,0 +1,141 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSche
tzulitai commented on code in PR #16:
URL:
https://github.com/apache/flink-connector-kafka/pull/16#discussion_r1160139972
##
flink-formats-kafka/flink-json-debezium/pom.xml:
##
@@ -0,0 +1,141 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSche
[
https://issues.apache.org/jira/browse/FLINK-31746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haoze Wu updated FLINK-31746:
-
Description:
We are doing testing on Flink-1.14.0 (We know 1.14.0 is not supported now so we
are also t
Haoze Wu created FLINK-31746:
Summary: Batch workload output completes while the job client fails
Key: FLINK-31746
URL: https://issues.apache.org/jira/browse/FLINK-31746
Project: Flink
Issue Type
zentol commented on code in PR #16:
URL:
https://github.com/apache/flink-connector-kafka/pull/16#discussion_r1160135014
##
flink-formats-kafka/flink-json-debezium/pom.xml:
##
@@ -0,0 +1,141 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema
tzulitai closed pull request #23: [hotfix] Update NOTICE files to reflect year
2023
URL: https://github.com/apache/flink-connector-kafka/pull/23
--
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 s
HuangZhenQiu commented on code in PR #22298:
URL: https://github.com/apache/flink/pull/22298#discussion_r1160103711
##
flink-runtime/src/main/java/org/apache/flink/runtime/security/token/DefaultDelegationTokenManager.java:
##
@@ -213,6 +213,20 @@ public void
obtainDelegationTok
reta commented on code in PR #16:
URL:
https://github.com/apache/flink-connector-opensearch/pull/16#discussion_r1160093049
##
.github/workflows/weekly.yml:
##
@@ -26,7 +26,7 @@ jobs:
if: github.repository_owner == 'apache'
strategy:
matrix:
-flink: [1.1
[
https://issues.apache.org/jira/browse/FLINK-31717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi reassigned FLINK-31717:
--
Assignee: Mate Czagany (was: Matyas Orhidi)
> Unit tests running with local kube con
flinkbot commented on PR #22366:
URL: https://github.com/apache/flink/pull/22366#issuecomment-1499317476
## CI report:
* af31921182b351ba1a50629f82f998933f1aa427 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #22365:
URL: https://github.com/apache/flink/pull/22365#issuecomment-1499317260
## CI report:
* c11af68e7aa448a62ef168c075fcdb72a597541e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
darenwkt commented on PR #22366:
URL: https://github.com/apache/flink/pull/22366#issuecomment-1499316939


![Screenshot 2023-04-06 at 17-10-29
D
darenwkt opened a new pull request, #22365:
URL: https://github.com/apache/flink/pull/22365
…into Flink docs
## What is the purpose of the change
Integrate Opensearch docs into Flink docs for Flink 1.16
## Brief change log
- See comment for pages changed
[
https://issues.apache.org/jira/browse/FLINK-31740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709440#comment-17709440
]
Tzu-Li (Gordon) Tai commented on FLINK-31740:
-
Fix via fc31198d864ebafd36cf2
[
https://issues.apache.org/jira/browse/FLINK-31740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-31740:
Fix Version/s: kafka-4.1.0
> Allow setting boundedness for upsert-kafka SQL connec
tzulitai closed pull request #22: [FLINK-31740] [upsert-kafka] Allows setting
boundedness for SQL Upsert Kafka Connector
URL: https://github.com/apache/flink-connector-kafka/pull/22
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
tzulitai commented on PR #22:
URL:
https://github.com/apache/flink-connector-kafka/pull/22#issuecomment-1499280862
Thank you for the review @Ge @dawidwys! Merging this ...
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
[
https://issues.apache.org/jira/browse/FLINK-31735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-31735.
Resolution: Fixed
master: 8ee66535879ce90882f0320b0c0d8ab7ef44ed37
1.17: a70554b51a4f73527
zentol merged PR #22357:
URL: https://github.com/apache/flink/pull/22357
--
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-30844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709423#comment-17709423
]
Anton Kalashnikov commented on FLINK-30844:
---
In conclusion, I haven't found an
[
https://issues.apache.org/jira/browse/FLINK-30844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Kalashnikov closed FLINK-30844.
-
Resolution: Fixed
> TaskTest.testInterruptibleSharedLockInInvokeAndCancel causes a JVM s
MartijnVisser commented on code in PR #16:
URL:
https://github.com/apache/flink-connector-opensearch/pull/16#discussion_r1159923772
##
.github/workflows/weekly.yml:
##
@@ -26,7 +26,7 @@ jobs:
if: github.repository_owner == 'apache'
strategy:
matrix:
-fl
[
https://issues.apache.org/jira/browse/FLINK-31733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-31733.
Resolution: Fixed
master:
76d1a4678c383a927caf596ee594ba0ae5b5e1df
dcca520cb47a22354301174
[
https://issues.apache.org/jira/browse/FLINK-30844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Kalashnikov updated FLINK-30844:
--
Fix Version/s: 1.17.1
> TaskTest.testInterruptibleSharedLockInInvokeAndCancel causes a
akalash merged PR #22354:
URL: https://github.com/apache/flink/pull/22354
--
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.apach
zentol merged PR #22355:
URL: https://github.com/apache/flink/pull/22355
--
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
reta commented on code in PR #16:
URL:
https://github.com/apache/flink-connector-opensearch/pull/16#discussion_r1159891707
##
.github/workflows/weekly.yml:
##
@@ -26,7 +26,7 @@ jobs:
if: github.repository_owner == 'apache'
strategy:
matrix:
-flink: [1.1
[
https://issues.apache.org/jira/browse/FLINK-31722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31722:
---
Labels: pull-request-available (was: )
> Remove dependency on flink-shaded
> --
echauchot opened a new pull request, #7:
URL: https://github.com/apache/flink-connector-cassandra/pull/7
R: @zentol
--
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 unsu
[
https://issues.apache.org/jira/browse/FLINK-31593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709396#comment-17709396
]
Matthias Pohl commented on FLINK-31593:
---
[~Yanfei Lei] Roman has a point with temp
MartijnVisser commented on PR #57:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/57#issuecomment-1499113198
> Thanks @MartijnVisser for the sync~
Thank you for the PR!
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-31739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-31739.
--
Resolution: Fixed
Elasticsearch v3.0: 57e7883e270b1e3d5814bf52e808ce6099e45481
Cassandra v3.0:
MartijnVisser merged PR #57:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/57
--
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
Martijn Visser created FLINK-31745:
--
Summary: Performance regression on serializerHeavyString since
April 3rd
Key: FLINK-31745
URL: https://issues.apache.org/jira/browse/FLINK-31745
Project: Flink
flinkbot commented on PR #22364:
URL: https://github.com/apache/flink/pull/22364#issuecomment-1499063492
## CI report:
* 6109c840dde0f7a435d5076081c651d901272704 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
mendansandesh opened a new pull request, #629:
URL: https://github.com/apache/flink-web/pull/629
- removed duplicate word
- some english grammar/formatting fix
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-31744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31744:
---
Labels: pull-request-available (was: )
> Extend Adaptive Scheduler sparse EG to contain max
reswqa commented on PR #57:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/57#issuecomment-1499055091
Thanks @MartijnVisser for the sync~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
zentol opened a new pull request, #22364:
URL: https://github.com/apache/flink/pull/22364
Include all JobVertex-level information in the sparse execution graph,
created by the Adaptive Scheduler when in the WaitingForResources state, like
the vertex id/name and the maxParallelism.
Th
Chesnay Schepler created FLINK-31744:
Summary: Extend Adaptive Scheduler sparse EG to contain
maxParallelism
Key: FLINK-31744
URL: https://issues.apache.org/jira/browse/FLINK-31744
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-31728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-31728.
Resolution: Fixed
master: 0415f7d1f9f32f93cbafa1000f1a33d66b06e1d1
> Remove Scala API dep
zentol merged PR #22349:
URL: https://github.com/apache/flink/pull/22349
--
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-31233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709369#comment-17709369
]
Weihua Hu commented on FLINK-31233:
---
[~xtsong] Could you take a look at this
> no err
[
https://issues.apache.org/jira/browse/FLINK-31529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709367#comment-17709367
]
Weihua Hu commented on FLINK-31529:
---
[~xtsong] Could you take a look at this
> Let ya
boring-cyborg[bot] commented on PR #6:
URL:
https://github.com/apache/flink-connector-cassandra/pull/6#issuecomment-1499006407
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
1 - 100 of 184 matches
Mail list logo