[
https://issues.apache.org/jira/browse/FLINK-27118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao closed FLINK-27118.
---
Resolution: Fixed
> Flink on Yarned failed with the default flink-conf
> ---
[
https://issues.apache.org/jira/browse/FLINK-27118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519863#comment-17519863
]
Yun Gao commented on FLINK-27118:
-
Merged on master via 6e55d223efdc2563f0b7600a393ff9a3
gaoyunhaii closed pull request #19411: (1.15) [FLINK-27118][yarn] TM ignores
localhost BIND_HOST
URL: https://github.com/apache/flink/pull/19411
--
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
gaoyunhaii commented on PR #19411:
URL: https://github.com/apache/flink/pull/19411#issuecomment-1093624176
Merged
--
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 unsubsc
ZhangChaoming commented on PR #18386:
URL: https://github.com/apache/flink/pull/18386#issuecomment-1093598127
@slinkydeveloper Please 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
ZhangChaoming commented on code in PR #18386:
URL: https://github.com/apache/flink/pull/18386#discussion_r846561758
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala:
##
@@ -717,21 +717,21 @@ class TableEnvironmentTest {
[
https://issues.apache.org/jira/browse/FLINK-27134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519855#comment-17519855
]
wujinhu commented on FLINK-27134:
-
[~AlexZax] You used EnvironmentVariableCredentialsPro
gaoyunhaii commented on PR #19411:
URL: https://github.com/apache/flink/pull/19411#issuecomment-1093556377
@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
[
https://issues.apache.org/jira/browse/FLINK-27137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519852#comment-17519852
]
dengziming edited comment on FLINK-27137 at 4/9/22 12:50 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-27137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519852#comment-17519852
]
dengziming commented on FLINK-27137:
[~arvid] In fact, Spark also use Adminclient to
[
https://issues.apache.org/jira/browse/FLINK-18640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-18640:
---
Labels: auto-deprioritized-major pull-request-available stale-minor (was:
auto-deprioritize
[
https://issues.apache.org/jira/browse/FLINK-25449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-25449:
---
Labels: stale-major test-stability (was: test-stability)
I am the [Flink Jira Bot|https://g
[
https://issues.apache.org/jira/browse/FLINK-18441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-18441:
---
Labels: auto-deprioritized-major pull-request-available stale-minor (was:
auto-deprioritize
[
https://issues.apache.org/jira/browse/FLINK-18263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-18263:
---
Labels: auto-deprioritized-major pull-request-available stale-minor (was:
auto-deprioritize
[
https://issues.apache.org/jira/browse/FLINK-18234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-18234:
---
Labels: auto-deprioritized-major stale-minor (was:
auto-deprioritized-major)
I am the [Fli
[
https://issues.apache.org/jira/browse/FLINK-17874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-17874:
---
Labels: auto-deprioritized-major auto-unassigned pull-request-available
stale-minor (was: a
[
https://issues.apache.org/jira/browse/FLINK-17613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-17613:
---
Labels: auto-deprioritized-major auto-unassigned pull-request-available
stale-minor starter
[
https://issues.apache.org/jira/browse/FLINK-18729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-18729:
---
Labels: auto-deprioritized-major pull-request-available stale-minor (was:
auto-deprioritize
[
https://issues.apache.org/jira/browse/FLINK-19157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-19157:
---
Labels: auto-deprioritized-major pull-request-available stale-minor (was:
auto-deprioritize
[
https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-18049:
---
Labels: auto-deprioritized-critical auto-deprioritized-major
pull-request-available stale-mi
[
https://issues.apache.org/jira/browse/FLINK-25966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-25966:
---
Labels: stale-major test-stability (was: test-stability)
I am the [Flink Jira Bot|https://g
[
https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-23391:
---
Labels: pull-request-available stale-assigned test-stability (was:
pull-request-available t
[
https://issues.apache.org/jira/browse/FLINK-19028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-19028:
---
Labels: auto-deprioritized-major pull-request-available stale-minor (was:
auto-deprioritize
[
https://issues.apache.org/jira/browse/FLINK-18704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-18704:
---
Labels: auto-deprioritized-major pull-request-available stale-minor starter
(was: auto-depr
[
https://issues.apache.org/jira/browse/FLINK-26173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-26173:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-26086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-26086:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-27150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27150:
---
Labels: pull-request-available (was: )
> Improve error reporting in Flink Web UI
>
rkhachatryan commented on PR #19287:
URL: https://github.com/apache/flink/pull/19287#issuecomment-1093316886
I've tried `width: auto` and it worked, thanks for the suggestion (pushed
2308446).
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
[
https://issues.apache.org/jira/browse/FLINK-27150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-27150:
--
Summary: Improve error reporting in Flink Web UI (was: Improve error
reporting in Fli
Roman Khachatryan created FLINK-27150:
-
Summary: Improve error reporting in Flink UI
Key: FLINK-27150
URL: https://issues.apache.org/jira/browse/FLINK-27150
Project: Flink
Issue Type: Imp
flinkbot commented on PR #19412:
URL: https://github.com/apache/flink/pull/19412#issuecomment-1093300685
## CI report:
* 2ddb5ea77256a466f9339479e23c923feceaf6f6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
rkhachatryan opened a new pull request, #19412:
URL: https://github.com/apache/flink/pull/19412
Backport of #19331 to 1.15.
--
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.
rkhachatryan merged PR #19331:
URL: https://github.com/apache/flink/pull/19331
--
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.
rkhachatryan commented on PR #19331:
URL: https://github.com/apache/flink/pull/19331#issuecomment-1093257789
Build succeeded, merging.
--
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
ZhangChaoming commented on code in PR #18386:
URL: https://github.com/apache/flink/pull/18386#discussion_r846408411
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -786,6 +786,24 @@ void createFunction(
*/
Stri
ZhangChaoming commented on code in PR #18386:
URL: https://github.com/apache/flink/pull/18386#discussion_r846407990
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala:
##
@@ -696,15 +695,46 @@ class TableEnvironmentTest {
@
[
https://issues.apache.org/jira/browse/FLINK-16835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519754#comment-17519754
]
Marios Trivyzas commented on FLINK-16835:
-
[~twalthr] Can we close this issue no
[
https://issues.apache.org/jira/browse/FLINK-27141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27141:
---
Labels: Starter pull-request-available (was: Starter)
> Improve FlinkService#waitForCluster
SteNicholas opened a new pull request, #161:
URL: https://github.com/apache/flink-kubernetes-operator/pull/161
The current `waitForClusterShutdown` logic has a hardcoded 60 second timeout
and prints a log message after every second, which should be improved to make
the max timeout configura
flinkbot commented on PR #19411:
URL: https://github.com/apache/flink/pull/19411#issuecomment-1093104202
## CI report:
* bb1d3fc731dbb92a3743d1de722ec85040c12c4b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gaoyunhaii opened a new pull request, #19411:
URL: https://github.com/apache/flink/pull/19411
This picks #19395 to 1.15
--
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 u
[
https://issues.apache.org/jira/browse/FLINK-27148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519720#comment-17519720
]
Roman Khachatryan commented on FLINK-27148:
---
https://dev.azure.com/apache-flin
[
https://issues.apache.org/jira/browse/FLINK-27149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519717#comment-17519717
]
Roman Khachatryan commented on FLINK-27149:
---
In the logs, I see "Cannot mark f
[
https://issues.apache.org/jira/browse/FLINK-27111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519716#comment-17519716
]
Martijn Visser commented on FLINK-27111:
Fixed in release-1.15: f35195737ce3228d
[
https://issues.apache.org/jira/browse/FLINK-27111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-27111.
--
Fix Version/s: 1.15.0
Resolution: Fixed
> Update docs regarding EnvironmentSettings / T
MartijnVisser commented on PR #19401:
URL: https://github.com/apache/flink/pull/19401#issuecomment-1093086962
@RocMarshal Could you help with a review here?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
[
https://issues.apache.org/jira/browse/FLINK-27063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-27063.
--
Fix Version/s: 1.16.0
Resolution: Fixed
Fixed in master: a5037cc7954d401783671cbb2d347e
MartijnVisser merged PR #19364:
URL: https://github.com/apache/flink/pull/19364
--
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
Roman Khachatryan created FLINK-27149:
-
Summary: KafkaSourceE2ECase.testScaleUp failed on AZP
Key: FLINK-27149
URL: https://issues.apache.org/jira/browse/FLINK-27149
Project: Flink
Issue
MartijnVisser merged PR #19402:
URL: https://github.com/apache/flink/pull/19402
--
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
[
https://issues.apache.org/jira/browse/FLINK-26644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-26644:
--
Affects Version/s: 1.14.4
> python
> StreamExecutionEnvironmentTests.test_generate_st
[
https://issues.apache.org/jira/browse/FLINK-26644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519697#comment-17519697
]
Roman Khachatryan edited comment on FLINK-26644 at 4/8/22 4:48 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-26644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519697#comment-17519697
]
Roman Khachatryan commented on FLINK-26644:
---
[https://dev.azure.com/apache-fli
JingGe commented on code in PR #19377:
URL: https://github.com/apache/flink/pull/19377#discussion_r846309162
##
flink-architecture-tests/flink-architecture-tests-production/src/main/java/org/apache/flink/architecture/rules/ConnectorRules.java:
##
@@ -0,0 +1,64 @@
+/*
+ * License
rkhachatryan commented on PR #19331:
URL: https://github.com/apache/flink/pull/19331#issuecomment-1093074703
@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
rkhachatryan commented on PR #19331:
URL: https://github.com/apache/flink/pull/19331#issuecomment-1093074453
Build failures unrelated:
- PR: FLINK-27148
- private branch: FLINK-27148, FLINK-27031
However, `finegrained_resource_management` phase failed in both builds. I"ve
restarted
[
https://issues.apache.org/jira/browse/FLINK-26995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519689#comment-17519689
]
Chesnay Schepler edited comment on FLINK-26995 at 4/8/22 4:34 PM:
[
https://issues.apache.org/jira/browse/FLINK-27148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519691#comment-17519691
]
Roman Khachatryan commented on FLINK-27148:
---
Here's KafkaSourceE2ECase.testSca
[
https://issues.apache.org/jira/browse/FLINK-26995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-26995.
Resolution: Fixed
master: 118294385161c9b76511ab6bf1ee999fb843cb77
> Enable fork-reuse fo
zentol merged PR #19404:
URL: https://github.com/apache/flink/pull/19404
--
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.apache
[
https://issues.apache.org/jira/browse/FLINK-27143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-27143.
Fix Version/s: 1.16.0
Assignee: RocMarshal
Resolution: Fixed
master: 11829
gaborgsomogyi commented on PR #19372:
URL: https://github.com/apache/flink/pull/19372#issuecomment-1093068781
@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 comm
[
https://issues.apache.org/jira/browse/FLINK-27031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519687#comment-17519687
]
Roman Khachatryan commented on FLINK-27031:
---
[https://dev.azure.com/khachatrya
zentol merged PR #19407:
URL: https://github.com/apache/flink/pull/19407
--
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.apache
[
https://issues.apache.org/jira/browse/FLINK-27148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-27148:
--
Description:
[https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=3
[
https://issues.apache.org/jira/browse/FLINK-27148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519681#comment-17519681
]
Roman Khachatryan commented on FLINK-27148:
---
So far I've only seen it on maste
[
https://issues.apache.org/jira/browse/FLINK-27148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-27148:
--
Priority: Blocker (was: Critical)
> UnalignedCheckpointITCase fails on AZP
>
[
https://issues.apache.org/jira/browse/FLINK-27148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-27148:
--
Description:
[https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=3
matriv commented on code in PR #19410:
URL: https://github.com/apache/flink/pull/19410#discussion_r846285936
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FunctionCatalog.java:
##
@@ -621,7 +626,7 @@ public void registerTemporarySystemFunction(
Roman Khachatryan created FLINK-27148:
-
Summary: UnalignedCheckpointITCase fails on AZP
Key: FLINK-27148
URL: https://issues.apache.org/jira/browse/FLINK-27148
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-27137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519679#comment-17519679
]
Gyula Fora commented on FLINK-27137:
Even KafkaConsumer 2.0.0 supports all these API
[
https://issues.apache.org/jira/browse/FLINK-27137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519674#comment-17519674
]
Arvid Heise commented on FLINK-27137:
-
Hi [~gyfora], sorry if you perceived my messa
flinkbot commented on PR #19410:
URL: https://github.com/apache/flink/pull/19410#issuecomment-1093008517
## CI report:
* 5819f99906d857d550f5c2ce5ba6793076398fbe UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-15635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-15635:
---
Labels: pull-request-available (was: )
> Allow passing a ClassLoader to EnvironmentSettings
slinkydeveloper opened a new pull request, #19410:
URL: https://github.com/apache/flink/pull/19410
This PR solves the issue of allowing the user to provide its own classloader
for UDFs and at other places where it's more appropriate than the current
Thread context classloader.
The PR
gaoyunhaii closed pull request #19395: [FLINK-27118][yarn] TM ignores localhost
BIND_HOST
URL: https://github.com/apache/flink/pull/19395
--
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
[
https://issues.apache.org/jira/browse/FLINK-27141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519622#comment-17519622
]
Gyula Fora commented on FLINK-27141:
go ahead :)
> Improve FlinkService#waitForClu
[
https://issues.apache.org/jira/browse/FLINK-27141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-27141:
--
Assignee: Nicholas Jiang
> Improve FlinkService#waitForClusterShutdown logic
> --
[
https://issues.apache.org/jira/browse/FLINK-27141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519617#comment-17519617
]
Nicholas Jiang commented on FLINK-27141:
[~gyfora], are you working for this tic
RocMarshal commented on code in PR #19403:
URL: https://github.com/apache/flink/pull/19403#discussion_r846193557
##
docs/content.zh/docs/dev/configuration/overview.md:
##
@@ -67,7 +67,7 @@ $ curl https://flink.apache.org/q/quickstart.sh | bash -s {{<
version >}}
{{< /tab >}}
twalthr commented on PR #13832:
URL: https://github.com/apache/flink/pull/13832#issuecomment-1092929282
@godfreyhe Why was this never merged? It seems like good improvement. Maybe
you can give us some background.
--
This is an automated message from the Apache Git Service.
To respond to t
twalthr commented on code in PR #18179:
URL: https://github.com/apache/flink/pull/18179#discussion_r846157113
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/typeutils/SymbolUtil.java:
##
@@ -184,6 +184,27 @@
addSymbolMapping(null, null,
flinkbot commented on PR #19409:
URL: https://github.com/apache/flink/pull/19409#issuecomment-1092913816
## CI report:
* f041c44622d047c780c6ebc125471c39fe3d97d1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519591#comment-17519591
]
Gyula Fora commented on FLINK-27137:
[~arvid] "so I'd be inclined to close this tick
matriv commented on code in PR #19409:
URL: https://github.com/apache/flink/pull/19409#discussion_r846159965
##
flink-table/flink-table-planner/src/main/java/org/apache/calcite/rex/RexSimplify.java:
##
@@ -2024,7 +2029,9 @@ private RexNode simplifySearch(RexCall call, RexUnknown
alpreu commented on code in PR #19377:
URL: https://github.com/apache/flink/pull/19377#discussion_r846159554
##
flink-architecture-tests/flink-architecture-tests-production/src/main/java/org/apache/flink/architecture/rules/ConnectorRules.java:
##
@@ -0,0 +1,64 @@
+/*
+ * License
matriv commented on PR #19409:
URL: https://github.com/apache/flink/pull/19409#issuecomment-1092910642
To allow this cast we need to make changes to `RexSimplify` and `RexLiteral`.
If you agree with these, I'll update the javadocs of those classes to
reference the changes we need.
--
T
[
https://issues.apache.org/jira/browse/FLINK-24577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24577:
---
Labels: pull-request-available (was: )
> Support cast from BINARY/VARBINARY/BYTES to of RAW
matriv opened a new pull request, #19409:
URL: https://github.com/apache/flink/pull/19409
## What is the purpose of the change
Implement `CAST` from `BINARY`/`VARBINARY`/`BYTES` to `RAW()`.
## Brief change log
- Implement `BinaryToRawCastRule`
- Add support for exp
[
https://issues.apache.org/jira/browse/FLINK-26617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519583#comment-17519583
]
Fil Karnicki commented on FLINK-26617:
--
Hi [~trohrmann], I think that my requiremen
[
https://issues.apache.org/jira/browse/FLINK-27147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fil Karnicki updated FLINK-27147:
-
Summary: Change DataStream's RequestReplyFunctionBuilder to use the netty
client (was: Move Da
[
https://issues.apache.org/jira/browse/FLINK-26852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang resolved FLINK-26852.
--
Fix Version/s: 1.16.0
Resolution: Fixed
merged in master: 241e819d82bf84535b355e3822894d6b685db
Fil Karnicki created FLINK-27147:
Summary: Move DataStream's RequestReplyFunctionBuilder to use the
netty client
Key: FLINK-27147
URL: https://issues.apache.org/jira/browse/FLINK-27147
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519579#comment-17519579
]
Abdullah alkhawatrah commented on FLINK-27127:
--
[~chesnay] can you please t
Myasuka merged PR #19399:
URL: https://github.com/apache/flink/pull/19399
--
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.apach
JingGe commented on code in PR #19377:
URL: https://github.com/apache/flink/pull/19377#discussion_r846138318
##
flink-architecture-tests/flink-architecture-tests-production/src/main/java/org/apache/flink/architecture/rules/ConnectorRules.java:
##
@@ -0,0 +1,64 @@
+/*
+ * License
matriv commented on PR #19402:
URL: https://github.com/apache/flink/pull/19402#issuecomment-1092883433
@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.
T
alpreu commented on code in PR #19377:
URL: https://github.com/apache/flink/pull/19377#discussion_r846082122
##
flink-architecture-tests/flink-architecture-tests-production/src/main/java/org/apache/flink/architecture/rules/ConnectorRules.java:
##
@@ -0,0 +1,64 @@
+/*
+ * License
alpreu commented on code in PR #19377:
URL: https://github.com/apache/flink/pull/19377#discussion_r846082122
##
flink-architecture-tests/flink-architecture-tests-production/src/main/java/org/apache/flink/architecture/rules/ConnectorRules.java:
##
@@ -0,0 +1,64 @@
+/*
+ * License
AHeise commented on code in PR #19228:
URL: https://github.com/apache/flink/pull/19228#discussion_r845810559
##
flink-runtime/src/main/java/org/apache/flink/runtime/messages/ThreadInfoSample.java:
##
@@ -54,6 +61,27 @@ private ThreadInfoSample(Thread.State threadState,
StackTra
1 - 100 of 270 matches
Mail list logo
