[
https://issues.apache.org/jira/browse/FLINK-34192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-34192:
--
Assignee: Jiabao Sun
> Update flink-connector-kafka to be compatible with updated
[
https://issues.apache.org/jira/browse/FLINK-34244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-34244.
--
Resolution: Fixed
Fixed in apache/flink-connector-kafka
main:
MartijnVisser merged PR #81:
URL: https://github.com/apache/flink-connector-kafka/pull/81
--
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:
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815943#comment-17815943
]
Martijn Visser commented on FLINK-33365:
[~rahulchundeth] See the Dev mailing list for an
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815934#comment-17815934
]
Rahul Raj commented on FLINK-33365:
---
Hi Team,
when we can expect next version of flink-connector-jdbc
hejufang commented on PR #24274:
URL: https://github.com/apache/flink/pull/24274#issuecomment-1935352424
@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.
mtfelisb commented on code in PR #53:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/53#discussion_r1483760795
##
flink-connector-elasticsearch8/src/test/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8AsyncWriterITCase.java:
##
@@ -0,0
mtfelisb commented on PR #53:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/53#issuecomment-1935170882
> > This pull request is working on every Flink version but `1.19-SNAPSHOT`
>
> I'm suspecting that's because of
[
https://issues.apache.org/jira/browse/FLINK-34413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-34413:
--
Assignee: Ferenc Csaky
> Drop support for HBase v1
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-34344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-34344:
--
Fix Version/s: 1.18.2
> Wrong JobID in CheckpointStatsTracker
>
[
https://issues.apache.org/jira/browse/FLINK-34344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-34344:
--
Fix Version/s: 1.20.0
> Wrong JobID in CheckpointStatsTracker
>
[
https://issues.apache.org/jira/browse/FLINK-34344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-34344:
--
Affects Version/s: 1.18.1
1.20.0
> Wrong JobID in
rkhachatryan merged PR #24254:
URL: https://github.com/apache/flink/pull/24254
--
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:
rkhachatryan commented on PR #24254:
URL: https://github.com/apache/flink/pull/24254#issuecomment-1934827477
Thanks for the review!
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
rkhachatryan commented on code in PR #24254:
URL: https://github.com/apache/flink/pull/24254#discussion_r1483515377
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java:
##
@@ -112,8 +112,9 @@ public class CheckpointStatsTracker {
flinkbot commented on PR #24292:
URL: https://github.com/apache/flink/pull/24292#issuecomment-1934796687
## CI report:
* 605d23d07cc51916ac746b9760a400dd363c0044 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34417:
---
Labels: pull-request-available (was: )
> Add JobID to logging MDC
>
rkhachatryan opened a new pull request, #24292:
URL: https://github.com/apache/flink/pull/24292
## What is the purpose of the change
Add Flink JobID to logging MDC to make analysing the logs easier.
## Verifying this change
- added
Roman Khachatryan created FLINK-34417:
-
Summary: Add JobID to logging MDC
Key: FLINK-34417
URL: https://issues.apache.org/jira/browse/FLINK-34417
Project: Flink
Issue Type: Improvement
bvarghese1 commented on code in PR #24219:
URL: https://github.com/apache/flink/pull/24219#discussion_r1483474513
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/RestoreTestCompleteness.java:
##
@@ -0,0 +1,130 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-34393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge closed FLINK-34393.
---
Resolution: Fixed
> Release Testing Instructions: Verify FLINK-20767 Add nested field support for
>
[
https://issues.apache.org/jira/browse/FLINK-34393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815791#comment-17815791
]
Jing Ge commented on FLINK-34393:
-
Thanks for the clarification.
> Release Testing Instructions: Verify
[
https://issues.apache.org/jira/browse/FLINK-34393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815786#comment-17815786
]
Venkata krishnan Sowrirajan commented on FLINK-34393:
-
Looks like I don't have
[
https://issues.apache.org/jira/browse/FLINK-34393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815785#comment-17815785
]
Venkata krishnan Sowrirajan edited comment on FLINK-34393 at 2/8/24 6:42 PM:
[
https://issues.apache.org/jira/browse/FLINK-34393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815785#comment-17815785
]
Venkata krishnan Sowrirajan commented on FLINK-34393:
-
It won't be required in this
XComp commented on PR #24285:
URL: https://github.com/apache/flink/pull/24285#issuecomment-1934710721
@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-34289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815766#comment-17815766
]
Piotr Nowojski commented on FLINK-34289:
That definitely would prevent my confusion :)
>
[
https://issues.apache.org/jira/browse/FLINK-34404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815765#comment-17815765
]
Alan Sheinberg commented on FLINK-34404:
I did recently add a test, so if for some reason we
[
https://issues.apache.org/jira/browse/FLINK-34200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-34200.
---
Resolution: Fixed
master:
XComp merged PR #24286:
URL: https://github.com/apache/flink/pull/24286
--
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:
hejufang commented on PR #24274:
URL: https://github.com/apache/flink/pull/24274#issuecomment-1934485237
@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-34411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815746#comment-17815746
]
Ferenc Csaky commented on FLINK-34411:
--
The current
[
https://issues.apache.org/jira/browse/FLINK-34413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815744#comment-17815744
]
Ferenc Csaky commented on FLINK-34413:
--
Thanks for creating this ticket, feel free to assign it to
[
https://issues.apache.org/jira/browse/FLINK-34285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-34285:
Description:
This is an umbrella ticket for the Flink 1.19 testing efforts.
There're two kinds
[
https://issues.apache.org/jira/browse/FLINK-34285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-34285:
Description:
This is an umbrella ticket for the Flink 1.19 testing efforts.
RM opened a
XComp commented on code in PR #24285:
URL: https://github.com/apache/flink/pull/24285#discussion_r1483225410
##
flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointITCase.java:
##
@@ -105,7 +103,6 @@
*
*/
@RunWith(Parameterized.class)
JingGe commented on code in PR #24279:
URL: https://github.com/apache/flink/pull/24279#discussion_r1483214554
##
docs/content.zh/docs/ops/debugging/flame_graphs.md:
##
@@ -27,36 +27,37 @@ under the License.
# Flame Graphs
-[Flame
[
https://issues.apache.org/jira/browse/FLINK-34416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815738#comment-17815738
]
Matthias Pohl commented on FLINK-34416:
---
We should investigate whether that could be fixed or
Matthias Pohl created FLINK-34416:
-
Summary: "Local recovery and sticky scheduling end-to-end test"
still doesn't work with AdaptiveScheduler
Key: FLINK-34416
URL:
[
https://issues.apache.org/jira/browse/FLINK-34285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-34285:
Attachment: screenshot-3.png
> [Umbrella] Test Flink Release 1.19
>
[
https://issues.apache.org/jira/browse/FLINK-34415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-34415:
---
Description:
The current Flink Kafka connector still uses Zookeeper for Kafka-based
[
https://issues.apache.org/jira/browse/FLINK-34289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815735#comment-17815735
]
lincoln lee commented on FLINK-34289:
-
[~pnowojski] Really appreciate for your valuable inputs! I
[
https://issues.apache.org/jira/browse/FLINK-34391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815731#comment-17815731
]
Jing Ge commented on FLINK-34391:
-
pinged [~xiangyu0xf] in the Slack, waiting for the feedback
>
[
https://issues.apache.org/jira/browse/FLINK-34395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815730#comment-17815730
]
Jing Ge commented on FLINK-34395:
-
pinged [~yunfengzhou] in the Slack, waiting for the feedback
>
[
https://issues.apache.org/jira/browse/FLINK-34393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815728#comment-17815728
]
Jing Ge commented on FLINK-34393:
-
pinged [~vsowrirajan] in the Slack, waiting for the feedback
>
[
https://issues.apache.org/jira/browse/FLINK-34367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815727#comment-17815727
]
Jing Ge commented on FLINK-34367:
-
Hi [~asheinberg] would you like to create a release testing ticket
MartijnVisser commented on code in PR #81:
URL:
https://github.com/apache/flink-connector-kafka/pull/81#discussion_r1483192402
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/DockerImageVersions.java:
##
@@ -24,7 +24,9 @@
*/
public class
Martijn Visser created FLINK-34415:
--
Summary: Move away from Kafka-Zookeeper based tests in favor of
Kafka-KRaft
Key: FLINK-34415
URL: https://issues.apache.org/jira/browse/FLINK-34415
Project:
[
https://issues.apache.org/jira/browse/FLINK-34399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-34399:
Labels: release-testing (was: )
> Release Testing: Verify FLINK-33644 Make QueryOperations SQL
MartijnVisser commented on code in PR #81:
URL:
https://github.com/apache/flink-connector-kafka/pull/81#discussion_r1483185495
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/DockerImageVersions.java:
##
@@ -24,7 +24,9 @@
*/
public class
[
https://issues.apache.org/jira/browse/FLINK-34289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-34289:
Attachment: screenshot-2.png
> Release Testing Instructions: Verify FLINK-33695 Introduce
snuyanzin commented on code in PR #81:
URL:
https://github.com/apache/flink-connector-kafka/pull/81#discussion_r1483182849
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/DockerImageVersions.java:
##
@@ -24,7 +24,9 @@
*/
public class
[
https://issues.apache.org/jira/browse/FLINK-34305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815724#comment-17815724
]
Jing Ge commented on FLINK-34305:
-
Hi [~sudewei.sdw] I have assigned this ticket to you
> Release
[
https://issues.apache.org/jira/browse/FLINK-34305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge reassigned FLINK-34305:
---
Assignee: SuDewei (was: Zhanghao Chen)
> Release Testing Instructions: Verify FLINK-33261 Support
[
https://issues.apache.org/jira/browse/FLINK-34244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-34244:
---
Fix Version/s: kafka-3.1.1
> Upgrade Confluent Platform to latest compatible version
>
MartijnVisser merged PR #24202:
URL: https://github.com/apache/flink/pull/24202
--
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:
[
https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815719#comment-17815719
]
Martijn Visser commented on FLINK-34252:
[~fanrui] I'm curious on your thoughts on this one,
Jiabao-Sun commented on code in PR #84:
URL:
https://github.com/apache/flink-connector-kafka/pull/84#discussion_r1483154745
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/YamlFileMetadataService.java:
##
@@ -23,20 +23,19 @@
import
MartijnVisser commented on code in PR #84:
URL:
https://github.com/apache/flink-connector-kafka/pull/84#discussion_r1483132533
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/YamlFileMetadataService.java:
##
@@ -23,20 +23,19 @@
import
Rafał Trójczak created FLINK-34414:
--
Summary: EXACTLY_ONCE guarantee doesn't work properly for
Flink/Pulsar connector
Key: FLINK-34414
URL: https://issues.apache.org/jira/browse/FLINK-34414
[
https://issues.apache.org/jira/browse/FLINK-24239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-24239.
Resolution: Implemented
Implemented in 01cdc703ee6fa56bdfdf799d016c0e882e9e5d99
> Event
dawidwys merged PR #24253:
URL: https://github.com/apache/flink/pull/24253
--
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:
snuyanzin commented on PR #24253:
URL: https://github.com/apache/flink/pull/24253#issuecomment-1934213444
yes, also played locally , seems working, thanks
--
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
[
https://issues.apache.org/jira/browse/FLINK-34403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815685#comment-17815685
]
Piotr Nowojski commented on FLINK-34403:
[
https://issues.apache.org/jira/browse/FLINK-34403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-34403:
---
Priority: Critical (was: Major)
> VeryBigPbProtoToRowTest#testSimple cannot pass due to
pnowojski commented on PR #24274:
URL: https://github.com/apache/flink/pull/24274#issuecomment-1934175386
@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
mxm commented on code in PR #762:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1483002425
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricEvaluator.java:
##
@@ -314,13 +315,19 @@ protected static Map
pvary commented on PR #34:
URL:
https://github.com/apache/flink-connector-shared-utils/pull/34#issuecomment-1934091836
> @pvary do you remember why we added the old conda version here?
IIRC the issue was to run the python tests on Mac with the new Python
versions
--
This is an
pvary commented on PR #84:
URL:
https://github.com/apache/flink-connector-kafka/pull/84#issuecomment-1934089389
The SinkV2 related changes are ok (There is some extra casts which are
needed)
--
This is an automated message from the Apache Git Service.
To respond to the message, please
Jiabao-Sun commented on code in PR #53:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/53#discussion_r1482924435
##
flink-connector-elasticsearch8/src/test/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8AsyncWriterITCase.java:
##
@@ -0,0
Jiabao-Sun commented on PR #53:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/53#issuecomment-1934031525
> Hi, @MartijnVisser. I have a question regarding compatibility. This pull
request is working on every Flink version but `1.19-SNAPSHOT`. I've checked
[this
[
https://issues.apache.org/jira/browse/FLINK-34404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815660#comment-17815660
]
Matthias Pohl commented on FLINK-34404:
---
I attached the debug logs for the failed run in CI and a
[
https://issues.apache.org/jira/browse/FLINK-34404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34404:
--
Attachment: FLINK-34404.failure.log
> GroupWindowAggregateProcTimeRestoreTest#testRestore
[
https://issues.apache.org/jira/browse/FLINK-34404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34404:
--
Attachment: (was: FLINK-34404.log)
> GroupWindowAggregateProcTimeRestoreTest#testRestore
[
https://issues.apache.org/jira/browse/FLINK-34404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34404:
--
Attachment: FLINK-34404.success.log
> GroupWindowAggregateProcTimeRestoreTest#testRestore
[
https://issues.apache.org/jira/browse/FLINK-34404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34404:
--
Attachment: FLINK-34404.log
> GroupWindowAggregateProcTimeRestoreTest#testRestore times out
>
[
https://issues.apache.org/jira/browse/FLINK-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815654#comment-17815654
]
Matthias Pohl commented on FLINK-34273:
---
gyfora commented on code in PR #762:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1482812605
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricEvaluator.java:
##
@@ -314,13 +315,19 @@ protected static Map
gyfora commented on code in PR #762:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1482812605
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricEvaluator.java:
##
@@ -314,13 +315,19 @@ protected static Map
mxm commented on code in PR #762:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1482810083
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/MemoryTuningUtils.java:
##
@@ -0,0 +1,238 @@
+/*
+ * Licensed to the Apache Software
mxm commented on code in PR #762:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1482809329
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/MemoryTuningUtils.java:
##
@@ -0,0 +1,238 @@
+/*
+ * Licensed to the Apache Software
mxm commented on code in PR #762:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1482802937
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/config/AutoScalerOptions.java:
##
@@ -250,6 +251,31 @@ private static
[
https://issues.apache.org/jira/browse/FLINK-33960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815475#comment-17815475
]
Rui Fan edited comment on FLINK-33960 at 2/8/24 10:57 AM:
--
Merged to:
1996fanrui merged PR #24287:
URL: https://github.com/apache/flink/pull/24287
--
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:
1996fanrui commented on PR #24288:
URL: https://github.com/apache/flink/pull/24288#issuecomment-1933823128
@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
XComp commented on PR #24286:
URL: https://github.com/apache/flink/pull/24286#issuecomment-1933821366
@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.
XComp commented on PR #24286:
URL: https://github.com/apache/flink/pull/24286#issuecomment-1933821158
The [CI
failure](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=57393)
is due to another issue which is documented in FLINK-34411
--
This
gyfora commented on code in PR #762:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1482771329
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/MemoryTuningUtils.java:
##
@@ -0,0 +1,238 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-34411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815626#comment-17815626
]
Matthias Pohl commented on FLINK-34411:
---
[
https://issues.apache.org/jira/browse/FLINK-33960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33960:
Fix Version/s: 1.19.0
1.18.2
1.20.0
> Adaptive Scheduler doesn't
dawidwys commented on code in PR #24253:
URL: https://github.com/apache/flink/pull/24253#discussion_r1482693914
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/TemporalJoinTestPrograms.java:
##
@@ -84,6 +130,36 @@ public
dawidwys commented on PR #24253:
URL: https://github.com/apache/flink/pull/24253#issuecomment-1933701764
@snuyanzin There is a test for using an entry from a map:
```
INSERT INTO MySink
SELECT amount * r.rate
FROM OrdersNestedId AS o
JOIN RatesHistory FOR SYSTEM_TIME AS OF
Martijn Visser created FLINK-34413:
--
Summary: Drop support for HBase v1
Key: FLINK-34413
URL: https://issues.apache.org/jira/browse/FLINK-34413
Project: Flink
Issue Type: Technical Debt
[
https://issues.apache.org/jira/browse/FLINK-34381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan reassigned FLINK-34381:
-
Assignee: xuyang
> `RelDataType#getFullTypeString` should be used to print in
>
snuyanzin commented on PR #24253:
URL: https://github.com/apache/flink/pull/24253#issuecomment-1933613412
Out of curiocity: I didn't find tests for nested arrays/maps/row... Are they
out of scope?
I mean e.g. this
```sql
CREATE TABLE A (
a MAP>,
ts
[
https://issues.apache.org/jira/browse/FLINK-34403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815577#comment-17815577
]
Matthias Pohl commented on FLINK-34403:
---
[
https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815576#comment-17815576
]
Matthias Pohl commented on FLINK-34202:
---
1.17:
Matthias Pohl created FLINK-34412:
-
Summary: ResultPartitionDeploymentDescriptorTest fails due to
fatal error (239 exit code)
Key: FLINK-34412
URL: https://issues.apache.org/jira/browse/FLINK-34412
[
https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-22765:
--
Affects Version/s: 1.20.0
> ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable
[
https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815573#comment-17815573
]
Matthias Pohl commented on FLINK-22765:
---
1 - 100 of 104 matches
Mail list logo
