flinkbot commented on PR #20362:
URL: https://github.com/apache/flink/pull/20362#issuecomment-1195155393
## CI report:
* 05b106fc9c6c9be7b4429f09178eedffe5f45694 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zhuzhurk commented on code in PR #20296:
URL: https://github.com/apache/flink/pull/20296#discussion_r929628681
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/messages/ClusterOverviewWithVersion.java:
##
@@ -70,11 +76,20 @@ public
[
https://issues.apache.org/jira/browse/FLINK-28684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Zhang resolved FLINK-28684.
---
Resolution: Fixed
fixed on (1) master: 8df38791a0243870d9b11f03ee5ae24cae880d89 (2)
[
https://issues.apache.org/jira/browse/FLINK-28684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Zhang updated FLINK-28684:
--
Fix Version/s: ml-2.2.0
ml-2.1.1
> NullPointerException at
[
https://issues.apache.org/jira/browse/FLINK-28492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28492:
---
Labels: pull-request-available (was: )
> Support "ANALYZE TABLE" execution
>
godfreyhe opened a new pull request, #20363:
URL: https://github.com/apache/flink/pull/20363
## What is the purpose of the change
*Support "ANALYZE TABLE" execution, see
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=217386481 for
more details*
##
[
https://issues.apache.org/jira/browse/FLINK-28686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-28686:
-
Priority: Blocker (was: Major)
> Spark table with column comment cannot be read/write by Flink
[
https://issues.apache.org/jira/browse/FLINK-28177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28177:
---
Labels: pull-request-available test-stability (was: test-stability)
>
dingweiqings opened a new pull request, #20362:
URL: https://github.com/apache/flink/pull/20362
## What is the purpose of the change
Fix FLINK-28177, this it case failed sometimes because elasticsearch
service is temporary unavaliable. So I add fixed restart strategy to avoid
zhipeng93 merged PR #138:
URL: https://github.com/apache/flink-ml/pull/138
--
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:
zhipeng93 merged PR #137:
URL: https://github.com/apache/flink-ml/pull/137
--
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:
zhipeng93 commented on PR #137:
URL: https://github.com/apache/flink-ml/pull/137#issuecomment-1195143184
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
Huang Xingbo created FLINK-28688:
Summary: Support DataStream PythonWindowOperator in Thread Mode
Key: FLINK-28688
URL: https://issues.apache.org/jira/browse/FLINK-28688
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-28671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-28671:
-
Priority: Minor (was: Blocker)
> Update Spark3 to create/drop table in Compatibility Matrix
>
[
https://issues.apache.org/jira/browse/FLINK-28686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-28686:
--
Description:
The reason is that org.apache.flink.table.api.TableSchema#toPhysicalRowDataType
lost
[
https://issues.apache.org/jira/browse/FLINK-28687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-28687:
-
Priority: Blocker (was: Major)
> BucketSelector is wrong when hashcode is negative
>
[
https://issues.apache.org/jira/browse/FLINK-28687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28687:
---
Labels: pull-request-available (was: )
> BucketSelector is wrong when hashcode is negative
JingsongLi opened a new pull request, #239:
URL: https://github.com/apache/flink-table-store/pull/239
The calculation of bucket should be `Math.abs(hashcode % numBucket)` instead
of `hashcode % numBucket`.
--
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-28686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-28686:
--
Attachment: screenshot-1.png
> Spark table with column comment cannot be read/write by Flink
>
Jingsong Lee created FLINK-28687:
Summary: BucketSelector is wrong when hashcode is negative
Key: FLINK-28687
URL: https://issues.apache.org/jira/browse/FLINK-28687
Project: Flink
Issue
Jane Chan created FLINK-28686:
-
Summary: Spark table with column comment cannot be read/write by
Flink
Key: FLINK-28686
URL: https://issues.apache.org/jira/browse/FLINK-28686
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571257#comment-17571257
]
Robert Metzger commented on FLINK-28680:
The cleanup script which runs before each test is
[
https://issues.apache.org/jira/browse/FLINK-28592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-28592:
--
Description:
* add counters at global level
* add option to turn on/off the metrics
was:
[
https://issues.apache.org/jira/browse/FLINK-28678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571254#comment-17571254
]
Martijn Visser commented on FLINK-28678:
[~xuyangzhong] Please make sure that you also create
[
https://issues.apache.org/jira/browse/FLINK-28677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571251#comment-17571251
]
Jingsong Lee edited comment on FLINK-28677 at 7/26/22 7:35 AM:
---
master:
xuyangzhong commented on PR #20359:
URL: https://github.com/apache/flink/pull/20359#issuecomment-1195117384
@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
[
https://issues.apache.org/jira/browse/FLINK-28677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28677.
Resolution: Fixed
master: ac950a299c487416b9f558f9067df0b0c3606304
> Primary key should not be
JingsongLi merged PR #237:
URL: https://github.com/apache/flink-table-store/pull/237
--
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:
zoltar9264 commented on PR #20103:
URL: https://github.com/apache/flink/pull/20103#issuecomment-1195101790
Hi @rkhachatryan , I fixed this with yanfei's tip. And I test it locally, it
works now.
--
This is an automated message from the Apache Git Service.
To respond to the message,
flinkbot commented on PR #20361:
URL: https://github.com/apache/flink/pull/20361#issuecomment-1195101786
## CI report:
* 17cb8f4798aed78ed0ba43fe094dc6c6f763d10e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zoltar9264 commented on code in PR #20103:
URL: https://github.com/apache/flink/pull/20103#discussion_r929606940
##
flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/job-checkpoints.component.html:
##
@@ -551,15 +551,15 @@
-
[
https://issues.apache.org/jira/browse/FLINK-27790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27790:
---
Labels: pull-request-available (was: )
> Port ADD JAR /SHOW JARS syntax implementation
fsk119 commented on code in PR #20298:
URL: https://github.com/apache/flink/pull/20298#discussion_r929604300
##
flink-table/flink-sql-gateway-api/src/main/java/org/apache/flink/table/gateway/api/SqlGatewayService.java:
##
@@ -108,6 +120,16 @@ void closeOperation(SessionHandle
Myracle opened a new pull request, #20361:
URL: https://github.com/apache/flink/pull/20361
## What is the purpose of the change
*Port ADD JAR /SHOW JARS syntax implementation from SqlClient to
TableEnvironment side for more common use.*
## Brief change log
- *Add
LadyForest closed pull request #237: [FLINK-28677] Primary key should not be
null when creating Spark table
URL: https://github.com/apache/flink-table-store/pull/237
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
dannycranmer commented on PR #20360:
URL: https://github.com/apache/flink/pull/20360#issuecomment-1195076222
@DavidLiu001 I can see the [CI build has already
failed](https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=38732=results).
Before pushing your branch
dannycranmer commented on PR #20338:
URL: https://github.com/apache/flink/pull/20338#issuecomment-1195074655
@DavidLiu001 in future instead of opening a new PR, you can simply push a
new commit to you branch and the PR will automatically update? You can even
squash and force push to
[
https://issues.apache.org/jira/browse/FLINK-28610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28610.
---
Resolution: Done
Done via 9192446847b6fb29beb8d36d49d6900de1e61685
> Enable speculative execution of
zhuzhurk closed pull request #20345: [FLINK-28610][runtime] Enable speculative
execution for sources
URL: https://github.com/apache/flink/pull/20345
--
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
zoltar9264 commented on PR #20103:
URL: https://github.com/apache/flink/pull/20103#issuecomment-1195070679
Sorry @rkhachatryan , you are right. I test it on yarn cluster before and it
works. I test it locally just now, it really does't work. I will check it.
--
This is an automated
wangyang0918 commented on PR #19772:
URL: https://github.com/apache/flink/pull/19772#issuecomment-1195070066
@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
yunfengzhou-hub opened a new pull request, #138:
URL: https://github.com/apache/flink-ml/pull/138
This PR fixes the NullPointerException that might be generated during
OneHotEncoder's checkpoint process.
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-28684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Zhang updated FLINK-28684:
--
Issue Type: Bug (was: New Feature)
> NullPointerException at
[
https://issues.apache.org/jira/browse/FLINK-27691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571225#comment-17571225
]
Qingsheng Ren commented on FLINK-27691:
---
An instance on my own Azure pipeline:
[
https://issues.apache.org/jira/browse/FLINK-28684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571223#comment-17571223
]
Yunfeng Zhou commented on FLINK-28684:
--
It is not found that this problem exists in other variables
[
https://issues.apache.org/jira/browse/FLINK-28684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28684:
---
Labels: pull-request-available (was: )
> NullPointerException at
yunfengzhou-hub opened a new pull request, #137:
URL: https://github.com/apache/flink-ml/pull/137
This PR fixes the NullPointerException that might be generated during
OneHotEncoder's checkpoint process.
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-28684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571221#comment-17571221
]
Yunfeng Zhou commented on FLINK-28684:
--
This problem occurs when a checkpoint barrier reaches a
fsk119 commented on code in PR #20298:
URL: https://github.com/apache/flink/pull/20298#discussion_r929567090
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/endpoint/hive/util/ThriftObjectConversions.java:
##
@@ -51,25 +261,250 @@ public static
[
https://issues.apache.org/jira/browse/FLINK-28685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-28685:
-
Priority: Minor (was: Major)
> Optimize CatalogManager getTable implementation
>
JingsongLi commented on code in PR #237:
URL: https://github.com/apache/flink-table-store/pull/237#discussion_r929555403
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/schema/UpdateSchema.java:
##
@@ -80,6 +83,33 @@ public String comment() {
201 - 251 of 251 matches
Mail list logo
