xintongsong commented on PR #25516:
URL: https://github.com/apache/flink/pull/25516#issuecomment-2451383721
@liangyu-1
Sorry for the late response. I was on a business travel for the past 2 weeks.
I'm not entirely sure about this feature. Why do we need thread level audit
logs
RanJinh commented on PR #25594:
URL: https://github.com/apache/flink/pull/25594#issuecomment-2451354439
@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.
LvYanquan created FLINK-36648:
-
Summary: bump flink version to 2.0-preview1 for Kafka connector
Key: FLINK-36648
URL: https://issues.apache.org/jira/browse/FLINK-36648
Project: Flink
Issue Type:
yuxiqian closed pull request #3676: [hotfix][tests] Tolerate schema change
timeout failure and retry, suppress false alarms
URL: https://github.com/apache/flink-cdc/pull/3676
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
yuxiqian commented on PR #3676:
URL: https://github.com/apache/flink-cdc/pull/3676#issuecomment-2451223322
After some pressure tests, it turns out that job just keeps stuck even after
restarts. Seems some special pattern of event mixture will 100% cause
FlushEvent to stuck. This won't make
[
https://issues.apache.org/jira/browse/FLINK-36613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894752#comment-17894752
]
Jinhao Ran commented on FLINK-36613:
here's another
one:https://dev.azure.com/apach
RanJinh commented on PR #25595:
URL: https://github.com/apache/flink/pull/25595#issuecomment-2451177330
@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.
yuxiqian commented on code in PR #3677:
URL: https://github.com/apache/flink-cdc/pull/3677#discussion_r1825343077
##
docs/content.zh/docs/core-concept/transform.md:
##
@@ -131,18 +131,18 @@ Flink CDC uses [Calcite](https://calcite.apache.org/) to
parse expressions and [
## T
yuxiqian commented on PR #3676:
URL: https://github.com/apache/flink-cdc/pull/3676#issuecomment-2451135558
Low priority but should improve CI passing rate, cc @ruanhang1993
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
aiwenmo commented on code in PR #3677:
URL: https://github.com/apache/flink-cdc/pull/3677#discussion_r1825342027
##
docs/content/docs/core-concept/transform.md:
##
@@ -131,18 +131,18 @@ Flink CDC uses [Calcite](https://calcite.apache.org/) to
parse expressions and [
## Tempo
aiwenmo commented on code in PR #3677:
URL: https://github.com/apache/flink-cdc/pull/3677#discussion_r1825341915
##
docs/content.zh/docs/core-concept/transform.md:
##
@@ -131,18 +131,18 @@ Flink CDC uses [Calcite](https://calcite.apache.org/) to
parse expressions and [
## Te
yuxiqian commented on code in PR #3677:
URL: https://github.com/apache/flink-cdc/pull/3677#discussion_r1825331347
##
flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformOperatorTest.java:
##
@@ -1483,6 +1496,107 @@ void testCastErrorTran
aiwenmo commented on code in PR #3677:
URL: https://github.com/apache/flink-cdc/pull/3677#discussion_r1825341113
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/SystemFunctionUtils.java:
##
@@ -645,4 +645,32 @@ private static String castObjectIntoString
aiwenmo commented on code in PR #3677:
URL: https://github.com/apache/flink-cdc/pull/3677#discussion_r1825340723
##
flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformOperatorTest.java:
##
@@ -1483,6 +1496,107 @@ void testCastErrorTrans
yuxiqian commented on code in PR #3677:
URL: https://github.com/apache/flink-cdc/pull/3677#discussion_r1825335218
##
docs/content/docs/core-concept/transform.md:
##
@@ -131,18 +131,18 @@ Flink CDC uses [Calcite](https://calcite.apache.org/) to
parse expressions and [
## Temp
yuxiqian commented on PR #3656:
URL: https://github.com/apache/flink-cdc/pull/3656#issuecomment-2451133207
> Seems that the CI test of `2024-10-30T13:03:29.2042562Z [ERROR]
TransformE2eITCase.testHeteroSchemaTransform Time elapsed: 74.649 s <<< ERROR!
2024-10-30T13:03:29.2049354Z java.util.
herunkang2018 commented on PR #3656:
URL: https://github.com/apache/flink-cdc/pull/3656#issuecomment-2451129024
Seems that the CI test of `2024-10-30T13:03:29.2042562Z [ERROR]
TransformE2eITCase.testHeteroSchemaTransform Time elapsed: 74.649 s <<< ERROR!
2024-10-30T13:03:29.2049354Z ja
[
https://issues.apache.org/jira/browse/FLINK-36647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894746#comment-17894746
]
Wenkai Qi commented on FLINK-36647:
---
[~leonard]. I would like to hear your suggestion.
Wenkai Qi created FLINK-36647:
-
Summary: Support TimestampDiff function in cdc pipeline transform
Key: FLINK-36647
URL: https://issues.apache.org/jira/browse/FLINK-36647
Project: Flink
Issue Type
cobolbaby commented on PR #2571:
URL: https://github.com/apache/flink-cdc/pull/2571#issuecomment-2451102085
Please take some time to review the PR. Many improvements haven’t been
merged yet.
@loserwang1024
--
This is an automated message from the Apache Git Service.
To respond to t
github-actions[bot] commented on PR #2571:
URL: https://github.com/apache/flink-cdc/pull/2571#issuecomment-2451043878
This pull request has been closed because it has not had recent activity.
You could reopen it if you try to continue your work, and anyone who are
interested in it are encou
github-actions[bot] closed pull request #2705: [hotfix] [base] Fix the
serialization error occurring with table names containing dot
URL: https://github.com/apache/flink-cdc/pull/2705
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
github-actions[bot] closed pull request #3430: [FLINK-35654][docs] Add CDC
release verification & Installation guide
URL: https://github.com/apache/flink-cdc/pull/3430
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
github-actions[bot] closed pull request #2571: [postgres] Remove unnecessary
schema fresh to improve performance.
URL: https://github.com/apache/flink-cdc/pull/2571
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
github-actions[bot] commented on PR #3430:
URL: https://github.com/apache/flink-cdc/pull/3430#issuecomment-2451043774
This pull request has been closed because it has not had recent activity.
You could reopen it if you try to continue your work, and anyone who are
interested in it are encou
github-actions[bot] commented on PR #3467:
URL: https://github.com/apache/flink-cdc/pull/3467#issuecomment-2451043710
This pull request has been closed because it has not had recent activity.
You could reopen it if you try to continue your work, and anyone who are
interested in it are encou
github-actions[bot] commented on PR #2705:
URL: https://github.com/apache/flink-cdc/pull/2705#issuecomment-2451043858
This pull request has been closed because it has not had recent activity.
You could reopen it if you try to continue your work, and anyone who are
interested in it are encou
github-actions[bot] closed pull request #3467: [FLINK-35757][mysql] support
dynamically capture new tables
URL: https://github.com/apache/flink-cdc/pull/3467
--
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 t
SamBarker commented on PR #893:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/893#issuecomment-2450957960
I think I've finally got the excludes to align with main. *sigh* That was a
lot more fuss than I wanted and doesn't end up as clean as I was hoping.
However I think thi
[
https://issues.apache.org/jira/browse/FLINK-36645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi reassigned FLINK-36645:
-
Assignee: Sai Sharath Dandi
> Gracefully handle null execution plan from autoscaler
> -
[
https://issues.apache.org/jira/browse/FLINK-36645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-36645:
--
Component/s: Kubernetes Operator
> Gracefully handle null execution plan from autoscaler
> ---
[
https://issues.apache.org/jira/browse/FLINK-36646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rob Young updated FLINK-36646:
--
Description:
Currently if I execute the operator quickstart, but change the FlinkDeployment
image to
[
https://issues.apache.org/jira/browse/FLINK-36646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rob Young updated FLINK-36646:
--
Description:
Currently if I execute the operator quickstart (for operator 1.10.0) , but
change the Fl
[
https://issues.apache.org/jira/browse/FLINK-36646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rob Young updated FLINK-36646:
--
Description:
Currently if I execute the operator quickstart, but change the FlinkDeployment
image to
[
https://issues.apache.org/jira/browse/FLINK-36646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rob Young updated FLINK-36646:
--
Description:
Currently if I execute the operator quickstart, but change the FlinkDeployment
image to
Rob Young created FLINK-36646:
-
Summary: Support Java 17+ job images more conveniently in the
operator
Key: FLINK-36646
URL: https://issues.apache.org/jira/browse/FLINK-36646
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-36644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36644:
---
Labels: pull-request-available (was: )
> TIMESTAMPDIFF can not be string serialized
> -
hlteoh37 merged PR #178:
URL: https://github.com/apache/flink-connector-aws/pull/178
--
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: issues-unsubscr...@
[
https://issues.apache.org/jira/browse/FLINK-36409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894700#comment-17894700
]
Sai Sharath Dandi commented on FLINK-36409:
---
Hello [~morhidi] , are you workin
Sai Sharath Dandi created FLINK-36645:
-
Summary: Gracefully handle null execution plan from autoscaler
Key: FLINK-36645
URL: https://issues.apache.org/jira/browse/FLINK-36645
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-36640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-36640:
--
Description:
FLINK-32589 introduced a feature to carry over parallelism overrides between
app
[
https://issues.apache.org/jira/browse/FLINK-36640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894670#comment-17894670
]
Gyula Fora commented on FLINK-36640:
That was a design choice we made, so max parall
[
https://issues.apache.org/jira/browse/FLINK-36640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894667#comment-17894667
]
Matyas Orhidi commented on FLINK-36640:
---
We have also seen issues reported that cu
twalthr commented on code in PR #25582:
URL: https://github.com/apache/flink/pull/25582#discussion_r1824871775
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OverTypeStrategy.java:
##
@@ -182,18 +204,16 @@ private Optional valid
[
https://issues.apache.org/jira/browse/FLINK-36640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894666#comment-17894666
]
Gyula Fora commented on FLINK-36640:
[https://nightlies.apache.org/flink/flink-docs-
[
https://issues.apache.org/jira/browse/FLINK-36639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-36639:
-
Description:
Certain operations do not work without explicitly scoping a fieldreference.
[
https://issues.apache.org/jira/browse/FLINK-36637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh resolved FLINK-36637.
-
Resolution: Fixed
merged commit
[{{30d32fd}}|https://github.com/apache/flink-connector
twalthr commented on code in PR #25582:
URL: https://github.com/apache/flink/pull/25582#discussion_r1824689298
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Expressions.java:
##
@@ -947,6 +947,120 @@ public static ApiExpression jsonArrayAgg(JsonOnN
[
https://issues.apache.org/jira/browse/FLINK-36636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-36636:
--
Assignee: Wenkai Qi
> Timestamp data can not be compared in cdc pipeline transform
>
dawidwys commented on code in PR #25582:
URL: https://github.com/apache/flink/pull/25582#discussion_r1824757089
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OverTypeStrategy.java:
##
@@ -182,18 +204,16 @@ private Optional vali
dawidwys commented on code in PR #25582:
URL: https://github.com/apache/flink/pull/25582#discussion_r1824754990
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OverTypeStrategy.java:
##
@@ -182,18 +204,16 @@ private Optional vali
[
https://issues.apache.org/jira/browse/FLINK-36643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36643:
---
Labels: pull-request-available (was: )
> Upgrade aws-java-sdk-core to 1.12.773+ to fix vuln
aiwenmo commented on PR #3677:
URL: https://github.com/apache/flink-cdc/pull/3677#issuecomment-2450240189
PTAL @leonardBang @yuxiqian
--
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
[
https://issues.apache.org/jira/browse/FLINK-36641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-36641:
--
Assignee: LvYanquan
> Support and Release Connectors for Flink 1.20
> ---
flinkbot commented on PR #25595:
URL: https://github.com/apache/flink/pull/25595#issuecomment-2449167467
## CI report:
* fdfd5e2d49d4a18af5b603458f106e92a57f7910 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #25600:
URL: https://github.com/apache/flink/pull/25600#issuecomment-2450231843
## CI report:
* d4c6986268474212bb53e762524f7e4e5de36f86 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #25599:
URL: https://github.com/apache/flink/pull/25599#issuecomment-2450185146
## CI report:
* bfb5fdfd897de9b790f0516cb00a54315abeccfa UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
tomncooper opened a new pull request, #25600:
URL: https://github.com/apache/flink/pull/25600
## What is the purpose of the change
The current version of `aws-java-sdk-core`, used in the `flink-s3-fs-base`
module, has a high severity vulnerability
([CVE-2024-21634](https://nvd.nist.g
[
https://issues.apache.org/jira/browse/FLINK-36637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36637:
---
Labels: pull-request-available (was: )
> Fix ListShards for Kinesis streams with large numb
elphastori opened a new pull request, #178:
URL: https://github.com/apache/flink-connector-aws/pull/178
## Purpose of the change
Fixes ListShards for Kinesis streams with large number of shards
## Verifying this change
This change is already covered by existing unit tests
rkhachatryan commented on code in PR #25598:
URL: https://github.com/apache/flink/pull/25598#discussion_r1824687101
##
flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java:
##
@@ -166,53 +171,57 @@ public SourceCoordinator(
@Visib
[
https://issues.apache.org/jira/browse/FLINK-36626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduardo Breijo updated FLINK-36626:
---
Description:
There is a behavior change I found when migrating to Flink 1.18 or Flink 1.20
dawidwys commented on PR #24699:
URL: https://github.com/apache/flink/pull/24699#issuecomment-2450178329
@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.
dawidwys opened a new pull request, #25599:
URL: https://github.com/apache/flink/pull/25599
## What is the purpose of the change
Make it possible to string serialize `TIMESTAMPDIFF`
## Verifying this change
Added tests in `ExpressionSerializationTest`
## Does t
[
https://issues.apache.org/jira/browse/FLINK-36643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Cooper updated FLINK-36643:
--
Affects Version/s: 2.0.0
> Upgrade aws-java-sdk-core to 1.12.773+ to fix vulnerability
> -
Thomas Cooper created FLINK-36643:
-
Summary: Upgrade aws-java-sdk-core to 1.12.773+ to fix
vulnerability
Key: FLINK-36643
URL: https://issues.apache.org/jira/browse/FLINK-36643
Project: Flink
Dawid Wysakowicz created FLINK-36644:
Summary: TIMESTAMPDIFF can not be string serialized
Key: FLINK-36644
URL: https://issues.apache.org/jira/browse/FLINK-36644
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-36643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Cooper updated FLINK-36643:
--
Component/s: FileSystems
> Upgrade aws-java-sdk-core to 1.12.773+ to fix vulnerability
> -
mxm commented on PR #25218:
URL: https://github.com/apache/flink/pull/25218#issuecomment-2450152448
The idea of the JobResourceRequirements API is to allow changing the
resource profile of jobs. Users expect lower resource requirements to result in
fewer TaskManagers, which isn't the case w
Fabian Hueske created FLINK-36642:
-
Summary: Table API expressions with several built-in functions are
not correctly serialized to SQL
Key: FLINK-36642
URL: https://issues.apache.org/jira/browse/FLINK-36642
pnowojski opened a new pull request, #25598:
URL: https://github.com/apache/flink/pull/25598
## What is the purpose of the change
Log JobID from the SourceCoordinator
## Brief change log
Log JobID from the SourceCoordinator
## Verifying this change
Adds
tomncooper commented on PR #25573:
URL: https://github.com/apache/flink/pull/25573#issuecomment-2450102032
@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-36635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36635:
---
Labels: pull-request-available (was: )
> PhysicalSlotRequestBulkImpl is not used and can be
[
https://issues.apache.org/jira/browse/FLINK-36626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduardo Breijo updated FLINK-36626:
---
Summary: Flink SQL temporal lookup JOINs behavior change from Flink 1.15 to
Flink 1.20 (was
[
https://issues.apache.org/jira/browse/FLINK-36626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduardo Breijo updated FLINK-36626:
---
Attachment: (was: Flink-SQL-query.txt)
> Flink SQL temporal lookup JOINs behavior change
[
https://issues.apache.org/jira/browse/FLINK-36640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-36640:
--
Description:
FLINK-32589 introduced a feature to carry over parallelism overrides between
app
[
https://issues.apache.org/jira/browse/FLINK-36640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-36640:
--
Description:
FLINK-32589 introduced a feature to carry over parallelism overrides between
app
snuyanzin commented on code in PR #25597:
URL: https://github.com/apache/flink/pull/25597#discussion_r1824531739
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/SourceQueryOperation.java:
##
@@ -43,6 +41,7 @@
@Internal
public class SourceQue
flinkbot commented on PR #25598:
URL: https://github.com/apache/flink/pull/25598#issuecomment-2449903861
## CI report:
* 122ac9207e0c519886741746ad5f3a0ff561ff96 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36624:
---
Labels: pull-request-available (was: )
> Log JobID in SourceCoordinator
> -
[
https://issues.apache.org/jira/browse/FLINK-36626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduardo Breijo updated FLINK-36626:
---
Description:
There is a behavior change I found when migrating to Flink 1.18+ from Flink
1.
[
https://issues.apache.org/jira/browse/FLINK-36626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduardo Breijo updated FLINK-36626:
---
Description:
There is a behavior change I found when migrating to Flink 1.18 or Flink 1.20
[
https://issues.apache.org/jira/browse/FLINK-36626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduardo Breijo updated FLINK-36626:
---
Summary: Flink SQL temporal lookup JOINs behavior change from Flink 1.15 to
Flink 1.20+ (wa
[
https://issues.apache.org/jira/browse/FLINK-36626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduardo Breijo updated FLINK-36626:
---
Attachment: Tasks Execution Plan.txt
> Flink SQL temporal lookup JOINs behavior change from
[
https://issues.apache.org/jira/browse/FLINK-36626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eduardo Breijo updated FLINK-36626:
---
Description:
There is a behavior change I found when migrating to Flink 1.18+ from Flink
1.
[
https://issues.apache.org/jira/browse/FLINK-36640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-36640:
--
Description:
FLINK-32589 introduced a feature to carry over parallelism overrides between
app
noorall commented on code in PR #25414:
URL: https://github.com/apache/flink/pull/25414#discussion_r1824264927
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/util/ImmutableStreamNode.java:
##
@@ -0,0 +1,70 @@
+/*
+ * Licensed to the Apache Software Foundatio
[
https://issues.apache.org/jira/browse/FLINK-36640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-36640:
--
Description: FLINK-32589 introduced a feature to carry over parallelism
overrides between appl
[
https://issues.apache.org/jira/browse/FLINK-36640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894574#comment-17894574
]
Matyas Orhidi commented on FLINK-36640:
---
I couldn't find the {{jobvertex-paralleli
flinkbot commented on PR #25597:
URL: https://github.com/apache/flink/pull/25597#issuecomment-2449787647
## CI report:
* ab1906321e0548c6ffafb6c31d198a1a05bad0bc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36636:
---
Labels: pull-request-available (was: )
> Timestamp data can not be compared in cdc pipeline
[
https://issues.apache.org/jira/browse/FLINK-35136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894555#comment-17894555
]
Ferenc Csaky commented on FLINK-35136:
--
[{{35c5d83}}|https://github.com/apache/flin
[
https://issues.apache.org/jira/browse/FLINK-36639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36639:
---
Labels: pull-request-available (was: )
> Use table aliases in Table API asSerializableStrin
dawidwys opened a new pull request, #25597:
URL: https://github.com/apache/flink/pull/25597
## What is the purpose of the change
Scope all references in Table API when converting to a SQL string.
## Verifying this change
This change adapted tests in
`org.apache.flink
[
https://issues.apache.org/jira/browse/FLINK-36640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894558#comment-17894558
]
Gyula Fora commented on FLINK-36640:
I don't think that we would need to introduce a
LvYanquan created FLINK-36641:
-
Summary: Support and Release Connectors for Flink 1.20
Key: FLINK-36641
URL: https://issues.apache.org/jira/browse/FLINK-36641
Project: Flink
Issue Type: Improveme
[
https://issues.apache.org/jira/browse/FLINK-36640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-36640:
--
Description: FLINK-32589 introduced a feature to carry over parallelism
overrides between appl
Matyas Orhidi created FLINK-36640:
-
Summary: Provide an easy way to reset autoscaling
Key: FLINK-36640
URL: https://issues.apache.org/jira/browse/FLINK-36640
Project: Flink
Issue Type: Improv
ferenc-csaky merged PR #46:
URL: https://github.com/apache/flink-connector-hbase/pull/46
--
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: issues-unsubscr
[
https://issues.apache.org/jira/browse/FLINK-36637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh reassigned FLINK-36637:
---
Assignee: Elphas Toringepi
> Fix ListShards for Kinesis streams with large number o
1 - 100 of 134 matches
Mail list logo
