[
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-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
[
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
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`
[
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
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-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
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-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
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`
[
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
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
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:
RocMarshal opened a new pull request, #116:
URL: https://github.com/apache/flink-connector-jdbc/pull/116
- Support property authentication connection for JDBC catalog & dynamic table
--
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-34574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-34574.
--
Fix Version/s: kubernetes-operator-1.9.0
Resolution: Fixed
merged to main
gyfora merged PR #789:
URL: https://github.com/apache/flink-kubernetes-operator/pull/789
--
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-35176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-35176:
---
Parent: FLINK-25420
Issue Type: Sub-task (was: Improvement)
> Support property
RocMarshal created FLINK-35176:
--
Summary: Support property authentication connection for JDBC
catalog & dynamic table
Key: FLINK-35176
URL: https://issues.apache.org/jira/browse/FLINK-35176
Project:
[
https://issues.apache.org/jira/browse/FLINK-35159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-35159.
Resolution: Fixed
> CreatingExecutionGraph can leak CheckpointCoordinator and cause JM
[
https://issues.apache.org/jira/browse/FLINK-35159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838908#comment-17838908
]
Chesnay Schepler edited comment on FLINK-35159 at 4/19/24 3:03 PM:
---
zentol merged PR #24686:
URL: https://github.com/apache/flink/pull/24686
--
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:
afedulov commented on PR #23777:
URL: https://github.com/apache/flink/pull/23777#issuecomment-2066761675
CI is green:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=58998=results
--
This is an automated message from the Apache Git Service.
To respond to the
RocMarshal commented on code in PR #115:
URL:
https://github.com/apache/flink-connector-jdbc/pull/115#discussion_r1572398050
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcConnectionOptions.java:
##
@@ -90,13 +98,31 @@ public
RocMarshal commented on code in PR #115:
URL:
https://github.com/apache/flink-connector-jdbc/pull/115#discussion_r1572398050
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcConnectionOptions.java:
##
@@ -90,13 +98,31 @@ public
[
https://issues.apache.org/jira/browse/FLINK-35159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838908#comment-17838908
]
Chesnay Schepler edited comment on FLINK-35159 at 4/19/24 1:40 PM:
---
zentol commented on PR #24686:
URL: https://github.com/apache/flink/pull/24686#issuecomment-2066614601
@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.
zentol merged PR #24687:
URL: https://github.com/apache/flink/pull/24687
--
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-35175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839001#comment-17839001
]
Ryan Skraba commented on FLINK-35175:
-
1.20 Hadoop 3.1.3 / Compile
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839002#comment-17839002
]
Ryan Skraba commented on FLINK-34227:
-
1.18 AdaptiveScheduler / Test (module: table)
[
https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839003#comment-17839003
]
Ryan Skraba commented on FLINK-18476:
-
1.19 Java 11 / Test (module: misc)
[
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
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
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
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 {
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
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
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"
},
+
[
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
[
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
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-35069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838962#comment-17838962
]
Hong Liang Teoh commented on FLINK-35069:
-
Thanks [~lijinzhong] for the fix! Are we planning to
flinkbot commented on PR #24690:
URL: https://github.com/apache/flink/pull/24690#issuecomment-2066354887
## CI report:
* 5fa3b48c1caed9d9e4ff9b31c1b8640318c18555 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35168:
---
Labels: pull-request-available (was: )
> Basic State Iterator for async processing
>
Zakelly opened a new pull request, #24690:
URL: https://github.com/apache/flink/pull/24690
## What is the purpose of the change
This PR ship the basic logic of state iterator, only leave the necessary
part abstract for subclass to implement. Most of the code is future-related.
[
https://issues.apache.org/jira/browse/FLINK-35174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838954#comment-17838954
]
Danny Cranmer commented on FLINK-35174:
---
Merged commit 66e323a into apache:main
> Bump
Myasuka commented on PR #24689:
URL: https://github.com/apache/flink/pull/24689#issuecomment-2066319875
@yeezychao Can your solution also works in standalone environment?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
dannycranmer merged PR #28:
URL: https://github.com/apache/flink-connector-rabbitmq/pull/28
--
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=17838951#comment-17838951
]
Yun Tang commented on FLINK-35039:
--
[~wczhu] Already assigned to you.
> Create Profiling
[
https://issues.apache.org/jira/browse/FLINK-35039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-35039:
Assignee: ude
> Create Profiling JobManager/TaskManager Instance failed
>
yuxiqian commented on PR #3212:
URL: https://github.com/apache/flink-cdc/pull/3212#issuecomment-2066306357
Seems removing connector jar dependencies break SQL Job E2e tests. Need to
fix this first.
--
This is an automated message from the Apache Git Service.
To respond to the message,
dannycranmer merged PR #27:
URL: https://github.com/apache/flink-connector-rabbitmq/pull/27
--
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:
dannycranmer merged PR #24:
URL: https://github.com/apache/flink-connector-rabbitmq/pull/24
--
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:
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
eskabetxe commented on code in PR #115:
URL:
https://github.com/apache/flink-connector-jdbc/pull/115#discussion_r1572162247
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcConnectionOptions.java:
##
@@ -90,13 +98,31 @@ public
[
https://issues.apache.org/jira/browse/FLINK-35137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838591#comment-17838591
]
Danny Cranmer edited comment on FLINK-35137 at 4/19/24 10:28 AM:
-
RC2
[
https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838086#comment-17838086
]
Danny Cranmer edited comment on FLINK-35139 at 4/19/24 10:28 AM:
-
RC1
[
https://issues.apache.org/jira/browse/FLINK-35137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838181#comment-17838181
]
Danny Cranmer edited comment on FLINK-35137 at 4/19/24 10:28 AM:
-
RC1
[
https://issues.apache.org/jira/browse/FLINK-35132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838058#comment-17838058
]
Danny Cranmer edited comment on FLINK-35132 at 4/19/24 10:27 AM:
-
RC1
[
https://issues.apache.org/jira/browse/FLINK-35135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838590#comment-17838590
]
Danny Cranmer edited comment on FLINK-35135 at 4/19/24 10:28 AM:
-
RC1
[
https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838592#comment-17838592
]
Danny Cranmer edited comment on FLINK-35139 at 4/19/24 10:28 AM:
-
RC2
hlteoh37 commented on PR #28:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/28#issuecomment-2066287030
Seems like there is a dependency convergence error
```
Warning:
Dependency convergence error for org.apache.commons:commons-lang3:3.14.0
paths to dependency
[
https://issues.apache.org/jira/browse/FLINK-35132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838949#comment-17838949
]
Danny Cranmer commented on FLINK-35132:
---
RC2 Vote:
eskabetxe commented on code in PR #115:
URL:
https://github.com/apache/flink-connector-jdbc/pull/115#discussion_r1572162247
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcConnectionOptions.java:
##
@@ -90,13 +98,31 @@ public
ljz2051 commented on PR #24681:
URL: https://github.com/apache/flink/pull/24681#issuecomment-2066281635
@Zakelly Thanks for your review! I have addressed all comments your
mentioned.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
ljz2051 commented on code in PR #24681:
URL: https://github.com/apache/flink/pull/24681#discussion_r1572160266
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStDBOperation.java:
##
@@ -0,0 +1,42 @@
+/*
+ * Licensed to the Apache
ljz2051 commented on code in PR #24681:
URL: https://github.com/apache/flink/pull/24681#discussion_r1572156946
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ContextKey.java:
##
@@ -0,0 +1,73 @@
+/*
+ * Licensed to the Apache
ljz2051 commented on code in PR #24681:
URL: https://github.com/apache/flink/pull/24681#discussion_r1572153463
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ContextKey.java:
##
@@ -0,0 +1,73 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-35142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35142:
--
Summary: Release flink-connector-rabbitmq v3.1.0 for Flink 1.19 (was:
Release
Tan-JiaLiang commented on PR #20:
URL:
https://github.com/apache/flink-connector-hbase/pull/20#issuecomment-2066268025
@Jackson-xky This is a serious problem in the hbase lookup join. Are you
still working on it? I'd be happy to help.
--
This is an automated message from the Apache Git
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 #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
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
[
https://issues.apache.org/jira/browse/FLINK-35174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35174:
--
Description:
Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink
[
https://issues.apache.org/jira/browse/FLINK-35174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35174:
--
Fix Version/s: rabbitmq-3.1.0
(was: aws-connector-4.3.0)
> Bump
[
https://issues.apache.org/jira/browse/FLINK-35174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35174:
--
Component/s: Connectors/ RabbitMQ
(was: Connectors / AWS)
> Bump
[
https://issues.apache.org/jira/browse/FLINK-35174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35174:
--
Summary: Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for
Flink RabbitMQ
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
[
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
>
dannycranmer closed pull request #25: Bump org.apache.commons:commons-compress
from 1.24.0 to 1.26.0
URL: https://github.com/apache/flink-connector-rabbitmq/pull/25
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
Danny Cranmer created FLINK-35174:
-
Summary: Bump org.apache.commons:commons-compress from 1.25.0 to
1.26.1 for Flink RabbitMQ connector
Key: FLINK-35174
URL: https://issues.apache.org/jira/browse/FLINK-35174
[
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
]
ASF GitHub Bot updated FLINK-35142:
---
Labels: pull-request-available (was: )
> Release flink-connector-rabbitmq vX.X.X for Flink
[
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 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: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 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-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
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-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
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
[
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
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
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.
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
[
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
1 - 100 of 153 matches
Mail list logo
