[
https://issues.apache.org/jira/browse/FLINK-33082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17771716#comment-17771716
]
Matthias Pohl commented on FLINK-33082:
---
[~Sergey Nuyanzin] That looks like a Azur
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 alre
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 beh
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 case
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 an
[
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 Bot|https:
[
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 stal
[
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 Bot|https:
[
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 Bot|https:
[
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 Ji
[
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: au
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 comment.
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-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-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-22668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-22668:
---
Component/s: Connectors / HybridSource
(was: Connectors / Common)
> FLI
[
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)
> Hyb
[
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-22790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-22790:
---
Component/s: Connectors / HybridSource
(was: Connectors / Common)
> Hyb
[
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)
> Hyb
[
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)
> Hyb
[
https://issues.apache.org/jira/browse/FLINK-33170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17771610#comment-17771610
]
Martijn Visser commented on FLINK-33170:
[~robertjira] Have a look at
https://f
[
https://issues.apache.org/jira/browse/FLINK-33178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17771603#comment-17771603
]
Martijn Visser commented on FLINK-33178:
[~iemre] Thanks for opening the ticket,
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:
##
@@ -0,
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 | M
[
https://issues.apache.org/jira/browse/FLINK-33175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17771586#comment-17771586
]
Martijn Visser commented on FLINK-33175:
It looks like uploads are still happeni
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: issues-unsubscr
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 re
[
https://issues.apache.org/jira/browse/FLINK-30284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17771507#comment-17771507
]
Dominik Wosiński commented on FLINK-30284:
--
This basically makes it impossible
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-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 except
[
https://issues.apache.org/jira/browse/FLINK-33158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17771467#comment-17771467
]
Dawid Wysakowicz edited comment on FLINK-33158 at 10/3/23 12:51 PM:
--
[
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 ther
[
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 w
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: issues-unsubscr...@flink.apac
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.apach
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: Su
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:
##
@@ -0,0
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: issues-unsubscr...@flink.
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, e-
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:
##
@
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:
##
@
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
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,
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:
##
@@ -
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:
#
[
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 Tabl
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
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 comme
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 s
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 lo
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 Git
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 messa
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 +1
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 Softw
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`
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`
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`
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
## Brief
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
## Brief
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
## Brief
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
## Brief
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, #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
## Brief
67 matches
Mail list logo
