[jira] [Updated] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator chained in a single task

2019-04-22 Thread Congxian Qiu(klion26) (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-12296: -- Issue Type: Bug (was: Test) > Data loss silently in RocksDBStateBackend when

[jira] [Updated] (FLINK-12297) Clean the closure for OutputTags in PatternStream

2019-04-22 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-12297: - Summary: Clean the closure for OutputTags in PatternStream (was: We should clean the cl

[jira] [Updated] (FLINK-12295) avoid to call retractExpressions method of max/min function in retractable aggregate code-gen

2019-04-22 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12295: --- Summary: avoid to call retractExpressions method of max/min function in retractable aggregate code-g

[jira] [Created] (FLINK-12297) We should clean the closure for OutputTags

2019-04-22 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-12297: Summary: We should clean the closure for OutputTags Key: FLINK-12297 URL: https://issues.apache.org/jira/browse/FLINK-12297 Project: Flink Issue Type

[jira] [Updated] (FLINK-12295) avoid to call retractExpressions method for max/min in retractable aggregate code-gen

2019-04-22 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12295: --- Summary: avoid to call retractExpressions method for max/min in retractable aggregate code-gen (was

[jira] [Updated] (FLINK-12295) avoid to call retractExpressions method for max/min function in retractable aggregate code-gen

2019-04-22 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12295: --- Summary: avoid to call retractExpressions method for max/min function in retractable aggregate code-

[jira] [Created] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator chained in a single task

2019-04-22 Thread Congxian Qiu(klion26) (JIRA)
Congxian Qiu(klion26) created FLINK-12296: - Summary: Data loss silently in RocksDBStateBackend when more than one operator chained in a single task Key: FLINK-12296 URL: https://issues.apache.org/jira/bro

[jira] [Updated] (FLINK-12295) use retract aggregate function instead of regular aggregate function for retractable aggregate in code gen

2019-04-22 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12295: --- Description: after {{FlinkRelMdModifiedMonotonicity}} introduced, a max/min function whose result va

[GitHub] [flink] dawidwys commented on issue #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces

2019-04-22 Thread GitBox
dawidwys commented on issue #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces URL: https://github.com/apache/flink/pull/8050#issuecomment-485665450 Hi @sunjincheng121 , I will merge this once I finish the review, are you fine with this?

[jira] [Created] (FLINK-12295) use retract aggregate function instead of regular aggregate function for retractable aggregate in code gen

2019-04-22 Thread godfrey he (JIRA)
godfrey he created FLINK-12295: -- Summary: use retract aggregate function instead of regular aggregate function for retractable aggregate in code gen Key: FLINK-12295 URL: https://issues.apache.org/jira/browse/FLINK-1

[GitHub] [flink] flinkbot edited a comment on issue #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces

2019-04-22 Thread GitBox
flinkbot edited a comment on issue #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces URL: https://github.com/apache/flink/pull/8050#issuecomment-476498188 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] sunjincheng121 commented on issue #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces

2019-04-22 Thread GitBox
sunjincheng121 commented on issue #8050: [FLINK-11067][table] Convert TableEnvironments to interfaces URL: https://github.com/apache/flink/pull/8050#issuecomment-485664028 Thanks for the update @hequn8128! The changes look good to me! +1 to merged. Will be merged if there no o

[GitHub] [flink] flinkbot commented on issue #8241: Update MainThreadValidatorUtil.java

2019-04-22 Thread GitBox
flinkbot commented on issue #8241: Update MainThreadValidatorUtil.java URL: https://github.com/apache/flink/pull/8241#issuecomment-485663017 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use th

[GitHub] [flink] likejian opened a new pull request #8241: Update MainThreadValidatorUtil.java

2019-04-22 Thread GitBox
likejian opened a new pull request #8241: Update MainThreadValidatorUtil.java URL: https://github.com/apache/flink/pull/8241 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That w

[GitHub] [flink] asfgit closed pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation.

2019-04-22 Thread GitBox
asfgit closed pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation. URL: https://github.com/apache/flink/pull/8203 This is

[jira] [Closed] (FLINK-12208) Introduce Sort & TemporalSort & SortLimit & Limit operators for blink streaming runtime

2019-04-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-12208. --- Resolution: Fixed Assignee: Jing Zhang Implemented in 1.9.0: 945eb30877103bff84fe936457c905b3636d8490

[jira] [Updated] (FLINK-12208) Introduce Sort & TemporalSort & SortLimit & Limit operators for blink streaming runtime

2019-04-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-12208: Fix Version/s: 1.9.0 > Introduce Sort & TemporalSort & SortLimit & Limit operators for blink > streaming

[jira] [Updated] (FLINK-12208) Introduce Sort & TemporalSort & SortLimit & Limit operators for blink streaming runtime

2019-04-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-12208: Summary: Introduce Sort & TemporalSort & SortLimit & Limit operators for blink streaming runtime (was: Su

[GitHub] [flink] tianchen92 commented on issue #8219: [FLINK-10441]Don't log warning when creating upload directory

2019-04-22 Thread GitBox
tianchen92 commented on issue #8219: [FLINK-10441]Don't log warning when creating upload directory URL: https://github.com/apache/flink/pull/8219#issuecomment-485661495 Hi @uce, could you please help review this PR? thanks Th

[jira] [Updated] (FLINK-10972) Enhancements to Flink Table API

2019-04-22 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-10972: Description: [link title|http://example.com/]With the continuous efforts from the community, the

[jira] [Closed] (FLINK-11290) BatchTableEnvironment and StreamTableEnvironment should transparent to users

2019-04-22 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11290. --- Resolution: Fixed FLIP-32 will deal with the unifycation of TableEnvironment. so close this JIRA. >

[jira] [Commented] (FLINK-9679) Implement ConfluentRegistryAvroSerializationSchema

2019-04-22 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16823719#comment-16823719 ] Dawid Wysakowicz commented on FLINK-9679: - Hi [~Wosinsan] I haven't heard from th

[GitHub] [flink] wuchong commented on issue #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation.

2019-04-22 Thread GitBox
wuchong commented on issue #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation. URL: https://github.com/apache/flink/pull/8203#issuecomment-485658580 Merging...

[GitHub] [flink] tianchen92 commented on issue #8240: [FLINK-12293][docs, datastream]Fix some comment typos in flink-streaming-java.

2019-04-22 Thread GitBox
tianchen92 commented on issue #8240: [FLINK-12293][docs, datastream]Fix some comment typos in flink-streaming-java. URL: https://github.com/apache/flink/pull/8240#issuecomment-485658381 @dawidwys Thanks for your comments, I have resolved them, please have a look. --

[GitHub] [flink] dawidwys merged pull request #8232: [hotfix] Remove some unused import statements

2019-04-22 Thread GitBox
dawidwys merged pull request #8232: [hotfix] Remove some unused import statements URL: https://github.com/apache/flink/pull/8232 This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Closed] (FLINK-11967) Add Column Operators/Operations

2019-04-22 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11967. --- Resolution: Fixed > Add Column Operators/Operations > --- > >

[GitHub] [flink] flinkbot edited a comment on issue #8187: [FLINK-12197] [Formats] Avro row deser for Confluent binary format

2019-04-22 Thread GitBox
flinkbot edited a comment on issue #8187: [FLINK-12197] [Formats] Avro row deser for Confluent binary format URL: https://github.com/apache/flink/pull/8187#issuecomment-483647039 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to r

[GitHub] [flink] dawidwys commented on issue #8187: [FLINK-12197] [Formats] Avro row deser for Confluent binary format

2019-04-22 Thread GitBox
dawidwys commented on issue #8187: [FLINK-12197] [Formats] Avro row deser for Confluent binary format URL: https://github.com/apache/flink/pull/8187#issuecomment-485656187 Hi @EugeneYushin I have not read the whole PR, but I have one general concern regarding the architecture of this chang

[jira] [Created] (FLINK-12294) kafka consumer, data locality

2019-04-22 Thread Sergey (JIRA)
Sergey created FLINK-12294: -- Summary: kafka consumer, data locality Key: FLINK-12294 URL: https://issues.apache.org/jira/browse/FLINK-12294 Project: Flink Issue Type: Improvement Component

[GitHub] [flink] dawidwys commented on a change in pull request #8240: [FLINK-12293][docs, datastream]Fix some comment typos in flink-streaming-java.

2019-04-22 Thread GitBox
dawidwys commented on a change in pull request #8240: [FLINK-12293][docs, datastream]Fix some comment typos in flink-streaming-java. URL: https://github.com/apache/flink/pull/8240#discussion_r277527122 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/util

[GitHub] [flink] dawidwys commented on a change in pull request #8240: [FLINK-12293][docs, datastream]Fix some comment typos in flink-streaming-java.

2019-04-22 Thread GitBox
dawidwys commented on a change in pull request #8240: [FLINK-12293][docs, datastream]Fix some comment typos in flink-streaming-java. URL: https://github.com/apache/flink/pull/8240#discussion_r277526849 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runt

[GitHub] [flink] dawidwys commented on a change in pull request #8240: [FLINK-12293][docs, datastream]Fix some comment typos in flink-streaming-java.

2019-04-22 Thread GitBox
dawidwys commented on a change in pull request #8240: [FLINK-12293][docs, datastream]Fix some comment typos in flink-streaming-java. URL: https://github.com/apache/flink/pull/8240#discussion_r277526713 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runt

[jira] [Updated] (FLINK-6227) Introduce the DataConsumptionException for downstream task failure

2019-04-22 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-6227: Component/s: Runtime / Coordination > Introduce the DataConsumptionException for downstream task failure >

[GitHub] [flink] flinkbot edited a comment on issue #8222: [FLINK-11518] [table] Add partition related catalog APIs and implement them in GenericInMemoryCatalog

2019-04-22 Thread GitBox
flinkbot edited a comment on issue #8222: [FLINK-11518] [table] Add partition related catalog APIs and implement them in GenericInMemoryCatalog URL: https://github.com/apache/flink/pull/8222#issuecomment-484775277 Thanks a lot for your contribution to the Apache Flink project. I'm the @fli

[GitHub] [flink] JingsongLi commented on issue #8222: [FLINK-11518] [table] Add partition related catalog APIs and implement them in GenericInMemoryCatalog

2019-04-22 Thread GitBox
JingsongLi commented on issue #8222: [FLINK-11518] [table] Add partition related catalog APIs and implement them in GenericInMemoryCatalog URL: https://github.com/apache/flink/pull/8222#issuecomment-485650723 @flinkbot attention @wuchong ---

[GitHub] [flink] flinkbot edited a comment on issue #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation.

2019-04-22 Thread GitBox
flinkbot edited a comment on issue #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation. URL: https://github.com/apache/flink/pull/8203#issuecomment-484360424 Thanks a lot for your contribution to the Ap

[GitHub] [flink] wuchong commented on issue #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation.

2019-04-22 Thread GitBox
wuchong commented on issue #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation. URL: https://github.com/apache/flink/pull/8203#issuecomment-485647538 LGTM +1 ---

[GitHub] [flink] wuchong commented on issue #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation.

2019-04-22 Thread GitBox
wuchong commented on issue #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation. URL: https://github.com/apache/flink/pull/8203#issuecomment-485647563 @flinkbot approve all -

[GitHub] [flink] tianchen92 closed pull request #8223: [FLINK-9904]Allow users to control MaxDirectMemorySize

2019-04-22 Thread GitBox
tianchen92 closed pull request #8223: [FLINK-9904]Allow users to control MaxDirectMemorySize URL: https://github.com/apache/flink/pull/8223 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] tianchen92 opened a new pull request #8223: [FLINK-9904]Allow users to control MaxDirectMemorySize

2019-04-22 Thread GitBox
tianchen92 opened a new pull request #8223: [FLINK-9904]Allow users to control MaxDirectMemorySize URL: https://github.com/apache/flink/pull/8223 ## What is the purpose of the change *This PR is related to FLINK-9904. Make MaxDirectMemorySize configurable via flink-conf.yaml.*

[GitHub] [flink] wuchong commented on a change in pull request #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module

2019-04-22 Thread GitBox
wuchong commented on a change in pull request #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module URL: https://github.com/apache/flink/pull/8205#discussion_r277514706 ## File path: flink-connectors/fli

[GitHub] [flink] flinkbot commented on issue #8240: [FLINK-12293]Fix some comment typos in flink-streaming-java.

2019-04-22 Thread GitBox
flinkbot commented on issue #8240: [FLINK-12293]Fix some comment typos in flink-streaming-java. URL: https://github.com/apache/flink/pull/8240#issuecomment-485636592 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pu

[jira] [Updated] (FLINK-12293) Fix some comment typos in flink-streaming-java.

2019-04-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12293: --- Labels: pull-request-available (was: ) > Fix some comment typos in flink-streaming-java. >

[GitHub] [flink] tianchen92 opened a new pull request #8240: [FLINK-12293]Fix some comment typos in flink-streaming-java.

2019-04-22 Thread GitBox
tianchen92 opened a new pull request #8240: [FLINK-12293]Fix some comment typos in flink-streaming-java. URL: https://github.com/apache/flink/pull/8240 ## What is the purpose of the change *This PR is related to [FLINK-12293](https://issues.apache.org/jira/browse/FLINK-12293). F

[jira] [Created] (FLINK-12293) Fix some comment typos in flink-streaming-java.

2019-04-22 Thread Ji Liu (JIRA)
Ji Liu created FLINK-12293: -- Summary: Fix some comment typos in flink-streaming-java. Key: FLINK-12293 URL: https://issues.apache.org/jira/browse/FLINK-12293 Project: Flink Issue Type: Improvement

[GitHub] [flink] bowenli86 commented on a change in pull request #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module

2019-04-22 Thread GitBox
bowenli86 commented on a change in pull request #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module URL: https://github.com/apache/flink/pull/8205#discussion_r277470763 ## File path: flink-connectors/f

[GitHub] [flink] wuchong commented on issue #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation.

2019-04-22 Thread GitBox
wuchong commented on issue #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation. URL: https://github.com/apache/flink/pull/8203#issuecomment-485628378 @flinkbot approve-until quality --

[GitHub] [flink] wuchong commented on a change in pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformati

2019-04-22 Thread GitBox
wuchong commented on a change in pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation. URL: https://github.com/apache/flink/pull/8203#discussion_r277504403 ## File path: flink-table

[GitHub] [flink] wuchong commented on a change in pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformati

2019-04-22 Thread GitBox
wuchong commented on a change in pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation. URL: https://github.com/apache/flink/pull/8203#discussion_r277503391 ## File path: flink-table

[GitHub] [flink] wuchong commented on a change in pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformati

2019-04-22 Thread GitBox
wuchong commented on a change in pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation. URL: https://github.com/apache/flink/pull/8203#discussion_r277505248 ## File path: flink-table

[GitHub] [flink] wuchong commented on a change in pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformati

2019-04-22 Thread GitBox
wuchong commented on a change in pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation. URL: https://github.com/apache/flink/pull/8203#discussion_r277505457 ## File path: flink-table

[GitHub] [flink] wuchong commented on a change in pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformati

2019-04-22 Thread GitBox
wuchong commented on a change in pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation. URL: https://github.com/apache/flink/pull/8203#discussion_r277502721 ## File path: flink-table

[GitHub] [flink] wuchong commented on a change in pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformati

2019-04-22 Thread GitBox
wuchong commented on a change in pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation. URL: https://github.com/apache/flink/pull/8203#discussion_r277502857 ## File path: flink-table

[GitHub] [flink] wuchong commented on a change in pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformati

2019-04-22 Thread GitBox
wuchong commented on a change in pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation. URL: https://github.com/apache/flink/pull/8203#discussion_r277503077 ## File path: flink-table

[GitHub] [flink] wuchong commented on a change in pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformati

2019-04-22 Thread GitBox
wuchong commented on a change in pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation. URL: https://github.com/apache/flink/pull/8203#discussion_r277504403 ## File path: flink-table

[GitHub] [flink] wuchong commented on a change in pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformati

2019-04-22 Thread GitBox
wuchong commented on a change in pull request #8203: [Flink-12208][table-planner-blink] Support translation from StreamExecSort / TemporalSort / SortLimit/ Limit to StreamTransformation. URL: https://github.com/apache/flink/pull/8203#discussion_r277502987 ## File path: flink-table

[jira] [Updated] (FLINK-12287) A document error in "StreamElement.java"

2019-04-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12287: --- Labels: pull-request-available starter (was: starter) > A document error in "StreamElement.

[GitHub] [flink] flinkbot commented on issue #8239: [FLINK-12287] [Runtime / Operators] A document error in StreamElement…

2019-04-22 Thread GitBox
flinkbot commented on issue #8239: [FLINK-12287] [Runtime / Operators] A document error in StreamElement… URL: https://github.com/apache/flink/pull/8239#issuecomment-485626537 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

[GitHub] [flink] Leeviiii opened a new pull request #8239: [FLINK-12287] [Runtime / Operators] A document error in StreamElement…

2019-04-22 Thread GitBox
Leev opened a new pull request #8239: [FLINK-12287] [Runtime / Operators] A document error in StreamElement… URL: https://github.com/apache/flink/pull/8239 ….java ## What is the purpose of the change This pull request is to fix a error doc in StreamElement.java

[jira] [Updated] (FLINK-11877) Implement the runtime handling of the InputSelectable interface

2019-04-22 Thread Haibo Sun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haibo Sun updated FLINK-11877: -- Description: - Introduces a new `Input` interface to represent the logical input of operators. - Int

[jira] [Created] (FLINK-12292) Add benchmarks for the input processors

2019-04-22 Thread Haibo Sun (JIRA)
Haibo Sun created FLINK-12292: - Summary: Add benchmarks for the input processors Key: FLINK-12292 URL: https://issues.apache.org/jira/browse/FLINK-12292 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-12291) Add benchmarks for the input processors

2019-04-22 Thread Haibo Sun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haibo Sun closed FLINK-12291. - Resolution: Invalid > Add benchmarks for the input processors > ---

[jira] [Created] (FLINK-12291) Add benchmarks for the input processors

2019-04-22 Thread Haibo Sun (JIRA)
Haibo Sun created FLINK-12291: - Summary: Add benchmarks for the input processors Key: FLINK-12291 URL: https://issues.apache.org/jira/browse/FLINK-12291 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-12115) Add support in Flink to persist state in Azure's blob store

2019-04-22 Thread Liya Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16823638#comment-16823638 ] Liya Fan commented on FLINK-12115: -- I vote for this issue, because it enhances the port

[GitHub] [flink] JingsongLi commented on issue #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types

2019-04-22 Thread GitBox
JingsongLi commented on issue #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types URL: https://github.com/apache/flink/pull/8179#issuecomment-485614157 The PR component tag should be [table-planner] instead of [Table API? --

[GitHub] [flink] JingsongLi commented on a change in pull request #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types

2019-04-22 Thread GitBox
JingsongLi commented on a change in pull request #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types URL: https://github.com/apache/flink/pull/8179#discussion_r277493916 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/util/ExplodeF

[GitHub] [flink] JingsongLi commented on a change in pull request #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types

2019-04-22 Thread GitBox
JingsongLi commented on a change in pull request #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types URL: https://github.com/apache/flink/pull/8179#discussion_r277493902 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/util/ExplodeF

[GitHub] [flink] wuchong commented on issue #7799: [FLINK-11613][chinese-translation, Documentation]Translate the "Project Template for Scala" page into Chinese

2019-04-22 Thread GitBox
wuchong commented on issue #7799: [FLINK-11613][chinese-translation,Documentation]Translate the "Project Template for Scala" page into Chinese URL: https://github.com/apache/flink/pull/7799#issuecomment-485610406 Thanks @Tom-Goong , I will review it today.

[GitHub] [flink] Tom-Goong commented on issue #7799: [FLINK-11613][chinese-translation, Documentation]Translate the "Project Template for Scala" page into Chinese

2019-04-22 Thread GitBox
Tom-Goong commented on issue #7799: [FLINK-11613][chinese-translation,Documentation]Translate the "Project Template for Scala" page into Chinese URL: https://github.com/apache/flink/pull/7799#issuecomment-485609509 Hi @wuchong, sorry, i failed to rebase my commit to the first place. so I'v

[jira] [Updated] (FLINK-12283) Allow non-static inner class as UDF

2019-04-22 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-12283: --- Summary: Allow non-static inner class as UDF (was: Allow non-static inner UDF) > Allow non-static

[jira] [Updated] (FLINK-12283) Allow non-static inner UDF

2019-04-22 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-12283: --- Summary: Allow non-static inner UDF (was: Allow non static UDF) > Allow non-static inner UDF >

[jira] [Commented] (FLINK-12283) Allow non-static inner UDF

2019-04-22 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16823603#comment-16823603 ] Jeff Zhang commented on FLINK-12283: Thanks [~phoenixjiangnan], I have updated the t

[GitHub] [flink] bowenli86 commented on issue #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module

2019-04-22 Thread GitBox
bowenli86 commented on issue #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module URL: https://github.com/apache/flink/pull/8205#issuecomment-485588196 @zentol @twalthr @KurtYoung @wuchong Can you please help t

[GitHub] [flink] gauravtiwari89 commented on a change in pull request #8220: [FLINK-12259][flink-clients]Improve debuggability of method invocatio…

2019-04-22 Thread GitBox
gauravtiwari89 commented on a change in pull request #8220: [FLINK-12259][flink-clients]Improve debuggability of method invocatio… URL: https://github.com/apache/flink/pull/8220#discussion_r277444942 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/Optimize

[GitHub] [flink] art4ul commented on a change in pull request #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types

2019-04-22 Thread GitBox
art4ul commented on a change in pull request #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types URL: https://github.com/apache/flink/pull/8179#discussion_r277435848 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/Log

[GitHub] [flink] art4ul commented on a change in pull request #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types

2019-04-22 Thread GitBox
art4ul commented on a change in pull request #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types URL: https://github.com/apache/flink/pull/8179#discussion_r277435909 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/Log

[jira] [Commented] (FLINK-12283) Allow non static UDF

2019-04-22 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16823357#comment-16823357 ] Bowen Li commented on FLINK-12283: -- Should the title be "Allow non-static inner class a

[jira] [Comment Edited] (FLINK-12283) Allow non static UDF

2019-04-22 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16823357#comment-16823357 ] Bowen Li edited comment on FLINK-12283 at 4/22/19 7:15 PM: --- Sh

[GitHub] [flink] KurtYoung commented on a change in pull request #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types

2019-04-22 Thread GitBox
KurtYoung commented on a change in pull request #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types URL: https://github.com/apache/flink/pull/8179#discussion_r277284753 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/util/ExplodeFu

[GitHub] [flink] KurtYoung commented on a change in pull request #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types

2019-04-22 Thread GitBox
KurtYoung commented on a change in pull request #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types URL: https://github.com/apache/flink/pull/8179#discussion_r277284602 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/

[GitHub] [flink] KurtYoung commented on a change in pull request #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types

2019-04-22 Thread GitBox
KurtYoung commented on a change in pull request #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types URL: https://github.com/apache/flink/pull/8179#discussion_r277284678 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/

[GitHub] [flink] KurtYoung commented on a change in pull request #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types

2019-04-22 Thread GitBox
KurtYoung commented on a change in pull request #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types URL: https://github.com/apache/flink/pull/8179#discussion_r277284544 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/

[GitHub] [flink] KurtYoung commented on a change in pull request #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types

2019-04-22 Thread GitBox
KurtYoung commented on a change in pull request #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types URL: https://github.com/apache/flink/pull/8179#discussion_r277284447 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/

[GitHub] [flink] KurtYoung commented on a change in pull request #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types

2019-04-22 Thread GitBox
KurtYoung commented on a change in pull request #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types URL: https://github.com/apache/flink/pull/8179#discussion_r277285495 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/util/ExplodeFu

[jira] [Assigned] (FLINK-11634) Translate "State Backends" page into Chinese

2019-04-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-11634: --- Assignee: (was: Jark Wu) > Translate "State Backends" page into Chinese > -

[jira] [Assigned] (FLINK-11636) Translate "State Schema Evolution" into Chinese

2019-04-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-11636: --- Assignee: (was: Jark Wu) > Translate "State Schema Evolution" into Chinese > --

[jira] [Assigned] (FLINK-11634) Translate "State Backends" page into Chinese

2019-04-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-11634: --- Assignee: Jark Wu > Translate "State Backends" page into Chinese >

[jira] [Assigned] (FLINK-11637) Translate "Checkpoints" page into Chinese

2019-04-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-11637: --- Assignee: (was: Jark Wu) > Translate "Checkpoints" page into Chinese >

[jira] [Assigned] (FLINK-11638) Translate "Savepoints" page into Chinese

2019-04-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-11638: --- Assignee: (was: Jark Wu) > Translate "Savepoints" page into Chinese > -

[jira] [Assigned] (FLINK-11637) Translate "Checkpoints" page into Chinese

2019-04-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-11637: --- Assignee: Jark Wu > Translate "Checkpoints" page into Chinese > ---

[jira] [Assigned] (FLINK-11638) Translate "Savepoints" page into Chinese

2019-04-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-11638: --- Assignee: Jark Wu > Translate "Savepoints" page into Chinese >

[jira] [Assigned] (FLINK-11636) Translate "State Schema Evolution" into Chinese

2019-04-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-11636: --- Assignee: Jark Wu > Translate "State Schema Evolution" into Chinese > -

[jira] [Assigned] (FLINK-11635) Translate "Checkpointing" page into Chinese

2019-04-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-11635: --- Assignee: Jark Wu > Translate "Checkpointing" page into Chinese > -

[jira] [Assigned] (FLINK-11635) Translate "Checkpointing" page into Chinese

2019-04-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-11635: --- Assignee: (was: Jark Wu) > Translate "Checkpointing" page into Chinese > --

[jira] [Updated] (FLINK-11732) Add a language switch to the sidebar for Flink documents

2019-04-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11732: --- Labels: pull-request-available (was: ) > Add a language switch to the sidebar for Flink doc

[GitHub] [flink] wuchong commented on issue #8238: [FLINK-11732] [docs] Add a language switch to the sidebar for Flink documents

2019-04-22 Thread GitBox
wuchong commented on issue #8238: [FLINK-11732] [docs] Add a language switch to the sidebar for Flink documents URL: https://github.com/apache/flink/pull/8238#issuecomment-485405316 Hi @xccui @fhueske , do you have time to have a look at this PR ? --

[GitHub] [flink] flinkbot commented on issue #8238: [FLINK-11732] [docs] Add a language switch to the sidebar for Flink documents

2019-04-22 Thread GitBox
flinkbot commented on issue #8238: [FLINK-11732] [docs] Add a language switch to the sidebar for Flink documents URL: https://github.com/apache/flink/pull/8238#issuecomment-485405256 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] wuchong opened a new pull request #8238: [FLINK-11732] [docs] Add a language switch to the sidebar for Flink documents

2019-04-22 Thread GitBox
wuchong opened a new pull request #8238: [FLINK-11732] [docs] Add a language switch to the sidebar for Flink documents URL: https://github.com/apache/flink/pull/8238 ## What is the purpose of the change Add a language switch to the sidebar for Flink documents. ## Brief cha

[GitHub] [flink] art4ul commented on issue #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types

2019-04-22 Thread GitBox
art4ul commented on issue #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types URL: https://github.com/apache/flink/pull/8179#issuecomment-485403604 @KurtYoung @JingsongLi Could you please review this pull request or connect to guys who responsible for this component? Thanks in ad

[GitHub] [flink] flinkbot commented on issue #8237: [FLINK-12290][flink-runtime]Fix the misleading exception message in S…

2019-04-22 Thread GitBox
flinkbot commented on issue #8237: [FLINK-12290][flink-runtime]Fix the misleading exception message in S… URL: https://github.com/apache/flink/pull/8237#issuecomment-485403508 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

  1   2   >