[jira] [Commented] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903998#comment-16903998 ] Tzu-Li (Gordon) Tai commented on FLINK-12122: - I've removed the fix version values. Please

[jira] [Updated] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12122: Fix Version/s: (was: 1.8.2) (was: 1.7.3)

[jira] [Updated] (FLINK-13601) RegionFailoverITCase is unstable

[ https://issues.apache.org/jira/browse/FLINK-13601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13601: Fix Version/s: (was: 1.9.0) 1.10.0 > RegionFailoverITCase

[jira] [Updated] (FLINK-13490) Fix return null in JDBCUtils::getFieldFromResultSet

[ https://issues.apache.org/jira/browse/FLINK-13490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13490: Fix Version/s: (was: 1.9.0) 1.10.0 > Fix return null in

[jira] [Updated] (FLINK-13599) Kinesis end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13599: Fix Version/s: (was: 1.9.0) 1.10.0 > Kinesis end-to-end

[jira] [Updated] (FLINK-13489) Heavy deployment end-to-end test fails on Travis with TM heartbeat timeout

[ https://issues.apache.org/jira/browse/FLINK-13489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13489: Fix Version/s: (was: 1.9.0) 1.10.0 > Heavy deployment

[jira] [Commented] (FLINK-13489) Heavy deployment end-to-end test fails on Travis with TM heartbeat timeout

[ https://issues.apache.org/jira/browse/FLINK-13489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903996#comment-16903996 ] Tzu-Li (Gordon) Tai commented on FLINK-13489: - Since this is no longer a blocker for 1.9.0

[jira] [Updated] (FLINK-13438) Hive source/sink/udx should respect the conversion class of DataType

[ https://issues.apache.org/jira/browse/FLINK-13438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13438: Fix Version/s: (was: 1.9.0) 1.10.0 > Hive source/sink/udx

[jira] [Updated] (FLINK-12164) JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout is unstable

[ https://issues.apache.org/jira/browse/FLINK-12164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12164: Fix Version/s: (was: 1.9.0) 1.10.0 >

[jira] [Updated] (FLINK-13285) Check connectors runnable in blink runner

[ https://issues.apache.org/jira/browse/FLINK-13285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13285: Fix Version/s: (was: 1.9.0) 1.10.0 > Check connectors

[jira] [Updated] (FLINK-11843) Dispatcher fails to recover jobs if leader change happens during JobManagerRunner termination

[ https://issues.apache.org/jira/browse/FLINK-11843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11843: Fix Version/s: (was: 1.9.0) 1.10.0 > Dispatcher fails to

[jira] [Updated] (FLINK-11631) TaskExecutorITCase#testJobReExecutionAfterTaskExecutorTermination unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-11631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11631: Fix Version/s: (was: 1.9.0) 1.10.0 >

[jira] [Updated] (FLINK-11835) ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLeaderChange failed

[ https://issues.apache.org/jira/browse/FLINK-11835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11835: Fix Version/s: (was: 1.9.0) 1.10.0 >

[GitHub] [flink] flinkbot edited a comment on issue #9407: [FLINK-13670][ml] Add class for VectorAssemblerMapper

flinkbot edited a comment on issue #9407: [FLINK-13670][ml] Add class for VectorAssemblerMapper URL: https://github.com/apache/flink/pull/9407#issuecomment-51995 ## CI report: * bf69f9f25f8a62a494f530e7cba75879ac002412 : FAILURE

[GitHub] [flink] flinkbot commented on issue #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper

flinkbot commented on issue #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper URL: https://github.com/apache/flink/pull/9413#issuecomment-519968250 ## CI report: * a585d0f8fef391d4da791b0cd1506e4f8b1acdc1 : PENDING

[GitHub] [flink] flinkbot commented on issue #9411: [FLINK-13674][ml] Add class of Vector Size Hint Mapper

flinkbot commented on issue #9411: [FLINK-13674][ml] Add class of Vector Size Hint Mapper URL: https://github.com/apache/flink/pull/9411#issuecomment-519965855 ## CI report: * 4af38a946a55d1d6b68d7d249f87a65239c947f7 : PENDING

[GitHub] [flink] flinkbot commented on issue #9412: [FLINK-13675][ml] Add class of Vector Slice Mapper

flinkbot commented on issue #9412: [FLINK-13675][ml] Add class of Vector Slice Mapper URL: https://github.com/apache/flink/pull/9412#issuecomment-519965864 ## CI report: * e9ff64826d561117cbd984df4201d15e0523b091 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9406: [FLINK-13669][ml] Add class for BinarizerMapper

flinkbot edited a comment on issue #9406: [FLINK-13669][ml] Add class for BinarizerMapper URL: https://github.com/apache/flink/pull/9406#issuecomment-519954683 ## CI report: * eb27a4f02fee6d3d96a102ef7b4734d06442596a : FAILURE

[GitHub] [flink] flinkbot commented on issue #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper

flinkbot commented on issue #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper URL: https://github.com/apache/flink/pull/9413#issuecomment-519964647 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Updated] (FLINK-13676) Add class of Vector to Columns mapper

[ https://issues.apache.org/jira/browse/FLINK-13676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13676: --- Labels: pull-request-available (was: ) > Add class of Vector to Columns mapper >

[GitHub] [flink] xuyang1706 opened a new pull request #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper

xuyang1706 opened a new pull request #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper URL: https://github.com/apache/flink/pull/9413 ## What is the purpose of the change VectorToColumnsMapper maps one vector to many column objects. The number of columns

[GitHub] [flink] flinkbot commented on issue #9410: [FLINK-13673][ml] Add class of Vector Normalize Mapper

flinkbot commented on issue #9410: [FLINK-13673][ml] Add class of Vector Normalize Mapper URL: https://github.com/apache/flink/pull/9410#issuecomment-519963431 ## CI report: * 06b26ce69e490794f3bcda79766f8edc9d6e48ce : PENDING

[jira] [Created] (FLINK-13676) Add class of Vector to Columns mapper

Xu Yang created FLINK-13676: --- Summary: Add class of Vector to Columns mapper Key: FLINK-13676 URL: https://issues.apache.org/jira/browse/FLINK-13676 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot commented on issue #9412: [FLINK-13675][ml] Add class of Vector Slice Mapper

flinkbot commented on issue #9412: [FLINK-13675][ml] Add class of Vector Slice Mapper URL: https://github.com/apache/flink/pull/9412#issuecomment-519963321 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Updated] (FLINK-13675) Add class of Vector Slice Mapper

[ https://issues.apache.org/jira/browse/FLINK-13675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13675: --- Labels: pull-request-available (was: ) > Add class of Vector Slice Mapper >

[GitHub] [flink] xuyang1706 opened a new pull request #9412: [FLINK-13675][ml] Add class of Vector Slice Mapper

xuyang1706 opened a new pull request #9412: [FLINK-13675][ml] Add class of Vector Slice Mapper URL: https://github.com/apache/flink/pull/9412 ## What is the purpose of the change VectorSlicerMapper maps a vector to a thin vector , which define by input indices. It is

[jira] [Created] (FLINK-13675) Add class of Vector Slice Mapper

Xu Yang created FLINK-13675: --- Summary: Add class of Vector Slice Mapper Key: FLINK-13675 URL: https://issues.apache.org/jira/browse/FLINK-13675 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot commented on issue #9411: [FLINK-13674][ml] Add class of Vector Size Hint Mapper

flinkbot commented on issue #9411: [FLINK-13674][ml] Add class of Vector Size Hint Mapper URL: https://github.com/apache/flink/pull/9411#issuecomment-519962081 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Updated] (FLINK-13674) Add class of Vector Size Hint Mapper

[ https://issues.apache.org/jira/browse/FLINK-13674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13674: --- Labels: pull-request-available (was: ) > Add class of Vector Size Hint Mapper >

[GitHub] [flink] xuyang1706 opened a new pull request #9411: [FLINK-13674][ml] Add class of Vector Size Hint Mapper

xuyang1706 opened a new pull request #9411: [FLINK-13674][ml] Add class of Vector Size Hint Mapper URL: https://github.com/apache/flink/pull/9411 ## What is the purpose of the change VectorSizeHintMapper maps a vector to one or zero vector. If vector size is right, vector

[GitHub] [flink] flinkbot commented on issue #9408: [FLINK-13671][ml] Add class for VectorEleWiseProductMapper

flinkbot commented on issue #9408: [FLINK-13671][ml] Add class for VectorEleWiseProductMapper URL: https://github.com/apache/flink/pull/9408#issuecomment-519961164 ## CI report: * fbf9704fe2812d28d7a6b9ca6272a260e91089b3 : PENDING

[GitHub] [flink] flinkbot commented on issue #9409: [FLINK-13672][ml] Add class for VectorInteractionMapper

flinkbot commented on issue #9409: [FLINK-13672][ml] Add class for VectorInteractionMapper URL: https://github.com/apache/flink/pull/9409#issuecomment-519961173 ## CI report: * 9b5e1620eb70dd95996ec3e8b7bebe1f38ac89a5 : PENDING

[jira] [Created] (FLINK-13674) Add class of Vector Size Hint Mapper

Xu Yang created FLINK-13674: --- Summary: Add class of Vector Size Hint Mapper Key: FLINK-13674 URL: https://issues.apache.org/jira/browse/FLINK-13674 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot commented on issue #9410: [FLINK-13673][ml] Add class of Vector Normalize Mapper

flinkbot commented on issue #9410: [FLINK-13673][ml] Add class of Vector Normalize Mapper URL: https://github.com/apache/flink/pull/9410#issuecomment-519960860 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Updated] (FLINK-13673) Add class of Vector Normalize Mapper

[ https://issues.apache.org/jira/browse/FLINK-13673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13673: --- Labels: pull-request-available (was: ) > Add class of Vector Normalize Mapper >

[GitHub] [flink] xuyang1706 opened a new pull request #9410: [FLINK-13673][ml] Add class of Vector Normalize Mapper

xuyang1706 opened a new pull request #9410: [FLINK-13673][ml] Add class of Vector Normalize Mapper URL: https://github.com/apache/flink/pull/9410 ## What is the purpose of the change NormalizerMapper maps a vector to a new one which is normalized. It takes parameter p,

[GitHub] [flink] flinkbot commented on issue #9409: [FLINK-13672][ml] Add class for VectorInteractionMapper

flinkbot commented on issue #9409: [FLINK-13672][ml] Add class for VectorInteractionMapper URL: https://github.com/apache/flink/pull/9409#issuecomment-519959656 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Created] (FLINK-13673) Add class of Vector Normalize Mapper

Xu Yang created FLINK-13673: --- Summary: Add class of Vector Normalize Mapper Key: FLINK-13673 URL: https://issues.apache.org/jira/browse/FLINK-13673 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-13672) Add class for VectorInteractionMapper

[ https://issues.apache.org/jira/browse/FLINK-13672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13672: --- Labels: pull-request-available (was: ) > Add class for VectorInteractionMapper >

[GitHub] [flink] flinkbot commented on issue #9407: [FLINK-13670][ml] Add class for VectorAssemblerMapper

flinkbot commented on issue #9407: [FLINK-13670][ml] Add class for VectorAssemblerMapper URL: https://github.com/apache/flink/pull/9407#issuecomment-51995 ## CI report: * bf69f9f25f8a62a494f530e7cba75879ac002412 : PENDING

[GitHub] [flink] xuyang1706 opened a new pull request #9409: [FLINK-13672][ml] Add class for VectorInteractionMapper

xuyang1706 opened a new pull request #9409: [FLINK-13672][ml] Add class for VectorInteractionMapper URL: https://github.com/apache/flink/pull/9409 ## What is the purpose of the change VectorInteraction transfroms two vectors or double-valued columns into a single vector

[jira] [Created] (FLINK-13672) Add class for VectorInteractionMapper

Xu Yang created FLINK-13672: --- Summary: Add class for VectorInteractionMapper Key: FLINK-13672 URL: https://issues.apache.org/jira/browse/FLINK-13672 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot commented on issue #9408: [FLINK-13671][ml] Add class for VectorEleWiseProductMapper

flinkbot commented on issue #9408: [FLINK-13671][ml] Add class for VectorEleWiseProductMapper URL: https://github.com/apache/flink/pull/9408#issuecomment-519958177 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[jira] [Updated] (FLINK-13671) Add class for VectorEleWiseProductMapper

[ https://issues.apache.org/jira/browse/FLINK-13671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13671: --- Labels: pull-request-available (was: ) > Add class for VectorEleWiseProductMapper >

[GitHub] [flink] xuyang1706 opened a new pull request #9408: [FLINK-13671][ml] Add class for VectorEleWiseProductMapper

xuyang1706 opened a new pull request #9408: [FLINK-13671][ml] Add class for VectorEleWiseProductMapper URL: https://github.com/apache/flink/pull/9408 ## What is the purpose of the change VectorEleWiseProduct multiplies each input vector by a provided “scaling” vector, using

[jira] [Created] (FLINK-13671) Add class for VectorEleWiseProductMapper

Xu Yang created FLINK-13671: --- Summary: Add class for VectorEleWiseProductMapper Key: FLINK-13671 URL: https://issues.apache.org/jira/browse/FLINK-13671 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot commented on issue #9407: [FLINK-13670][ml] Add class for VectorAssemblerMapper

flinkbot commented on issue #9407: [FLINK-13670][ml] Add class for VectorAssemblerMapper URL: https://github.com/apache/flink/pull/9407#issuecomment-519955674 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Updated] (FLINK-13670) Add class for VectorAssemblerMapper

[ https://issues.apache.org/jira/browse/FLINK-13670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13670: --- Labels: pull-request-available (was: ) > Add class for VectorAssemblerMapper >

[GitHub] [flink] xuyang1706 opened a new pull request #9407: [FLINK-13670][ml] Add class for VectorAssemblerMapper

xuyang1706 opened a new pull request #9407: [FLINK-13670][ml] Add class for VectorAssemblerMapper URL: https://github.com/apache/flink/pull/9407 ## What is the purpose of the change VectorAssembler is a transformer that combines a given list of columns(vector or numerical

[GitHub] [flink] flinkbot commented on issue #9406: [FLINK-13669][ml] Add class for BinarizerMapper

flinkbot commented on issue #9406: [FLINK-13669][ml] Add class for BinarizerMapper URL: https://github.com/apache/flink/pull/9406#issuecomment-519954683 ## CI report: * eb27a4f02fee6d3d96a102ef7b4734d06442596a : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/122608982)

[jira] [Created] (FLINK-13670) Add class for VectorAssemblerMapper

Xu Yang created FLINK-13670: --- Summary: Add class for VectorAssemblerMapper Key: FLINK-13670 URL: https://issues.apache.org/jira/browse/FLINK-13670 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot commented on issue #9406: [FLINK-13669][ml] Add class for BinarizerMapper

flinkbot commented on issue #9406: [FLINK-13669][ml] Add class for BinarizerMapper URL: https://github.com/apache/flink/pull/9406#issuecomment-519953396 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request.

[jira] [Updated] (FLINK-13669) Add class for BinarizerMapper

[ https://issues.apache.org/jira/browse/FLINK-13669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13669: --- Labels: pull-request-available (was: ) > Add class for BinarizerMapper >

[GitHub] [flink] xuyang1706 opened a new pull request #9406: [FLINK-13669][ml] Add class for BinarizerMapper

xuyang1706 opened a new pull request #9406: [FLINK-13669][ml] Add class for BinarizerMapper URL: https://github.com/apache/flink/pull/9406 ## What is the purpose of the change BinarizerMapper is a transformer to binarize a continuous variable using a threshold. The features

[jira] [Created] (FLINK-13669) Add class for BinarizerMapper

Xu Yang created FLINK-13669: --- Summary: Add class for BinarizerMapper Key: FLINK-13669 URL: https://issues.apache.org/jira/browse/FLINK-13669 Project: Flink Issue Type: Sub-task

[GitHub] [flink] JingsongLi commented on a change in pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner

JingsongLi commented on a change in pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#discussion_r312511146 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner

JingsongLi commented on a change in pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#discussion_r312514891 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner

JingsongLi commented on a change in pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#discussion_r312507009 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner

JingsongLi commented on a change in pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#discussion_r312517306 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner

JingsongLi commented on a change in pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#discussion_r312506342 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner

JingsongLi commented on a change in pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#discussion_r312514228 ## File path:

[GitHub] [flink] hequn8128 closed pull request #9281: [hotfix][table]Rename TableAggFunctionCallVisitor to TableAggFunctionCallResolver

hequn8128 closed pull request #9281: [hotfix][table]Rename TableAggFunctionCallVisitor to TableAggFunctionCallResolver URL: https://github.com/apache/flink/pull/9281 This is an automated message from the Apache Git Service.

[jira] [Resolved] (FLINK-13637) Anchors not working in document(building.md, common.md, queryable_state.md)

[ https://issues.apache.org/jira/browse/FLINK-13637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng resolved FLINK-13637. - Resolution: Fixed > Anchors not working in document(building.md, common.md, queryable_state.md)

[GitHub] [flink] sunjincheng121 commented on issue #9396: [FLINK-13473][table] Add stream Windowed FlatAggregate support for blink planner

sunjincheng121 commented on issue #9396: [FLINK-13473][table] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#issuecomment-519933231 Thanks for the review @wuchong ! This commit will be squashed when merge, So I think

[jira] [Commented] (FLINK-13637) Anchors not working in document(building.md, common.md, queryable_state.md)

[ https://issues.apache.org/jira/browse/FLINK-13637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903919#comment-16903919 ] Hequn Cheng commented on FLINK-13637: - Fix in master: 56c6b487ee1bc395d700579f69f9fb8884724243 1.9:

[GitHub] [flink] hequn8128 closed pull request #9384: [FLINK-13637][docs] Fix problems of anchors in document(building.md, common.md, queryable_state.md)

hequn8128 closed pull request #9384: [FLINK-13637][docs] Fix problems of anchors in document(building.md, common.md, queryable_state.md) URL: https://github.com/apache/flink/pull/9384 This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table

flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table URL: https://github.com/apache/flink/pull/9404#issuecomment-519872127 ## CI report: * 4a726770daa19b1a587c5f8d9221a95e08387592 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9405: [FLINK-13668][ml] Add abstract classes for three typical scenarios of (Flat)Mapper

flinkbot edited a comment on issue #9405: [FLINK-13668][ml] Add abstract classes for three typical scenarios of (Flat)Mapper URL: https://github.com/apache/flink/pull/9405#issuecomment-519901201 ## CI report: * c1fedc4de6a92bc2c5f84d0e0c3038f29fd8944f : FAILURE

[jira] [Resolved] (FLINK-13522) Verify and correct builtin function's semantic for Blink planner

[ https://issues.apache.org/jira/browse/FLINK-13522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-13522. - Resolution: Fixed > Verify and correct builtin function's semantic for Blink planner >

[GitHub] [flink] wuchong closed pull request #9394: [FLINK-13547][table-planner-blink] Verify and correct string function's semantic for Blink planner

wuchong closed pull request #9394: [FLINK-13547][table-planner-blink] Verify and correct string function's semantic for Blink planner URL: https://github.com/apache/flink/pull/9394 This is an automated message from the

[GitHub] [flink] wuchong commented on issue #9394: [FLINK-13547][table-planner-blink] Verify and correct string function's semantic for Blink planner

wuchong commented on issue #9394: [FLINK-13547][table-planner-blink] Verify and correct string function's semantic for Blink planner URL: https://github.com/apache/flink/pull/9394#issuecomment-519912224 Merge with: 5e697cf148f2d4ea09b0117d4c22102de98440c4

[jira] [Resolved] (FLINK-13547) Verify and correct string function's semantic for Blink planner

[ https://issues.apache.org/jira/browse/FLINK-13547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-13547. - Resolution: Fixed [table-planner-blink] Remove LENGTH(), JSONVALUE(), KEYVALUE(), SUBSTR() builtin

[GitHub] [flink] flinkbot edited a comment on issue #9385: [FLINK-13635][datastream] Avoid unexpected interruption of AsyncFunction

flinkbot edited a comment on issue #9385: [FLINK-13635][datastream] Avoid unexpected interruption of AsyncFunction URL: https://github.com/apache/flink/pull/9385#issuecomment-519155346 ## CI report: * a8446f27e86b43424e1aa686529a3f4592b8f108 : FAILURE

[jira] [Resolved] (FLINK-13527) Instable KafkaProducerExactlyOnceITCase due to CheckpointFailureManager

[ https://issues.apache.org/jira/browse/FLINK-13527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-13527. --- Resolution: Duplicate This test instability should be fixed via FLINK-13593. > Instable

[jira] [Updated] (FLINK-13527) Instable KafkaProducerExactlyOnceITCase due to CheckpointFailureManager

[ https://issues.apache.org/jira/browse/FLINK-13527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13527: -- Fix Version/s: (was: 1.9.0) > Instable KafkaProducerExactlyOnceITCase due to

[GitHub] [flink] tillrohrmann closed pull request #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager

tillrohrmann closed pull request #9364: [FLINK-13593][checkpointing] Prevent failing the wrong execution attempt in CheckpointFailureManager URL: https://github.com/apache/flink/pull/9364 This is an automated message from

[jira] [Resolved] (FLINK-13593) Prevent failing the wrong execution attempt in CheckpointFailureManager

[ https://issues.apache.org/jira/browse/FLINK-13593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-13593. --- Resolution: Fixed Fixed via 1.10.0: 7a1222f354499a78e7047db47b403f73460207b1 1.9.0:

[GitHub] [flink] flinkbot commented on issue #9405: [FLINK-13668][ml] Add abstract classes for three typical scenarios of (Flat)Mapper

flinkbot commented on issue #9405: [FLINK-13668][ml] Add abstract classes for three typical scenarios of (Flat)Mapper URL: https://github.com/apache/flink/pull/9405#issuecomment-519901201 ## CI report: * c1fedc4de6a92bc2c5f84d0e0c3038f29fd8944f : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9394: [FLINK-13547][table-planner-blink] Verify and correct string function's semantic for Blink planner

flinkbot edited a comment on issue #9394: [FLINK-13547][table-planner-blink] Verify and correct string function's semantic for Blink planner URL: https://github.com/apache/flink/pull/9394#issuecomment-519467299 ## CI report: * 861d120d83964d267c95d024993b82186b1e6e7a : FAILURE

[jira] [Updated] (FLINK-13668) Add abstract classes for three typical scenarios of (Flat)Mapper.

[ https://issues.apache.org/jira/browse/FLINK-13668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Yang updated FLINK-13668: Description: _FlatMapper transforms one Row type data into zero_, _one_, _or more Row type result data_,

[GitHub] [flink] flinkbot commented on issue #9405: [FLINK-13668][ml] Add abstract classes for three typical scenarios of (Flat)Mapper

flinkbot commented on issue #9405: [FLINK-13668][ml] Add abstract classes for three typical scenarios of (Flat)Mapper URL: https://github.com/apache/flink/pull/9405#issuecomment-519899176 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] xuyang1706 opened a new pull request #9405: [FLINK-13668][ml] Add abstract classes for three typical scenarios of…

xuyang1706 opened a new pull request #9405: [FLINK-13668][ml] Add abstract classes for three typical scenarios of… URL: https://github.com/apache/flink/pull/9405 … (Flat)Mapper. ## What is the purpose of the change Add abstract classes for three typical scenarios of

[jira] [Updated] (FLINK-13668) Add abstract classes for three typical scenarios of (Flat)Mapper.

[ https://issues.apache.org/jira/browse/FLINK-13668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13668: --- Labels: pull-request-available (was: ) > Add abstract classes for three typical scenarios

[jira] [Created] (FLINK-13668) Add abstract classes for three typical scenarios of (Flat)Mapper.

Xu Yang created FLINK-13668: --- Summary: Add abstract classes for three typical scenarios of (Flat)Mapper. Key: FLINK-13668 URL: https://issues.apache.org/jira/browse/FLINK-13668 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #9403: [FLINK-13666][ml] Add an implement of collector with the row type

flinkbot edited a comment on issue #9403: [FLINK-13666][ml] Add an implement of collector with the row type URL: https://github.com/apache/flink/pull/9403#issuecomment-519855210 ## CI report: * 24d8508b97496d8db713e414d0b56ca35503b393 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9348: [FLINK-13505][docs-zh] Translate "Java Lambda Expressions" page into Chinese

flinkbot edited a comment on issue #9348: [FLINK-13505][docs-zh] Translate "Java Lambda Expressions" page into Chinese URL: https://github.com/apache/flink/pull/9348#issuecomment-517906070 ## CI report: * 1e2137271f7d7e3c7036a9e2e045ae3a4a4ff3c1 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9402: [FLINK-13665][flink-planner] Use of decimal(p, s) where p is less tha…

flinkbot edited a comment on issue #9402: [FLINK-13665][flink-planner] Use of decimal(p, s) where p is less tha… URL: https://github.com/apache/flink/pull/9402#issuecomment-519853135 ## CI report: * 97da69b22c3432e83c4e0869df4037fa630b5a4f : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9347: [FLINK-13563] [table-planner-blink] TumblingGroupWindow should implement toString method to explain more info

flinkbot edited a comment on issue #9347: [FLINK-13563] [table-planner-blink] TumblingGroupWindow should implement toString method to explain more info URL: https://github.com/apache/flink/pull/9347#issuecomment-517895998 ## CI report: * 212cd6c24fdb696aa13bed1cfff875f9bfc01d09 :

[GitHub] [flink] flinkbot commented on issue #9404: [FLINK-13667][ml] Add the utility class for the Table

flinkbot commented on issue #9404: [FLINK-13667][ml] Add the utility class for the Table URL: https://github.com/apache/flink/pull/9404#issuecomment-519872127 ## CI report: * 4a726770daa19b1a587c5f8d9221a95e08387592 : PENDING

[GitHub] [flink] flinkbot commented on issue #9404: [FLINK-13667][ml] Add the utility class for the Table

flinkbot commented on issue #9404: [FLINK-13667][ml] Add the utility class for the Table URL: https://github.com/apache/flink/pull/9404#issuecomment-519869219 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Commented] (FLINK-13411) SqlClient swallow the error when fails to submit job

[ https://issues.apache.org/jira/browse/FLINK-13411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903795#comment-16903795 ] Simon Su commented on FLINK-13411: -- For DDL cases if sql-client connect to a persist catalog, It should

[jira] [Updated] (FLINK-13667) Add the utility class for the Table

[ https://issues.apache.org/jira/browse/FLINK-13667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13667: --- Labels: pull-request-available (was: ) > Add the utility class for the Table >

[GitHub] [flink] xuyang1706 opened a new pull request #9404: [FLINK-13667][ml] Add the utility class for the Table

xuyang1706 opened a new pull request #9404: [FLINK-13667][ml] Add the utility class for the Table URL: https://github.com/apache/flink/pull/9404 ## What is the purpose of the change Add the utility class for the Table  ## Brief change log - *Add the

[GitHub] [flink] flinkbot edited a comment on issue #9385: [FLINK-13635][datastream] Avoid unexpected interruption of AsyncFunction

flinkbot edited a comment on issue #9385: [FLINK-13635][datastream] Avoid unexpected interruption of AsyncFunction URL: https://github.com/apache/flink/pull/9385#issuecomment-519155346 ## CI report: * a8446f27e86b43424e1aa686529a3f4592b8f108 : FAILURE

[jira] [Created] (FLINK-13667) Add the utility class for the Table

Xu Yang created FLINK-13667: --- Summary: Add the utility class for the Table Key: FLINK-13667 URL: https://issues.apache.org/jira/browse/FLINK-13667 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on issue #9394: [FLINK-13547][table-planner-blink] Verify and correct string function's semantic for Blink planner

flinkbot edited a comment on issue #9394: [FLINK-13547][table-planner-blink] Verify and correct string function's semantic for Blink planner URL: https://github.com/apache/flink/pull/9394#issuecomment-519467299 ## CI report: * 861d120d83964d267c95d024993b82186b1e6e7a : FAILURE

[GitHub] [flink] docete edited a comment on issue #9402: [FLINK-13665][flink-planner] Use of decimal(p, s) where p is less tha…

docete edited a comment on issue #9402: [FLINK-13665][flink-planner] Use of decimal(p, s) where p is less tha… URL: https://github.com/apache/flink/pull/9402#issuecomment-519850099 Hi @twalthr, I found an illegal use of decimal type in old planner, and add some code in FlinkTypeFactory

[GitHub] [flink] flinkbot edited a comment on issue #9349: [FLINK-13564] [table-planner-blink] throw exception if constant with YEAR TO MONTH resolution was used for group windows

flinkbot edited a comment on issue #9349: [FLINK-13564] [table-planner-blink] throw exception if constant with YEAR TO MONTH resolution was used for group windows URL: https://github.com/apache/flink/pull/9349#issuecomment-517912973 ## CI report: *

[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903760#comment-16903760 ] Truong Duc Kien commented on FLINK-10114: - Hi, [~hiliuxg] I take a look at your project. It's

[GitHub] [flink] flinkbot commented on issue #9403: [FLINK-13666][ml] Add an implement of collector with the row type

flinkbot commented on issue #9403: [FLINK-13666][ml] Add an implement of collector with the row type URL: https://github.com/apache/flink/pull/9403#issuecomment-519855210 ## CI report: * 24d8508b97496d8db713e414d0b56ca35503b393 : PENDING

<    1   2   3   >