dannycranmer opened a new pull request, #23483:
URL: https://github.com/apache/flink/pull/23483
## What is the purpose of the change
- Docs update to rename Amazon Kinesis Data Analytics for Apache Flink to
Amazon Managed Service for Apache Flink and update website
##
dannycranmer opened a new pull request, #23487:
URL: https://github.com/apache/flink/pull/23487
## What is the purpose of the change
- Docs update to rename Amazon Kinesis Data Analytics for Apache Flink to
Amazon Managed Service for Apache Flink and update website
##
dannycranmer opened a new pull request, #23486:
URL: https://github.com/apache/flink/pull/23486
## What is the purpose of the change
- Docs update to rename Amazon Kinesis Data Analytics for Apache Flink to
Amazon Managed Service for Apache Flink and update website
##
gyfora commented on code in PR #677:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/677#discussion_r1343674332
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/DefaultJobAutoScalerContext.java:
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache
flinkbot commented on PR #23483:
URL: https://github.com/apache/flink/pull/23483#issuecomment-1744373180
## CI report:
* 0f3d135164217899d3a557c05bd9c4815d602754 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dannycranmer opened a new pull request, #23484:
URL: https://github.com/apache/flink/pull/23484
## What is the purpose of the change
- Docs update to rename Amazon Kinesis Data Analytics for Apache Flink to
Amazon Managed Service for Apache Flink and update website
##
dannycranmer opened a new pull request, #23485:
URL: https://github.com/apache/flink/pull/23485
## What is the purpose of the change
- Docs update to rename Amazon Kinesis Data Analytics for Apache Flink to
Amazon Managed Service for Apache Flink and update website
##
flinkbot commented on PR #23485:
URL: https://github.com/apache/flink/pull/23485#issuecomment-1744397445
## CI report:
* 10df774d2d902603cecf4446df2875a08c8d9731 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #23484:
URL: https://github.com/apache/flink/pull/23484#issuecomment-1744397241
## CI report:
* 02cae0220bfee1e56fcbe73640dc79e30aadfc69 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #23486:
URL: https://github.com/apache/flink/pull/23486#issuecomment-1744397925
## CI report:
* e6be950185fca51e8d3cc11508b9b970f7112dac UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gyfora commented on code in PR #677:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/677#discussion_r1343663466
##
flink-autoscaler/pom.xml:
##
@@ -45,6 +45,32 @@ under the License.
provided
+
+org.projectlombok
+
flinkbot commented on PR #23487:
URL: https://github.com/apache/flink/pull/23487#issuecomment-1744398510
## CI report:
* 9b45d84f21974e49ed84f3c45b0d8b4ce22ab5e8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gyfora commented on code in PR #682:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/682#discussion_r1343685178
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/validation/AutoScalerValidator.java:
##
@@ -0,0
Chandra Prakash created FLINK-33180:
---
Summary: Implement support for processing subset of shards/traffic
Key: FLINK-33180
URL: https://issues.apache.org/jira/browse/FLINK-33180
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-33116:
---
Labels: stale-critical test-stability (was: test-stability)
I am the [Flink Jira
[
https://issues.apache.org/jira/browse/FLINK-33114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-33114:
---
Labels: stale-critical test-stability (was: test-stability)
I am the [Flink Jira
[
https://issues.apache.org/jira/browse/FLINK-33115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-33115:
---
Labels: stale-critical test-stability (was: test-stability)
I am the [Flink Jira
[
https://issues.apache.org/jira/browse/FLINK-32471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-32471:
---
Labels: auto-deprioritized-major pull-request-available (was:
pull-request-available
[
https://issues.apache.org/jira/browse/FLINK-20886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-20886:
---
Labels: auto-deprioritized-major auto-deprioritized-minor stale-assigned
usability (was:
[
https://issues.apache.org/jira/browse/FLINK-32743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-32743:
---
Labels: pull-request-available stale-major (was: pull-request-available)
I am the [Flink
jgagnon1 commented on PR #23453:
URL: https://github.com/apache/flink/pull/23453#issuecomment-1745673593
@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
tzulitai commented on PR #52:
URL:
https://github.com/apache/flink-connector-kafka/pull/52#issuecomment-1745834273
Thanks for the explanation @Tan-JiaLiang. This is aligned with @Ge and
my understanding as well after we discussed this offline.
I'm going to do one more pass now
tzulitai commented on PR #52:
URL:
https://github.com/apache/flink-connector-kafka/pull/52#issuecomment-1745879187
I thought about this more closely, and while the current fix will work, I'm
not so sure it's actually how we want to do things. My main issue with this PR
is the following
tzulitai commented on PR #52:
URL:
https://github.com/apache/flink-connector-kafka/pull/52#issuecomment-1745836707
One more comment:
It seems like the old `FlinkKafkaConsumer` (on the deprecated
`SourceFunction` interface) was handling this case correctly.
Apparently, this corner
srpraneeth commented on code in PR #682:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/682#discussion_r1344537516
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/validation/AutoScalerValidator.java:
##
@@
srpraneeth commented on PR #682:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/682#issuecomment-1745493021
@mateczagany @gyfora
Can you please review again. I have fixed the comments and the latest rules
validated as below
|| Rule | Affecting Property |
dannycranmer merged PR #103:
URL: https://github.com/apache/flink-connector-aws/pull/103
--
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-23633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-23633:
---
Component/s: Connectors / HybridSource
(was: Connectors / FileSystem)
[
https://issues.apache.org/jira/browse/FLINK-24252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-24252:
---
Component/s: Connectors / HybridSource
> HybridSource should return TypeInformation
>
[
https://issues.apache.org/jira/browse/FLINK-33178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17771603#comment-17771603
]
Martijn Visser commented on FLINK-33178:
[~iemre] Thanks for opening the ticket, but Flink 1.13
[
https://issues.apache.org/jira/browse/FLINK-22793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-22793:
---
Component/s: Connectors / HybridSource
(was: Connectors / Common)
>
[
https://issues.apache.org/jira/browse/FLINK-22668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-22668:
---
Component/s: Connectors / HybridSource
(was: Connectors / Common)
>
[
https://issues.apache.org/jira/browse/FLINK-33179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33179:
---
Labels: pull-request-available (was: )
> Improve reporting serialisation issues
>
dawidwys opened a new pull request, #23488:
URL: https://github.com/apache/flink/pull/23488
## What is the purpose of the change
The change prohibits serialising `ExecNode` with a wrong type. Previously it
was possible to create a `null_null` type.
Moreover it gives a better
[
https://issues.apache.org/jira/browse/FLINK-33175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17771586#comment-17771586
]
Martijn Visser commented on FLINK-33175:
It looks like uploads are still happening, like in
[
https://issues.apache.org/jira/browse/FLINK-30514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-30514:
---
Component/s: Connectors / HybridSource
(was: Connectors / FileSystem)
[
https://issues.apache.org/jira/browse/FLINK-27529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-27529:
---
Component/s: Connectors / HybridSource
(was: Connectors / Common)
>
[
https://issues.apache.org/jira/browse/FLINK-33170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-33170:
---
Component/s: Connectors / HybridSource
(was: Connectors / Common)
>
[
https://issues.apache.org/jira/browse/FLINK-22790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-22790:
---
Component/s: Connectors / HybridSource
(was: Connectors / Common)
>
flinkbot commented on PR #23488:
URL: https://github.com/apache/flink/pull/23488#issuecomment-1745071411
## CI report:
* 8db7aca7cca1f6a3ac0c82e70d3de36ae7400015 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17771507#comment-17771507
]
Dominik Wosiński commented on FLINK-30284:
--
This basically makes it impossible to directly
hlteoh37 opened a new pull request, #103:
URL: https://github.com/apache/flink-connector-aws/pull/103
## Purpose of the change
* Fix AWS end to end tests in CI build.
## Verifying this change
Verified that the secrets are pulled + AWS e2e tests run successfully in
private
[
https://issues.apache.org/jira/browse/FLINK-33170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17771610#comment-17771610
]
Martijn Visser commented on FLINK-33170:
[~robertjira] Have a look at
tzulitai commented on PR #52:
URL:
https://github.com/apache/flink-connector-kafka/pull/52#issuecomment-1745990525
@Tan-JiaLiang @Ge I'm going to open a new alternative PR tonight that
addresses the problem based on my latest proposal, and will cherry pick over
all new tests added
MartijnVisser closed pull request #15152: [FLINK-20625][pubsub,e2e] Add Google
Cloud Pub/Sub source connector in accordance with FLIP-27
URL: https://github.com/apache/flink/pull/15152
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
dannycranmer commented on code in PR #102:
URL:
https://github.com/apache/flink-connector-aws/pull/102#discussion_r1343856160
##
flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/RowDataKinesisDeserializationSchema.java:
Emre Kartoglu created FLINK-33178:
-
Summary: Highly parallel apps suffer from bottleneck in NativePRNG
Key: FLINK-33178
URL: https://issues.apache.org/jira/browse/FLINK-33178
Project: Flink
z3d1k commented on code in PR #102:
URL:
https://github.com/apache/flink-connector-aws/pull/102#discussion_r1343894856
##
flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/RowDataKinesisDeserializationSchema.java:
##
[
https://issues.apache.org/jira/browse/FLINK-33176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33176:
---
Labels: pull-request-available (was: )
> Kinesis source throws NullPointerException in
z3d1k opened a new pull request, #102:
URL: https://github.com/apache/flink-connector-aws/pull/102
## Purpose of the change
Handle null value during record deserialization in Table API with metadata
fields present in source table definition.
## Verifying this change
RyanSkraba commented on PR #15152:
URL: https://github.com/apache/flink/pull/15152#issuecomment-1744455194
For info: this PR has been migrated with the connector and can be closed.
The new PR is from my repo but the commits retain @JakobEdding 's authorship.
--
This is an automated
MartijnVisser commented on PR #20775:
URL: https://github.com/apache/flink/pull/20775#issuecomment-1744498589
@Aitozi Can you move this PR to
https://github.com/apache/flink-connector-kafka ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please
MartijnVisser commented on PR #20775:
URL: https://github.com/apache/flink/pull/20775#issuecomment-1744499362
@Aitozi Can you rebase 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 above to go to the
dannycranmer commented on PR #23485:
URL: https://github.com/apache/flink/pull/23485#issuecomment-1744604395
@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
hlteoh37 commented on code in PR #102:
URL:
https://github.com/apache/flink-connector-aws/pull/102#discussion_r1343874669
##
flink-connector-aws/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/testutils/FakeDeserializationSchema.java:
##
@@
foxus commented on PR #23483:
URL: https://github.com/apache/flink/pull/23483#issuecomment-1744684088
LGTM.
--
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,
z3d1k commented on code in PR #102:
URL:
https://github.com/apache/flink-connector-aws/pull/102#discussion_r1343894856
##
flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/RowDataKinesisDeserializationSchema.java:
##
[
https://issues.apache.org/jira/browse/FLINK-33158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17771467#comment-17771467
]
Dawid Wysakowicz edited comment on FLINK-33158 at 10/3/23 12:51 PM:
sandesh89 opened a new pull request, #679:
URL: https://github.com/apache/flink-web/pull/679
(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.
To unsubscribe,
Dawid Wysakowicz created FLINK-33179:
Summary: Improve reporting serialisation issues
Key: FLINK-33179
URL: https://issues.apache.org/jira/browse/FLINK-33179
Project: Flink
Issue Type:
dannycranmer merged PR #679:
URL: https://github.com/apache/flink-web/pull/679
--
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:
z3d1k commented on code in PR #102:
URL:
https://github.com/apache/flink-connector-aws/pull/102#discussion_r1344022639
##
flink-connector-aws/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/testutils/FakeDeserializationSchema.java:
##
@@
dawidwys merged PR #23468:
URL: https://github.com/apache/flink/pull/23468
--
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-33158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-33158.
Resolution: Fixed
Fixed in 4afd09245823a1cf2d849dbd84c1b6d5ab58c875
> Cryptic exception
dawidwys commented on PR #23468:
URL: https://github.com/apache/flink/pull/23468#issuecomment-1744888627
Good point. I'll merge this since it is an improvement for `StreamExecSort`.
I'll work for a more generic solution for serialisation issues in the
`ExecNodeGraph` in
[
https://issues.apache.org/jira/browse/FLINK-33158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-33158:
-
Fix Version/s: 1.18.1
(was: 1.18.0)
> Cryptic exception when
66 matches
Mail list logo
