[
https://issues.apache.org/jira/browse/FLINK-33170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17770650#comment-17770650
]
Robert Hoyt commented on FLINK-33170:
-
If someone can point me to how to Flink's pol
[
https://issues.apache.org/jira/browse/FLINK-33170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Hoyt updated FLINK-33170:
Description:
Possibly related to FLINK-27916.
In all versions since 1.15.x there's a subtle bu
[
https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17770648#comment-17770648
]
袁枫 edited comment on FLINK-33155 at 9/30/23 4:22 AM:
-
The root cause
[
https://issues.apache.org/jira/browse/FLINK-33170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Hoyt updated FLINK-33170:
Description:
Possibly related to FLINK-27916.
In all versions since 1.15.x there's a subtle bu
[
https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17770648#comment-17770648
]
袁枫 commented on FLINK-33155:
The root cause might be that we are reading the delegation toke
[
https://issues.apache.org/jira/browse/FLINK-31689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17770637#comment-17770637
]
jirawech.s commented on FLINK-31689:
[~martijnvisser] Could you help with this PR, s
[
https://issues.apache.org/jira/browse/FLINK-31689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jirawech.s updated FLINK-31689:
---
Labels: pull-request-available (was: pull-request-available stale-assigned)
> Filesystem sink fails
Robert Hoyt created FLINK-33170:
---
Summary: HybridSourceSplitEnumerator causes dropped records in
Hybrid Sources with 3+ sources
Key: FLINK-33170
URL: https://issues.apache.org/jira/browse/FLINK-33170
Pr
[
https://issues.apache.org/jira/browse/FLINK-33028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-33028.
Resolution: Fixed
> FLIP-348: Make expanding behavior of virtual metadata columns configurable
> -
[
https://issues.apache.org/jira/browse/FLINK-33169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-33169.
Fix Version/s: 1.19.0
Resolution: Fixed
Fixed in master: b25b57c55d903e4fdd2b666de49c90bfba
alexey-lv commented on code in PR #23477:
URL: https://github.com/apache/flink/pull/23477#discussion_r1341861500
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/FlinkCalciteSqlValidator.java:
##
@@ -321,4 +332,131 @@ protected void addToSe
[
https://issues.apache.org/jira/browse/FLINK-33056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-33056:
---
Labels: auto-deprioritized-critical test-stability (was: stale-critical
test-stability)
[
https://issues.apache.org/jira/browse/FLINK-31406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-31406:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-16987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-16987:
---
Labels: auto-deprioritized-major pull-request-available (was:
pull-request-available stal
flinkbot commented on PR #23477:
URL: https://github.com/apache/flink/pull/23477#issuecomment-1741552430
## CI report:
* f87f3c33e5c345226efebdfbba51fe205f126a4f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33169:
---
Labels: pull-request-available (was: )
> Window TVFs don't consider column expansion
>
twalthr opened a new pull request, #23477:
URL: https://github.com/apache/flink/pull/23477
## What is the purpose of the change
"TABLE t" is translated into an implicit "SELECT * FROM t". This would
ignore columns
that are not expanded by default. However, the descriptor explicitly
[
https://issues.apache.org/jira/browse/FLINK-29398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-29398.
---
Resolution: Fixed
> Utilize Rack Awareness in Flink Consumer
> -
[
https://issues.apache.org/jira/browse/FLINK-29398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-29398:
Fix Version/s: kafka-3.1.0
> Utilize Rack Awareness in Flink Consumer
> --
[
https://issues.apache.org/jira/browse/FLINK-29398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17770582#comment-17770582
]
Tzu-Li (Gordon) Tai commented on FLINK-29398:
-
Thanks for driving this to th
tzulitai closed pull request #53: [FLINK-29398][connector/kafka] Provide rack
ID to Kafka Source to take advantage of Rack Awareness
URL: https://github.com/apache/flink-connector-kafka/pull/53
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
jeremy-degroot opened a new pull request, #53:
URL: https://github.com/apache/flink-connector-kafka/pull/53
## What is the purpose of the change
This PR adds a new method to KafkaSourceBuilder that sets the `client.id`
config for the KafkaSource to the value returned by the provided S
snuyanzin closed pull request #22412: [FLINK-31778][table-planner] Fix
RowToRowCastRule
URL: https://github.com/apache/flink/pull/22412
--
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 c
snuyanzin commented on PR #22412:
URL: https://github.com/apache/flink/pull/22412#issuecomment-1741286141
Thanks for the contibution and sorry for the fact that the fix was merged
under a different PR
I didn't know about this one till today
--
This is an automated message from the Ap
[
https://issues.apache.org/jira/browse/FLINK-31778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-31778.
---
Resolution: Duplicate
It looks like this issue has been fixed under
https://issues.apache.o
jeremy-degroot closed pull request #20: [FLINK-29398][connector/kafka] Provide
rack ID to Kafka Source to take advantage of Rack Awareness
URL: https://github.com/apache/flink-connector-kafka/pull/20
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
tzulitai commented on PR #20:
URL:
https://github.com/apache/flink-connector-kafka/pull/20#issuecomment-1741283245
Actually, @jeremy-degroot would you be able to squash all your changes into
one commit that is rebased on latest `main` branch? That would be super helpful.
--
This is an au
tzulitai commented on code in PR #20:
URL:
https://github.com/apache/flink-connector-kafka/pull/20#discussion_r1341644229
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java:
##
@@ -355,6 +360,17 @@ public KafkaSourceBuilder se
Timo Walther created FLINK-33169:
Summary: Window TVFs don't consider column expansion
Key: FLINK-33169
URL: https://issues.apache.org/jira/browse/FLINK-33169
Project: Flink
Issue Type: Sub-t
[
https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17770492#comment-17770492
]
Tzu-Li (Gordon) Tai commented on FLINK-30238:
-
[~martijnvisser] I've replied
[
https://issues.apache.org/jira/browse/FLINK-33028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reopened FLINK-33028:
--
> FLIP-348: Make expanding behavior of virtual metadata columns configurable
> ---
[
https://issues.apache.org/jira/browse/FLINK-33089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-33089:
---
Summary: Drop Flink 1.13 support (was: Drop Flink 1.14 support)
> Drop Flink 1.13 support
> ---
[
https://issues.apache.org/jira/browse/FLINK-33156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33156:
---
Labels: pull-request-available (was: )
> Remove flakiness from tests in OperatorStateBacken
asha-boyapati commented on PR #23464:
URL: https://github.com/apache/flink/pull/23464#issuecomment-1741011694
Thanks for your comments. I updated the title. I will look into your
suggestion of finding and fixing similar problems together.
--
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/FLINK-31778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17770463#comment-17770463
]
david radley commented on FLINK-31778:
--
[~soin08] It looks like this is fixed in m
gaborgsomogyi commented on PR #23417:
URL: https://github.com/apache/flink/pull/23417#issuecomment-1740951700
Rebased to the latest master.
--
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 spe
davidradl commented on PR #22412:
URL: https://github.com/apache/flink/pull/22412#issuecomment-1740879352
@soin08 hi , we are interested in getting this fix in - are you in a
position to fix the conflicts that are now present. Manyt thanks.
--
This is an automated message from the Apach
[
https://issues.apache.org/jira/browse/FLINK-31778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17770414#comment-17770414
]
david radley commented on FLINK-31778:
--
[~nictownsend] I have done a test on the s
rmetzger commented on PR #676:
URL: https://github.com/apache/flink-web/pull/676#issuecomment-1740784269
Why is "Powered By" in the footer and not in the "About" menu?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
RainerMatthiasS commented on PR #23239:
URL: https://github.com/apache/flink/pull/23239#issuecomment-1740768001
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 ?'
rmetzger commented on code in PR #676:
URL: https://github.com/apache/flink-web/pull/676#discussion_r1341269756
##
docs/i18n/zh.yaml:
##
@@ -0,0 +1,163 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE fil
rmetzger commented on code in PR #676:
URL: https://github.com/apache/flink-web/pull/676#discussion_r1341269428
##
docs/i18n/en.yaml:
##
@@ -0,0 +1,163 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE fil
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17770398#comment-17770398
]
Gabor Somogyi commented on FLINK-32223:
---
The normal build passed against master:
rmetzger commented on code in PR #676:
URL: https://github.com/apache/flink-web/pull/676#discussion_r1341267362
##
docs/i18n/en.yaml:
##
@@ -0,0 +1,163 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE fil
dannycranmer merged PR #677:
URL: https://github.com/apache/flink-web/pull/677
--
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.
echauchot commented on PR #23443:
URL: https://github.com/apache/flink/pull/23443#issuecomment-1740565364
R: @xintongsong I see your name in that code history, would you have time to
take a look ?
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
[
https://issues.apache.org/jira/browse/FLINK-33104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17770338#comment-17770338
]
Etienne Chauchot commented on FLINK-33104:
--
[~martijnvisser] actually it was ne
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi closed FLINK-32223.
-
> Add Hive delegation token support
> --
>
> Key: F
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi resolved FLINK-32223.
---
Fix Version/s: 1.19.0
Resolution: Fixed
e4c15aa on master
> Add Hive delegation tok
gaborgsomogyi commented on PR #23127:
URL: https://github.com/apache/flink/pull/23127#issuecomment-1740510003
We must track the nightly + all other builds not to break something. I'm
going to track things but I'm ask you @jiaoqingbo to do it also.
--
This is an automated message from the
gaborgsomogyi merged PR #23127:
URL: https://github.com/apache/flink/pull/23127
--
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
dawidwys commented on code in PR #23223:
URL: https://github.com/apache/flink/pull/23223#discussion_r1340991937
##
docs/layouts/shortcodes/generated/table_config_configuration.html:
##
@@ -62,6 +62,12 @@
String
The local time zone defines current sessio
52 matches
Mail list logo
