[
https://issues.apache.org/jira/browse/FLINK-33475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhengzhili closed FLINK-33475.
--
Resolution: Not A Bug
> yarn parameters cannot be set using flink.yarn.
>
[
https://issues.apache.org/jira/browse/FLINK-33475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhengzhili updated FLINK-33475:
---
Description:
yarn parameters cannot be set using flink.yarn.
[
https://issues.apache.org/jira/browse/FLINK-33475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhengzhili updated FLINK-33475:
---
Description:
yarn parameters cannot be set using flink.yarn.
[
https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783515#comment-17783515
]
zhengzhili commented on FLINK-33472:
Please assign it to me
> Solve the problem that the temporary
[
https://issues.apache.org/jira/browse/FLINK-33424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783516#comment-17783516
]
zhengzhili commented on FLINK-33424:
Please assign it to me
> Resolved an issue in
[
https://issues.apache.org/jira/browse/FLINK-33475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783514#comment-17783514
]
zhengzhili commented on FLINK-33475:
Please assign it to me
> yarn parameters cannot be set using
zhengzhili created FLINK-33475:
--
Summary: yarn parameters cannot be set using flink.yarn.
Key: FLINK-33475
URL: https://issues.apache.org/jira/browse/FLINK-33475
Project: Flink
Issue Type: Bug
liyubin117 commented on PR #23678:
URL: https://github.com/apache/flink/pull/23678#issuecomment-1797943557
@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
Sxnan commented on code in PR #23521:
URL: https://github.com/apache/flink/pull/23521#discussion_r1384475401
##
flink-tests/src/test/java/org/apache/flink/test/streaming/api/datastream/StreamingWithBacklogITCase.java:
##
@@ -0,0 +1,180 @@
+/*
+ * Licensed to the Apache Software
Sxnan commented on code in PR #23521:
URL: https://github.com/apache/flink/pull/23521#discussion_r1384473467
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.java:
##
@@ -146,6 +147,8 @@ public void copy(DataInputView
[
https://issues.apache.org/jira/browse/FLINK-33398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33398:
---
Labels: pull-request-available (was: )
> Support switching from batch to stream mode for
Sxnan commented on code in PR #23521:
URL: https://github.com/apache/flink/pull/23521#discussion_r1384472347
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java:
##
@@ -569,6 +571,12 @@ public void handleOperatorEvent(OperatorEvent
X-czh commented on code in PR #23663:
URL: https://github.com/apache/flink/pull/23663#discussion_r1384471051
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/InputFormatProvider.java:
##
@@ -44,6 +50,29 @@ public boolean isBounded() {
X-czh commented on PR #23663:
URL: https://github.com/apache/flink/pull/23663#issuecomment-1797931258
@libenchao Thanks for the review. For `SourceFunctionProvider`, since it has
already been deprecated now, I think there's no need to extend its interface,
WDYT? For the other two providers
libenchao commented on code in PR #23663:
URL: https://github.com/apache/flink/pull/23663#discussion_r1384455373
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/FactoryUtil.java:
##
@@ -104,6 +104,15 @@ public final class FactoryUtil {
[
https://issues.apache.org/jira/browse/FLINK-33354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-33354.
-
Resolution: Fixed
> Cache TaskInformation and JobInformation to avoid deserializing duplicate big
>
[
https://issues.apache.org/jira/browse/FLINK-33354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783499#comment-17783499
]
Rui Fan commented on FLINK-33354:
-
Merged to master<1.19> via 64992471c5dd52fb4269f6de51c15e27c2a45b55
[
https://issues.apache.org/jira/browse/FLINK-33354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33354:
Fix Version/s: 1.19.0
> Cache TaskInformation and JobInformation to avoid deserializing duplicate big
>
1996fanrui merged PR #23599:
URL: https://github.com/apache/flink/pull/23599
--
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 #23678:
URL: https://github.com/apache/flink/pull/23678#issuecomment-1797892255
## CI report:
* 9a0c9bf92b2e80707c82b2e9e0bcaf2c699f9c50 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-32993:
-
Description:
create table as follows:
!image-2023-08-30-11-51-44-498.png!
results:
[
https://issues.apache.org/jira/browse/FLINK-32993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32993:
---
Labels: pull-request-available (was: )
> Datagen connector handles fixed-length data types
liyubin117 opened a new pull request, #23678:
URL: https://github.com/apache/flink/pull/23678
## What is the purpose of the change
Datagen connector handles fixed-length data types according to the original
definition by default
## Brief change log
* modify the
flinkbot commented on PR #23677:
URL: https://github.com/apache/flink/pull/23677#issuecomment-1797880355
## CI report:
* 27454f1956d42f11e00a5ea1214f42abd5197be0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yuchen-ecnu commented on PR #23677:
URL: https://github.com/apache/flink/pull/23677#issuecomment-1797878291
Hi @Myasuka, would you like to help review this PR?
--
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-33474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33474:
---
Labels: pull-request-available (was: )
> ShowPlan throws undefined exception In Flink Web
[
https://issues.apache.org/jira/browse/FLINK-32993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-32993:
-
Description:
create table as follows:
!image-2023-08-30-11-51-44-498.png!
results:
yuchen-ecnu opened a new pull request, #23677:
URL: https://github.com/apache/flink/pull/23677
…bmit page
## What is the purpose of the change
Fix the undefined exception of Plan Visualization in the Job Submit Page on
Flink WEB.
## Brief change log
- Before
Yu Chen created FLINK-33474:
---
Summary: ShowPlan throws undefined exception In Flink Web Submit
Page
Key: FLINK-33474
URL: https://issues.apache.org/jira/browse/FLINK-33474
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-32993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-32993:
-
Summary: Datagen connector handles fixed-length data types according to the
original definition by
[
https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhengzhili updated FLINK-33472:
---
Description:
Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem
cannot
[
https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhengzhili updated FLINK-33472:
---
Attachment: image-2023-11-07-13-46-58-907.png
> Solve the problem that the temporary file of
[
https://issues.apache.org/jira/browse/FLINK-33473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783484#comment-17783484
]
Rui Fan commented on FLINK-33473:
-
Hi [~prabhujoseph] , this Jira duplicates with FLINK-33403.
And
Prabhu Joseph created FLINK-33473:
-
Summary: Update Flink client to 1.18.0
Key: FLINK-33473
URL: https://issues.apache.org/jira/browse/FLINK-33473
Project: Flink
Issue Type: Improvement
huwh commented on code in PR #23599:
URL: https://github.com/apache/flink/pull/23599#discussion_r1384389582
##
flink-runtime/src/main/java/org/apache/flink/runtime/deployment/TaskDeploymentDescriptor.java:
##
@@ -253,13 +274,19 @@ public void loadBigData(
libenchao commented on code in PR #23162:
URL: https://github.com/apache/flink/pull/23162#discussion_r1384342316
##
flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbConstant.java:
##
@@ -27,4 +27,10 @@ public class PbConstant {
public static
libenchao commented on code in PR #23162:
URL: https://github.com/apache/flink/pull/23162#discussion_r1384342316
##
flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbConstant.java:
##
@@ -27,4 +27,10 @@ public class PbConstant {
public static
[
https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783463#comment-17783463
]
Yue Ma commented on FLINK-7:
Update:
[https://github.com/facebook/rocksdb/pull/11646] merged in
zhengzhili created FLINK-33472:
--
Summary: Solve the problem that the temporary file of
flink-conf.yaml in S3AFileSystem cannot be uploaded
Key: FLINK-33472
URL: https://issues.apache.org/jira/browse/FLINK-33472
libenchao commented on code in PR #23162:
URL: https://github.com/apache/flink/pull/23162#discussion_r1383199488
##
flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbCodeSplitter.java:
##
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-33099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-33099.
-
Resolution: Fixed
> Introduce the Standalone Autoscaler and support flink cluster
>
[
https://issues.apache.org/jira/browse/FLINK-33099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783460#comment-17783460
]
Rui Fan commented on FLINK-33099:
-
Merged master<1.7.0> via : a309af647c1eab5bd3ae0b4f056e53a43d01b607
1996fanrui merged PR #698:
URL: https://github.com/apache/flink-kubernetes-operator/pull/698
--
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:
1996fanrui commented on PR #698:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/698#issuecomment-1797380552
Thanks a lot everyone for the review, merging~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
masteryhx commented on PR #23239:
URL: https://github.com/apache/flink/pull/23239#issuecomment-1797370868
> > > Hi @masteryhx , thank you for the review again, I also synced my fork
with the upstream, if that was what you meant by 'Could you also rebase all
your commits to the master ?'
[
https://issues.apache.org/jira/browse/FLINK-32993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-32993:
-
Description:
create table as follows:
!image-2023-08-30-11-51-44-498.png!
results:
[
https://issues.apache.org/jira/browse/FLINK-32993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-32993:
-
Issue Type: Improvement (was: Bug)
> Datagen connector deal with fixed length data type automately
>
[
https://issues.apache.org/jira/browse/FLINK-32993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-32993:
-
Summary: Datagen connector deal with fixed length data type automately
(was: Datagen connector produce
flinkbot commented on PR #23676:
URL: https://github.com/apache/flink/pull/23676#issuecomment-1797352588
## CI report:
* d420e386f030331c162f0e7ca4e38947f5669992 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783452#comment-17783452
]
Zakelly Lan commented on FLINK-6755:
I would like to implement this function in CLI, since we do meet
[
https://issues.apache.org/jira/browse/FLINK-20672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-20672:
---
Assignee: Zakelly Lan
> notifyCheckpointAborted RPC failure can fail JM
>
[
https://issues.apache.org/jira/browse/FLINK-20672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20672:
---
Labels: auto-deprioritized-major auto-deprioritized-minor
pull-request-available (was:
Zakelly opened a new pull request, #23676:
URL: https://github.com/apache/flink/pull/23676
## What is the purpose of the change
Avoid the RPC failure from JM to TM causing JM exit.
## Brief change log
Use try catch to protect the sending logic in async executor when
1996fanrui commented on code in PR #698:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/698#discussion_r1384265384
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/event/LoggableEventHandler.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-33171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan closed FLINK-33171.
-
> Consistent implicit type coercion support for equal and non-equal comparisons
> for codegen
>
[
https://issues.apache.org/jira/browse/FLINK-33171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-33171:
--
Affects Version/s: (was: 1.19.0)
> Consistent implicit type coercion support for equal and
[
https://issues.apache.org/jira/browse/FLINK-33171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-33171:
--
Affects Version/s: 1.19.0
> Consistent implicit type coercion support for equal and non-equal
[
https://issues.apache.org/jira/browse/FLINK-33171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan resolved FLINK-33171.
---
Fix Version/s: 1.19.0
Resolution: Fixed
> Consistent implicit type coercion support for
[
https://issues.apache.org/jira/browse/FLINK-33171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783106#comment-17783106
]
Jane Chan edited comment on FLINK-33171 at 11/7/23 1:48 AM:
master:
LadyForest merged PR #23668:
URL: https://github.com/apache/flink/pull/23668
--
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:
LadyForest merged PR #23669:
URL: https://github.com/apache/flink/pull/23669
--
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:
1996fanrui commented on PR #23589:
URL: https://github.com/apache/flink/pull/23589#issuecomment-1797094035
Hey @pnowojski @RocMarshal , I have fixed the test, would you mind helping
double check? Thanks
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-33471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-33471:
---
Assignee: Sergey Nuyanzin
> Kubernetes operator supports compiling with Java 21
>
[
https://issues.apache.org/jira/browse/FLINK-33471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33471:
---
Labels: pull-request-available (was: )
> Kubernetes operator supports compiling with Java
snuyanzin opened a new pull request, #701:
URL: https://github.com/apache/flink-kubernetes-operator/pull/701
## What is the purpose of the change
The PR is aiming to support compilation with java 21
Since spotless and google java format needs to be updated to work with java
21
Sergey Nuyanzin created FLINK-33471:
---
Summary: Kubernetes operator supports compiling with Java 21
Key: FLINK-33471
URL: https://issues.apache.org/jira/browse/FLINK-33471
Project: Flink
gyfora commented on PR #23490:
URL: https://github.com/apache/flink/pull/23490#issuecomment-1796954415
Updated the PR @XComp , I did not address the test naming question because I
can't reply to it, I think it's fine to distinguish by prefix.
--
This is an automated message from the
Jim Hughes created FLINK-33470:
--
Summary: Implement restore tests for Join node
Key: FLINK-33470
URL: https://issues.apache.org/jira/browse/FLINK-33470
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-33466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jonas Weile updated FLINK-33466:
Component/s: Connectors / Common
(was: Connectors / Kafka)
[
https://issues.apache.org/jira/browse/FLINK-33466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jonas Weile updated FLINK-33466:
Description:
When setting up a bounded Kafka source, if the job is restored from a savepoint
[
https://issues.apache.org/jira/browse/FLINK-33466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jonas Weile updated FLINK-33466:
Description:
When setting up a bounded Kafka source, if the job is restored from a savepoint
jnh5y commented on code in PR #23652:
URL: https://github.com/apache/flink/pull/23652#discussion_r1383978823
##
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/SubQueryInputTypeStrategyTest.java:
##
@@ -0,0 +1,83 @@
+/*
+ *
jnh5y commented on code in PR #23652:
URL: https://github.com/apache/flink/pull/23652#discussion_r1383965282
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/expressions/subquery.scala:
##
@@ -1,78 +0,0 @@
-/*
- * Licensed to the Apache Software
jnh5y commented on code in PR #23652:
URL: https://github.com/apache/flink/pull/23652#discussion_r1383961004
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SubQueryInputTypeStrategy.java:
##
@@ -0,0 +1,115 @@
+/*
+ * Licensed
jnh5y commented on code in PR #23652:
URL: https://github.com/apache/flink/pull/23652#discussion_r1383951328
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/utils/LogicalTypeChecks.java:
##
@@ -242,6 +245,139 @@ public static boolean
jnh5y commented on code in PR #23652:
URL: https://github.com/apache/flink/pull/23652#discussion_r1383949729
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/utils/LogicalTypeChecks.java:
##
@@ -242,6 +245,139 @@ public static boolean
flinkbot commented on PR #23675:
URL: https://github.com/apache/flink/pull/23675#issuecomment-1796380778
## CI report:
* 58a68c00e76272dac969ca389f705f612b7517bf UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33469:
---
Labels: pull-request-available (was: )
> Implement restore tests for Limit node
>
jnh5y opened a new pull request, #23675:
URL: https://github.com/apache/flink/pull/23675
## What is the purpose of the change
Implement restore tests for Limit node
## Verifying this change
This change added tests and can be verified as follows:
* Added restore
Jim Hughes created FLINK-33469:
--
Summary: Implement restore tests for Limit node
Key: FLINK-33469
URL: https://issues.apache.org/jira/browse/FLINK-33469
Project: Flink
Issue Type: Sub-task
tzulitai commented on PR #11:
URL:
https://github.com/apache/flink-connector-kafka/pull/11#issuecomment-1796185531
@jm-paulin I think we can definitely do a 3.1.x release before that. Given
the CVE it would make sense to do this sooner as well. First step would be to
start a thread in dev
[
https://issues.apache.org/jira/browse/FLINK-32902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782804#comment-17782804
]
ZY tang edited comment on FLINK-32902 at 11/6/23 6:54 PM:
--
[~mapohl] I can
[ https://issues.apache.org/jira/browse/FLINK-32902 ]
ZY tang deleted comment on FLINK-32902:
-
was (Author: JIRAUSER302551):
[~mapohl]
> Docs creation and checks in multiple locations
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-32902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783336#comment-17783336
]
ZY tang commented on FLINK-32902:
-
[~mapohl]
> Docs creation and checks in multiple locations
>
dyccode commented on PR #23674:
URL: https://github.com/apache/flink/pull/23674#issuecomment-1795734309
@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.
jm-paulin commented on PR #11:
URL:
https://github.com/apache/flink-connector-kafka/pull/11#issuecomment-1795602705
Ah, that explains @tzulitai. thanks you!
We are looking at moving to Kafka 3.4.0 early next year (Jan 2024). This
upgrade is driven by
RyanSkraba commented on PR #21289:
URL: https://github.com/apache/flink/pull/21289#issuecomment-1795602499
Rebased and squashed!
--
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
gaborgsomogyi commented on PR #689:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/689#issuecomment-1795575344
Please see my comments inline:
> So the problem is that user declared flinkdeployments could specify the
cert directory wherever they want to, I didn't want
gyfora commented on code in PR #698:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/698#discussion_r1383701572
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/event/LoggableEventHandler.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache
tzulitai commented on PR #11:
URL:
https://github.com/apache/flink-connector-kafka/pull/11#issuecomment-1795559991
@jm-paulin Kafka version upgrade to 3.4.x is not part of the 3.0.x Kafka
connector series.
We're treating it as a major new feature and would only come with a new
[
https://issues.apache.org/jira/browse/FLINK-33285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-33285.
---
Resolution: Fixed
This issue was actually caused by the e2e tests running in a container.
[
https://issues.apache.org/jira/browse/FLINK-33458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sharath Avadoot Gururaj resolved FLINK-33458.
-
Resolution: Fixed
> Add env.java.opts.gateway option in flink-conf.yaml
[
https://issues.apache.org/jira/browse/FLINK-33458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783289#comment-17783289
]
Sharath Avadoot Gururaj commented on FLINK-33458:
-
Wow nice! thanks a lot for the reply
bvarghese1 commented on code in PR #23660:
URL: https://github.com/apache/flink/pull/23660#discussion_r1383682889
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/SortTestPrograms.java:
##
@@ -0,0 +1,109 @@
+/*
+ *
bvarghese1 commented on code in PR #23660:
URL: https://github.com/apache/flink/pull/23660#discussion_r1383682230
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/SortTestPrograms.java:
##
@@ -0,0 +1,109 @@
+/*
+ *
jm-paulin commented on PR #11:
URL:
https://github.com/apache/flink-connector-kafka/pull/11#issuecomment-1795517028
Right, that's also what I thought. so I added the dependecy:
--
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-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783286#comment-17783286
]
João Boto commented on FLINK-25420:
---
Sounds good [~RocMarshal]
> Port JDBC Source to new Source API
Matthias Pohl created FLINK-33468:
-
Summary: Run Kubernetes IT test fails due to wrong Maven version
Key: FLINK-33468
URL: https://issues.apache.org/jira/browse/FLINK-33468
Project: Flink
flinkbot commented on PR #23674:
URL: https://github.com/apache/flink/pull/23674#issuecomment-1795482536
## CI report:
* e9d1ae3410540dca565f612b73b6bb25becc8d7b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dyccode commented on PR #23674:
URL: https://github.com/apache/flink/pull/23674#issuecomment-1795480027
@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.
1 - 100 of 164 matches
Mail list logo
