[jira] [Updated] (FLINK-13865) Support custom config in Flink docker image

[ https://issues.apache.org/jira/browse/FLINK-13865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dagang Wei updated FLINK-13865: --- Component/s: (was: Deployment / Kubernetes) Deployment / Docker

[jira] [Commented] (FLINK-10995) Copy intermediate serialization results only once for broadcast mode

[ https://issues.apache.org/jira/browse/FLINK-10995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916401#comment-16916401 ] zhijiang commented on FLINK-10995: -- I think it was not planned in release-1.10 before. We could discuss

[jira] [Commented] (FLINK-13865) Support custom config in Flink docker image

[ https://issues.apache.org/jira/browse/FLINK-13865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916402#comment-16916402 ] Dagang Wei commented on FLINK-13865: I noticed FLINK-13380 which is helpful for Kubernetes, but it

[GitHub] [flink] flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor URL: https://github.com/apache/flink/pull/9477#issuecomment-522360024 ## CI report: *

[jira] [Updated] (FLINK-13865) Support custom config in Flink docker image

[ https://issues.apache.org/jira/browse/FLINK-13865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dagang Wei updated FLINK-13865: --- Environment: (was: I noticed FLINK-13380 which is helpful for Kubernetes, but it is still

[GitHub] [flink] zhijiangW commented on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

zhijiangW commented on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor URL: https://github.com/apache/flink/pull/9477#issuecomment-525149250 @flinkbot run travis

[jira] [Updated] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13488: --- Fix Version/s: (was: 1.9.1) (was: 1.10.0) 1.9.0 >

[jira] [Commented] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916399#comment-16916399 ] Kurt Young commented on FLINK-13488: Yeah, you're right. I will revert the change, thanks. >

[GitHub] [flink] dianfu commented on issue #9496: [FLINK-13011][build] Add the Build logic for Python API release package

dianfu commented on issue #9496: [FLINK-13011][build] Add the Build logic for Python API release package URL: https://github.com/apache/flink/pull/9496#issuecomment-525145865 @sunjincheng121 Thanks a lot for the PR. LGTM. +1 from my side.

[GitHub] [flink] flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner

flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner URL: https://github.com/apache/flink/pull/9511#issuecomment-523878126 ## CI report: * 11889a791a35b40ef0a4f5456da889cec0ebf990 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner

flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner URL: https://github.com/apache/flink/pull/9511#issuecomment-523878126 ## CI report: * 11889a791a35b40ef0a4f5456da889cec0ebf990 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner

flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner URL: https://github.com/apache/flink/pull/9511#issuecomment-523878126 ## CI report: * 11889a791a35b40ef0a4f5456da889cec0ebf990 : CANCELED

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r317895384 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r317895515 ## File path:

[jira] [Comment Edited] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916370#comment-16916370 ] Dian Fu edited comment on FLINK-13488 at 8/27/19 5:01 AM: -- Hi [~ykt836], I

[jira] [Commented] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916370#comment-16916370 ] Dian Fu commented on FLINK-13488: - Hi [~ykt836], I guess this fix is actually contained in

[GitHub] [flink] flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor URL: https://github.com/apache/flink/pull/9477#issuecomment-522360024 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

flinkbot edited a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#issuecomment-522053886 ## CI report: * 009da497d7c551ba854dc7ed8fa658f2acd6d6ce : SUCCESS

[jira] [Updated] (FLINK-13364) Add documentation for setting resources in blink planner

[ https://issues.apache.org/jira/browse/FLINK-13364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13364: Fix Version/s: (was: 1.9.1) > Add documentation for setting resources in blink planner >

[jira] [Updated] (FLINK-13361) Add documentation for JDBC connector for Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-13361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13361: Fix Version/s: 1.10.0 > Add documentation for JDBC connector for Table API & SQL >

[jira] [Updated] (FLINK-13365) Add documentation for reusing upstream operations when multi-sink is applied

[ https://issues.apache.org/jira/browse/FLINK-13365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13365: Fix Version/s: (was: 1.9.1) (was: 1.10.0) > Add documentation for reusing

[jira] [Updated] (FLINK-13360) Add documentation for HBase connector for Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-13360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13360: Fix Version/s: 1.10.0 > Add documentation for HBase connector for Table API & SQL >

[jira] [Updated] (FLINK-13363) Add documentation for streaming aggregate performance tunning.

[ https://issues.apache.org/jira/browse/FLINK-13363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13363: Fix Version/s: 1.10.0 > Add documentation for streaming aggregate performance tunning. >

[jira] [Updated] (FLINK-13708) transformations should be cleared because a table environment could execute multiple job

[ https://issues.apache.org/jira/browse/FLINK-13708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13708: Fix Version/s: 1.10.0 > transformations should be cleared because a table environment could execute >

[jira] [Updated] (FLINK-13520) Add documentation for the different behavior of row count sliding window in blink planner

[ https://issues.apache.org/jira/browse/FLINK-13520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13520: Fix Version/s: 1.10.0 > Add documentation for the different behavior of row count sliding window in >

[jira] [Updated] (FLINK-13365) Add documentation for reusing upstream operations when multi-sink is applied

[ https://issues.apache.org/jira/browse/FLINK-13365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13365: Fix Version/s: 1.10.0 > Add documentation for reusing upstream operations when multi-sink is applied >

[jira] [Updated] (FLINK-13359) Add documentation for DDL introduction

[ https://issues.apache.org/jira/browse/FLINK-13359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13359: --- Fix Version/s: 1.10.0 > Add documentation for DDL introduction >

[jira] [Updated] (FLINK-13362) Add documentation for Kafka & ES & FileSystem DDL

[ https://issues.apache.org/jira/browse/FLINK-13362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13362: --- Fix Version/s: 1.10.0 > Add documentation for Kafka & ES & FileSystem DDL >

[jira] [Updated] (FLINK-13105) Add documentation for blink planner's built-in functions

[ https://issues.apache.org/jira/browse/FLINK-13105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13105: --- Fix Version/s: 1.10.0 > Add documentation for blink planner's built-in functions >

[jira] [Updated] (FLINK-13354) Add documentation for how to use blink planner

[ https://issues.apache.org/jira/browse/FLINK-13354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13354: --- Fix Version/s: 1.10.0 > Add documentation for how to use blink planner >

[jira] [Updated] (FLINK-13564) blink planner should also throw exception if constant with YEAR TO MONTH resolution was used for group windows

[ https://issues.apache.org/jira/browse/FLINK-13564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13564: --- Fix Version/s: 1.10.0 > blink planner should also throw exception if constant with YEAR TO MONTH >

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r317887398 ## File path:

[jira] [Commented] (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:comment-tabpanel=16916349#comment-16916349 ] Kurt Young commented on FLINK-13599: I've updated the fix version to 1.9.1 since this is not

[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 ] Kurt Young updated FLINK-13599: --- Fix Version/s: (was: 1.9.0) 1.9.1 > Kinesis end-to-end test failed on Travis

[GitHub] [flink] flinkbot edited a comment on issue #9540: [FLINK-13859][docs] JSONDeserializationSchema spell error

flinkbot edited a comment on issue #9540: [FLINK-13859][docs] JSONDeserializationSchema spell error URL: https://github.com/apache/flink/pull/9540#issuecomment-525128086 ## CI report: * 5cb9691c978214d5f868c0e6a43f782b05b29ff6 : PENDING

[jira] [Commented] (FLINK-13277) add documentation of Hive source/sink

[ https://issues.apache.org/jira/browse/FLINK-13277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916347#comment-16916347 ] Kurt Young commented on FLINK-13277: Looks like this issue already merged, [~phoenixjiangnan] could

[jira] [Updated] (FLINK-13738) NegativeArraySizeException in LongHybridHashTable

[ https://issues.apache.org/jira/browse/FLINK-13738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13738: --- Fix Version/s: 1.10.0 > NegativeArraySizeException in LongHybridHashTable >

[jira] [Updated] (FLINK-13739) BinaryRowTest.testWriteString() fails in some environments

[ https://issues.apache.org/jira/browse/FLINK-13739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13739: --- Fix Version/s: 1.10.0 > BinaryRowTest.testWriteString() fails in some environments >

[jira] [Updated] (FLINK-13742) Fix code generation when aggregation contains both distinct aggregate with and without filter

[ https://issues.apache.org/jira/browse/FLINK-13742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13742: --- Fix Version/s: 1.10.0 > Fix code generation when aggregation contains both distinct aggregate with

[jira] [Updated] (FLINK-13277) add documentation of Hive source/sink

[ https://issues.apache.org/jira/browse/FLINK-13277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13277: --- Fix Version/s: 1.10.0 > add documentation of Hive source/sink >

[jira] [Commented] (FLINK-13737) flink-dist should add provided dependency on flink-examples-table

[ https://issues.apache.org/jira/browse/FLINK-13737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916346#comment-16916346 ] Kurt Young commented on FLINK-13737: I've updated the fix version to 1.9.1 since this is not

[jira] [Updated] (FLINK-13737) flink-dist should add provided dependency on flink-examples-table

[ https://issues.apache.org/jira/browse/FLINK-13737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13737: --- Fix Version/s: (was: 1.9.0) 1.9.1 1.10.0 > flink-dist

[jira] [Commented] (FLINK-13688) HiveCatalogUseBlinkITCase.testBlinkUdf constantly failed with 1.9.0-rc2

[ https://issues.apache.org/jira/browse/FLINK-13688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916344#comment-16916344 ] Kurt Young commented on FLINK-13688: [~till.rohrmann] Thanks for the heads up, this was planned. I'm

[jira] [Commented] (FLINK-13706) add documentation of how to use Hive functions in Flink

[ https://issues.apache.org/jira/browse/FLINK-13706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916339#comment-16916339 ] Kurt Young commented on FLINK-13706: I've updated the fix version to 1.9.1 since this is not

[jira] [Updated] (FLINK-13706) add documentation of how to use Hive functions in Flink

[ https://issues.apache.org/jira/browse/FLINK-13706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13706: --- Fix Version/s: (was: 1.9.0) 1.9.1 1.10.0 > add

[jira] [Updated] (FLINK-13501) Fixes a few issues in documentation for Hive integration

[ https://issues.apache.org/jira/browse/FLINK-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13501: --- Fix Version/s: (was: 1.9.0) 1.9.1 1.10.0 > Fixes a few

[jira] [Commented] (FLINK-13415) Document how to use hive connector in scala shell

[ https://issues.apache.org/jira/browse/FLINK-13415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916338#comment-16916338 ] Kurt Young commented on FLINK-13415: I've updated the fix version to 1.9.1 since this is not

[jira] [Updated] (FLINK-13415) Document how to use hive connector in scala shell

[ https://issues.apache.org/jira/browse/FLINK-13415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13415: --- Fix Version/s: (was: 1.9.0) 1.9.1 1.10.0 > Document how

[jira] [Commented] (FLINK-13501) Fixes a few issues in documentation for Hive integration

[ https://issues.apache.org/jira/browse/FLINK-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916337#comment-16916337 ] Kurt Young commented on FLINK-13501: I've updated the fix version to 1.9.1 since this is not

[jira] [Updated] (FLINK-13534) Unable to query Hive table with decimal column

[ https://issues.apache.org/jira/browse/FLINK-13534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13534: --- Fix Version/s: 1.10.0 > Unable to query Hive table with decimal column >

[jira] [Commented] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916336#comment-16916336 ] Kurt Young commented on FLINK-13488: I've updated the fix version to 1.9.1 since this is not

[jira] [Updated] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13488: --- Fix Version/s: (was: 1.9.0) 1.9.1 1.10.0 > flink-python

[jira] [Updated] (FLINK-13517) Restructure Hive Catalog documentation

[ https://issues.apache.org/jira/browse/FLINK-13517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13517: --- Fix Version/s: 1.10.0 > Restructure Hive Catalog documentation >

[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 ] Kurt Young updated FLINK-13490: --- Fix Version/s: 1.10.0 > Fix return null in JDBCUtils::getFieldFromResultSet >

[jira] [Updated] (FLINK-13526) Switching to a non existing catalog or database crashes sql-client

[ https://issues.apache.org/jira/browse/FLINK-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13526: --- Fix Version/s: 1.10.0 > Switching to a non existing catalog or database crashes sql-client >

[jira] [Updated] (FLINK-13563) TumblingGroupWindow should implement toString method

[ https://issues.apache.org/jira/browse/FLINK-13563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13563: --- Fix Version/s: 1.10.0 > TumblingGroupWindow should implement toString method >

[jira] [Updated] (FLINK-13562) throws exception when FlinkRelMdColumnInterval meets two stage stream group aggregate

[ https://issues.apache.org/jira/browse/FLINK-13562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13562: --- Fix Version/s: 1.10.0 > throws exception when FlinkRelMdColumnInterval meets two stage stream group

[jira] [Updated] (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 ] Kurt Young updated FLINK-13637: --- Fix Version/s: 1.10.0 > Anchors not working in document(building.md, common.md, queryable_state.md)

[GitHub] [flink] flinkbot commented on issue #9540: [FLINK-13859][docs] JSONDeserializationSchema spell error

flinkbot commented on issue #9540: [FLINK-13859][docs] JSONDeserializationSchema spell error URL: https://github.com/apache/flink/pull/9540#issuecomment-525128086 ## CI report: * 5cb9691c978214d5f868c0e6a43f782b05b29ff6 : UNKNOWN

[jira] [Commented] (FLINK-13517) Restructure Hive Catalog documentation

[ https://issues.apache.org/jira/browse/FLINK-13517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916323#comment-16916323 ] Kurt Young commented on FLINK-13517: I've updated the fix version to 1.9.1 since this is not

[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=16916320#comment-16916320 ] Kurt Young commented on FLINK-13637: I've updated the fix version to 1.9.1 since this is not

[jira] [Updated] (FLINK-13517) Restructure Hive Catalog documentation

[ https://issues.apache.org/jira/browse/FLINK-13517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13517: --- Fix Version/s: (was: 1.9.0) 1.9.1 > Restructure Hive Catalog documentation >

[jira] [Updated] (FLINK-13526) Switching to a non existing catalog or database crashes sql-client

[ https://issues.apache.org/jira/browse/FLINK-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13526: --- Fix Version/s: (was: 1.9.0) 1.9.1 > Switching to a non existing catalog or

[jira] [Commented] (FLINK-13526) Switching to a non existing catalog or database crashes sql-client

[ https://issues.apache.org/jira/browse/FLINK-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916319#comment-16916319 ] Kurt Young commented on FLINK-13526: I've updated the fix version to 1.9.1 since this is not

[jira] [Updated] (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 ] Kurt Young updated FLINK-13637: --- Fix Version/s: (was: 1.9.0) 1.9.1 > Anchors not working in

[jira] [Commented] (FLINK-10995) Copy intermediate serialization results only once for broadcast mode

[ https://issues.apache.org/jira/browse/FLINK-10995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916315#comment-16916315 ] Kurt Young commented on FLINK-10995: Would it possible to open the Jira for writing only one file in

[GitHub] [flink] flinkbot commented on issue #9540: [FLINK-13859][docs] JSONDeserializationSchema spell error

flinkbot commented on issue #9540: [FLINK-13859][docs] JSONDeserializationSchema spell error URL: https://github.com/apache/flink/pull/9540#issuecomment-525126046 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-13859) JSONDeserializationSchema spell error

[ https://issues.apache.org/jira/browse/FLINK-13859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13859: --- Labels: pull-request-available (was: ) > JSONDeserializationSchema spell error >

[GitHub] [flink] flinkbot edited a comment on issue #9539: [hotfix][docs] Fix typo

flinkbot edited a comment on issue #9539: [hotfix][docs] Fix typo URL: https://github.com/apache/flink/pull/9539#issuecomment-525098010 ## CI report: * 9430aca9b85c3a226cf5d5546e174d57daa8174e : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/124669373)

[GitHub] [flink] taizilongxu opened a new pull request #9540: [FLINK-13859][docs] JSONDeserializationSchema spell error

taizilongxu opened a new pull request #9540: [FLINK-13859][docs] JSONDeserializationSchema spell error URL: https://github.com/apache/flink/pull/9540 ## What is the purpose of the change The doc spell error ## Brief change log JsonDeserializationSchema ->

[jira] [Commented] (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:comment-tabpanel=16916313#comment-16916313 ] Kevin Zhang commented on FLINK-13547: - Thanks [~docete] and [~jark], we will have a look at the

[GitHub] [flink] flinkbot edited a comment on issue #9510: [FLINK-13807][tests] Read file with UTF-8 charset in TestBaseUtils.getResultReader

flinkbot edited a comment on issue #9510: [FLINK-13807][tests] Read file with UTF-8 charset in TestBaseUtils.getResultReader URL: https://github.com/apache/flink/pull/9510#issuecomment-523878082 ## CI report: * 7e7bc9b213b2fadb8759449b65e5be19b11aa829 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner

flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner URL: https://github.com/apache/flink/pull/9511#issuecomment-523878126 ## CI report: * 11889a791a35b40ef0a4f5456da889cec0ebf990 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner

flinkbot edited a comment on issue #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner URL: https://github.com/apache/flink/pull/9511#issuecomment-523878126 ## CI report: * 11889a791a35b40ef0a4f5456da889cec0ebf990 : CANCELED

[GitHub] [flink] JingsongLi commented on a change in pull request #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner

JingsongLi commented on a change in pull request #9511: [FLINK-13356][table][docs] Add documentation for TopN and Deduplication in blink planner URL: https://github.com/apache/flink/pull/9511#discussion_r317879792 ## File path: docs/dev/table/sql.md ## @@ -813,6 +813,222

[GitHub] [flink] flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor URL: https://github.com/apache/flink/pull/9477#issuecomment-522360024 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor URL: https://github.com/apache/flink/pull/9477#issuecomment-522360024 ## CI report: *

[GitHub] [flink] xuefuz commented on issue #8738: [FLINK-12845][sql-client] Execute multiple statements in command line…

xuefuz commented on issue #8738: [FLINK-12845][sql-client] Execute multiple statements in command line… URL: https://github.com/apache/flink/pull/8738#issuecomment-525118500 As a reference, Hive has been doing, which seems quite simple.

[GitHub] [flink] flinkbot edited a comment on issue #9538: [hotfix][docs] Fix typo

flinkbot edited a comment on issue #9538: [hotfix][docs] Fix typo URL: https://github.com/apache/flink/pull/9538#issuecomment-525097982 ## CI report: * 07c04045c445ccd5d844ffc733d01ac7adbf88ee : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/124669351)

[GitHub] [flink] zhijiangW commented on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

zhijiangW commented on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor URL: https://github.com/apache/flink/pull/9477#issuecomment-525116894 Thanks for the confirmation and I would merge it after travis green.

[jira] [Updated] (FLINK-13765) Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

[ https://issues.apache.org/jira/browse/FLINK-13765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13765: - Description: In StreamTwoInputSelectableProcessor there are three fields \{InputSelectable, 

[GitHub] [flink] flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

flinkbot edited a comment on issue #9477: [FLINK-13765][task] Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor URL: https://github.com/apache/flink/pull/9477#issuecomment-522360024 ## CI report: *

[jira] [Updated] (FLINK-13765) Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

[ https://issues.apache.org/jira/browse/FLINK-13765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13765: - Description: In StreamTwoInputSelectableProcessor there are three fields \{InputSelectable, 

[GitHub] [flink] flinkbot edited a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

flinkbot edited a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#issuecomment-522053886 ## CI report: * 009da497d7c551ba854dc7ed8fa658f2acd6d6ce : SUCCESS

[jira] [Updated] (FLINK-13765) Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

[ https://issues.apache.org/jira/browse/FLINK-13765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13765: - Summary: Introduce TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

[GitHub] [flink] Lemonjing commented on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

Lemonjing commented on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#issuecomment-525112986 @flinkbot run travis This is an automated message

[jira] [Updated] (FLINK-13765) Introduce the TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

[ https://issues.apache.org/jira/browse/FLINK-13765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13765: - Summary: Introduce the TwoInputSelectionHandler for selecting input in

[GitHub] [flink] flinkbot edited a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

flinkbot edited a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#issuecomment-522053886 ## CI report: * 009da497d7c551ba854dc7ed8fa658f2acd6d6ce : SUCCESS

[GitHub] [flink] Lemonjing commented on a change in pull request #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

Lemonjing commented on a change in pull request #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#discussion_r317871779 ## File path:

[GitHub] [flink] Lemonjing commented on a change in pull request #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

Lemonjing commented on a change in pull request #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#discussion_r317868102 ## File path:

[GitHub] [flink] Lemonjing removed a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

Lemonjing removed a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#issuecomment-522054960 @flinkbot attention @yanghua @buptljy This

[jira] [Commented] (FLINK-10995) Copy intermediate serialization results only once for broadcast mode

[ https://issues.apache.org/jira/browse/FLINK-10995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916286#comment-16916286 ] zhijiang commented on FLINK-10995: -- [~ykt836], this Jira is for improving the serialization stack in

[jira] [Commented] (FLINK-9477) Support SQL 2016 JSON functions in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916283#comment-16916283 ] Jark Wu commented on FLINK-9477: Hi [~x1q1j1], it would be great if you can summarize the

[GitHub] [flink] Lemonjing removed a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

Lemonjing removed a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#issuecomment-525108063 @flinkbot run travis This is an automated

[GitHub] [flink] Lemonjing commented on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

Lemonjing commented on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#issuecomment-525108063 @flinkbot run travis This is an automated message

[jira] [Commented] (FLINK-13862) Remove or rewrite Execution Plan docs

[ https://issues.apache.org/jira/browse/FLINK-13862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916282#comment-16916282 ] TisonKun commented on FLINK-13862: -- After a close look I would prefer removing it at least for now.

[GitHub] [flink] Lemonjing commented on a change in pull request #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

Lemonjing commented on a change in pull request #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#discussion_r317868102 ## File path:

[GitHub] [flink] Lemonjing commented on a change in pull request #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

Lemonjing commented on a change in pull request #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#discussion_r317623406 ## File path:

[GitHub] [flink] wuchong commented on issue #8738: [FLINK-12845][sql-client] Execute multiple statements in command line…

wuchong commented on issue #8738: [FLINK-12845][sql-client] Execute multiple statements in command line… URL: https://github.com/apache/flink/pull/8738#issuecomment-525106464 > I agree the current PR is way too hacky. However, I don't see the need of extending SQL parser just to support

[GitHub] [flink] flinkbot edited a comment on issue #9510: [FLINK-13807][tests] Read file with UTF-8 charset in TestBaseUtils.getResultReader

flinkbot edited a comment on issue #9510: [FLINK-13807][tests] Read file with UTF-8 charset in TestBaseUtils.getResultReader URL: https://github.com/apache/flink/pull/9510#issuecomment-523878082 ## CI report: * 7e7bc9b213b2fadb8759449b65e5be19b11aa829 : PENDING

  1   2   3   4   5   >