[
https://issues.apache.org/jira/browse/FLINK-28060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557289#comment-17557289
]
Martijn Visser commented on FLINK-28060:
I'm not sure that we have a test for this behaviour. It
chenzihao5 commented on code in PR #19797:
URL: https://github.com/apache/flink/pull/19797#discussion_r903383377
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/OverAggregateITCase.scala:
##
@@ -159,6 +159,66 @@ class
[
https://issues.apache.org/jira/browse/FLINK-28190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng closed FLINK-28190.
---
Resolution: Not A Problem
> NullPointerException is thrown if the intermediate result of nesting
[
https://issues.apache.org/jira/browse/FLINK-28166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28166:
---
Labels: pull-request-available (was: )
> Configurable Automatic Retries on Error
>
[
https://issues.apache.org/jira/browse/FLINK-28160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557259#comment-17557259
]
cjh commented on FLINK-28160:
-
[~twalthr] , The original SQL query is as follows:
select
dt_str,
morhidi opened a new pull request, #273:
URL: https://github.com/apache/flink-kubernetes-operator/pull/273
JOSDK defaults to the following retry configuration (exponential backoff)
```
GenericRetry.defaultLimitedExponentialRetry()
.setInitialInterval(2000)
[
https://issues.apache.org/jira/browse/FLINK-27292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557274#comment-17557274
]
jjiey commented on FLINK-27292:
---
Hi [~jark], Could you assign this to me? thank you.
> Translate the
pnowojski commented on PR #20038:
URL: https://github.com/apache/flink/pull/20038#issuecomment-1162728339
It would create even more garbage commits in the master, so let's keep it as
it is.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/FLINK-27667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557287#comment-17557287
]
Biao Geng commented on FLINK-27667:
---
Hi [~martijnvisser] , I see [~ferenc-csaky] has created the PR
[
https://issues.apache.org/jira/browse/FLINK-27667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-27667.
--
Fix Version/s: 1.16.0
Resolution: Fixed
Fixed in master:
zhoulii commented on code in PR #20039:
URL: https://github.com/apache/flink/pull/20039#discussion_r903336973
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionDeployer.java:
##
@@ -0,0 +1,386 @@
+/*
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/FLINK-28175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28175:
---
Labels: pull-request-available (was: )
> Improve LicenseChecker output
>
zentol commented on PR #20003:
URL: https://github.com/apache/flink/pull/20003#issuecomment-1162721597
> If we force to use parent-first mode, then the classloader behavior is
inconsistent between local job compiling and distributed. Say the user wants to
use child-first for distributed
Jane Chan created FLINK-28192:
-
Summary: RescaleBucketITCase is not stable
Key: FLINK-28192
URL: https://issues.apache.org/jira/browse/FLINK-28192
Project: Flink
Issue Type: Bug
gyfora opened a new pull request, #274:
URL: https://github.com/apache/flink-kubernetes-operator/pull/274
This PR includes a refactor and unification of the reconciler hieararchy we
have right now:
- SessionReconciler
- AbstractDeploymentReconciler
- ApplicationReconciler
[
https://issues.apache.org/jira/browse/FLINK-28180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28180:
---
Labels: pull-request-available (was: )
> Unify Application and SessionJob reconcilers
>
gyfora commented on PR #274:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/274#issuecomment-1162750385
cc @Aitozi
--
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
zentol commented on PR #20003:
URL: https://github.com/apache/flink/pull/20003#issuecomment-1162750463
I'm pretty sure you are correct.
We never actually had the case where we had a tree of classloaders with
different order settings between nodes.
It's always been either all
[
https://issues.apache.org/jira/browse/FLINK-27741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557303#comment-17557303
]
chenzihao commented on FLINK-27741:
---
Hi, [~godfreyhe] . Can you help to confirm this ticket? What do
[
https://issues.apache.org/jira/browse/FLINK-28146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28146:
---
Assignee: Lijie Wang
> Sync blocklist information between JobMaster & ResourceManager
>
nyingping commented on PR #20028:
URL: https://github.com/apache/flink/pull/20028#issuecomment-1162687881
@Myasuka updated. sorry for delay.
--
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-27972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-27972.
Fix Version/s: 1.16.0
Resolution: Fixed
master:
[
https://issues.apache.org/jira/browse/FLINK-28068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-28068:
Assignee: Jingsong Lee
> Control the total memory of a sink task
>
zentol merged PR #19968:
URL: https://github.com/apache/flink/pull/19968
--
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-28143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28143:
---
Assignee: Lijie Wang
> Introduce BlocklistHandler
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-28145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28145:
---
Assignee: Lijie Wang
> Let ResourceManager support blocklist mechanism
>
[
https://issues.apache.org/jira/browse/FLINK-28130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28130:
---
Assignee: Lijie Wang
> FLIP-224: Blocklist Mechanism
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-28144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28144:
---
Assignee: Lijie Wang
> Let JobMaster support blocklist mechanism
>
[
https://issues.apache.org/jira/browse/FLINK-28142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28142:
---
Assignee: Lijie Wang
> Enrich TaskManagerLocation with node information
>
zhoulii commented on code in PR #20039:
URL: https://github.com/apache/flink/pull/20039#discussion_r903335396
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionDeployer.java:
##
@@ -0,0 +1,386 @@
+/*
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/FLINK-28192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557292#comment-17557292
]
Jane Chan commented on FLINK-28192:
---
Maybe we don't need this assertion, let me remove it. cc
gyfora commented on code in PR #273:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/273#discussion_r903396030
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorConfigOptions.java:
##
@@ -203,4 +203,28 @@
gaborgsomogyi commented on PR #20011:
URL: https://github.com/apache/flink/pull/20011#issuecomment-1162678662
@MartijnVisser I've added your suggestions, may I ask to have another look
plz?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/FLINK-27292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557274#comment-17557274
]
jjiey edited comment on FLINK-27292 at 6/22/22 6:44 AM:
Thank [~yckkcy] for your
wuchong commented on PR #20003:
URL: https://github.com/apache/flink/pull/20003#issuecomment-1162734430
This still seems inconsistent classloader behavior compared to the
distributed execution. Please correct me if I'm wrong.
When resolve-order is child-first, the classloader order
[
https://issues.apache.org/jira/browse/FLINK-26541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557293#comment-17557293
]
LuNing Wang commented on FLINK-26541:
-
big +1 for this feature
> SQL Client should support
wuchong commented on PR #20003:
URL: https://github.com/apache/flink/pull/20003#issuecomment-1162757295
Thank you @zentol .
So are you fine with the `MutableURLClassLoader` approach which is
straightforward and (looks like so far) has no side effects?
--
This is an automated message
chenzihao5 commented on code in PR #19797:
URL: https://github.com/apache/flink/pull/19797#discussion_r903392287
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/RankLikeAggFunctionBase.java:
##
@@ -98,7 +98,7 @@ protected
XComp commented on code in PR #19907:
URL: https://github.com/apache/flink/pull/19907#discussion_r903346279
##
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java:
##
@@ -685,13 +687,27 @@ public CompletableFuture submitTask(
zentol opened a new pull request, #20041:
URL: https://github.com/apache/flink/pull/20041
With this PR the output of the license checker is grouped by module and
severity, hopefully making the problems easier to understand.
--
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-28191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28191:
---
Affects Version/s: (was: 1.14.3)
> 【flink-runtime】Achieve metrics summary and unified
bgeng777 commented on PR #20012:
URL: https://github.com/apache/flink/pull/20012#issuecomment-1162724423
LGTM as well. Thanks @ferenc-csaky !
--
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
MartijnVisser merged PR #20012:
URL: https://github.com/apache/flink/pull/20012
--
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-28193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28193:
---
Assignee: Zhu Zhu
> Enable to identify whether a job vertex contains source/sink operators
>
Zhu Zhu created FLINK-28193:
---
Summary: Enable to identify whether a job vertex contains
source/sink operators
Key: FLINK-28193
URL: https://issues.apache.org/jira/browse/FLINK-28193
Project: Flink
flinkbot commented on PR #20043:
URL: https://github.com/apache/flink/pull/20043#issuecomment-1162794636
## CI report:
* ba3c08d53b06c92f5345ae2dd20357411484d155 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gyfora commented on code in PR #268:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/268#discussion_r903452192
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorConfigOptions.java:
##
@@ -203,4 +203,11 @@
reswqa commented on code in PR #20039:
URL: https://github.com/apache/flink/pull/20039#discussion_r903456529
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultExecutionDeployerTest.java:
##
@@ -0,0 +1,388 @@
+/*
+ * Licensed to the Apache Software
wuchong commented on code in PR #19823:
URL: https://github.com/apache/flink/pull/19823#discussion_r903436449
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/utils/ThreadUtils.java:
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache
MartijnVisser merged PR #20044:
URL: https://github.com/apache/flink/pull/20044
--
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:
liuzhuang2017 commented on PR #19966:
URL: https://github.com/apache/flink/pull/19966#issuecomment-1162875025
@mbalassi ,Sorry to bother you again, can you help me review this pr? Thank
you.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
zentol commented on PR #20041:
URL: https://github.com/apache/flink/pull/20041#issuecomment-1162888702
@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-28068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28068:
---
Labels: pull-request-available (was: )
> Control the total memory of a sink task
>
JingsongLi opened a new pull request, #171:
URL: https://github.com/apache/flink-table-store/pull/171
Currently, Sink's MemTable memory is self-managed Heap, and compaction also
consumes memory, which is not very easy to use, and the memory problem will be
more serious if there are
KarmaGYZ commented on code in PR #20042:
URL: https://github.com/apache/flink/pull/20042#discussion_r903535308
##
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java:
##
@@ -208,6 +210,16 @@ protected void runApplication(String[] args) throws
Exception {
[
https://issues.apache.org/jira/browse/FLINK-27832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557367#comment-17557367
]
Chesnay Schepler commented on FLINK-27832:
--
This is the build from zhu zhu:
[
https://issues.apache.org/jira/browse/FLINK-24666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-24666:
Summary: Add job level "table.exec.state-staled.error-handling" option and
apply to related
[
https://issues.apache.org/jira/browse/FLINK-28198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557388#comment-17557388
]
Martijn Visser commented on FLINK-28198:
[~echauchot] I'm seeing this failure quite frequently,
Martijn Visser created FLINK-28198:
--
Summary:
CassandraConnectorITCase#testRaiseCassandraRequestsTimeouts fails with timeout
Key: FLINK-28198
URL: https://issues.apache.org/jira/browse/FLINK-28198
[
https://issues.apache.org/jira/browse/FLINK-28199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557390#comment-17557390
]
Martijn Visser commented on FLINK-28199:
[~ferenc-csaky] [~bgeng777] This error occurred after
[
https://issues.apache.org/jira/browse/FLINK-27703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557392#comment-17557392
]
Martijn Visser commented on FLINK-27703:
[
https://issues.apache.org/jira/browse/FLINK-27703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-27703:
---
Priority: Critical (was: Major)
>
flinkbot commented on PR #20048:
URL: https://github.com/apache/flink/pull/20048#issuecomment-1163008132
## CI report:
* 1efa958a738744969e25c59f1ce58f65c0d972d1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yangjf2019 opened a new pull request, #552:
URL: https://github.com/apache/flink-web/pull/552
When the user clicks on the 'Getting started' --> 'with flink' jump in
https://flink.apache.org/, there is a redundant '/' symbol in the url, which I
have eliminated.
--
This is an automated
mbalassi commented on PR #20037:
URL: https://github.com/apache/flink/pull/20037#issuecomment-1162845179
@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-28053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557329#comment-17557329
]
Jark Wu commented on FLINK-28053:
-
Similar issue in HiveServer: HIVE-11402
> Introduce queue to execute
flinkbot commented on PR #20045:
URL: https://github.com/apache/flink/pull/20045#issuecomment-1162876594
## CI report:
* b75234d42f6c40593ba8163f735aa981272c951b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
nyingping commented on PR #20028:
URL: https://github.com/apache/flink/pull/20028#issuecomment-1162909126
@Myasuka Updated.
--
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.
zentol opened a new pull request, #20046:
URL: https://github.com/apache/flink/pull/20046
Prevent conflicts with the `hadoop.version` property in the Hadoop parent
pom, when using Maven 3.8.5+.
This lead to our modules that use Hadoop 3 to partially bundle Hadoop 2.8.5
when
[
https://issues.apache.org/jira/browse/FLINK-28196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28196:
---
Labels: pull-request-available (was: )
> Rename hadoop.version property
>
JingsongLi commented on code in PR #167:
URL: https://github.com/apache/flink-table-store/pull/167#discussion_r903568556
##
docs/content/docs/development/rescale-bucket.md:
##
@@ -0,0 +1,141 @@
+---
+title: "Rescale Bucket"
+weight: 5
+type: docs
+aliases:
+-
rkhachatryan commented on code in PR #19679:
URL: https://github.com/apache/flink/pull/19679#discussion_r903571015
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java:
##
@@ -477,6 +478,50 @@
liujiawinds commented on PR #20047:
URL: https://github.com/apache/flink/pull/20047#issuecomment-1162929493
@MartijnVisser @zentol Could you have a look?
Btw, Is there any way to trigger hadoop3 cron build manually?
--
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-27792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-27792.
Resolution: Duplicate
> InterruptedException thrown by ChannelStateWriterImpl
>
[
https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557387#comment-17557387
]
Aitozi commented on FLINK-28187:
thanks, I will check it now
> Duplicate job submission for
fsk119 commented on code in PR #19823:
URL: https://github.com/apache/flink/pull/19823#discussion_r903621101
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/utils/ThreadUtils.java:
##
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Software
Martijn Visser created FLINK-28199:
--
Summary: Failures on
YARNHighAvailabilityITCase.testClusterClientRetrieval and
YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint
Key: FLINK-28199
URL:
bobby-richard opened a new pull request, #20048:
URL: https://github.com/apache/flink/pull/20048
## What is the purpose of the change
Add support for reading and writing postgres UUID types via Flink SQL STRING
type
## Brief change log
- modified
[
https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557404#comment-17557404
]
Aitozi commented on FLINK-28187:
I get your meaning now, but I think the case is a bit different from
[
https://issues.apache.org/jira/browse/FLINK-26270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557410#comment-17557410
]
fengjk commented on FLINK-26270:
Can you assign this problem to me.
> Flink SQL write data to kafka by
fsk119 commented on code in PR #19823:
URL: https://github.com/apache/flink/pull/19823#discussion_r903417787
##
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/result/ResultFetcherTest.java:
##
@@ -0,0 +1,355 @@
+/*
+ * Licensed to the Apache
gyfora commented on code in PR #268:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/268#discussion_r903434917
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorConfigOptions.java:
##
@@ -203,4 +203,11 @@
SteNicholas commented on code in PR #268:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/268#discussion_r903447982
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorConfigOptions.java:
##
@@ -203,4 +203,11
fsk119 opened a new pull request, #553:
URL: https://github.com/apache/flink-web/pull/553
Modified Web snapshot:
![image](https://user-images.githubusercontent.com/33114724/174984069-eebba57d-8f70-42b9-ab82-2f3675321201.png)
[
https://issues.apache.org/jira/browse/FLINK-28192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557324#comment-17557324
]
Jingsong Lee commented on FLINK-28192:
--
master: d8e415ae88677698903d0445cbca19dd12270a75
>
JingsongLi merged PR #170:
URL: https://github.com/apache/flink-table-store/pull/170
--
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-28192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28192:
---
Labels: pull-request-available (was: )
> RescaleBucketITCase is not stable
>
[
https://issues.apache.org/jira/browse/FLINK-28192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28192.
Assignee: Jane Chan
Resolution: Fixed
> RescaleBucketITCase is not stable
>
MartijnVisser commented on PR #20012:
URL: https://github.com/apache/flink/pull/20012#issuecomment-1162857409
You too @mbalassi :)
--
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
MartijnVisser opened a new pull request, #20044:
URL: https://github.com/apache/flink/pull/20044
## What is the purpose of the change
* Fix CI due to a new libssl being released
## Brief change log
* Changed libssl download link
## Verifying this change
MartijnVisser merged PR #19966:
URL: https://github.com/apache/flink/pull/19966
--
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-28194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28194:
---
Labels: pull-request-available (was: )
> Remove workaround around avro sql jar
>
liuzhuang2017 commented on PR #19966:
URL: https://github.com/apache/flink/pull/19966#issuecomment-1162884234
@MartijnVisser , Thank you very much for your review.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
fsk119 merged PR #553:
URL: https://github.com/apache/flink-web/pull/553
--
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-28173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557345#comment-17557345
]
Martijn Visser commented on FLINK-28173:
[~sonice_lj] I've assigned it to you.
> Multiple
[
https://issues.apache.org/jira/browse/FLINK-28173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-28173:
--
Assignee: jia liu
> Multiple Parquet format tests are failing with NoSuchMethodError
[
https://issues.apache.org/jira/browse/FLINK-27832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557348#comment-17557348
]
Roman Khachatryan commented on FLINK-27832:
---
[~zhuzh] could you check whether
LadyForest commented on code in PR #167:
URL: https://github.com/apache/flink-table-store/pull/167#discussion_r903578903
##
docs/content/docs/development/rescale-bucket.md:
##
@@ -0,0 +1,141 @@
+---
+title: "Rescale Bucket"
+weight: 5
+type: docs
+aliases:
+-
zhuzhurk commented on PR #20043:
URL: https://github.com/apache/flink/pull/20043#issuecomment-116290
> Could you not infer this from the size of `inputs`/`results` in the
`JobVertex`?
A job vertex with no input/output does not mean it is a true source/sink
vertex.
-
zhipeng93 opened a new pull request, #114:
URL: https://github.com/apache/flink-ml/pull/114
This PR optimizes the performance of VectorAssembler. It increases the
throughput by 30%-50%.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
1 - 100 of 318 matches
Mail list logo