[
https://issues.apache.org/jira/browse/FLINK-31808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li closed FLINK-31808.
--
Fix Version/s: 1.18.0
Resolution: Fixed
Fixed via
[
https://issues.apache.org/jira/browse/FLINK-31808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li reassigned FLINK-31808:
--
Assignee: Weihua Hu
> wrong examples of how to set operator name in documents
>
libenchao closed pull request #22401: [FLINK-31808][docs] fix wrong examples of
how to set operator name in documents
URL: https://github.com/apache/flink/pull/22401
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
noomanee commented on PR #22400:
URL: https://github.com/apache/flink/pull/22400#issuecomment-1509476169
@luoyuxia Could you help review? I see that the CI is in failure state. Do
you have any advices?
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-31811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712595#comment-17712595
]
jirawech.s commented on FLINK-31811:
[~KristoffSC] I see. It may be duplicated issue, yet i see
MartijnVisser commented on PR #40:
URL:
https://github.com/apache/flink-connector-jdbc/pull/40#issuecomment-1509098543
> Do you mean we need to shade some class of the Guava dependency in the
pom? Currently there is a shade plugin but nothing is shaded.
Yes indeed. So that it's not
[
https://issues.apache.org/jira/browse/FLINK-31772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31772:
---
Labels: pull-request-available (was: )
> AsyncSinkWriter Performance regression due to
vahmed-hamdy opened a new pull request, #70:
URL: https://github.com/apache/flink-connector-aws/pull/70
## Purpose of the change
*For example: Implements the Table API for the Kinesis Source.*
## Verifying this change
Please make sure both new and
boring-cyborg[bot] commented on PR #70:
URL:
https://github.com/apache/flink-connector-aws/pull/70#issuecomment-1508997457
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is an
tzulitai commented on code in PR #22291:
URL: https://github.com/apache/flink/pull/22291#discussion_r1167082068
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/SourceOperatorAlignmentTest.java:
##
@@ -160,13 +160,18 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-31632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712464#comment-17712464
]
Tzu-Li (Gordon) Tai commented on FLINK-31632:
-
Hey [~haishui], I'm currently taking a look
tzulitai commented on PR #632:
URL: https://github.com/apache/flink-web/pull/632#issuecomment-1508912728
> If I may ask, is it right that this release will not be compatible with
Flink 1.16.x?
@asardaes correct, this release is initially compatible with Flink 1.17.x
only.
--
This
reswqa commented on PR #22381:
URL: https://github.com/apache/flink/pull/22381#issuecomment-1508885180
All commits have been squashed, merged % AZP green.
--
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
reswqa commented on PR #22381:
URL: https://github.com/apache/flink/pull/22381#issuecomment-1508782160
Thanks @akalash for the review! I have squash all previous commits and
revert the changes in `hasExcessBuffers ` and `isRequestedSizeReached` in a
fix-up commit, PTAL.
--
This is an
reswqa commented on code in PR #22381:
URL: https://github.com/apache/flink/pull/22381#discussion_r1166961006
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java:
##
@@ -766,13 +776,12 @@ private void returnExcessMemorySegments() {
reswqa commented on code in PR #22381:
URL: https://github.com/apache/flink/pull/22381#discussion_r1166952794
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java:
##
@@ -766,13 +776,12 @@ private void returnExcessMemorySegments() {
vahmed-hamdy commented on code in PR #65:
URL:
https://github.com/apache/flink-connector-aws/pull/65#discussion_r1166947224
##
flink-connector-aws-kinesis-streams/src/test/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkITCase.java:
##
@@ -343,18 +344,21 @@ void
vahmed-hamdy commented on code in PR #65:
URL:
https://github.com/apache/flink-connector-aws/pull/65#discussion_r1166944534
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSink.java:
##
@@ -89,13 +92,23 @@
[
https://issues.apache.org/jira/browse/FLINK-31802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712430#comment-17712430
]
Sergey Nuyanzin commented on FLINK-31802:
-
//cc [~jark] , [~hxbks2ks]
> Python py37-cython:
[
https://issues.apache.org/jira/browse/FLINK-31802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-31802:
Description:
{noformat}
Apr 06 05:55:13 ___ summary
[
https://issues.apache.org/jira/browse/FLINK-31802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-31802:
Summary: Python py37-cython: commands failed, error at setup of
[
https://issues.apache.org/jira/browse/FLINK-31802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-31802:
Description:
{noformat}
Apr 06 05:55:13 ___ summary
echauchot opened a new pull request, #643:
URL: https://github.com/apache/flink-web/pull/643
Last article of the series about testing the created batch source in the
previous article.
R:@zentol. Feel free to delegate as you have already the previous 2 articles
to review.
--
[
https://issues.apache.org/jira/browse/FLINK-31811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712410#comment-17712410
]
Krzysztof Chmielewski edited comment on FLINK-31811 at 4/14/23 2:18 PM:
[
https://issues.apache.org/jira/browse/FLINK-31811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712390#comment-17712390
]
Krzysztof Chmielewski edited comment on FLINK-31811 at 4/14/23 2:18 PM:
[
https://issues.apache.org/jira/browse/FLINK-31811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712410#comment-17712410
]
Krzysztof Chmielewski edited comment on FLINK-31811 at 4/14/23 2:17 PM:
[
https://issues.apache.org/jira/browse/FLINK-31811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712410#comment-17712410
]
Krzysztof Chmielewski commented on FLINK-31811:
---
[~jirawech.s] I've pasted a wrong ticket
[
https://issues.apache.org/jira/browse/FLINK-31811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712390#comment-17712390
]
Krzysztof Chmielewski edited comment on FLINK-31811 at 4/14/23 2:16 PM:
[
https://issues.apache.org/jira/browse/FLINK-31811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712390#comment-17712390
]
Krzysztof Chmielewski edited comment on FLINK-31811 at 4/14/23 2:15 PM:
kingsathurthi commented on PR #552:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/552#issuecomment-1508585990
can you take over if itis compatability issue?
--
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-31811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712400#comment-17712400
]
jirawech.s commented on FLINK-31811:
[~KristoffSC] I guess what you mentioned is parquet reader. I
[
https://issues.apache.org/jira/browse/FLINK-30852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Kalashnikov closed FLINK-30852.
-
Fix Version/s: 1.17.1
Resolution: Fixed
>
[
https://issues.apache.org/jira/browse/FLINK-30852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712398#comment-17712398
]
Anton Kalashnikov commented on FLINK-30852:
---
merged to master: a6f0165c
>
[
https://issues.apache.org/jira/browse/FLINK-31812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nicolas Fraison updated FLINK-31812:
Description:
Since https://issues.apache.org/jira/browse/FLINK-29543 the
savepointPath
akalash merged PR #21833:
URL: https://github.com/apache/flink/pull/21833
--
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:
akalash commented on code in PR #21833:
URL: https://github.com/apache/flink/pull/21833#discussion_r1166866708
##
flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskTest.java:
##
@@ -1300,9 +1304,7 @@ public TestInvokableCorrect(Environment environment) {
akalash commented on code in PR #22381:
URL: https://github.com/apache/flink/pull/22381#discussion_r1166841760
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java:
##
@@ -766,13 +776,12 @@ private void returnExcessMemorySegments() {
echauchot commented on code in PR #631:
URL: https://github.com/apache/flink-web/pull/631#discussion_r1166772518
##
docs/content/posts/2023-04-12-howto-migrate-to-datastream.md:
##
@@ -0,0 +1,190 @@
+---
+title: "Howto migrate a real-life batch pipeline from the DataSet API to
echauchot commented on code in PR #631:
URL: https://github.com/apache/flink-web/pull/631#discussion_r1166855536
##
docs/content/posts/2023-04-12-howto-migrate-to-datastream.md:
##
@@ -0,0 +1,190 @@
+---
+title: "Howto migrate a real-life batch pipeline from the DataSet API to
[
https://issues.apache.org/jira/browse/FLINK-31811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712390#comment-17712390
]
Krzysztof Chmielewski commented on FLINK-31811:
---
I think this might be a duplicate of
Hong Liang Teoh created FLINK-31813:
---
Summary: Initial implementation of Kinesis Source using FLIP-27
Key: FLINK-31813
URL: https://issues.apache.org/jira/browse/FLINK-31813
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-31812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nicolas Fraison updated FLINK-31812:
Summary: SavePoint from /jars/:jarid:/run api on body is not anymore set to
null if empty
Nicolas Fraison created FLINK-31812:
---
Summary: SavePoint from /jars/:jarid:/run api on body is not
anymore emptyToNull if empty
Key: FLINK-31812
URL: https://issues.apache.org/jira/browse/FLINK-31812
jirawech.s created FLINK-31811:
--
Summary: Unsupported complex data type for Flink SQL
Key: FLINK-31811
URL: https://issues.apache.org/jira/browse/FLINK-31811
Project: Flink
Issue Type: Bug
echauchot commented on code in PR #641:
URL: https://github.com/apache/flink-web/pull/641#discussion_r1166797078
##
docs/content/posts/2023-04-13-howto-create-batch-source.md:
##
@@ -0,0 +1,221 @@
+---
+title: "Howto create a batch source with the new Source framework"
+date:
[
https://issues.apache.org/jira/browse/FLINK-31789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712365#comment-17712365
]
Martijn Visser commented on FLINK-31789:
[~satanicmechanic] I'm inclined to also close this as
[
https://issues.apache.org/jira/browse/FLINK-31800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712257#comment-17712257
]
Martijn Visser edited comment on FLINK-31800 at 4/14/23 12:39 PM:
--
echauchot commented on code in PR #631:
URL: https://github.com/apache/flink-web/pull/631#discussion_r1166772518
##
docs/content/posts/2023-04-12-howto-migrate-to-datastream.md:
##
@@ -0,0 +1,190 @@
+---
+title: "Howto migrate a real-life batch pipeline from the DataSet API to
[
https://issues.apache.org/jira/browse/FLINK-31752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712353#comment-17712353
]
Dong Lin commented on FLINK-31752:
--
[~yunfengzhou] Could you help fix this bug?
>
[
https://issues.apache.org/jira/browse/FLINK-31752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-31752:
Assignee: Yunfeng Zhou (was: Dong Lin)
> SourceOperatorStreamTask increments numRecordsOut
[
https://issues.apache.org/jira/browse/FLINK-31495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhang haoyan reopened FLINK-31495:
--
> Improve metrics tab on flink ui
> ---
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-31495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712343#comment-17712343
]
zhang haoyan commented on FLINK-31495:
--
sorry for my late reply
since there is no pop-ups in flink
[
https://issues.apache.org/jira/browse/FLINK-31495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhang haoyan updated FLINK-31495:
-
Attachment: image-2023-04-14-19-17-07-773.png
> Improve metrics tab on flink ui
>
Robert Metzger created FLINK-31810:
--
Summary: RocksDBException: Bad table magic number on checkpoint
rescale
Key: FLINK-31810
URL: https://issues.apache.org/jira/browse/FLINK-31810
Project: Flink
1996fanrui commented on code in PR #22392:
URL: https://github.com/apache/flink/pull/22392#discussion_r1166686196
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java:
##
@@ -381,7 +383,7 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-31805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712320#comment-17712320
]
Danny Cranmer commented on FLINK-31805:
---
Given this is backwards compatible I am moving to v3.1.0
[
https://issues.apache.org/jira/browse/FLINK-31805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31805:
--
Fix Version/s: cassandra-3.1.0
(was: cassandra-4.0.0)
> Cassandra
[
https://issues.apache.org/jira/browse/FLINK-31722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31722:
--
Fix Version/s: cassandra-3.1.0
> Remove dependency on flink-shaded
>
[
https://issues.apache.org/jira/browse/FLINK-30963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-30963:
--
Fix Version/s: cassandra-3.1.0
> Switch binary downloads to archive.apache.org
>
[
https://issues.apache.org/jira/browse/FLINK-28198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-28198:
--
Fix Version/s: cassandra-3.1.0
(was: cassandra-4.0.0)
>
[
https://issues.apache.org/jira/browse/FLINK-28198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712319#comment-17712319
]
Danny Cranmer commented on FLINK-28198:
---
Given this is backwards compatible I am moving this to
hlteoh37 commented on PR #67:
URL:
https://github.com/apache/flink-connector-aws/pull/67#issuecomment-1508289752
Should we change the notice files for the other SQL connectors as well?
(like in https://github.com/apache/flink-connector-aws/pull/68/files)
--
This is an automated message
[
https://issues.apache.org/jira/browse/FLINK-31723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712312#comment-17712312
]
Sergey Nuyanzin commented on FLINK-31723:
-
[
https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712308#comment-17712308
]
Sergey Nuyanzin commented on FLINK-26974:
-
[
https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712305#comment-17712305
]
Sergey Nuyanzin commented on FLINK-26974:
-
[
https://issues.apache.org/jira/browse/FLINK-30140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712304#comment-17712304
]
Sergey Nuyanzin commented on FLINK-30140:
-
// cc [~chesnay], since your were involved in similar
[
https://issues.apache.org/jira/browse/FLINK-31809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-31809:
-
Summary: Improve the efficiency of ListStateWithCache#snapshotState (was:
Improve efficiency of
[
https://issues.apache.org/jira/browse/FLINK-31809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-31809:
-
Description:
In the current implementation of {{{}ListStateWithCache{}}}, the
{{snapshotState}}
[
https://issues.apache.org/jira/browse/FLINK-30140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-30140:
Description:
[This
echauchot commented on code in PR #631:
URL: https://github.com/apache/flink-web/pull/631#discussion_r1166606129
##
content/2023/04/12/howto-migrate-a-real-life-batch-pipeline-from-the-dataset-api-to-the-datastream-api/index.html:
##
@@ -0,0 +1,1093 @@
+
+
+
Review Comment:
[
https://issues.apache.org/jira/browse/FLINK-31803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-31803:
Component/s: Runtime / Coordination
>
[
https://issues.apache.org/jira/browse/FLINK-31803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-31803:
Priority: Critical (was: Major)
>
[
https://issues.apache.org/jira/browse/FLINK-30140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-30140:
Component/s: Runtime / Coordination
> flink-runtime intergration tests fail due to
[
https://issues.apache.org/jira/browse/FLINK-30140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-30140:
Priority: Critical (was: Major)
> flink-runtime intergration tests fail due to Process
Fan Hong created FLINK-31809:
Summary: Improve efficiency of ListStateWithCache#snapshotState
Key: FLINK-31809
URL: https://issues.apache.org/jira/browse/FLINK-31809
Project: Flink
Issue Type:
flinkbot commented on PR #22401:
URL: https://github.com/apache/flink/pull/22401#issuecomment-1508233302
## CI report:
* 7c089389921f0db15e1fd5ae439c218b051e2bb9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31808:
---
Labels: pull-request-available (was: )
> wrong examples of how to set operator name in
huwh opened a new pull request, #22401:
URL: https://github.com/apache/flink/pull/22401
## What is the purpose of the change
fix wrong examples of how to set operator name in documents
## Verifying this change
This change is a trivial rework / code cleanup without any test
flinkbot commented on PR #22400:
URL: https://github.com/apache/flink/pull/22400#issuecomment-1508225694
## CI report:
* 75d23cad6dba8d175248788d0ea761305776cb28 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712290#comment-17712290
]
jirawech.s commented on FLINK-31689:
[~luoyuxia] I open
[
https://issues.apache.org/jira/browse/FLINK-31471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek resolved FLINK-31471.
---
Fix Version/s: 1.18.0
Resolution: Fixed
> Allow changing per-vertex desired
[
https://issues.apache.org/jira/browse/FLINK-31689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31689:
---
Labels: pull-request-available (was: )
> Filesystem sink fails when parallelism of
noomanee opened a new pull request, #22400:
URL: https://github.com/apache/flink/pull/22400
## What is the purpose of the change
This PR is to fix the issue that CompactOperator could not iterate the
expired states correctly when Flink parallelism increases, leading to Java
Weihua Hu created FLINK-31808:
-
Summary: wrong examples of how to set operator name in documents
Key: FLINK-31808
URL: https://issues.apache.org/jira/browse/FLINK-31808
Project: Flink
Issue
yangjf2019 commented on PR #552:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/552#issuecomment-1508210933
Hey, is it handled? This is a compatibility issue, consider dealing with
version information!
--
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-31471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712284#comment-17712284
]
David Morávek commented on FLINK-31471:
---
master: 40d2cfbc11f4c3598dcba5cbc7367237a9ddbf2f
> Allow
jayjayjpg closed pull request #22396: [hotfix][docs] fix typo in mysql db prompt
URL: https://github.com/apache/flink/pull/22396
--
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.
dmvk merged PR #22350:
URL: https://github.com/apache/flink/pull/22350
--
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:
MartijnVisser commented on code in PR #632:
URL: https://github.com/apache/flink-web/pull/632#discussion_r1166541332
##
docs/data/flink_connectors.yml:
##
@@ -50,6 +50,13 @@ jdbc:
source_release_sha512_url:
MartijnVisser commented on PR #22291:
URL: https://github.com/apache/flink/pull/22291#issuecomment-1508164176
@mas-chen Are you OK with it? If so, @tzulitai do you want to have a final
look before merging it?
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-31745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-31745.
--
Resolution: Not A Problem
It just restored performance back to the level from ~12th Jan
zentol commented on code in PR #12:
URL:
https://github.com/apache/flink-connector-cassandra/pull/12#discussion_r1166505427
##
flink-connector-cassandra/archunit-violations/dc1ba6f4-3d84-498c-a085-e02ba5936201:
##
@@ -1,6 +1,12 @@
[
https://issues.apache.org/jira/browse/FLINK-31807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31807:
---
Labels: pull-request-available (was: )
> Test architecture tests don't cover all test code
zentol commented on code in PR #12:
URL:
https://github.com/apache/flink-connector-cassandra/pull/12#discussion_r1166505427
##
flink-connector-cassandra/archunit-violations/dc1ba6f4-3d84-498c-a085-e02ba5936201:
##
@@ -1,6 +1,12 @@
[
https://issues.apache.org/jira/browse/FLINK-31805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-31805.
Resolution: Fixed
main: 1b8794380b268aad3b74d2b67ded8f59c1f07ea9
> Cassandra Source
boring-cyborg[bot] commented on PR #11:
URL:
https://github.com/apache/flink-connector-cassandra/pull/11#issuecomment-1508152481
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
zentol merged PR #11:
URL: https://github.com/apache/flink-connector-cassandra/pull/11
--
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:
zentol commented on code in PR #631:
URL: https://github.com/apache/flink-web/pull/631#discussion_r1166476933
##
docs/content/posts/2023-04-12-howto-migrate-to-datastream.md:
##
@@ -0,0 +1,190 @@
+---
+title: "Howto migrate a real-life batch pipeline from the DataSet API to
[
https://issues.apache.org/jira/browse/FLINK-31749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712265#comment-17712265
]
Etienne Chauchot commented on FLINK-31749:
--
[~martijnvisser] I'd say both:
* Datastream output
[
https://issues.apache.org/jira/browse/FLINK-31632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712261#comment-17712261
]
haishui commented on FLINK-31632:
-
Hi there. The PR may be ready to merge. When can it get into 1.15
1 - 100 of 153 matches
Mail list logo
