flinkbot commented on PR #24691:
URL: https://github.com/apache/flink/pull/24691#issuecomment-2066992465
## CI report:
* 38765977f787a0f88f247cd9ccfa7660f1c4d80b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
masteryhx opened a new pull request, #24691:
URL: https://github.com/apache/flink/pull/24691
## What is the purpose of the change
Hadoop whose version below 3.3.0 doesn't support reading and positionable
reading with ByteBuffer, which may cause compile error.
See
[
https://issues.apache.org/jira/browse/FLINK-35175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839068#comment-17839068
]
Hangxiang Yu commented on FLINK-35175:
--
[~rskraba] Thanks for reporting this!
I think it's better
[
https://issues.apache.org/jira/browse/FLINK-35175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35175:
---
Labels: pull-request-available (was: )
> HadoopDataInputStream can't compile with Hadoop
tweise merged PR #23777:
URL: https://github.com/apache/flink/pull/23777
--
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:
masteryhx commented on PR #24691:
URL: https://github.com/apache/flink/pull/24691#issuecomment-2066998011
@Zakelly @RyanSkraba Could you help to take a look ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-33379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839184#comment-17839184
]
Yubin Li commented on FLINK-33379:
--
[~pgodowski] sorry for the late reply, it seems that 3.1.0 branch
flinkbot commented on PR #24692:
URL: https://github.com/apache/flink/pull/24692#issuecomment-2067479443
## CI report:
* 4d0723dfc64326e5fab53b2b59c495f341a865df UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
morozov opened a new pull request, #24692:
URL: https://github.com/apache/flink/pull/24692
## What is the purpose of the change
The code
[examples](https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/connectors/datastream/datagen/#rate-limiting)
used in the
[
https://issues.apache.org/jira/browse/FLINK-34918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-34918:
-
Summary: Introduce comment for Catalog (was: Introduce comment support for
Catalog)
> Introduce
[
https://issues.apache.org/jira/browse/FLINK-33463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33463:
---
Labels: pull-request-available (was: )
> Support the implementation of dynamic source
RocMarshal opened a new pull request, #117:
URL: https://github.com/apache/flink-connector-jdbc/pull/117
- Support the implementation of dynamic source tables based on the new source
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-35177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35177:
---
Labels: pull-request-available (was: )
> Datagen examples in documentation do not compile
[
https://issues.apache.org/jira/browse/FLINK-35177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergei Morozov updated FLINK-35177:
---
Description:
Currently, the
Sergei Morozov created FLINK-35177:
--
Summary: Datagen examples in documentation do not compile
Key: FLINK-35177
URL: https://issues.apache.org/jira/browse/FLINK-35177
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-35159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838908#comment-17838908
]
Chesnay Schepler commented on FLINK-35159:
--
master: 131358b918ba511064c23dfee96969a628d07d2a
eskabetxe commented on code in PR #115:
URL:
https://github.com/apache/flink-connector-jdbc/pull/115#discussion_r1572010803
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcConnectionOptions.java:
##
@@ -90,13 +98,31 @@ public
zentol merged PR #24680:
URL: https://github.com/apache/flink/pull/24680
--
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-35039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838907#comment-17838907
]
ude commented on FLINK-35039:
-
Hi [~yunta] , I don't know why YARN doesn't support HTTP POST,I guess
zentol opened a new pull request, #24687:
URL: https://github.com/apache/flink/pull/24687
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them on
flinkbot commented on PR #24686:
URL: https://github.com/apache/flink/pull/24686#issuecomment-2066087596
## CI report:
* ddcc5c722292bb4aaeb9c4206399ccc136baf470 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #24687:
URL: https://github.com/apache/flink/pull/24687#issuecomment-2066096333
## CI report:
* 69f87df23d25a8103168daae796b6c8772c34253 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
TanYuxin-tyx commented on code in PR #24688:
URL: https://github.com/apache/flink/pull/24688#discussion_r1572064146
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/SortBufferAccumulator.java:
##
@@ -338,11 +365,22 @@ private
[
https://issues.apache.org/jira/browse/FLINK-35172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838924#comment-17838924
]
melin commented on FLINK-35172:
---
cc [~1365976...@qq.com]
> DDL statement is added to the Schema Change
[
https://issues.apache.org/jira/browse/FLINK-31923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31923:
--
Fix Version/s: cassandra-3.2.0
(was: cassandra-4.0.0)
> Connector
TanYuxin-tyx commented on code in PR #24688:
URL: https://github.com/apache/flink/pull/24688#discussion_r1572099075
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/SortBufferAccumulator.java:
##
@@ -338,11 +365,22 @@ private
[
https://issues.apache.org/jira/browse/FLINK-32826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838929#comment-17838929
]
Nuno Afonso commented on FLINK-32826:
-
Could this be related to
ZhengYu Chen created FLINK-35173:
Summary: Debezium Custom Time Serializer
Key: FLINK-35173
URL: https://issues.apache.org/jira/browse/FLINK-35173
Project: Flink
Issue Type: Improvement
yeezychao opened a new pull request, #24689:
URL: https://github.com/apache/flink/pull/24689
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
yuxiqian commented on code in PR #3226:
URL: https://github.com/apache/flink-cdc/pull/3226#discussion_r1571940092
##
PatrickRen merged PR #3237:
URL: https://github.com/apache/flink-cdc/pull/3237
--
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:
PatrickRen merged PR #3186:
URL: https://github.com/apache/flink-cdc/pull/3186
--
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 #24689:
URL: https://github.com/apache/flink/pull/24689#issuecomment-2066235806
## CI report:
* 5179e513e55a60de15d50b32497442d432cf051b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838938#comment-17838938
]
Danny Cranmer commented on FLINK-34954:
---
Merged commit
[
https://issues.apache.org/jira/browse/FLINK-35039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35039:
---
Labels: pull-request-available (was: )
> Create Profiling JobManager/TaskManager Instance
GOODBOY008 opened a new pull request, #24685:
URL: https://github.com/apache/flink/pull/24685
changes:
- Migrate module core to junit5 with core package.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
TanYuxin-tyx opened a new pull request, #24688:
URL: https://github.com/apache/flink/pull/24688
## What is the purpose of the change
*When using sortBufferAccumulator, we should recycle the buffers to
freeSegments before releasing the data buffer. The reason is that when
reswqa commented on code in PR #24688:
URL: https://github.com/apache/flink/pull/24688#discussion_r1572050446
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/SortBufferAccumulator.java:
##
@@ -338,11 +365,22 @@ private Buffer
[
https://issues.apache.org/jira/browse/FLINK-31698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31698:
--
Fix Version/s: cassandra-3.2.0
> Cassandra nightly CI failure
>
[
https://issues.apache.org/jira/browse/FLINK-31807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31807:
--
Fix Version/s: cassandra-3.2.0
(was: cassandra-4.0.0)
> Test
[
https://issues.apache.org/jira/browse/FLINK-31749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31749:
--
Fix Version/s: cassandra-3.2.0
> The Using Hadoop OutputFormats example is not avaliable for
zhongqishang commented on code in PR #3226:
URL: https://github.com/apache/flink-cdc/pull/3226#discussion_r1572098665
##
[
https://issues.apache.org/jira/browse/FLINK-35171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838928#comment-17838928
]
Feng Jin commented on FLINK-35171:
--
[~chenyu-opensource] {color:#00}You should build the
TanYuxin-tyx commented on code in PR #24688:
URL: https://github.com/apache/flink/pull/24688#discussion_r1572099075
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/SortBufferAccumulator.java:
##
@@ -338,11 +365,22 @@ private
dannycranmer merged PR #138:
URL: https://github.com/apache/flink-connector-aws/pull/138
--
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-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838934#comment-17838934
]
Danny Cranmer commented on FLINK-35115:
---
Merged commit
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-35115.
---
Resolution: Fixed
> Kinesis connector writes wrong Kinesis sequence number at stop with
[
https://issues.apache.org/jira/browse/FLINK-35171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838902#comment-17838902
]
chenyu commented on FLINK-35171:
Or I misunderstood? please give me a reply.
> Class
flinkbot commented on PR #24685:
URL: https://github.com/apache/flink/pull/24685#issuecomment-2066063146
## CI report:
* 2b1bc24cbfb7a12d0741a34caae26bd52ad195f5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838905#comment-17838905
]
chenyu commented on FLINK-35171:
Generated sources?
> Class 'FlinkSqlParserImpl' is missed
>
fredia commented on PR #24667:
URL: https://github.com/apache/flink/pull/24667#issuecomment-2066106851
After offline discussion, FLIP-425 is only used for stateful operators,
hence ,`async-mode` was changed back to `async-state`.
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-35169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35169:
---
Labels: pull-request-available (was: )
> Recycle buffers to freeSegments before releasing
flinkbot commented on PR #24688:
URL: https://github.com/apache/flink/pull/24688#issuecomment-2066126044
## CI report:
* df2d8f00cfc6feb3008df014655cc4d167c4ea62 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenyu closed FLINK-31883.
--
Resolution: Not A Problem
> StreamSQLExample.Order has nullability issues
>
RocMarshal commented on code in PR #115:
URL:
https://github.com/apache/flink-connector-jdbc/pull/115#discussion_r1572083767
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcConnectionOptions.java:
##
@@ -90,13 +98,31 @@ public
melin created FLINK-35172:
-
Summary: DDL statement is added to the Schema Change Event
Key: FLINK-35172
URL: https://issues.apache.org/jira/browse/FLINK-35172
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-35172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-35172:
--
Description:
The current implementation of the [kafka pipeline data sink connector
[
https://issues.apache.org/jira/browse/FLINK-32014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-32014:
--
Fix Version/s: cassandra-3.2.0
> Cassandra source documentation is missing and javadoc is out
reswqa commented on code in PR #24688:
URL: https://github.com/apache/flink/pull/24688#discussion_r1572088653
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/SortBufferAccumulator.java:
##
@@ -338,11 +365,22 @@ private Buffer
GOODBOY008 commented on PR #24685:
URL: https://github.com/apache/flink/pull/24685#issuecomment-2066192460
@Jiabao-Sun @1996fanrui PTAL
--
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-35133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35133:
--
Summary: Release flink-connector-cassandra v3.2.0 for Flink 1.19 (was:
Release
reswqa commented on code in PR #24678:
URL: https://github.com/apache/flink/pull/24678#discussion_r1572117471
##
flink-datastream/src/main/java/org/apache/flink/datastream/impl/operators/ProcessOperator.java:
##
@@ -23,15 +23,15 @@
import
fredia commented on PR #24672:
URL: https://github.com/apache/flink/pull/24672#issuecomment-2066225062
@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-34954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-34954:
--
Affects Version/s: 1.19.0
> Kryo input implementation NoFetchingInput fails to handle zero
[
https://issues.apache.org/jira/browse/FLINK-35039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838867#comment-17838867
]
Yun Tang commented on FLINK-35039:
--
[~wczhu] Thanks for finding this problem in YARN environment. I
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838884#comment-17838884
]
Danny Cranmer commented on FLINK-35115:
---
[~vadim.vararu] yes it will. 4.3.0 will support Flink
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838884#comment-17838884
]
Danny Cranmer edited comment on FLINK-35115 at 4/19/24 7:04 AM:
[
https://issues.apache.org/jira/browse/FLINK-35170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fengfengzai updated FLINK-35170:
Affects Version/s: 3.1.0
(was: 2.0.0)
> SqlServer connector support
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838894#comment-17838894
]
Vadim Vararu commented on FLINK-35115:
--
Great, thanks for quick fix (y)
> Kinesis connector writes
[
https://issues.apache.org/jira/browse/FLINK-35109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reassigned FLINK-35109:
---
Assignee: Ufuk Celebi
> Add support for Flink 1.20-SNAPSHOT in Flink Kafka connector and
PatrickRen commented on PR #3194:
URL: https://github.com/apache/flink-cdc/pull/3194#issuecomment-2065990714
@skymilong Thanks for the update! Could you rebase the latest master branch?
I just merged a commit for fixing unstable CI tests
--
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-35111:
-
Fix Version/s: 1.19.0
(was: 1.20.0)
> Modify the spelling mistakes in the
[
https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-35111:
-
Affects Version/s: (was: 1.19.0)
> Modify the spelling mistakes in the taskmanager html
>
fengfengzai created FLINK-35170:
---
Summary: SqlServer connector support scanNewlyAddedTableEnabled
param
Key: FLINK-35170
URL: https://issues.apache.org/jira/browse/FLINK-35170
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenyu updated FLINK-35171:
---
Attachment: screenshot-1.png
> Class 'FlinkSqlParserImpl' is missed
>
[
https://issues.apache.org/jira/browse/FLINK-35171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenyu updated FLINK-35171:
---
Attachment: missed in github.png
> Class 'FlinkSqlParserImpl' is missed
>
[
https://issues.apache.org/jira/browse/FLINK-35171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenyu updated FLINK-35171:
---
Attachment: (was: screenshot-1.png)
> Class 'FlinkSqlParserImpl' is missed
>
chenyu created FLINK-35171:
--
Summary: Class 'FlinkSqlParserImpl' is missed
Key: FLINK-35171
URL: https://issues.apache.org/jira/browse/FLINK-35171
Project: Flink
Issue Type: Bug
Affects
dannycranmer opened a new pull request, #28:
URL: https://github.com/apache/flink-connector-cassandra/pull/28
(no comment)
--
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-35133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35133:
---
Labels: pull-request-available (was: )
> Release flink-connector-cassandra v3.2.0 for
[
https://issues.apache.org/jira/browse/FLINK-32151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838980#comment-17838980
]
Ryan Skraba commented on FLINK-32151:
-
1.20 e2e_1_c1
yunfengzhou-hub commented on code in PR #24672:
URL: https://github.com/apache/flink/pull/24672#discussion_r1572300164
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperatorV2.java:
##
@@ -113,6
yunfengzhou-hub commented on code in PR #24667:
URL: https://github.com/apache/flink/pull/24667#discussion_r1572344539
##
flink-core/src/main/java/org/apache/flink/configuration/ExecutionOptions.java:
##
@@ -181,4 +182,62 @@ public class ExecutionOptions {
afedulov commented on code in PR #24564:
URL: https://github.com/apache/flink/pull/24564#discussion_r1572305374
##
docs/layouts/shortcodes/generated/rest_v1_dispatcher.html:
##
@@ -1277,6 +1277,9 @@
"parallelism" : {
"type" : "integer"
},
+
afedulov commented on code in PR #24564:
URL: https://github.com/apache/flink/pull/24564#discussion_r1571313741
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricStore.java:
##
@@ -184,6 +184,21 @@ public synchronized ComponentMetricStore
Ryan Skraba created FLINK-35175:
---
Summary: HadoopDataInputStream can't compile with Hadoop 3.2.3
Key: FLINK-35175
URL: https://issues.apache.org/jira/browse/FLINK-35175
Project: Flink
Issue
RyanSkraba commented on code in PR #24632:
URL: https://github.com/apache/flink/pull/24632#discussion_r1572359539
##
flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopDataInputStream.java:
##
@@ -140,4 +144,56 @@ public void skipFully(long
[
https://issues.apache.org/jira/browse/FLINK-35175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838999#comment-17838999
]
Ryan Skraba commented on FLINK-35175:
-
[~hangxiang]: what do you think? Is it better to bump the
[
https://issues.apache.org/jira/browse/FLINK-34954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-34954:
-
Assignee: Qinghui Xu
> Kryo input implementation NoFetchingInput fails to handle zero
[
https://issues.apache.org/jira/browse/FLINK-34954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-34954:
--
Component/s: API / Type Serialization System
> Kryo input implementation NoFetchingInput
[
https://issues.apache.org/jira/browse/FLINK-34954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838937#comment-17838937
]
Danny Cranmer commented on FLINK-34954:
---
Thanks for the bug report and fix, [~q.xu] .
> Kryo
[
https://issues.apache.org/jira/browse/FLINK-34954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-34954.
---
Resolution: Fixed
> Kryo input implementation NoFetchingInput fails to handle zero length
[
https://issues.apache.org/jira/browse/FLINK-34954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-34954:
--
Fix Version/s: 1.20.0
> Kryo input implementation NoFetchingInput fails to handle zero length
dannycranmer merged PR #24586:
URL: https://github.com/apache/flink/pull/24586
--
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-35142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-35142:
-
Assignee: Danny Cranmer
> Release flink-connector-rabbitmq vX.X.X for Flink 1.19
>
[
https://issues.apache.org/jira/browse/FLINK-35142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35142:
--
Fix Version/s: rabbitmq-3.1.0
> Release flink-connector-rabbitmq v3.1.0 for Flink 1.19
>
ljz2051 commented on code in PR #24681:
URL: https://github.com/apache/flink/pull/24681#discussion_r1572151847
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStValueState.java:
##
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the Apache
dannycranmer commented on PR #25:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/25#issuecomment-2066266504
https://issues.apache.org/jira/browse/FLINK-35174
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
dependabot[bot] commented on PR #25:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/25#issuecomment-2066266561
OK, I won't notify you again about this release, but will get in touch when
a new version is available. If you'd rather skip all updates until the next
major or
dannycranmer commented on PR #28:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/28#issuecomment-2066294353
> Seems like there is a dependency convergence error
>
> ```
> Warning:
> Dependency convergence error for org.apache.commons:commons-lang3:3.14.0
paths
1 - 100 of 153 matches
Mail list logo
