LadyForest commented on PR #23678:
URL: https://github.com/apache/flink/pull/23678#issuecomment-1806728583
Hi @liyubin117 thanks for your contributionon!
As concluded in the offline discussion, since this is a question regarding
modification of the default behavior for the datagen
[
https://issues.apache.org/jira/browse/FLINK-33524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZhangTao updated FLINK-33524:
-
Labels: (was: pull-request-available)
> IntervalJoinOperator 's judgment on late data has bug
>
flinkbot commented on PR #23699:
URL: https://github.com/apache/flink/pull/23699#issuecomment-1806722894
## CI report:
* 0bc5397f48610d1a26681974af917ac9230d17be UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33524:
---
Labels: pull-request-available (was: )
> IntervalJoinOperator 's judgment on late data has
Tao-Zhang9876 opened a new pull request, #23699:
URL: https://github.com/apache/flink/pull/23699
Due to the Watermark calculation method :
```
public void onPeriodicEmit(WatermarkOutput output) {
output.emitWatermark(new Watermark(maxTs - delayTime - 1L));
LadyForest commented on code in PR #23620:
URL: https://github.com/apache/flink/pull/23620#discussion_r1390116335
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/FlinkRelOptUtil.scala:
##
@@ -524,4 +530,219 @@ object FlinkRelOptUtil {
ZhangTao created FLINK-33524:
Summary: IntervalJoinOperator 's judgment on late data has bug
Key: FLINK-33524
URL: https://issues.apache.org/jira/browse/FLINK-33524
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-33523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prabhu Joseph updated FLINK-33523:
--
Description:
When upgrading Iceberg's Flink version to 1.18, we found the Flink-related unit
Prabhu Joseph created FLINK-33523:
-
Summary: DataType ARRAY fails to cast into Object[]
Key: FLINK-33523
URL: https://issues.apache.org/jira/browse/FLINK-33523
Project: Flink
Issue Type: Bug
1996fanrui commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1390096801
##
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultResourceAllocationStrategy.java:
##
@@ -95,7 +96,7 @@ public
RocMarshal commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1390096271
##
flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java:
##
@@ -708,6 +711,60 @@ public class TaskManagerOptions {
dchristle commented on PR #2:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/2#issuecomment-1806569957
Hi @RyanSkraba,
Thank you for shepherding and improving this connector implementation over
the years. I'm hoping to help review & improve it so we can finally get
dchristle commented on code in PR #2:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/2#discussion_r1389778481
##
flink-connector-gcp-pubsub/src/main/java/org/apache/flink/connector/gcp/pubsub/source/PubSubSource.java:
##
@@ -0,0 +1,304 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-33522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-33522:
---
Description:
Under certain circumstances, savepoint creation can succeed but the
[
https://issues.apache.org/jira/browse/FLINK-33522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33522:
---
Labels: pull-request-available (was: )
> Savepoint upgrade mode fails despite the
mxm opened a new pull request, #706:
URL: https://github.com/apache/flink-kubernetes-operator/pull/706
Under certain circumstances, savepoint creation can succeed but the job
fails afterwards. One example is when there are messages being distributed by
the source coordinator to
Maximilian Michels created FLINK-33522:
--
Summary: Savepoint upgrade mode fails despite the savepoint
succeeding
Key: FLINK-33522
URL: https://issues.apache.org/jira/browse/FLINK-33522
Project:
mxm merged PR #705:
URL: https://github.com/apache/flink-kubernetes-operator/pull/705
--
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:
mxm commented on PR #705:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/705#issuecomment-1806431131
Thanks!
--
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-33385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Samrat Deb updated FLINK-33385:
---
Summary: Flink connector redshift Sink API implementation (was: Flink
connector redshift Sink
[
https://issues.apache.org/jira/browse/FLINK-33132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Samrat Deb updated FLINK-33132:
---
Summary: Flink Connector Redshift Implementation (Table-API) (was: Flink
Connector Redshift Sink
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785031#comment-17785031
]
david radley edited comment on FLINK-33365 at 11/10/23 6:18 PM:
I am not
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785031#comment-17785031
]
david radley commented on FLINK-33365:
--
I am not sure about the design intent in this area. Should
[ https://issues.apache.org/jira/browse/FLINK-33365 ]
david radley deleted comment on FLINK-33365:
--
was (Author: JIRAUSER300523):
Testing against MariaDB I see:
select CAST(0 AS INT) as type from c;
+--+
|type|
+--+
| 0|
|
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784915#comment-17784915
]
david radley edited comment on FLINK-33365 at 11/10/23 4:33 PM:
an
sofam commented on PR #23489:
URL: https://github.com/apache/flink/pull/23489#issuecomment-1806052931
Any progress on this? We need it for upgrading our jobs to 1.18 :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
flinkbot commented on PR #23698:
URL: https://github.com/apache/flink/pull/23698#issuecomment-1806045977
## CI report:
* 815fdd06b59c593124bfbe8d9443949c05b4dba4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #23697:
URL: https://github.com/apache/flink/pull/23697#issuecomment-1806033945
## CI report:
* ac8e2bd3884973b10c8e17110f4dae8e625576fb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
local cluster setup.
> Update Web UI to adopt the new "endpoint" field
[
https://issues.apache.org/jira/browse/FLINK-33515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33515:
---
Labels: pull-request-available (was: )
> PythonDriver need to stream python process output
gaborgsomogyi opened a new pull request, #23697:
URL: https://github.com/apache/flink/pull/23697
## What is the purpose of the change
`PythonDriver` now collects the python process output in a `Stringbuilder`
instead of streaming it. It can cause OOM when the python process is
gaborgsomogyi commented on PR #23697:
URL: https://github.com/apache/flink/pull/23697#issuecomment-1806023401
cc @gyfora @mbalassi @morhidi
--
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
flinkbot commented on PR #23696:
URL: https://github.com/apache/flink/pull/23696#issuecomment-1806015650
## CI report:
* 741114833862d9def23b3ea09b886c8f5afe0b7b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gaborgsomogyi commented on PR #689:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/689#issuecomment-1806013754
Just for the reference for others:
https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/security/security-ssl/#rest-endpoints-external-connectivity
[
https://issues.apache.org/jira/browse/FLINK-33520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33520:
---
Labels: pull-request-available (was: )
> FileNotFoundException when running GPUDriverTest
RyanSkraba opened a new pull request, #23696:
URL: https://github.com/apache/flink/pull/23696
## What is the purpose of the change
This is a *very* minor change to avoid depending on the value of the
`FLINK_HOME` environment variable when discovering the value of the gpu
discovery
gaborgsomogyi commented on PR #689:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/689#issuecomment-1806003173
Makes sense, mTLS is one reason what justifies to add the remaining 3
keystore related configs.
--
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-13786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-13786.
Resolution: Won't Fix
> Implement type inference for other functions
>
[
https://issues.apache.org/jira/browse/FLINK-13786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784990#comment-17784990
]
Dawid Wysakowicz commented on FLINK-13786:
--
I'll close this ticket in favour of more granular
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784915#comment-17784915
]
david radley edited comment on FLINK-33365 at 11/10/23 3:08 PM:
an
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784915#comment-17784915
]
david radley edited comment on FLINK-33365 at 11/10/23 3:04 PM:
an
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784924#comment-17784924
]
david radley edited comment on FLINK-33365 at 11/10/23 3:01 PM:
Testing
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784915#comment-17784915
]
david radley edited comment on FLINK-33365 at 11/10/23 3:01 PM:
an
[
https://issues.apache.org/jira/browse/FLINK-33521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jim Hughes reassigned FLINK-33521:
--
Assignee: Jim Hughes
> Implement restore tests for PythonCalc node
>
Jim Hughes created FLINK-33521:
--
Summary: Implement restore tests for PythonCalc node
Key: FLINK-33521
URL: https://issues.apache.org/jira/browse/FLINK-33521
Project: Flink
Issue Type: Sub-task
Ryan Skraba created FLINK-33520:
---
Summary: FileNotFoundException when running GPUDriverTest
Key: FLINK-33520
URL: https://issues.apache.org/jira/browse/FLINK-33520
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-33419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-33419.
Resolution: Implemented
Implemented in 3dd98430e5cc7ee88051d0eb6bc2c71908eb997b
> Port
dawidwys merged PR #23634:
URL: https://github.com/apache/flink/pull/23634
--
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-33507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784930#comment-17784930
]
jinzhuguang commented on FLINK-33507:
-
[~martijnvisser] Thank you for your reply. In my scenario, I
[ https://issues.apache.org/jira/browse/FLINK-33507 ]
jinzhuguang deleted comment on FLINK-33507:
-
was (Author: JIRAUSER302532):
Thank you for your reply. In my scenario, I just want to recognize zero date as
null, but json.ignore-parse-errors
[
https://issues.apache.org/jira/browse/FLINK-33507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784929#comment-17784929
]
jinzhuguang commented on FLINK-33507:
-
Thank you for your reply. In my scenario, I just want to
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784924#comment-17784924
]
david radley edited comment on FLINK-33365 at 11/10/23 12:47 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784924#comment-17784924
]
david radley commented on FLINK-33365:
--
Testing against MariaDB I see:
select CAST(0 AS INT) as
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784924#comment-17784924
]
david radley edited comment on FLINK-33365 at 11/10/23 12:46 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784915#comment-17784915
]
david radley edited comment on FLINK-33365 at 11/10/23 12:29 PM:
-
an
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784915#comment-17784915
]
david radley commented on FLINK-33365:
--
an update on what I have found:
I have switched on
[
https://issues.apache.org/jira/browse/FLINK-33251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784905#comment-17784905
]
Jorick Caberio commented on FLINK-33251:
No
> SQL Client query execution aborts after a few
chaoran.su created FLINK-33519:
--
Summary: standalone mode could not create keytab secret
Key: FLINK-33519
URL: https://issues.apache.org/jira/browse/FLINK-33519
Project: Flink
Issue Type: Bug
tagarr commented on PR #689:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/689#issuecomment-1805607794
You're right truststore would normally only be needed, it depends on if we
want to cater for mTLS. If we did we would need to include keystore info.
Quick question if
sdahlbac opened a new pull request, #705:
URL: https://github.com/apache/flink-kubernetes-operator/pull/705
## What is the purpose of the change
*(For example: This pull request adds a new feature to periodically create
and maintain savepoints through the `FlinkDeployment`
pvary commented on PR #23555:
URL: https://github.com/apache/flink/pull/23555#issuecomment-1805565611
@mbalassi: Rebased, and got a green run
--
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
leonardBang commented on PR #20:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/20#issuecomment-1805552181
> @leonardBang If we want to bump the minimum version to 1.17.0, you'll also
need to address the dependency convergence.
>
> However, looking at the code, we
[
https://issues.apache.org/jira/browse/FLINK-33507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784767#comment-17784767
]
Martijn Visser commented on FLINK-33507:
[~lucas_jin] There is already the option
[
https://issues.apache.org/jira/browse/FLINK-33510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-33510:
---
Issue Type: Technical Debt (was: Improvement)
> Update plugin for SBOM generation to
[
https://issues.apache.org/jira/browse/FLINK-33510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-33510:
---
Component/s: Build System
> Update plugin for SBOM generation to 2.7.10
>
MartijnVisser closed pull request #65: [hotfix][docs] refer to
sql_connector_download_table shortcode in zh docs
URL: https://github.com/apache/flink-connector-kafka/pull/65
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
MartijnVisser commented on PR #65:
URL:
https://github.com/apache/flink-connector-kafka/pull/65#issuecomment-1805462974
Closed, duplicate of https://github.com/apache/flink-connector-kafka/pull/64
--
This is an automated message from the Apache Git Service.
To respond to the message,
MartijnVisser commented on PR #20:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/20#issuecomment-1805460516
@leonardBang If we want to bump the minimum version to 1.17.0, you'll also
need to address the dependency convergence.
However, looking at the code, we
[
https://issues.apache.org/jira/browse/FLINK-33514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784758#comment-17784758
]
Martijn Visser commented on FLINK-33514:
This sounds like you're missing a dependency. What's in
[
https://issues.apache.org/jira/browse/FLINK-30314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Etienne Chauchot resolved FLINK-30314.
--
Fix Version/s: 1.19.0
Resolution: Fixed
Fixed by
[
https://issues.apache.org/jira/browse/FLINK-33207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-33207:
--
Assignee: tanjialiang
> Scan hbase table will throw error when table is empty
>
[
https://issues.apache.org/jira/browse/FLINK-33207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-33207.
--
Fix Version/s: hbase-3.0.1
Resolution: Fixed
Fixed in apache/flink-connector-hbase
[
https://issues.apache.org/jira/browse/FLINK-32807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yong yang closed FLINK-32807.
-
Resolution: Duplicate
> when i use emitUpdateWithRetract of udtagg,bug error
>
MartijnVisser merged PR #23:
URL: https://github.com/apache/flink-connector-hbase/pull/23
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
[
https://issues.apache.org/jira/browse/FLINK-33484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784752#comment-17784752
]
Darcy Lin commented on FLINK-33484:
---
[~martijnvisser] The issue remains the same with
boring-cyborg[bot] commented on PR #20:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/20#issuecomment-1805427501
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
leonardBang opened a new pull request, #20:
URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/20
Bump lowest supported flink version to 1.17.0 as the discussion thread[1]
[1] https://lists.apache.org/thread/2qqd59nng50k4po1dlyoxkwjmvb2fmb4
--
This is an automated
Jacky Lau created FLINK-33518:
-
Summary: Implement restore tests for WatermarkAssigner node
Key: FLINK-33518
URL: https://issues.apache.org/jira/browse/FLINK-33518
Project: Flink
Issue Type:
Jacky Lau created FLINK-33517:
-
Summary: Implement restore tests for Value node
Key: FLINK-33517
URL: https://issues.apache.org/jira/browse/FLINK-33517
Project: Flink
Issue Type: Sub-task
boring-cyborg[bot] commented on PR #67:
URL:
https://github.com/apache/flink-connector-kafka/pull/67#issuecomment-1805424464
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
531651225 opened a new pull request, #67:
URL: https://github.com/apache/flink-connector-kafka/pull/67
- Removing unnecessary transition symbols'/'in the document
` 'properties.sasl.jaas.config' =
'org.apache.kafka.common.security.scram.ScramLoginModule required
Martijn Visser created FLINK-33516:
--
Summary: Create dedicated PyFlink channel
Key: FLINK-33516
URL: https://issues.apache.org/jira/browse/FLINK-33516
Project: Flink
Issue Type: Improvement
gaborgsomogyi commented on PR #689:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/689#issuecomment-1805421386
What you're suggesting sounds better. I think we need 2 additional
parameters:
* `...trustore`
* `...trustore-password`
Not yet understand why keystore
ferenc-csaky commented on PR #23:
URL:
https://github.com/apache/flink-connector-hbase/pull/23#issuecomment-1805419097
cc @MartijnVisser
--
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
grzegorz8 commented on PR #67:
URL:
https://github.com/apache/flink-connector-jdbc/pull/67#issuecomment-1805376630
@eskabetxe Could you review the PR, please?
--
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-33513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784739#comment-17784739
]
Gabor Somogyi commented on FLINK-33513:
---
If that hurts the solution is not caching but adding a
KevDi commented on PR #75:
URL:
https://github.com/apache/flink-connector-jdbc/pull/75#issuecomment-1805360349
@eskabetxe @MartijnVisser i looked into this error but i was unable to
resolve it. I removed the mentioned import with explicit imports but then i get
an error telling me that
gyfora merged PR #704:
URL: https://github.com/apache/flink-kubernetes-operator/pull/704
--
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 PR #23656:
URL: https://github.com/apache/flink/pull/23656#issuecomment-1805337202
> I have a question, why we always follow hive and spark? if we thinks is a
feature need to support, we can implement it firstly. i think having rich
functions is better
[
https://issues.apache.org/jira/browse/FLINK-33059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Etienne Chauchot resolved FLINK-33059.
--
Fix Version/s: 1.19.0
Resolution: Fixed
master:
leoyy0316 commented on PR #23656:
URL: https://github.com/apache/flink/pull/23656#issuecomment-1805324411
> > trino support this function, we need use this function, so can we
suuport this function?
>
> I don't think Trino is the primary engine we compare ourselves against.
Does the
[
https://issues.apache.org/jira/browse/FLINK-33488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-33488.
Resolution: Implemented
Implemented in 88953ba622f4d3b67b59f56e15e1983e7932b926
>
[
https://issues.apache.org/jira/browse/FLINK-33401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784724#comment-17784724
]
Yuxin Tan edited comment on FLINK-33401 at 11/10/23 8:47 AM:
-
After merging
[
https://issues.apache.org/jira/browse/FLINK-33401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784724#comment-17784724
]
Yuxin Tan edited comment on FLINK-33401 at 11/10/23 8:47 AM:
-
After merging
dawidwys closed pull request #23686: [FLINK-33488] Implement restore tests for
Deduplicate node
URL: https://github.com/apache/flink/pull/23686
--
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-33401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784724#comment-17784724
]
Yuxin Tan commented on FLINK-33401:
---
After merging the Flink 1.19 hotfix
Zakelly commented on PR #23679:
URL: https://github.com/apache/flink/pull/23679#issuecomment-1805307753
> Can you squash the latest two fixup commits into the first two commits:
>
> ```
> [[FLINK-6755] Support manual checkpoints triggering from
Gabor Somogyi created FLINK-33515:
-
Summary: PythonDriver need to stream python process output to log
instead of collecting it in memory
Key: FLINK-33515
URL: https://issues.apache.org/jira/browse/FLINK-33515
Zakelly commented on code in PR #23679:
URL: https://github.com/apache/flink/pull/23679#discussion_r1389074605
##
docs/content.zh/docs/deployment/cli.md:
##
@@ -153,6 +153,35 @@ $ ./bin/flink savepoint \
Triggering the savepoint disposal through the `savepoint` action does not
1 - 100 of 125 matches
Mail list logo
