[
https://issues.apache.org/jira/browse/FLINK-30061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-30061:
--
Assignee: Martijn Visser
> Create and initialize repository for HBase connector
>
echauchot commented on PR #2:
URL:
https://github.com/apache/flink-connector-cassandra/pull/2#issuecomment-1323805158
> CI is failing due to dependency convergence; we'll need to add a few
entries to the dependency management section like we had to in other connectors.
Yes I'm
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1029431451
##
flink-connector-opensearch-e2e-tests/src/test/java/org/apache/flink/streaming/tests/OpensearchSinkE2ECase.java:
##
@@ -0,0 +1,117 @@
+/*
+ * Licensed to
zentol commented on code in PR #2:
URL:
https://github.com/apache/flink-connector-cassandra/pull/2#discussion_r1029411061
##
flink-connector-cassandra/pom.xml:
##
@@ -0,0 +1,423 @@
+
+
+http://maven.apache.org/POM/4.0.0;
+
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1029422867
##
flink-connector-opensearch/src/test/java/org/apache/flink/connector/opensearch/table/IndexGeneratorTest.java:
##
@@ -0,0 +1,264 @@
+/*
+ * Licensed to
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1029420381
##
flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch/util/RetryRejectedExecutionFailureHandler.java:
##
@@ -0,0
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1029419750
##
flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch/util/IgnoringFailureHandler.java:
##
@@ -0,0 +1,38 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-18568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637293#comment-17637293
]
Martijn Visser commented on FLINK-18568:
This shouldn't be added to StreamingFileSink since
[
https://issues.apache.org/jira/browse/FLINK-30052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-30052:
--
Assignee: Mason Chen
> Move existing Kafka connector code from Flink repo to
[
https://issues.apache.org/jira/browse/FLINK-30051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser resolved FLINK-30051.
Fix Version/s: kafka-3.0.0
Resolution: Fixed
> Create and initialize repository
[
https://issues.apache.org/jira/browse/FLINK-30051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-30051:
--
Assignee: Martijn Visser
> Create and initialize repository for Kafka connector
>
[
https://issues.apache.org/jira/browse/FLINK-30051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637291#comment-17637291
]
Martijn Visser commented on FLINK-30051:
Created https://github.com/apache/flink-connector-kafka
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1029414934
##
flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch/OpensearchSink.java:
##
@@ -0,0 +1,807 @@
+/*
+ * Licensed to
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1029404923
##
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchDynamicSinkFactory.java:
##
@@ -0,0 +1,222 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-18568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637289#comment-17637289
]
Jun Qin commented on FLINK-18568:
-
[~ram_krish] Thanks. Are you targeting 1.17? Will it also work in
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1029395474
##
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchDynamicSinkFactory.java:
##
@@ -0,0 +1,222 @@
+/*
+ *
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1029389149
##
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchDynamicSinkFactory.java:
##
@@ -0,0 +1,222 @@
+/*
+ *
reswqa closed pull request #19882: [hotfix] fix a typo in NetworkBufferTest
URL: https://github.com/apache/flink/pull/19882
--
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
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1029386429
##
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchDynamicSink.java:
##
@@ -0,0 +1,201 @@
+/*
+ * Licensed to
reswqa commented on PR #20024:
URL: https://github.com/apache/flink/pull/20024#issuecomment-1323745881
@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-30062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-30062:
--
Assignee: Ferenc Csaky
> Move existing HBase connector code from Flink repo to
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1029363404
##
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchConfiguration.java:
##
@@ -0,0 +1,168 @@
+/*
+ * Licensed
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1029363404
##
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchConfiguration.java:
##
@@ -0,0 +1,168 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-30044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-30044.
Resolution: Fixed
master: 06fcd34eb2646f5e33796ca6bb411728acdfff62
> Deduplicate plugin
zentol merged PR #21338:
URL: https://github.com/apache/flink/pull/21338
--
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:
zentol commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1029349138
##
flink-connector-opensearch-e2e-tests/src/test/java/org/apache/flink/streaming/tests/OpensearchSinkE2ECase.java:
##
@@ -0,0 +1,117 @@
+/*
+ * Licensed
gaborgsomogyi commented on PR #21128:
URL: https://github.com/apache/flink/pull/21128#issuecomment-1323705086
@MartijnVisser could you rebase it to the latest master and I can have a
look too?
--
This is an automated message from the Apache Git Service.
To respond to the message, please
gaborgsomogyi commented on PR #20875:
URL: https://github.com/apache/flink/pull/20875#issuecomment-1323702730
I've tested it manually on live cluster and it works.
@HuangZhenQiu could you do a rebase to the latest master where tests are
more stable?
--
This is an automated message
[
https://issues.apache.org/jira/browse/FLINK-30154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-30154:
---
Priority: Blocker (was: Major)
> flinkConfiguration in SessionJob is not accepted
>
[
https://issues.apache.org/jira/browse/FLINK-30154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-30154:
---
Fix Version/s: kubernetes-operator-1.3.0
> flinkConfiguration in SessionJob is not accepted
>
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1029343888
##
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/NetworkClientConfig.java:
##
@@ -0,0 +1,86 @@
+/*
+ * Licensed to the
Emmanuel Leroy created FLINK-30154:
--
Summary: flinkConfiguration in SessionJob is not accepted
Key: FLINK-30154
URL: https://issues.apache.org/jira/browse/FLINK-30154
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637236#comment-17637236
]
Alexander Smirnov edited comment on FLINK-29427 at 11/22/22 1:37 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637236#comment-17637236
]
Alexander Smirnov edited comment on FLINK-29427 at 11/22/22 1:37 PM:
-
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1029334988
##
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchSink.java:
##
@@ -0,0 +1,91 @@
+/*
+ * Licensed to the
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1029330763
##
pom.xml:
##
@@ -0,0 +1,463 @@
+
+
+http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd;
+
[
https://issues.apache.org/jira/browse/FLINK-28326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637259#comment-17637259
]
Weijie Guo edited comment on FLINK-28326 at 11/22/22 1:29 PM:
--
[~renqs]
[
https://issues.apache.org/jira/browse/FLINK-28326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637259#comment-17637259
]
Weijie Guo commented on FLINK-28326:
[~renqs] Sorry for the reply. I checked the code path and
lintong commented on PR #18465:
URL: https://github.com/apache/flink/pull/18465#issuecomment-1323663589
Hi, when is it going to be possible to have a docker image with a release of
17 in it please?
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-30131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637165#comment-17637165
]
Weijie Guo edited comment on FLINK-30131 at 11/22/22 12:52 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637236#comment-17637236
]
Alexander Smirnov edited comment on FLINK-29427 at 11/22/22 12:48 PM:
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637236#comment-17637236
]
Alexander Smirnov edited comment on FLINK-29427 at 11/22/22 12:47 PM:
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637236#comment-17637236
]
Alexander Smirnov edited comment on FLINK-29427 at 11/22/22 12:47 PM:
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637236#comment-17637236
]
Alexander Smirnov commented on FLINK-29427:
---
Hi everyone! First of all, I'm very sorry for
SteNicholas commented on code in PR #397:
URL: https://github.com/apache/flink-table-store/pull/397#discussion_r1029260007
##
flink-table-store-common/src/main/java/org/apache/flink/table/store/utils/LocalFileUtils.java:
##
@@ -0,0 +1,50 @@
+/*
+ * Licensed to the Apache
SteNicholas commented on code in PR #397:
URL: https://github.com/apache/flink-table-store/pull/397#discussion_r1029245341
##
flink-table-store-common/src/main/java/org/apache/flink/table/store/utils/LocalFileUtils.java:
##
@@ -0,0 +1,50 @@
+/*
+ * Licensed to the Apache
SteNicholas commented on code in PR #397:
URL: https://github.com/apache/flink-table-store/pull/397#discussion_r1029245341
##
flink-table-store-common/src/main/java/org/apache/flink/table/store/utils/LocalFileUtils.java:
##
@@ -0,0 +1,50 @@
+/*
+ * Licensed to the Apache
MartijnVisser commented on PR #21128:
URL: https://github.com/apache/flink/pull/21128#issuecomment-1323541403
@gaborgsomogyi I did some debugging locally. If you correct the location to
the directory, the test still fails. For example, the `perJobYarnCluster` fails
because the job is being
[
https://issues.apache.org/jira/browse/FLINK-30030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637203#comment-17637203
]
Jing Zhang commented on FLINK-30030:
[~luoyuxia] Thanks for open this issue.
We also received some
[
https://issues.apache.org/jira/browse/FLINK-24742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-24742.
---
Fix Version/s: 1.17.0
Resolution: Fixed
master:
[
https://issues.apache.org/jira/browse/FLINK-30152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637189#comment-17637189
]
Martijn Visser commented on FLINK-30152:
I'm suspecting it was
XComp merged PR #17649:
URL: https://github.com/apache/flink/pull/17649
--
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-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637184#comment-17637184
]
Matthias Pohl commented on FLINK-29405:
---
[
https://issues.apache.org/jira/browse/FLINK-28741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637180#comment-17637180
]
Jing Zhang edited comment on FLINK-28741 at 11/22/22 11:11 AM:
---
> I'm
[
https://issues.apache.org/jira/browse/FLINK-30152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637182#comment-17637182
]
Matthias Pohl commented on FLINK-30152:
---
yeah, I created the ticket for documentation purposes.
[
https://issues.apache.org/jira/browse/FLINK-30152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637181#comment-17637181
]
Matthias Pohl commented on FLINK-30152:
---
[
https://issues.apache.org/jira/browse/FLINK-28741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637180#comment-17637180
]
Jing Zhang commented on FLINK-28741:
> I'm wondering is there some Hive2 users may expect the
[
https://issues.apache.org/jira/browse/FLINK-30152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637178#comment-17637178
]
Martijn Visser commented on FLINK-30152:
This mostly occurs when there's a connection issue at
[
https://issues.apache.org/jira/browse/FLINK-28199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637179#comment-17637179
]
Matthias Pohl commented on FLINK-28199:
---
[
https://issues.apache.org/jira/browse/FLINK-28741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637177#comment-17637177
]
Jing Zhang commented on FLINK-28741:
[~luoyuxia] Good question.
I test this behavior in spark, the
[
https://issues.apache.org/jira/browse/FLINK-29836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637175#comment-17637175
]
Matthias Pohl commented on FLINK-29836:
---
[
https://issues.apache.org/jira/browse/FLINK-30146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi updated FLINK-30146:
--
Summary: Evaluate operator error log whitelist entry: Exception while
listing jobs (was:
[
https://issues.apache.org/jira/browse/FLINK-30151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi updated FLINK-30151:
--
Summary: Evaluate operator error log whitelist entry: AuditUtils (was:
Evaluate operator
[
https://issues.apache.org/jira/browse/FLINK-30149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi updated FLINK-30149:
--
Summary: Evaluate operator error log whitelist entry: Error during event
processing (was:
[
https://issues.apache.org/jira/browse/FLINK-30147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi updated FLINK-30147:
--
Summary: Evaluate operator error log whitelist entry: Failed to submit a
listener
[
https://issues.apache.org/jira/browse/FLINK-30150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi updated FLINK-30150:
--
Summary: Evaluate operator error log whitelist entry: REST service in
session cluster is bad
[
https://issues.apache.org/jira/browse/FLINK-30148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi updated FLINK-30148:
--
Summary: Evaluate operator error log whitelist entry: Failed to submit job
to session cluster
[
https://issues.apache.org/jira/browse/FLINK-30145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi updated FLINK-30145:
--
Summary: Evaluate operator error log whitelist entry:
JmDeploymentStatus.ERROR.Count (was:
flinkbot commented on PR #21365:
URL: https://github.com/apache/flink/pull/21365#issuecomment-1323490928
## CI report:
* 861c87ee8b9f6a2f5adfe1a7367fff0424c64ab3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637171#comment-17637171
]
Matthias Pohl commented on FLINK-27164:
---
Matthias Pohl created FLINK-30153:
-
Summary: YARNSessionCapacitySchedulerITCase fails with
NoClassDefFoundError
Key: FLINK-30153
URL: https://issues.apache.org/jira/browse/FLINK-30153
Project: Flink
gaborgsomogyi commented on code in PR #446:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/446#discussion_r1029182710
##
e2e-tests/utils.sh:
##
@@ -108,12 +113,37 @@ function retry_times() {
return 1
}
+function check_operator_log_for_errors {
+ echo
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29427:
---
Labels: pull-request-available test-stability (was: test-stability)
> LookupJoinITCase
Matthias Pohl created FLINK-30152:
-
Summary: Failure in setting up the CI agent
Key: FLINK-30152
URL: https://issues.apache.org/jira/browse/FLINK-30152
Project: Flink
Issue Type: Bug
SmirAlex opened a new pull request, #21365:
URL: https://github.com/apache/flink/pull/21365
## What is the purpose of the change
This pull-request *tries to fix* unstable test `LookupJoinITCase` (error was
not succeeded to be reproduced locally). The errors contains a message
[
https://issues.apache.org/jira/browse/FLINK-30131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637165#comment-17637165
]
Weijie Guo commented on FLINK-30131:
[~landlord] Thanks for reporting this.
At present, I have not
[
https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637164#comment-17637164
]
Matthias Pohl commented on FLINK-26974:
---
[
https://issues.apache.org/jira/browse/FLINK-30147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi updated FLINK-30147:
--
Component/s: Kubernetes Operator
> Evaluate operator error log entry: Failed to submit a
[
https://issues.apache.org/jira/browse/FLINK-30148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi updated FLINK-30148:
--
Component/s: Kubernetes Operator
> Evaluate operator error log entry: Failed to submit job to
Gabor Somogyi created FLINK-30148:
-
Summary: Evaluate operator error log entry: Failed to submit job
to session cluster
Key: FLINK-30148
URL: https://issues.apache.org/jira/browse/FLINK-30148
Gabor Somogyi created FLINK-30150:
-
Summary: Evaluate operator error log entry: REST service in
session cluster is bad now
Key: FLINK-30150
URL: https://issues.apache.org/jira/browse/FLINK-30150
[
https://issues.apache.org/jira/browse/FLINK-26037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637163#comment-17637163
]
Matthias Pohl commented on FLINK-26037:
---
Gabor Somogyi created FLINK-30151:
-
Summary: Evaluate operator error log entry: AuditUtils
Key: FLINK-30151
URL: https://issues.apache.org/jira/browse/FLINK-30151
Project: Flink
Issue Type:
Gabor Somogyi created FLINK-30149:
-
Summary: Evaluate operator error log entry: Error during event
processing
Key: FLINK-30149
URL: https://issues.apache.org/jira/browse/FLINK-30149
Project: Flink
Gabor Somogyi created FLINK-30147:
-
Summary: Evaluate operator error log entry: Failed to submit a
listener notification task
Key: FLINK-30147
URL: https://issues.apache.org/jira/browse/FLINK-30147
Gabor Somogyi created FLINK-30146:
-
Summary: Evaluate operator error log entry: Exception while
listing jobs
Key: FLINK-30146
URL: https://issues.apache.org/jira/browse/FLINK-30146
Project: Flink
Gabor Somogyi created FLINK-30145:
-
Summary: Evaluate operator error log entry:
JmDeploymentStatus.ERROR.Count
Key: FLINK-30145
URL: https://issues.apache.org/jira/browse/FLINK-30145
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi updated FLINK-30117:
--
Summary: Evaluate operator error log whitelist entries added in FLINK-29475
(was: Evaluate
[
https://issues.apache.org/jira/browse/FLINK-29835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637161#comment-17637161
]
Matthias Pohl commented on FLINK-29835:
---
[
https://issues.apache.org/jira/browse/FLINK-30101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen closed FLINK-30101.
-
Resolution: Incomplete
> Always use StandaloneClientHAServices to create RestClusterClient when
[
https://issues.apache.org/jira/browse/FLINK-30101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637155#comment-17637155
]
Zhanghao Chen commented on FLINK-30101:
---
Thanks, you made a point. I did not take the case where
flinkbot commented on PR #21364:
URL: https://github.com/apache/flink/pull/21364#issuecomment-1323430526
## CI report:
* d7ec002ddc4849e1f34a3e27290f99feb247cde3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gaborgsomogyi commented on PR #21364:
URL: https://github.com/apache/flink/pull/21364#issuecomment-1323421508
cc @mbalassi @dannycranmer
--
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
[
https://issues.apache.org/jira/browse/FLINK-30134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30134:
---
Labels: pull-request-available (was: )
> Annotate all the public classes for the
gaborgsomogyi opened a new pull request, #21364:
URL: https://github.com/apache/flink/pull/21364
## What is the purpose of the change
On the discussion thread of the [delegation token framework
generalization](https://lists.apache.org/thread/vgg5hbf5jljcxopfhb32w3l0wjoyko4o)
popped
[
https://issues.apache.org/jira/browse/FLINK-28424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637135#comment-17637135
]
Matthias Pohl commented on FLINK-28424:
---
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637133#comment-17637133
]
Matthias Pohl commented on FLINK-18356:
---
[
https://issues.apache.org/jira/browse/FLINK-30144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30144:
---
Labels: pull-request-available (was: )
> Guarantee Flink ML operators function correctly
yunfengzhou-hub opened a new pull request, #179:
URL: https://github.com/apache/flink-ml/pull/179
## What is the purpose of the change
This PR set object-reuse configuration as enabled in Flink ML E2E test cases.
## Brief change log
- Sets object-reuse configuration as
Yunfeng Zhou created FLINK-30144:
Summary: Guarantee Flink ML operators function correctly with
object-reuse enabled
Key: FLINK-30144
URL: https://issues.apache.org/jira/browse/FLINK-30144
Project:
101 - 200 of 261 matches
Mail list logo
