[
https://issues.apache.org/jira/browse/FLINK-33170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17770650#comment-17770650
]
Robert Hoyt commented on FLINK-33170:
-
If someone can point me to how to Flink's policies on
[
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
[
https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17770648#comment-17770648
]
袁枫 edited comment on FLINK-33155 at 9/30/23 4:22 AM:
-
The root cause might be that
[
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
[
https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17770648#comment-17770648
]
袁枫 commented on FLINK-33155:
The root cause might be that we are reading the delegation token from JM local
[
https://issues.apache.org/jira/browse/FLINK-31689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17770637#comment-17770637
]
jirawech.s commented on FLINK-31689:
[~martijnvisser] Could you help with this PR, seems like no one
[
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
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
[
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:
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
[
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
[
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
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
[
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=17770582#comment-17770582
]
Tzu-Li (Gordon) Tai commented on FLINK-29398:
-
Thanks for driving this to the finish line
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
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
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
[
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
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,
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
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
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:
[
https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17770492#comment-17770492
]
Tzu-Li (Gordon) Tai commented on FLINK-30238:
-
[~martijnvisser] I've replied to your
[
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
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=17770463#comment-17770463
]
david radley commented on FLINK-31778:
--
[~soin08] It looks like this is fixed in master
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
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
[
https://issues.apache.org/jira/browse/FLINK-31778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17770414#comment-17770414
]
david radley commented on FLINK-31778:
--
[~nictownsend] I have done a test on the scenario you
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
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:
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,
[
https://issues.apache.org/jira/browse/FLINK-33104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17770338#comment-17770338
]
Etienne Chauchot commented on FLINK-33104:
--
[~martijnvisser] actually it was never fixed in
[
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:
[
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
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:
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
[
https://issues.apache.org/jira/browse/FLINK-33168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
macdoor615 updated FLINK-33168:
---
Description:
Environment:
{code:java}
Linux hb3-prod-hadoop-006 4.18.0-477.27.1.el8_8.x86_64 #1
macdoor615 created FLINK-33168:
--
Summary: An error occurred when executing sql,
java.lang.NoSuchFieldError: operands
Key: FLINK-33168
URL: https://issues.apache.org/jira/browse/FLINK-33168
Project:
54 matches
Mail list logo
