Tan-JiaLiang commented on PR #33:
URL:
https://github.com/apache/flink-connector-hbase/pull/33#issuecomment-1811994234
Please take a look when you are free, I'll always active util this PR
finish. CC @ferenc-csaky @MartijnVisser.
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-33543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-33543.
---
Fix Version/s: 1.19.0
Assignee: Matthias Pohl
Resolution: Fixed
master:
xuyangzhong opened a new pull request, #23716:
URL: https://github.com/apache/flink/pull/23716
## What is the purpose of the change
Cherry-pick from https://github.com/apache/flink/pull/23620.
This pr try to fix that join hints should also be resolved and work when
defined in
[
https://issues.apache.org/jira/browse/FLINK-33549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-33549:
-
Description:
When run a job in batch, it throws the following exception
{code:java}
Matthias Pohl created FLINK-33550:
-
Summary: "DataSet allround end-to-end test" failed due to
certificate error
Key: FLINK-33550
URL: https://issues.apache.org/jira/browse/FLINK-33550
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786252#comment-17786252
]
Matthias Pohl commented on FLINK-33550:
---
[
https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786253#comment-17786253
]
Matthias Pohl commented on FLINK-33502:
---
[
https://issues.apache.org/jira/browse/FLINK-33550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786252#comment-17786252
]
Matthias Pohl edited comment on FLINK-33550 at 11/15/23 9:21 AM:
-
*
[
https://issues.apache.org/jira/browse/FLINK-33550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786269#comment-17786269
]
Matthias Pohl commented on FLINK-33550:
---
[
https://issues.apache.org/jira/browse/FLINK-25568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786266#comment-17786266
]
Martijn Visser commented on FLINK-25568:
[~complone] Feel free to yes
> Add Elasticsearch 7
SmirAlex commented on PR #23521:
URL: https://github.com/apache/flink/pull/23521#issuecomment-1812134103
Hi @Sxnan! Sorry, I understand that I'm not a reviewer, but it happened that
I was testing functionality from this MR recently, and I found a bug (in my
opinion). It concerns the logic
Márton Balassi created FLINK-33556:
--
Summary: Test infrastructure for externalized python code
Key: FLINK-33556
URL: https://issues.apache.org/jira/browse/FLINK-33556
Project: Flink
Issue
1996fanrui commented on code in PR #710:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/710#discussion_r1394011445
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/state/ConfigMapStore.java:
##
@@ -44,13 +43,13 @@ public
[
https://issues.apache.org/jira/browse/FLINK-33536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786318#comment-17786318
]
Samrat Deb commented on FLINK-33536:
[~prabhujoseph] , [~martijnvisser]
I have tested the changes
[
https://issues.apache.org/jira/browse/FLINK-33548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-33548:
---
Summary: Replace taskManager/jobmanager.resource with resources conforming
to ResourceRequirements
XComp commented on PR #23719:
URL: https://github.com/apache/flink/pull/23719#issuecomment-1812507090
Yes, that change was rather meant to reduce the amount of runners that I
need to use in the GHA test. And I thought that it would be valuable to put it
into `master` as well.
snuyanzin merged PR #23721:
URL: https://github.com/apache/flink/pull/23721
--
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 #23721:
URL: https://github.com/apache/flink/pull/23721#issuecomment-1812552318
there should be testtemplate instead of test
--
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
Matthias Pohl created FLINK-33551:
-
Summary: HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable
failed due to
Key: FLINK-33551
URL: https://issues.apache.org/jira/browse/FLINK-33551
Project:
Márton Balassi created FLINK-33559:
--
Summary: Externalize Kafka Python connector code
Key: FLINK-33559
URL: https://issues.apache.org/jira/browse/FLINK-33559
Project: Flink
Issue Type:
xuyangzhong opened a new pull request, #23722:
URL: https://github.com/apache/flink/pull/23722
## What is the purpose of the change
Fix the failed case in DistinctAggregateTest.
## Brief change log
- *Fix the failed case*
## Verifying this change
This
[
https://issues.apache.org/jira/browse/FLINK-33528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi reassigned FLINK-33528:
--
Assignee: Peter Vary
> Externalize Python connector code
>
Samrat002 opened a new pull request, #23718:
URL: https://github.com/apache/flink/pull/23718
## What is the purpose of the change
Fix the error due to IOException: Stream closed
Calling persist() in case of filesystem is not syncable
Persist() behaves in same
[
https://issues.apache.org/jira/browse/FLINK-33536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33536:
---
Labels: pull-request-available (was: )
> Flink Table API CSV streaming sink fails with
gyfora opened a new pull request, #713:
URL: https://github.com/apache/flink-kubernetes-operator/pull/713
Release cut update for main
--
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-33550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786379#comment-17786379
]
Matthias Pohl commented on FLINK-33550:
---
This issue is caused by the switch to Java8:
* [Java 8
flinkbot commented on PR #23716:
URL: https://github.com/apache/flink/pull/23716#issuecomment-1812024016
## CI report:
* 1537e4b3547759d9e66bd5b3dd23dfb18e568138 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Matthias Pohl created FLINK-33552:
-
Summary: Job (and its data) is lost
Key: FLINK-33552
URL: https://issues.apache.org/jira/browse/FLINK-33552
Project: Flink
Issue Type: Sub-task
Matthias Pohl created FLINK-33555:
-
Summary:
LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory:
Key: FLINK-33555
URL: https://issues.apache.org/jira/browse/FLINK-33555
Márton Balassi created FLINK-33557:
--
Summary: Externalize Cassandra Python connector code
Key: FLINK-33557
URL: https://issues.apache.org/jira/browse/FLINK-33557
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-33558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-33558:
---
Component/s: API / Python
Connectors / ElasticSearch
> Externalize
mxm commented on code in PR #710:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/710#discussion_r1393995132
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/state/ConfigMapStore.java:
##
@@ -44,13 +43,13 @@ public class
mxm commented on code in PR #710:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/710#discussion_r1393995934
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/state/ConfigMapView.java:
##
@@ -0,0 +1,111 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-33557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-33557:
---
Component/s: API / Python
Connectors / Cassandra
> Externalize Cassandra
[
https://issues.apache.org/jira/browse/FLINK-33559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-33559:
---
Component/s: API / Python
Connectors / Kafka
> Externalize Kafka Python
Márton Balassi created FLINK-33560:
--
Summary: Externalize Kinesis Python connector code
Key: FLINK-33560
URL: https://issues.apache.org/jira/browse/FLINK-33560
Project: Flink
Issue Type:
Márton Balassi created FLINK-33562:
--
Summary: Externalize RabbitMQ Python connector code
Key: FLINK-33562
URL: https://issues.apache.org/jira/browse/FLINK-33562
Project: Flink
Issue Type:
1996fanrui commented on code in PR #710:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/710#discussion_r1394045676
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/state/ConfigMapStore.java:
##
@@ -99,49 +93,30 @@ public
flinkbot commented on PR #23718:
URL: https://github.com/apache/flink/pull/23718#issuecomment-1812317220
## CI report:
* b6741d6e0fd20bcde38003154ab45b9fe6daa30c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786326#comment-17786326
]
Matthias Pohl commented on FLINK-33276:
---
master:
[
https://issues.apache.org/jira/browse/FLINK-33276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-33276:
--
Affects Version/s: (was: 1.16.2)
(was: 1.17.1)
> Reorganize CI
MartijnVisser commented on PR #23693:
URL: https://github.com/apache/flink/pull/23693#issuecomment-1811991737
> After 1.19 released, the new links will be exposed to users, WDYT?
Those are wrong links to begin with: a Flink connector for 1.18 isn't
guaranteed to be compatible with
dawidwys commented on code in PR #23713:
URL: https://github.com/apache/flink/pull/23713#discussion_r1394132228
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OverTypeStrategy.java:
##
@@ -0,0 +1,197 @@
+/*
+ * Licensed to the
zentol commented on PR #23719:
URL: https://github.com/apache/flink/pull/23719#issuecomment-1812448493
Admittedly that could be a follow-up. 樂
--
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
ferenc-csaky commented on code in PR #33:
URL:
https://github.com/apache/flink-connector-hbase/pull/33#discussion_r1394135077
##
flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/sink/WritableMetadata.java:
##
@@ -83,4 +84,38 @@ public static
[
https://issues.apache.org/jira/browse/FLINK-33504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-33504:
--
Summary: Supported maximum parallel jobs (was: Supported parallel jobs)
> Supported maximum
zentol commented on code in PR #23553:
URL: https://github.com/apache/flink/pull/23553#discussion_r1394174857
##
flink-connectors/flink-connector-datagen/src/main/java/org/apache/flink/connector/datagen/functions/FromElementsGeneratorFunction.java:
##
@@ -0,0 +1,200 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786349#comment-17786349
]
Chesnay Schepler commented on FLINK-18356:
--
Switch to CI image that enables jmalloc:
master:
gyfora merged PR #713:
URL: https://github.com/apache/flink-kubernetes-operator/pull/713
--
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-33263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786219#comment-17786219
]
Yun Tang commented on FLINK-33263:
--
[~Zhanghao Chen] Thanks for the update. Looking forward to the PR.
Matthias Pohl created FLINK-33554:
-
Summary: SemiJoinITCase.testRewriteScalarQueryWithCorrelation3
failed due to heartbeat timeout
Key: FLINK-33554
URL: https://issues.apache.org/jira/browse/FLINK-33554
Márton Balassi created FLINK-33558:
--
Summary: Externalize Elasticsearch Python connector code
Key: FLINK-33558
URL: https://issues.apache.org/jira/browse/FLINK-33558
Project: Flink
Issue
Márton Balassi created FLINK-33561:
--
Summary: Externalize Pulsar Python connector code
Key: FLINK-33561
URL: https://issues.apache.org/jira/browse/FLINK-33561
Project: Flink
Issue Type:
zentol merged PR #26:
URL: https://github.com/apache/flink-connector-shared-utils/pull/26
--
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:
XComp merged PR #23712:
URL: https://github.com/apache/flink/pull/23712
--
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-33490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786327#comment-17786327
]
xuyang commented on FLINK-33490:
Hi, [~fsk119] , Can I take this jira?
> Validate the name conflicts
[
https://issues.apache.org/jira/browse/FLINK-33490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-33490:
-
Assignee: xuyang
> Validate the name conflicts when creating view
>
1996fanrui commented on PR #710:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/710#issuecomment-1812434659
Thanks @mxm for the cleaning up and simplifying, great work!
LGTM for now.
--
This is an automated message from the Apache Git Service.
To respond to the
afedulov commented on PR #23553:
URL: https://github.com/apache/flink/pull/23553#issuecomment-1812451001
> Do you want to cleanup the git history a bit or shall I just squash
everything?
I'll do it, thanks!
One thing to clarify before we merge - I just noticed yesterday that
[
https://issues.apache.org/jira/browse/FLINK-33522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-33522.
--
Resolution: Fixed
merged to main 2ce7486c7ee7ea6cb1a4160585fb5bc696025378
> Savepoint upgrade mode
[
https://issues.apache.org/jira/browse/FLINK-32960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-32960:
---
Fix Version/s: kubernetes-operator-1.8.0
(was: kubernetes-operator-1.7.0)
>
[
https://issues.apache.org/jira/browse/FLINK-32119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-32119:
---
Fix Version/s: kubernetes-operator-1.8.0
(was: kubernetes-operator-1.7.0)
>
[
https://issues.apache.org/jira/browse/FLINK-33006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-33006:
---
Fix Version/s: kubernetes-operator-1.8.0
(was: kubernetes-operator-1.7.0)
>
[
https://issues.apache.org/jira/browse/FLINK-32120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-32120:
---
Fix Version/s: kubernetes-operator-1.8.0
> Add autoscaler config option to disable parallelism key
[
https://issues.apache.org/jira/browse/FLINK-33546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-33546:
Assignee: Dawid Wysakowicz
> Implement type inference for order(asc/desc)
Dawid Wysakowicz created FLINK-33563:
Summary: Implement type inference for Agg functions
Key: FLINK-33563
URL: https://issues.apache.org/jira/browse/FLINK-33563
Project: Flink
Issue
flinkbot commented on PR #23717:
URL: https://github.com/apache/flink/pull/23717#issuecomment-1812137002
## CI report:
* 7adb5944ff509a1f80b3561cac00265802b07ceb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-18473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786304#comment-17786304
]
Rui Fan commented on FLINK-18473:
-
Hi [~yigress] , thanks for your feedback.
The current strategy is
gyfora commented on PR #710:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/710#issuecomment-1812440379
--
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.
dawidwys commented on code in PR #23713:
URL: https://github.com/apache/flink/pull/23713#discussion_r1394134177
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OverTypeStrategy.java:
##
@@ -0,0 +1,197 @@
+/*
+ * Licensed to the
dawidwys commented on code in PR #23713:
URL: https://github.com/apache/flink/pull/23713#discussion_r1394133583
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/OverConvertRule.java:
##
@@ -182,57 +191,59 @@ private RexNode
[
https://issues.apache.org/jira/browse/FLINK-32120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-32120:
---
Fix Version/s: (was: kubernetes-operator-1.7.0)
> Add autoscaler config option to disable
[
https://issues.apache.org/jira/browse/FLINK-32127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-32127.
--
Resolution: Fixed
Fixed by the improved true processing rate tracking
> Source busy time is
flinkbot commented on PR #23722:
URL: https://github.com/apache/flink/pull/23722#issuecomment-1812545859
## CI report:
* 597428fa53be57b1b453bb3da90995e6adcfd1e1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
XComp merged PR #23709:
URL: https://github.com/apache/flink/pull/23709
--
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:
ferenc-csaky commented on PR #32:
URL:
https://github.com/apache/flink-connector-hbase/pull/32#issuecomment-1812031612
@Tan-JiaLiang if you have some time, can you take a look pls?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
SmirAlex commented on PR #23521:
URL: https://github.com/apache/flink/pull/23521#issuecomment-1812051645
Hi @Sxnan! Sorry, I understand that I'm not a reviewer, but it happened that
I was testing functionality from this MR recently, and I found a bug (in my
opinion). It concerns the logic
luoyuxia created FLINK-33549:
Summary: Exception "Factory does not implement interface
YieldingOperatorFactory" thrown in batch mode
Key: FLINK-33549
URL: https://issues.apache.org/jira/browse/FLINK-33549
[
https://issues.apache.org/jira/browse/FLINK-33550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786255#comment-17786255
]
Matthias Pohl commented on FLINK-33550:
---
[
https://issues.apache.org/jira/browse/FLINK-33550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786257#comment-17786257
]
Matthias Pohl commented on FLINK-33550:
---
zentol opened a new pull request, #23717:
URL: https://github.com/apache/flink/pull/23717
Based on
https://github.com/zentol/flink-ci-docker/tree/3e5789ed4fb5558f364a45315bae752c272f7bd9.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/FLINK-33557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-33557:
---
Fix Version/s: 1.19.0
> Externalize Cassandra Python connector code
>
mxm commented on PR #711:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/711#issuecomment-1812285350
> Sounds reasonable. If we are optimizing state size at this level, how
about we also remove `RECOMMENDED_PARALLELISM` and `PARALLELISM` from the
history metrics, since they
flinkbot commented on PR #23719:
URL: https://github.com/apache/flink/pull/23719#issuecomment-1812425572
## CI report:
* cbb25a4fee81c6aaaed7ba666f8be65570cf32c5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
snuyanzin opened a new pull request, #23721:
URL: https://github.com/apache/flink/pull/23721
The PR is aiming to fix build failure
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=54581=logs=52b61abe-a3cc-5bde-cc35-1bbe89bb7df5=54421a62-0c80-5aad-3319-094ff69180bb
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786355#comment-17786355
]
david radley commented on FLINK-33365:
--
[~libenchao] Thanks for the quick feedback . I agree, I was
snuyanzin commented on PR #23722:
URL: https://github.com/apache/flink/pull/23722#issuecomment-1812557141
thanks for the fix looks like this was fixed within
https://github.com/apache/flink/pull/23721
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-33552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786259#comment-17786259
]
Matthias Pohl commented on FLINK-33552:
---
Same happened with this job:
[
https://issues.apache.org/jira/browse/FLINK-33550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786263#comment-17786263
]
Matthias Pohl commented on FLINK-33550:
---
[
https://issues.apache.org/jira/browse/FLINK-33551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786262#comment-17786262
]
Matthias Pohl commented on FLINK-33551:
---
Matthias Pohl created FLINK-33553:
-
Summary: FileUtilsTest.testDeleteDirectoryConcurrently failed (no
progress/output)
Key: FLINK-33553
URL: https://issues.apache.org/jira/browse/FLINK-33553
Project:
[
https://issues.apache.org/jira/browse/FLINK-33550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786271#comment-17786271
]
Matthias Pohl commented on FLINK-33550:
---
[
https://issues.apache.org/jira/browse/FLINK-33550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786270#comment-17786270
]
Matthias Pohl commented on FLINK-33550:
---
[
https://issues.apache.org/jira/browse/FLINK-33558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-33558:
---
Affects Version/s: 1.18.0
> Externalize Elasticsearch Python connector code
>
[
https://issues.apache.org/jira/browse/FLINK-33558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-33558:
---
Fix Version/s: 1.19.0
> Externalize Elasticsearch Python connector code
>
[
https://issues.apache.org/jira/browse/FLINK-33557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-33557:
---
Affects Version/s: 1.18.0
> Externalize Cassandra Python connector code
>
[
https://issues.apache.org/jira/browse/FLINK-33528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-33528:
---
Description:
During the connector externalization effort end to end tests for the python
mxm commented on code in PR #710:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/710#discussion_r1394033152
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/autoscaler/state/KubernetesAutoScalerStateStoreTest.java:
##
@@ -330,4
mxm commented on code in PR #710:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/710#discussion_r1394117281
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/state/ConfigMapView.java:
##
@@ -0,0 +1,116 @@
+/*
+ * Licensed
xuyangzhong opened a new pull request, #23720:
URL: https://github.com/apache/flink/pull/23720
## What is the purpose of the change
Cherry-pick from https://github.com/apache/flink/pull/23620.
This pr try to fix that join hints should also be resolved and work when
defined in
1 - 100 of 232 matches
Mail list logo
