WencongLiu commented on code in PR #20609:
URL: https://github.com/apache/flink/pull/20609#discussion_r953412031
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/SqlGatewayRestEndpointFactory.java:
##
@@ -94,6 +92,10 @@ public Set> requiredOptio
zhipeng93 commented on code in PR #145:
URL: https://github.com/apache/flink-ml/pull/145#discussion_r953393891
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/dct/DCT.java:
##
@@ -0,0 +1,138 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or m
zhipeng93 commented on code in PR #145:
URL: https://github.com/apache/flink-ml/pull/145#discussion_r953393891
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/dct/DCT.java:
##
@@ -0,0 +1,138 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or m
[
https://issues.apache.org/jira/browse/FLINK-28253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28253.
---
Resolution: Duplicate
> It reports "LocalDateTime is not supported in PyFlink currently" when
> converting
[
https://issues.apache.org/jira/browse/FLINK-28253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28253.
---
Fix Version/s: 1.16.0
Resolution: Fixed
Fixed in FLINK-28827 via 1c40dc15fbc29e8e5e514565109a3fb05b47
[
https://issues.apache.org/jira/browse/FLINK-28253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reopened FLINK-28253:
-
> It reports "LocalDateTime is not supported in PyFlink currently" when
> converting between Table and Data
[
https://issues.apache.org/jira/browse/FLINK-28253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-28253:
Fix Version/s: (was: 1.16.0)
> It reports "LocalDateTime is not supported in PyFlink currently" when
WencongLiu commented on code in PR #20609:
URL: https://github.com/apache/flink/pull/20609#discussion_r953375107
##
flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/FlinkDistribution.java:
##
@@ -301,7 +309,105 @@ public void s
WencongLiu commented on code in PR #20609:
URL: https://github.com/apache/flink/pull/20609#discussion_r953374948
##
flink-end-to-end-tests/flink-sql-gateway-test/src/test/java/org/apache/flink/table/gateway/SqlGatewayE2ECase.java:
##
@@ -117,8 +119,13 @@ public void testExecuteS
[
https://issues.apache.org/jira/browse/FLINK-29091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-29091:
Description:
RAND and RAND_INTEGER are dynamic function (isDynamicFuntion returns true), it
shoul
WencongLiu commented on code in PR #20609:
URL: https://github.com/apache/flink/pull/20609#discussion_r953374044
##
flink-end-to-end-tests/flink-sql-gateway-test/src/test/java/org/apache/flink/table/gateway/SqlGatewayE2ECase.java:
##
@@ -82,6 +83,7 @@ public class SqlGatewayE2EC
WencongLiu commented on code in PR #20609:
URL: https://github.com/apache/flink/pull/20609#discussion_r953373052
##
flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/FlinkDistribution.java:
##
@@ -301,7 +309,105 @@ public void s
WencongLiu commented on code in PR #20609:
URL: https://github.com/apache/flink/pull/20609#discussion_r953373052
##
flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/FlinkDistribution.java:
##
@@ -301,7 +309,105 @@ public void s
lincoln lee created FLINK-29091:
---
Summary: Correct RAND and RAND_INTEGER function to evaluate once
at query-level for batch mode
Key: FLINK-29091
URL: https://issues.apache.org/jira/browse/FLINK-29091
P
flinkbot commented on PR #20673:
URL: https://github.com/apache/flink/pull/20673#issuecomment-1225170281
## CI report:
* f00739f82d078c0ff05ce4d99a5db27cdef54e13 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
bzhaoopenstack commented on PR #20193:
URL: https://github.com/apache/flink/pull/20193#issuecomment-1225168894
@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 com
wangyang0918 opened a new pull request, #20673:
URL: https://github.com/apache/flink/pull/20673
Backport #20590 to 1.15.
--
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
flinkbot commented on PR #20672:
URL: https://github.com/apache/flink/pull/20672#issuecomment-1225162184
## CI report:
* 9e1a2a7c9f655a0448b8e429e92fe438c3137b55 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29059:
---
Labels: pull-request-available (was: )
> The existing column stats are deleted incorrectly
zhipeng93 commented on PR #145:
URL: https://github.com/apache/flink-ml/pull/145#issuecomment-1225160121
> Thanks for the PR. LGTM.
>
> @zhipeng93 Do you want to take another look?
Thanks for the review. I will do a pass today.
--
This is an automated message from the Apache
swuferhong opened a new pull request, #20672:
URL: https://github.com/apache/flink/pull/20672
## What is the purpose of the change
If there are three columns named `a, b, c` with column stats already exists
for non partition table, when user just analyze column `a` us
wangyang0918 commented on PR #20590:
URL: https://github.com/apache/flink/pull/20590#issuecomment-1225150694
@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 comme
wangyang0918 commented on PR #20590:
URL: https://github.com/apache/flink/pull/20590#issuecomment-1225140010
@XComp I will try to login and find out what's happening on the
`AlibabaCI002-agent01`.
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
[
https://issues.apache.org/jira/browse/FLINK-28684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-28684:
-
Affects Version/s: (was: ml-2.2.0)
> NullPointerException at OneHotEncoder.GenerateModelDataOperator
[
https://issues.apache.org/jira/browse/FLINK-28673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-28673:
-
Affects Version/s: (was: ml-2.2.0)
> Migrate Flink ML to Flink 1.15.1
>
[
https://issues.apache.org/jira/browse/FLINK-28684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-28684:
-
Fix Version/s: (was: ml-2.1.1)
> NullPointerException at OneHotEncoder.GenerateModelDataOperator.sna
[
https://issues.apache.org/jira/browse/FLINK-28601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved FLINK-28601.
--
Resolution: Fixed
> Add Transformer for FeatureHasher
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-28803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-28803:
-
Affects Version/s: (was: ml-2.2.0)
> Add Transformer and Estimator for KBinsDiscretizer
> --
[
https://issues.apache.org/jira/browse/FLINK-28943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-28943:
Assignee: weibo zhao
> Add Transformer and Estimator for MaxAbsScaler
> -
[
https://issues.apache.org/jira/browse/FLINK-28805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-28805:
-
Fix Version/s: ml-2.2.0
> Add Transformer for HashingTF
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-28805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved FLINK-28805.
--
Resolution: Fixed
> Add Transformer for HashingTF
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-28805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-28805:
-
Affects Version/s: (was: ml-2.2.0)
> Add Transformer for HashingTF
> -
>
lindong28 merged PR #141:
URL: https://github.com/apache/flink-ml/pull/141
--
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: issues-unsubscr...@flink.apac
lindong28 commented on PR #141:
URL: https://github.com/apache/flink-ml/pull/141#issuecomment-1225128761
Thanks for the PR! And thanks @yunfengzhou-hub for the review. LGTM.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
Aitozi commented on PR #20637:
URL: https://github.com/apache/flink/pull/20637#issuecomment-1225128196
cc @xintongsong
--
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 u
Aitozi commented on PR #20654:
URL: https://github.com/apache/flink/pull/20654#issuecomment-1225127747
cc @twalthr @godfreyhe please help take a look when you are free, thx
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
WencongLiu commented on code in PR #20622:
URL: https://github.com/apache/flink/pull/20622#discussion_r953285587
##
flink-docs/src/main/java/org/apache/flink/docs/rest/RestAPIDocGenerator.java:
##
@@ -131,7 +132,7 @@ public static void main(String[] args) throws IOException,
Co
WencongLiu commented on code in PR #20622:
URL: https://github.com/apache/flink/pull/20622#discussion_r953284454
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/session/TriggerSessionHeartbeatHeaders.java:
##
@@ -76,4 +76,9 @@ public Str
Aitozi commented on PR #20671:
URL: https://github.com/apache/flink/pull/20671#issuecomment-1225109186
Ps: the CI failed with doc build
--
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 specif
Aitozi commented on code in PR #20671:
URL: https://github.com/apache/flink/pull/20671#discussion_r953258798
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/artifact/HttpArtifactFetcher.java:
##
@@ -0,0 +1,71 @@
+/*
+ * Licensed to the Apache Software Foundation (A
WencongLiu commented on code in PR #20622:
URL: https://github.com/apache/flink/pull/20622#discussion_r953268832
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/operation/CancelOperationHeaders.java:
##
@@ -52,4 +52,9 @@ public String ge
yunfengzhou-hub commented on code in PR #146:
URL: https://github.com/apache/flink-ml/pull/146#discussion_r953267650
##
flink-ml-examples/src/main/java/org/apache/flink/ml/examples/feature/BinarizerExample.java:
##
@@ -0,0 +1,85 @@
+/*
Review Comment:
> The public API, i.e.,
[
https://issues.apache.org/jira/browse/FLINK-29011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29011:
---
Labels: pull-request-available (was: )
> Add Transformer for Binarizer
> --
[
https://issues.apache.org/jira/browse/FLINK-29090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Chen updated FLINK-29090:
---
Description:
!image-2022-08-24-10-15-11-824.png|width=589,height=284!
Currently, the code generatio
yunfengzhou-hub commented on code in PR #146:
URL: https://github.com/apache/flink-ml/pull/146#discussion_r953263844
##
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/BinarizerTest.java:
##
@@ -0,0 +1,164 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
Danny Chen created FLINK-29090:
--
Summary: Fix the code gen for ColumnarMapData and ColumnarArrayData
Key: FLINK-29090
URL: https://issues.apache.org/jira/browse/FLINK-29090
Project: Flink
Issue
[ https://issues.apache.org/jira/browse/FLINK-28993 ]
godfrey he deleted comment on FLINK-28993:
was (Author: godfreyhe):
Fixed in master: 1a0f591a59b59f0c6ce71f5af9e0660293c33fc1
> Fix adjusting join cost for dpp query pattern error
>
[
https://issues.apache.org/jira/browse/FLINK-28993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17583949#comment-17583949
]
godfrey he commented on FLINK-28993:
Fixed in master: 1a0f591a59b59f0c6ce71f5af9e066
[
https://issues.apache.org/jira/browse/FLINK-28993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-28993.
--
Resolution: Fixed
Fixed in master: 1a0f591a59b59f0c6ce71f5af9e0660293c33fc1
> Fix adjusting join cost
[
https://issues.apache.org/jira/browse/FLINK-28993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-28993:
--
Assignee: Yunhong Zheng
> Fix adjusting join cost for dpp query pattern error
> -
godfreyhe closed pull request #20596: [FLINK-28993][table-planner] Fix
adjusting join cost for dpp query pattern error
URL: https://github.com/apache/flink/pull/20596
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
lindong28 commented on PR #145:
URL: https://github.com/apache/flink-ml/pull/145#issuecomment-1225093865
Thanks for the PR. LGTM.
@zhipeng93 Do you want to take another look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
lsyldliu commented on PR #20635:
URL: https://github.com/apache/flink/pull/20635#issuecomment-1225074802
@twalthr Thanks for review, I've updated it.
--
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
lincoln-lil commented on PR #20577:
URL: https://github.com/apache/flink/pull/20577#issuecomment-1225065463
@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 commen
[
https://issues.apache.org/jira/browse/FLINK-29046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17583931#comment-17583931
]
luoyuxia commented on FLINK-29046:
--
Seems like a bug of orc 1.5.6 which Hive3 depends.
alpinegizmo commented on code in PR #20661:
URL: https://github.com/apache/flink/pull/20661#discussion_r953225902
##
docs/content/docs/dev/datastream/fault-tolerance/serialization/schema_evolution.md:
##
@@ -125,4 +125,10 @@ Additionally, the RocksDB state backend relies on bina
[
https://issues.apache.org/jira/browse/FLINK-27886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-27886:
---
Labels: auto-deprioritized-major pull-request-available (was:
pull-request-available stal
[
https://issues.apache.org/jira/browse/FLINK-25319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-25319:
---
Labels: auto-deprioritized-major stale-minor test-stability (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-25358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-25358:
---
Labels: auto-deprioritized-major stale-minor test-stability (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-27916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-27916:
---
Labels: stale-critical test-stability (was: test-stability)
I am the [Flink Jira Bot|https:
[
https://issues.apache.org/jira/browse/FLINK-24867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-24867:
---
Labels: auto-deprioritized-critical auto-deprioritized-major stale-minor
test-stability (wa
[
https://issues.apache.org/jira/browse/FLINK-12694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17583847#comment-17583847
]
Badrul Chowdhury commented on FLINK-12694:
--
Hi [~liyu] I would be interested in
diarworld commented on PR #18744:
URL: https://github.com/apache/flink/pull/18744#issuecomment-1224775527
Could anyone review this PR? It seems to be a very useful feature.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
[
https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-26760:
---
Assignee: (was: Arvid Heise)
> The new CSV source (file system source + CSV format) doe
morhidi commented on PR #352:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/352#issuecomment-1224272321
> @morhidi do you see any problems with this?
no, not really
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/FLINK-29089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17583712#comment-17583712
]
hjw commented on FLINK-29089:
-
[~wangyang0918] I'd like to file a PR to fix it. Please help
hjw created FLINK-29089:
---
Summary: Error when run test case in Windows
Key: FLINK-29089
URL: https://issues.apache.org/jira/browse/FLINK-29089
Project: Flink
Issue Type: Improvement
Component
gyfora commented on PR #352:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/352#issuecomment-1224252892
@morhidi do you see any problems with this?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
Aitozi created FLINK-29088:
--
Summary: Project push down cause the source reuse can not work
Key: FLINK-29088
URL: https://issues.apache.org/jira/browse/FLINK-29088
Project: Flink
Issue Type: Improve
flinkbot commented on PR #20671:
URL: https://github.com/apache/flink/pull/20671#issuecomment-1224207592
## CI report:
* 8ae2e84f3a1f915134f994d6dbfe5543cb8f1e16 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
SwimSweet commented on PR #20671:
URL: https://github.com/apache/flink/pull/20671#issuecomment-1224196427
Please help take a look when you are free @wangyang0918 @Aitozi . thx.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
[
https://issues.apache.org/jira/browse/FLINK-28915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28915:
---
Labels: pull-request-available (was: )
> Flink Native k8s mode jar localtion support s3 sch
SwimSweet opened a new pull request, #20671:
URL: https://github.com/apache/flink/pull/20671
## What is the purpose of the change
Flink On Kerbernetes Native K8s Application Mode supports fetching jar from
DFS schema(S3, OSS, HDFS, etc.).
## Brief change log
- Fetch jar fr
mxm commented on code in PR #20485:
URL: https://github.com/apache/flink/pull/20485#discussion_r951456255
##
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/fetcher/PauseOrResumeSplitsTask.java:
##
@@ -0,0 +1,84 @@
+/*
+ * Licens
mxm commented on code in PR #20485:
URL: https://github.com/apache/flink/pull/20485#discussion_r952615289
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/SourceOperatorSplitWatermarkAlignmentTest.java:
##
@@ -0,0 +1,144 @@
+/*
+Licensed to the Apac
XComp commented on PR #20590:
URL: https://github.com/apache/flink/pull/20590#issuecomment-1224187614
Something odd happened with the build. But it looks like it's unrelated to
the change. I'm wondering whether there's something wrong with
`AlibabaCI002-agent01`. Publishing the build artifa
Aitozi commented on PR #20639:
URL: https://github.com/apache/flink/pull/20639#issuecomment-1224172346
@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.
T
Aitozi commented on PR #20654:
URL: https://github.com/apache/flink/pull/20654#issuecomment-1224165877
@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.
T
[
https://issues.apache.org/jira/browse/FLINK-29043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved FLINK-29043.
--
Resolution: Fixed
> Improve ML iteration efficiency
> ---
>
>
Aitozi closed pull request #20662: [FLINK-29066][Table/Planner] Correct the
runtime property of serval f…
URL: https://github.com/apache/flink/pull/20662
--
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
[
https://issues.apache.org/jira/browse/FLINK-29043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-29043:
Assignee: Yunfeng Zhou
> Improve ML iteration efficiency
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-29043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-29043:
-
Fix Version/s: ml-2.2.0
> Improve ML iteration efficiency
> ---
>
>
Aitozi commented on PR #20662:
URL: https://github.com/apache/flink/pull/20662#issuecomment-1224159300
closing as it's invalid
--
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
lindong28 merged PR #147:
URL: https://github.com/apache/flink-ml/pull/147
--
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: issues-unsubscr...@flink.apac
lindong28 commented on PR #147:
URL: https://github.com/apache/flink-ml/pull/147#issuecomment-1224155897
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 comm
lindong28 commented on code in PR #147:
URL: https://github.com/apache/flink-ml/pull/147#discussion_r952697442
##
flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/HeadOperator.java:
##
@@ -607,16 +596,27 @@ public boolean tryYield() throws FlinkRuntimeExcepti
lindong28 commented on code in PR #147:
URL: https://github.com/apache/flink-ml/pull/147#discussion_r952697442
##
flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/HeadOperator.java:
##
@@ -607,16 +596,27 @@ public boolean tryYield() throws FlinkRuntimeExcepti
flinkbot commented on PR #20670:
URL: https://github.com/apache/flink/pull/20670#issuecomment-1224055360
## CI report:
* 8f90b2e95cec61d0ddf5e575b6ea1b9e6a02f5b6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29087:
---
Labels: pull-request-available (was: )
> Jdbc connector sql ITCase failed when run in idea
xuyangzhong opened a new pull request, #20670:
URL: https://github.com/apache/flink/pull/20670
## What is the purpose of the change
Currently, we rewrite calcite to full its logic on Flink. But in
connector-jdbc pom.xml, the wrong order about "flink-table-planner" and
"flink-table-pl
[
https://issues.apache.org/jira/browse/FLINK-29087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17583603#comment-17583603
]
xuyang commented on FLINK-29087:
I'll try to fix it.
> Jdbc connector sql ITCase failed
[
https://issues.apache.org/jira/browse/FLINK-29087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17583583#comment-17583583
]
dalongliu commented on FLINK-29087:
---
cc [~xuyangzhong]
> Jdbc connector sql ITCase f
dalongliu created FLINK-29087:
-
Summary: Jdbc connector sql ITCase failed when run in idea
Key: FLINK-29087
URL: https://issues.apache.org/jira/browse/FLINK-29087
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-27917:
--
Fix Version/s: 1.15.3
(was: 1.15.2)
> PulsarUnorderedPartitionSplitRead
[
https://issues.apache.org/jira/browse/FLINK-28853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-28853:
--
Assignee: Sebastian Mattheis
> FLIP-217 Support watermark alignment of source splits
[
https://issues.apache.org/jira/browse/FLINK-28951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-28951:
--
Fix Version/s: 1.15.3
(was: 1.15.2)
> Header in janino generated java f
[
https://issues.apache.org/jira/browse/FLINK-28504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17583571#comment-17583571
]
Piotr Nowojski commented on FLINK-28504:
{quote}
After giving this a second look
[
https://issues.apache.org/jira/browse/FLINK-29066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-29066:
---
Description:
I found a bit confused when implementing the inner built in functions when
dealing with the ru
[
https://issues.apache.org/jira/browse/FLINK-28977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved FLINK-28977.
--
Resolution: Fixed
> NullPointerException in HybridSourceSplitEnumerator.close
> --
[
https://issues.apache.org/jira/browse/FLINK-28977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-28977:
-
Fix Version/s: 1.17.0
> NullPointerException in HybridSourceSplitEnumerator.close
>
1 - 100 of 197 matches
Mail list logo
