HuangZhenQiu opened a new pull request, #26101:
URL: https://github.com/apache/flink/pull/26101
## What is the purpose of the change
In the Flink yarn deployment mode, It is possible that the deployment
service acquire the delegation tokens in advance for yarn clusters to download
ja
Zhanghao Chen created FLINK-37249:
-
Summary: Remove unnecessary --add-opens/--add-exports for
java.base/sun.net.util
Key: FLINK-37249
URL: https://issues.apache.org/jira/browse/FLINK-37249
Project: Fl
[
https://issues.apache.org/jira/browse/FLINK-37249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37249:
---
Labels: pull-request-available (was: )
> Remove unnecessary --add-opens/--add-exports for j
X-czh opened a new pull request, #26103:
URL: https://github.com/apache/flink/pull/26103
## What is the purpose of the change
-add-opens/-add-exports for java.base/sun.net.util was added in
[FLINK-25002](https://issues.apache.org/jira/browse/FLINK-25002), but was no
longer ne
X-czh closed pull request #25799: [FLINK-36904][BP-1.20] Fix document error on
how to programmatically configure serialization
URL: https://github.com/apache/flink/pull/25799
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
flinkbot commented on PR #26103:
URL: https://github.com/apache/flink/pull/26103#issuecomment-2632970947
## CI report:
* ceb878dff9874bc55cd1d5dcbb36bea713f1a3bf UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
911432 created FLINK-37248:
--
Summary: Scala was removed in flink 2.0
Key: FLINK-37248
URL: https://issues.apache.org/jira/browse/FLINK-37248
Project: Flink
Issue Type: Bug
Components: flin
JohnBattista opened a new pull request, #100:
URL: https://github.com/apache/flink-connector-pulsar/pull/100
This change allows us to use flink 1.20 and pulsar 3.0.2
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1940347668
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeRangeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,596 @@
+/*
flinkbot commented on PR #26100:
URL: https://github.com/apache/flink/pull/26100#issuecomment-2632036296
## CI report:
* d0d44d6196c02552179ec23c799d9769e128a8ae UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37246:
---
Labels: pull-request-available (was: )
> Delegation Token expire after enable delegation to
flinkbot commented on PR #26101:
URL: https://github.com/apache/flink/pull/26101#issuecomment-2632127786
## CI report:
* fe70df160f5698d8a942279c5e2158f3d18b63d2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JohnBattista opened a new pull request, #101:
URL: https://github.com/apache/flink-connector-pulsar/pull/101
This change allows us to use flink 1.20 and pulsar 3.0.2 while including the
custom callback code.
--
This is an automated message from the Apache Git Service.
To respond to the me
[
https://issues.apache.org/jira/browse/FLINK-37245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37245:
---
Labels: pull-request-available (was: )
> RowData#createFieldGetter can resurrect null value
Chris Nauroth created FLINK-37247:
-
Summary: Implement common Hadoop file system integration tests for
GCS.
Key: FLINK-37247
URL: https://issues.apache.org/jira/browse/FLINK-37247
Project: Flink
JohnBattista opened a new pull request, #102:
URL: https://github.com/apache/flink-connector-pulsar/pull/102
This change allows us to use flink 1.20 and pulsar 3.0.2 while including the
custom callback code.
--
This is an automated message from the Apache Git Service.
To respond to the me
[
https://issues.apache.org/jira/browse/FLINK-37247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37247:
---
Labels: pull-request-available (was: )
> Implement common Hadoop file system integration te
cnauroth opened a new pull request, #26102:
URL: https://github.com/apache/flink/pull/26102
## What is the purpose of the change
Increase test coverage for GCS integration by providing integration tests
implemented from the common flink-hadoop-fs test suites. These optional tests
run
cnauroth commented on PR #23489:
URL: https://github.com/apache/flink/pull/23489#issuecomment-2632370031
> Superseded by https://issues.apache.org/jira/browse/FLINK-33704 - Thanks
for the help/thinking on this @singhravidutt
>
> @singhravidutt @cnauroth Do you have any bandwidth to ad
flinkbot commented on PR #26102:
URL: https://github.com/apache/flink/pull/26102#issuecomment-2632386724
## CI report:
* e7c77da811995e1c321f310d798532aaa210d321 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gaborgsomogyi commented on PR #26035:
URL: https://github.com/apache/flink/pull/26035#issuecomment-2630460501
Any further comments?
--
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 co
snuyanzin commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1939113951
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java:
##
@@ -1290,6 +1353,24 @@ private static long floor(long a, long b) {
snuyanzin commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1939118228
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/BuiltInMethods.scala:
##
@@ -386,15 +386,29 @@ object BuiltInMethods {
snuyanzin commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1939120569
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/TimeFunctionsITCase.java:
##
@@ -50,7 +50,7 @@
class TimeFunctionsITCase ex
snuyanzin commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1939127803
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java:
##
@@ -1299,6 +1380,39 @@ private static long ceil(long a, long b) {
snuyanzin commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1939127803
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java:
##
@@ -1299,6 +1380,39 @@ private static long ceil(long a, long b) {
snuyanzin commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1939117293
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java:
##
@@ -1299,6 +1380,39 @@ private static long ceil(long a, long b) {
snuyanzin commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1939131169
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java:
##
@@ -1290,6 +1353,24 @@ private static long floor(long a, long b) {
snuyanzin commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1939132330
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java:
##
@@ -1290,6 +1353,24 @@ private static long floor(long a, long b) {
snuyanzin commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1939132330
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java:
##
@@ -1290,6 +1353,24 @@ private static long floor(long a, long b) {
snuyanzin commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1939132330
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java:
##
@@ -1290,6 +1353,24 @@ private static long floor(long a, long b) {
dawidwys merged PR #26022:
URL: https://github.com/apache/flink/pull/26022
--
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
[
https://issues.apache.org/jira/browse/FLINK-37175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz resolved FLINK-37175.
--
Fix Version/s: 2.1.0
(was: 2.0.0)
Assignee: Gustavo de
snuyanzin commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1939131169
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java:
##
@@ -1290,6 +1353,24 @@ private static long floor(long a, long b) {
snuyanzin commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1939157227
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java:
##
@@ -1275,7 +1314,31 @@ public static long timestampCeil(TimeUnitRa
[
https://issues.apache.org/jira/browse/FLINK-37245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-37245:
--
Assignee: Maximilian Michels
> RowData#createFieldGetter can resurrect null v
dawidwys commented on PR #26093:
URL: https://github.com/apache/flink/pull/26093#issuecomment-2630569707
As I thought, the SQL client goes against `TableEnvironment` design. I added
a hotfix. I was not sure how to change your test to make it pass. It fails now
with some missing properties.
gustavodemorais commented on PR #26055:
URL: https://github.com/apache/flink/pull/26055#issuecomment-2630587924
Hey @wangqinghuan, can you make this small change to the docs
https://github.com/apache/flink/pull/26022/commits/4e9160b3cad9ad0937785fb889c6fa3d9922806f?
thanks
--
This is an
gustavodemorais opened a new pull request, #26099:
URL: https://github.com/apache/flink/pull/26099
Backport of https://github.com/apache/flink/pull/26091
## What is the purpose of the change
We currently have no examples for some functions in the documentation. 5
examples o
davidradl commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1939195889
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java:
##
@@ -1299,6 +1380,39 @@ private static long ceil(long a, long b) {
flinkbot commented on PR #26099:
URL: https://github.com/apache/flink/pull/26099#issuecomment-2630632405
## CI report:
* dc8e2b506bef109547b9da0151a3a07cc168f725 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
pnowojski commented on code in PR #26075:
URL: https://github.com/apache/flink/pull/26075#discussion_r1939461797
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java:
##
@@ -554,6 +554,16 @@ public class ExecutionConfigO
Zhenqiu Huang created FLINK-37246:
-
Summary: Delegation Token expire after enable delegation token
framework
Key: FLINK-37246
URL: https://issues.apache.org/jira/browse/FLINK-37246
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-37246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenqiu Huang updated FLINK-37246:
--
Priority: Blocker (was: Major)
> Delegation Token expire after enable delegation token framew
[
https://issues.apache.org/jira/browse/FLINK-37193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923413#comment-17923413
]
Luís Costa commented on FLINK-37193:
Hello [~davidrad]
Can you please have a look i
JohnBattista opened a new pull request, #99:
URL: https://github.com/apache/flink-connector-pulsar/pull/99
This change allows us to use flink 1.20 and pulsar 3.0.2
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
boring-cyborg[bot] commented on PR #99:
URL:
https://github.com/apache/flink-connector-pulsar/pull/99#issuecomment-2631798009
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
wangqinghuan commented on PR #26055:
URL: https://github.com/apache/flink/pull/26055#issuecomment-2630640089
Done, please look. @gustavodemorais
--
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 t
[
https://issues.apache.org/jira/browse/FLINK-37245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923260#comment-17923260
]
Maximilian Michels commented on FLINK-37245:
Hi [~anirudhprabhakaran]! Yes,
davidradl commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1939195889
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java:
##
@@ -1299,6 +1380,39 @@ private static long ceil(long a, long b) {
snuyanzin merged PR #26099:
URL: https://github.com/apache/flink/pull/26099
--
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.apa
[
https://issues.apache.org/jira/browse/FLINK-37239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-37239:
Fix Version/s: 2.1.0
> Improve documentation for multiple built-in functions
> ---
[
https://issues.apache.org/jira/browse/FLINK-37239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923321#comment-17923321
]
Sergey Nuyanzin commented on FLINK-37239:
-
Merged as
2.0:
[7b2ab03fdce79548f97
[
https://issues.apache.org/jira/browse/FLINK-37239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-37239.
-
Resolution: Fixed
> Improve documentation for multiple built-in functions
>
[
https://issues.apache.org/jira/browse/FLINK-37239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-37239:
---
Assignee: Gustavo de Morais
> Improve documentation for multiple built-in functions
snuyanzin merged PR #26098:
URL: https://github.com/apache/flink/pull/26098
--
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.apa
thinker0 commented on PR #94:
URL:
https://github.com/apache/flink-connector-pulsar/pull/94#issuecomment-2631025696
@lvyanquan It works with mvn test, but not with git test, I don't know why.
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
lvyanquan commented on code in PR #709:
URL: https://github.com/apache/flink-web/pull/709#discussion_r1940609963
##
docs/data/flink_connectors.yml:
##
@@ -50,6 +50,13 @@ hbase:
source_release_sha512_url:
"https://downloads.apache.org/flink/flink-connector-hbase-4.0.0/flink-c
[
https://issues.apache.org/jira/browse/FLINK-37060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923607#comment-17923607
]
Zhanghao Chen commented on FLINK-37060:
---
[~xtsong] I've finished the instruction,
[
https://issues.apache.org/jira/browse/FLINK-37049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923605#comment-17923605
]
Zhanghao Chen commented on FLINK-37049:
---
In addition, FLINK-37248 reported that so
[
https://issues.apache.org/jira/browse/FLINK-37248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923601#comment-17923601
]
Yanquan Lv commented on FLINK-37248:
Hi, [~911432] are you working on it? if not, I
[
https://issues.apache.org/jira/browse/FLINK-37250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dmitriy Linevich updated FLINK-37250:
-
Environment: (was: ./flink run-application \
--parallelism 4 \
--target kuber
[
https://issues.apache.org/jira/browse/FLINK-37250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dmitriy Linevich updated FLINK-37250:
-
Description:
If run flink kubernetes application with dynamic properties (including
dep
Dmitriy Linevich created FLINK-37250:
Summary: The flink application does not start because of an error
in the configs
Key: FLINK-37250
URL: https://issues.apache.org/jira/browse/FLINK-37250
Proje
X-czh commented on PR #23323:
URL: https://github.com/apache/flink/pull/23323#issuecomment-2633016505
@zhougit86 @ljw-hit Hi, is there a plan to revive effort on it?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
dawidwys commented on PR #26093:
URL: https://github.com/apache/flink/pull/26093#issuecomment-2630396028
I'll have a look
--
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
67 matches
Mail list logo
