gyfora merged PR #612:
URL: https://github.com/apache/flink-kubernetes-operator/pull/612
--
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:
lindong28 commented on code in PR #242:
URL: https://github.com/apache/flink-ml/pull/242#discussion_r1225027030
##
flink-ml-servable-core/src/main/java/org/apache/flink/ml/linalg/Vector.java:
##
@@ -24,29 +24,29 @@
import java.io.Serializable;
-/** A vector of double
flinkbot commented on PR #22755:
URL: https://github.com/apache/flink/pull/22755#issuecomment-1585443242
## CI report:
* 0c118f4f84bd42c3e4329ca18c5869cd611edfec UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
hanyuzheng7 opened a new pull request, #22755:
URL: https://github.com/apache/flink/pull/22755
Find the minimum among all elements in the array for which ordering is
supported.
Syntax:
array_min(array)
Arguments:
array: An ARRAY to be handled.
Returns:
[
https://issues.apache.org/jira/browse/FLINK-32300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li reassigned FLINK-32300:
--
Assignee: Fang Yong
> Support get object for result set
> -
[
https://issues.apache.org/jira/browse/FLINK-32296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731149#comment-17731149
]
Benchao Li commented on FLINK-32296:
[~qingwei91] Thanks for reporting the issue, have you tried on
[
https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731148#comment-17731148
]
Benchao Li commented on FLINK-30093:
[~baugarten] Thanks for your work!
However, I think this is
[
https://issues.apache.org/jira/browse/FLINK-32285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-32285.
Resolution: Fixed
> Support multiple Flink versions in each Flink ML Java library release
>
lindong28 closed pull request #240: [FLINK-32285] Support multiple Flink
versions in each Flink ML Java library release
URL: https://github.com/apache/flink-ml/pull/240
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
lindong28 commented on PR #240:
URL: https://github.com/apache/flink-ml/pull/240#issuecomment-1585323096
Merged to apache/flink-ml master branch.
--
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
[
https://issues.apache.org/jira/browse/FLINK-32285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-32285:
-
Fix Version/s: ml-2.3.0
> Support multiple Flink versions in each Flink ML Java library release
>
[
https://issues.apache.org/jira/browse/FLINK-32285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731136#comment-17731136
]
Dong Lin commented on FLINK-32285:
--
Merged to apache/flink-ml master branch
[
https://issues.apache.org/jira/browse/FLINK-32285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-32285:
Assignee: Jiang Xin
> Support multiple Flink versions in each Flink ML Java library release
>
lindong28 commented on PR #240:
URL: https://github.com/apache/flink-ml/pull/240#issuecomment-1585320017
Thanks for the PR! LGTM.
--
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
yzang2019 commented on PR #22754:
URL: https://github.com/apache/flink/pull/22754#issuecomment-1585249703
@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
morhidi commented on code in PR #612:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/612#discussion_r1224879649
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ScalingMetricEvaluator.java:
##
@@ -137,6
morhidi commented on code in PR #612:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/612#discussion_r1224878956
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ScalingMetricEvaluator.java:
##
@@ -137,6
morhidi commented on code in PR #612:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/612#discussion_r1224878956
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ScalingMetricEvaluator.java:
##
@@ -137,6
becketqin commented on code in PR #22509:
URL: https://github.com/apache/flink/pull/22509#discussion_r1223687864
##
flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java:
##
@@ -620,4 +626,54 @@ public static YarnConfiguration getYarnConfiguration(
return
yzang2019 commented on PR #22754:
URL: https://github.com/apache/flink/pull/22754#issuecomment-1585186980
@flinkbot run azure
> ## CI report:
> *
[ab9f6d8](https://github.com/apache/flink/commit/ab9f6d8be388ccb2f4df650685e82dd0ec910da1)
Azure:
morhidi merged PR #617:
URL: https://github.com/apache/flink-kubernetes-operator/pull/617
--
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:
kenankule commented on PR #618:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/618#issuecomment-1585075820
Please refer to the following example from the ArgoCD docs:
gyfora commented on code in PR #617:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/617#discussion_r1224696456
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/JobAutoScalerImpl.java:
##
@@ -148,4 +162,22 @@
flinkbot commented on PR #22754:
URL: https://github.com/apache/flink/pull/22754#issuecomment-1585003869
## CI report:
* ab9f6d8be388ccb2f4df650685e82dd0ec910da1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32305:
---
Labels: pull-request-available (was: )
> History Server is slow at starting
>
yzang2019 opened a new pull request, #22754:
URL: https://github.com/apache/flink/pull/22754
## What is the purpose of the change
Problem:
Currently, if we have hundreds or thousands of history jobs sitting in HDFS,
everytime when we restart or redeploy history server, it will
[
https://issues.apache.org/jira/browse/FLINK-32305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yiming Zang updated FLINK-32305:
Component/s: Runtime / Web Frontend
> History Server is slow at starting
>
Yiming Zang created FLINK-32305:
---
Summary: History Server is slow at starting
Key: FLINK-32305
URL: https://issues.apache.org/jira/browse/FLINK-32305
Project: Flink
Issue Type: Bug
hanyuzheng7 commented on code in PR #22717:
URL: https://github.com/apache/flink/pull/22717#discussion_r1223408668
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/BaseExpressions.java:
##
@@ -1407,6 +1409,44 @@ public OutType
hanyuzheng7 commented on code in PR #22717:
URL: https://github.com/apache/flink/pull/22717#discussion_r1223408668
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/BaseExpressions.java:
##
@@ -1407,6 +1409,44 @@ public OutType
hanyuzheng7 commented on code in PR #22717:
URL: https://github.com/apache/flink/pull/22717#discussion_r1223414204
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayConcatFunction.java:
##
@@ -0,0 +1,72 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-26948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-26948:
--
Assignee: Jörn Kottmann
> Add SORT_ARRAY supported in SQL & Table API
>
morhidi commented on code in PR #617:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/617#discussion_r1224596698
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ScalingMetricEvaluator.java:
##
@@ -137,12
morhidi commented on code in PR #617:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/617#discussion_r1224596436
##
flink-kubernetes-operator-autoscaler/src/test/java/org/apache/flink/kubernetes/operator/autoscaler/RecommendedParallelismTest.java:
##
@@ -0,0
syhily commented on PR #51:
URL:
https://github.com/apache/flink-connector-pulsar/pull/51#issuecomment-1584941485
I think we can just close this PR and wait an upstream client bumping. WDYT?
@tisonkun @Samrat002
--
This is an automated message from the Apache Git Service.
To respond to
syhily commented on PR #51:
URL:
https://github.com/apache/flink-connector-pulsar/pull/51#issuecomment-1584935420
> I have one query regarding this, Do we really need pulsar client all here
in flink connector pulsar ? Cant we just use the only pulsar client that is
used , using pulsar
zentol commented on PR #158:
URL: https://github.com/apache/flink-docker/pull/158#issuecomment-1584926744
> Would there be an issue if more than one file matched the regex?
yes; that would cause multiple plugins to be copied into the same directory,
likely breaking them (the
[
https://issues.apache.org/jira/browse/FLINK-26948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731041#comment-17731041
]
Bonnie Varghese commented on FLINK-26948:
-
[~martijnvisser] can you please assign this ticket to
[
https://issues.apache.org/jira/browse/FLINK-32304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-32304:
-
Summary: Reduce rpc-akka jar size (was: Reduce rpc-akka jar)
> Reduce rpc-akka jar
flinkbot commented on PR #22753:
URL: https://github.com/apache/flink/pull/22753#issuecomment-1584891328
## CI report:
* 84192cf3cb3f73b28dcab1fcdbb2640ec722f13a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
bvarghese1 commented on code in PR #22717:
URL: https://github.com/apache/flink/pull/22717#discussion_r1224544984
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayConcatFunction.java:
##
@@ -0,0 +1,75 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-32304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32304:
---
Labels: pull-request-available (was: )
> Reduce rpc-akka jar
> ---
>
>
Chesnay Schepler created FLINK-32304:
Summary: Reduce rpc-akka jar
Key: FLINK-32304
URL: https://issues.apache.org/jira/browse/FLINK-32304
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-32303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731021#comment-17731021
]
Piotr Nowojski edited comment on FLINK-32303 at 6/9/23 4:48 PM:
I think
[
https://issues.apache.org/jira/browse/FLINK-32303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731021#comment-17731021
]
Piotr Nowojski commented on FLINK-32303:
I think this bug has been introduced by FLINK-25132 and
[
https://issues.apache.org/jira/browse/FLINK-32303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731021#comment-17731021
]
Piotr Nowojski edited comment on FLINK-32303 at 6/9/23 4:47 PM:
I think
[
https://issues.apache.org/jira/browse/FLINK-32303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731021#comment-17731021
]
Piotr Nowojski edited comment on FLINK-32303 at 6/9/23 4:47 PM:
I think
Piotr Nowojski created FLINK-32303:
--
Summary: Incorrect error message in KafkaSource
Key: FLINK-32303
URL: https://issues.apache.org/jira/browse/FLINK-32303
Project: Flink
Issue Type: Bug
flinkbot commented on PR #22752:
URL: https://github.com/apache/flink/pull/22752#issuecomment-1584839441
## CI report:
* 9e30572c08a768b4bff57402a70e9da4dd22a95d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731015#comment-17731015
]
Ben Augarten edited comment on FLINK-30093 at 6/9/23 4:18 PM:
--
Hey, thanks
[
https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731015#comment-17731015
]
Ben Augarten commented on FLINK-30093:
--
Hey, thanks for the contribution. I'm running into this
baugarten opened a new pull request, #22752:
URL: https://github.com/apache/flink/pull/22752
## What is the purpose of the change
This PR backports [this PR](https://github.com/apache/flink/pull/21613),
which fixes some compilation errors in the flink-protobuf package.
morhidi commented on code in PR #617:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/617#discussion_r1224460888
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ScalingMetricCollector.java:
##
@@ -101,6 +100,7
[
https://issues.apache.org/jira/browse/FLINK-31665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-31665:
Description:
This is an implementation of ARRAY_CONCEPT
The array_concat() function concatenates
[
https://issues.apache.org/jira/browse/FLINK-31665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-31665:
Description:
This is an implementation of ARRAY_CONCEPT
The array_concat() function concatenates
[
https://issues.apache.org/jira/browse/FLINK-31665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-31665:
Description:
This is an implementation of ARRAY_CONCEPT
The array_concat() function concatenates
[
https://issues.apache.org/jira/browse/FLINK-31665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hanyu Zheng updated FLINK-31665:
Description:
This is an implementation of ARRAY_CONCEPT
The array_concat() function concatenates
daniel-packard commented on PR #158:
URL: https://github.com/apache/flink-docker/pull/158#issuecomment-1584719615
@zentol - thanks for the detailed response!
I'll defer to you on the preferred way to handle this. I'm more comfortable
making the change here by adding symlinks, but I
[
https://issues.apache.org/jira/browse/FLINK-31636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730990#comment-17730990
]
Weijie Guo commented on FLINK-31636:
master(1.18) via 4e82ab0c37ace2a10dbfa3c4bf72659a23f3c8f1.
>
[
https://issues.apache.org/jira/browse/FLINK-31636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-31636.
Fix Version/s: 1.18.0
Resolution: Fixed
> Upstream supports reading buffers from tiered
[
https://issues.apache.org/jira/browse/FLINK-31636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-31636.
--
> Upstream supports reading buffers from tiered store
>
reswqa merged PR #22342:
URL: https://github.com/apache/flink/pull/22342
--
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:
flinkbot commented on PR #22751:
URL: https://github.com/apache/flink/pull/22751#issuecomment-1584659347
## CI report:
* f664f2a19a73f7b630b3fad1281f6bb33d0e355a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32302:
---
Labels: pull-request-available (was: )
> Disable Hbase 2.x tests on Java 17
>
zentol opened a new pull request, #22751:
URL: https://github.com/apache/flink/pull/22751
Consistently fail on Java 17, probably because our dependencies are
horrendously out-dated.
We can revert this later if someone looks into bumping our HBase dependency.
--
This is an automated
Chesnay Schepler created FLINK-32302:
Summary: Disable Hbase 2.x tests on Java 17
Key: FLINK-32302
URL: https://issues.apache.org/jira/browse/FLINK-32302
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-21949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730964#comment-17730964
]
Martijn Visser commented on FLINK-21949:
Given that ARRAY_AGG was added in Calcite 1.27 via
[
https://issues.apache.org/jira/browse/FLINK-26948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730963#comment-17730963
]
Jörn Kottmann commented on FLINK-26948:
---
Yes, I still would like to work on this.
> Add
kenankule opened a new pull request, #618:
URL: https://github.com/apache/flink-kubernetes-operator/pull/618
`syncOptions` field should reside under `.spec.syncPolicy`
## Documentation
- Does this pull request introduce a new feature? (yes / no)
no
--
This is an
flinkbot commented on PR #22750:
URL: https://github.com/apache/flink/pull/22750#issuecomment-1584587873
## CI report:
* 59fff5c20ea4ceb91564f287fea1e40801e76a49 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31757:
---
Labels: pull-request-available (was: )
> Optimize Flink un-balanced tasks scheduling
>
RocMarshal opened a new pull request, #22750:
URL: https://github.com/apache/flink/pull/22750
## What is the purpose of the change
Support balanced tasks scheduling.
## Brief change log
Introduce:
- TaskSchedulingStrategy
-
flinkbot commented on PR #22749:
URL: https://github.com/apache/flink/pull/22749#issuecomment-1584553865
## CI report:
* 13288d8800ad21126d5efb0aaee5cb1de048273e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32248:
---
Labels: pull-request-available (was: )
> Incorrect AssertJ usage
> ---
codenohup opened a new pull request, #22749:
URL: https://github.com/apache/flink/pull/22749
## What is the purpose of the change
This pull request attempts to fix some misuses of AssertJ, such as
withFailMessage placed at the end of the assert statement, and the assertThat
flinkbot commented on PR #22748:
URL: https://github.com/apache/flink/pull/22748#issuecomment-1584539956
## CI report:
* 6673cd3ce8a56217fd456b19efa2546b8def87ba UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32301:
---
Labels: pull-request-available (was: )
> common.sh#create_ha_config should use
Chesnay Schepler created FLINK-32301:
Summary: common.sh#create_ha_config should use set_config_key
Key: FLINK-32301
URL: https://issues.apache.org/jira/browse/FLINK-32301
Project: Flink
liuyongvs commented on PR #22143:
URL: https://github.com/apache/flink/pull/22143#issuecomment-1584527028
@snuyanzin one more thing
1. It is bug array_contains
2. the issues https://issues.apache.org/jira/browse/FLINK-27438 is about
array[map]. Totally different problem, why we also
echauchot commented on PR #22667:
URL: https://github.com/apache/flink/pull/22667#issuecomment-1584508623
> Since each of these modifies the rules I'd assume each of these
individually would also have to update the store. So it's either that or squash
them all together. (again, key rule is
section9-lab closed pull request #627: Translate menu bar to Chinese
URL: https://github.com/apache/flink-web/pull/627
--
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
Fang Yong created FLINK-32300:
-
Summary: Support get object for result set
Key: FLINK-32300
URL: https://issues.apache.org/jira/browse/FLINK-32300
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730942#comment-17730942
]
Liu commented on FLINK-30629:
-
Rebased. Thanks.
> ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat
[
https://issues.apache.org/jira/browse/FLINK-25000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730937#comment-17730937
]
Chesnay Schepler commented on FLINK-25000:
--
(pending testing) For 1.18 we could continue using
liuyongvs commented on PR #22143:
URL: https://github.com/apache/flink/pull/22143#issuecomment-1584440629
@snuyanzin
1) first, this https://issues.apache.org/jira/browse/FLINK-27438 is long
time, and don't have any progress.
2) from my side. this is 2 different problem indeed. we
[
https://issues.apache.org/jira/browse/FLINK-30919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia closed FLINK-30919.
Resolution: Fixed
> Fix typo in the document of User-defined Sources & Sinks
>
[
https://issues.apache.org/jira/browse/FLINK-30919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730861#comment-17730861
]
luoyuxia edited comment on FLINK-30919 at 6/9/23 11:27 AM:
---
master:
snuyanzin commented on PR #22143:
URL: https://github.com/apache/flink/pull/22143#issuecomment-1584413439
i try to have a look from user point of view:
now it does not work both via api and SQL
imagine after fixing this it will work via API however not via SQL and that
introducies
liuyongvs commented on PR #22143:
URL: https://github.com/apache/flink/pull/22143#issuecomment-1584403618
@snuyanzin Ha ha, may we fix one thing in one pr in the software development
principal. just my personal think.
--
This is an automated message from the Apache Git Service.
To
snuyanzin commented on PR #22143:
URL: https://github.com/apache/flink/pull/22143#issuecomment-1584396536
Well i don't see a good reason to fix something that could be checked only
via artifitial test-case and at the same time keep not working on SQL level...
In my opinion it's better to
liuyongvs commented on PR #22745:
URL: https://github.com/apache/flink/pull/22745#issuecomment-1584394645
hi @snuyanzin do you have time to review this?
we talk this before here https://github.com/apache/flink/pull/22324 and
calcite map is last_win default. and the original pr i submit
Shengkai Fang created FLINK-32299:
-
Summary: Upload python jar when sql contains python udf jar
Key: FLINK-32299
URL: https://issues.apache.org/jira/browse/FLINK-32299
Project: Flink
Issue
liuyongvs commented on PR #22143:
URL: https://github.com/apache/flink/pull/22143#issuecomment-1584386417
@snuyanzin but it is a different problem. that is to say, there are 2
problem. this https://issues.apache.org/jira/browse/FLINK-27438 i reported
before in the issue. so i think we
Aitozi commented on PR #22485:
URL: https://github.com/apache/flink/pull/22485#issuecomment-1584354342
The CI failure seems unrelated
--
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
FangYongs commented on code in PR #22718:
URL: https://github.com/apache/flink/pull/22718#discussion_r1224127445
##
flink-runtime/src/test/java/org/apache/flink/runtime/execution/librarycache/BlobLibraryCacheManagerTest.java:
##
@@ -585,6 +586,37 @@ public void
gyfora commented on code in PR #617:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/617#discussion_r1224109260
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ScalingMetricEvaluator.java:
##
@@ -137,12
mxm commented on code in PR #617:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/617#discussion_r1224078049
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ScalingMetricCollector.java:
##
@@ -101,6 +100,7 @@
Rui Fan created FLINK-32298:
---
Summary: The outputQueueSize is negative
Key: FLINK-32298
URL: https://issues.apache.org/jira/browse/FLINK-32298
Project: Flink
Issue Type: Bug
Components:
liuyongvs commented on PR #22143:
URL: https://github.com/apache/flink/pull/22143#issuecomment-1584281558
@snuyanzin i debug it, the sql way you offers, it is GenericRowData,
while
zhipeng93 commented on PR #242:
URL: https://github.com/apache/flink-ml/pull/242#issuecomment-1584281026
@lindong28 @HuangXingBo Can you help to review this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
1 - 100 of 178 matches
Mail list logo
