[jira] [Created] (FLINK-12352) [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with default ShuffleService and NetworkStack

Jiangjie Qin created FLINK-12352: Summary: [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with default ShuffleService and NetworkStack Key: FLINK-12352 URL:

[jira] [Updated] (FLINK-12352) [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with default ShuffleService and NetworkStack

[ https://issues.apache.org/jira/browse/FLINK-12352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-12352: - Fix Version/s: 1.9.0 > [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with

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

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827806#comment-16827806 ] Congxian Qiu(klion26) edited comment on FLINK-12296 at 4/28/19 4:44 AM:

[GitHub] [flink] klion26 commented on issue #8164: [FLINK-12184] history server compatible with old version

klion26 commented on issue #8164: [FLINK-12184] history server compatible with old version URL: https://github.com/apache/flink/pull/8164#issuecomment-487343113 @tillrohrmann thanks for your remind. @yumengz5 if you do not mind, I can take over this.

[GitHub] [flink] klion26 edited a comment on issue #8263: [FLINK-12296][StateBackend]Data loss silently in RocksDBStateBackend because of local directory collision

klion26 edited a comment on issue #8263: [FLINK-12296][StateBackend]Data loss silently in RocksDBStateBackend because of local directory collision URL: https://github.com/apache/flink/pull/8263#issuecomment-487342945 @StefanRRichter thanks for your review and advice, I've just adjusted the

[GitHub] [flink] klion26 commented on issue #8263: [FLINK-12296][StateBackend]Data loss silently in RocksDBStateBackend because of local directory collision

klion26 commented on issue #8263: [FLINK-12296][StateBackend]Data loss silently in RocksDBStateBackend because of local directory collision URL: https://github.com/apache/flink/pull/8263#issuecomment-487342945 @StefanRRichter as discussed offline, I've just adjusted the change and added a

[jira] [Updated] (FLINK-12333) Add documentation for all async operations through REST

[ https://issues.apache.org/jira/browse/FLINK-12333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-12333: - Summary: Add documentation for all async operations through REST (was: Add documentation around save

[jira] [Commented] (FLINK-12333) Add documentation around save point with cancel lifecycle through REST

[ https://issues.apache.org/jira/browse/FLINK-12333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827811#comment-16827811 ] Yun Tang commented on FLINK-12333: -- Actually, not only triggering savepoint operation, other operations

[jira] [Updated] (FLINK-12350) RocksDBStateBackendTest doesn't cover the incremental checkpoint code path

[ https://issues.apache.org/jira/browse/FLINK-12350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12350: --- Labels: pull-request-available (was: ) > RocksDBStateBackendTest doesn't cover the

[GitHub] [flink] flinkbot commented on issue #8297: [FLINK-12350] [State Backends] RocksDBStateBackendTest doesn't cover the incremental checkpoint code path

flinkbot commented on issue #8297: [FLINK-12350] [State Backends] RocksDBStateBackendTest doesn't cover the incremental checkpoint code path URL: https://github.com/apache/flink/pull/8297#issuecomment-487340509 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] carp84 opened a new pull request #8297: [FLINK-12350] [State Backends] RocksDBStateBackendTest doesn't cover the incremental checkpoint code path

carp84 opened a new pull request #8297: [FLINK-12350] [State Backends] RocksDBStateBackendTest doesn't cover the incremental checkpoint code path URL: https://github.com/apache/flink/pull/8297 ## What is the purpose of the change Fix `RocksDBStateBackendTest` to cover the

[GitHub] [flink] zhuzhurk commented on a change in pull request #8233: [FLINK-12227] [runtime] introduce SchedulingStrategy interface

zhuzhurk commented on a change in pull request #8233: [FLINK-12227] [runtime] introduce SchedulingStrategy interface URL: https://github.com/apache/flink/pull/8233#discussion_r279176101 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #8233: [FLINK-12227] [runtime] introduce SchedulingStrategy interface

zhuzhurk commented on a change in pull request #8233: [FLINK-12227] [runtime] introduce SchedulingStrategy interface URL: https://github.com/apache/flink/pull/8233#discussion_r279176271 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #8233: [FLINK-12227] [runtime] introduce SchedulingStrategy interface

zhuzhurk commented on a change in pull request #8233: [FLINK-12227] [runtime] introduce SchedulingStrategy interface URL: https://github.com/apache/flink/pull/8233#discussion_r279176066 ## File path:

[jira] [Created] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

Jark Wu created FLINK-12351: --- Summary: AsyncWaitOperator should deep copy StreamElement when object reuse is enabled Key: FLINK-12351 URL: https://issues.apache.org/jira/browse/FLINK-12351 Project: Flink

[jira] [Commented] (FLINK-12350) RocksDBStateBackendTest doesn't cover the incremental checkpoint code path

[ https://issues.apache.org/jira/browse/FLINK-12350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827807#comment-16827807 ] Yu Li commented on FLINK-12350: --- This issue is discovered during test of FLINK-12296 and thanks [~klion26]

[jira] [Created] (FLINK-12350) RocksDBStateBackendTest doesn't cover the incremental checkpoint code path

Yu Li created FLINK-12350: - Summary: RocksDBStateBackendTest doesn't cover the incremental checkpoint code path Key: FLINK-12350 URL: https://issues.apache.org/jira/browse/FLINK-12350 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827806#comment-16827806 ] Congxian Qiu(klion26) commented on FLINK-12296: --- After discussed offline with [~srichter],

[GitHub] [flink] JingsongLi commented on a change in pull request #8295: [FLINK-11974][runtime] Introduce StreamOperatorFactory

JingsongLi commented on a change in pull request #8295: [FLINK-11974][runtime] Introduce StreamOperatorFactory URL: https://github.com/apache/flink/pull/8295#discussion_r279175759 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #8295: [FLINK-11974][runtime] Introduce StreamOperatorFactory

JingsongLi commented on a change in pull request #8295: [FLINK-11974][runtime] Introduce StreamOperatorFactory URL: https://github.com/apache/flink/pull/8295#discussion_r279175823 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #8295: [FLINK-11974][runtime] Introduce StreamOperatorFactory

JingsongLi commented on a change in pull request #8295: [FLINK-11974][runtime] Introduce StreamOperatorFactory URL: https://github.com/apache/flink/pull/8295#discussion_r279175804 ## File path:

[jira] [Updated] (FLINK-12349) invalid

[ https://issues.apache.org/jira/browse/FLINK-12349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu updated FLINK-12349: --- Summary: invalid (was: [Java] Improve performance of BaseValueVector#getValidityBufferSizeFromCount) >

[jira] [Updated] (FLINK-12349) [Java] Improve performance of BaseValueVector#getValidityBufferSizeFromCount

[ https://issues.apache.org/jira/browse/FLINK-12349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu updated FLINK-12349: --- Description: (was: Now in _BaseValueVector#getValidityBufferSizeFromCount_ and 

[jira] [Closed] (FLINK-12349) [Java] Improve performance of BaseValueVector#getValidityBufferSizeFromCount

[ https://issues.apache.org/jira/browse/FLINK-12349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu closed FLINK-12349. -- Resolution: Invalid > [Java] Improve performance of BaseValueVector#getValidityBufferSizeFromCount >

[jira] [Created] (FLINK-12349) [Java] Improve performance of BaseValueVector#getValidityBufferSizeFromCount

Ji Liu created FLINK-12349: -- Summary: [Java] Improve performance of BaseValueVector#getValidityBufferSizeFromCount Key: FLINK-12349 URL: https://issues.apache.org/jira/browse/FLINK-12349 Project: Flink

[jira] [Comment Edited] (FLINK-12348) Use TableConfig in api module to replace TableConfig in blink-planner module.

[ https://issues.apache.org/jira/browse/FLINK-12348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827800#comment-16827800 ] Jing Zhang edited comment on FLINK-12348 at 4/28/19 3:09 AM: - IMO,

[GitHub] [flink] shuai-xu opened a new pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy

shuai-xu opened a new pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy URL: https://github.com/apache/flink/pull/8296 ## What is the purpose of the change *This pull request introduces the EAGER scheduling strategy based on the new scheduling

[GitHub] [flink] flinkbot commented on issue #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy

flinkbot commented on issue #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy URL: https://github.com/apache/flink/pull/8296#issuecomment-487337657 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-12228) Implement Eager Scheduling Strategy

[ https://issues.apache.org/jira/browse/FLINK-12228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12228: --- Labels: pull-request-available (was: ) > Implement Eager Scheduling Strategy >

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

[ https://issues.apache.org/jira/browse/FLINK-11638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Forward Xu updated FLINK-11638: --- Description: doc locates in flink/docs/ops/state/savepoints.zh.md (was: doc locates in

[jira] [Commented] (FLINK-12348) Use TableConfig in api module to replace TableConfig in blink-planner module.

[ https://issues.apache.org/jira/browse/FLINK-12348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827800#comment-16827800 ] Jing Zhang commented on FLINK-12348: IMO, `TableConfigOptions` should also exist in API module,

[GitHub] [flink] flinkbot commented on issue #8295: [FLINK-11974][runtime] Introduce StreamOperatorFactory

flinkbot commented on issue #8295: [FLINK-11974][runtime] Introduce StreamOperatorFactory URL: https://github.com/apache/flink/pull/8295#issuecomment-487337407 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] JingsongLi opened a new pull request #8295: [FLINK-11974][runtime] Introduce StreamOperatorFactory

JingsongLi opened a new pull request #8295: [FLINK-11974][runtime] Introduce StreamOperatorFactory URL: https://github.com/apache/flink/pull/8295 ## What is the purpose of the change Introduce StreamOperatorFactory to help table perform the whole Operator CodeGeneration ##

[jira] [Commented] (FLINK-11935) Remove DateTimeUtils pull-in and fix datetime casting problem

[ https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827799#comment-16827799 ] vinoyang commented on FLINK-11935: -- [~walterddr] My thoughts are similar to yours, and I am also

[jira] [Assigned] (FLINK-12307) Support translation from StreamExecWindowJoin to StreamTransformation.

[ https://issues.apache.org/jira/browse/FLINK-12307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang reassigned FLINK-12307: -- Assignee: Jing Zhang > Support translation from StreamExecWindowJoin to

[jira] [Assigned] (FLINK-12348) Use TableConfig in api module to replace TableConfig in blink-planner module.

[ https://issues.apache.org/jira/browse/FLINK-12348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang reassigned FLINK-12348: -- Assignee: Jing Zhang (was: Liya Fan) > Use TableConfig in api module to replace TableConfig

[jira] [Assigned] (FLINK-12348) Use TableConfig in api module to replace TableConfig in blink-planner module.

[ https://issues.apache.org/jira/browse/FLINK-12348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang reassigned FLINK-12348: -- Assignee: Liya Fan (was: Jing Zhang) > Use TableConfig in api module to replace TableConfig

[jira] [Assigned] (FLINK-12348) Use TableConfig in api module to replace TableConfig in blink-planner module.

[ https://issues.apache.org/jira/browse/FLINK-12348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang reassigned FLINK-12348: -- Assignee: Jing Zhang (was: Liya Fan) > Use TableConfig in api module to replace TableConfig

[jira] [Updated] (FLINK-12348) Use TableConfig in api module to replace TableConfig in blink-planner module.

[ https://issues.apache.org/jira/browse/FLINK-12348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-12348: --- Component/s: Table SQL / API > Use TableConfig in api module to replace TableConfig in

[jira] [Updated] (FLINK-12345) Add support for generating optimized logical plan for stream window aggregate

[ https://issues.apache.org/jira/browse/FLINK-12345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12345: --- Description: This issue aims to add support for generating optimized logical plan for stream

[GitHub] [flink] beyond1920 commented on issue #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module.

beyond1920 commented on issue #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module. URL: https://github.com/apache/flink/pull/8294#issuecomment-487336355 `TableConfigOptions` should also exist in API module. But

[jira] [Updated] (FLINK-12348) Use TableConfig in api module to replace TableConfig in blink-planner module.

[ https://issues.apache.org/jira/browse/FLINK-12348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12348: --- Labels: pull-request-available (was: ) > Use TableConfig in api module to replace

[GitHub] [flink] flinkbot commented on issue #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module.

flinkbot commented on issue #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module. URL: https://github.com/apache/flink/pull/8294#issuecomment-487335603 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] beyond1920 opened a new pull request #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module.

beyond1920 opened a new pull request #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module. URL: https://github.com/apache/flink/pull/8294 ## What is the purpose of the change Since TableConfig already moved to API

[jira] [Updated] (FLINK-12348) Use TableConfig in api module to replace TableConfig in blink-planner module.

[ https://issues.apache.org/jira/browse/FLINK-12348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-12348: --- Description: Since TableConfig already moved to API module in

[GitHub] [flink] shuai-xu commented on issue #8117: [FLINK-12115] [filesystems]: Add support for AzureFS

shuai-xu commented on issue #8117: [FLINK-12115] [filesystems]: Add support for AzureFS URL: https://github.com/apache/flink/pull/8117#issuecomment-487335165 @piyushnarang Thanks for your contribution. I have tested your implementation. It can works. However, there are serval potential

[GitHub] [flink] klion26 commented on a change in pull request #8263: [FLINK-12296][StateBackend]Data loss silently in RocksDBStateBackend because of local directory collision

klion26 commented on a change in pull request #8263: [FLINK-12296][StateBackend]Data loss silently in RocksDBStateBackend because of local directory collision URL: https://github.com/apache/flink/pull/8263#discussion_r279174526 ## File path:

[jira] [Assigned] (FLINK-12348) Use TableConfig in api module to replace TableConfig in blink-planner module.

[ https://issues.apache.org/jira/browse/FLINK-12348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan reassigned FLINK-12348: Assignee: Liya Fan > Use TableConfig in api module to replace TableConfig in blink-planner

[GitHub] [flink] flinkbot commented on issue #8293: [FLINK-12347][Table SQL/Runtime]add scala suffix for flink-table-runt…

flinkbot commented on issue #8293: [FLINK-12347][Table SQL/Runtime]add scala suffix for flink-table-runt… URL: https://github.com/apache/flink/pull/8293#issuecomment-487334082 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-12347) flink-table-runtime-blink is missing scala suffix

[ https://issues.apache.org/jira/browse/FLINK-12347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12347: --- Labels: pull-request-available (was: ) > flink-table-runtime-blink is missing scala suffix

[GitHub] [flink] liyafan82 opened a new pull request #8293: [FLINK-12347][Table SQL/Runtime]add scala suffix for flink-table-runt…

liyafan82 opened a new pull request #8293: [FLINK-12347][Table SQL/Runtime]add scala suffix for flink-table-runt… URL: https://github.com/apache/flink/pull/8293 …ime-blink ## What is the purpose of the change Add scala suffix to project flink-table-runtime-blink

[GitHub] [flink] flinkbot edited a comment on issue #8108: [hotfix][DataStream] Remove deprecated config `flushAlways` in StreamConfig

flinkbot edited a comment on issue #8108: [hotfix][DataStream] Remove deprecated config `flushAlways` in StreamConfig URL: https://github.com/apache/flink/pull/8108#issuecomment-479384246 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] link3280 commented on issue #8108: [hotfix][DataStream] Remove deprecated config `flushAlways` in StreamConfig

link3280 commented on issue #8108: [hotfix][DataStream] Remove deprecated config `flushAlways` in StreamConfig URL: https://github.com/apache/flink/pull/8108#issuecomment-487333031 @flinkbot attention @zentol This is an

[GitHub] [flink] wuchong commented on issue #8276: [FLINK-12314] [docs-zh] Translate the "Type Serialization" page into …

wuchong commented on issue #8276: [FLINK-12314] [docs-zh] Translate the "Type Serialization" page into … URL: https://github.com/apache/flink/pull/8276#issuecomment-487332970 @Leev sure, I will review it today. This is

[jira] [Created] (FLINK-12348) Use TableConfig in api module to replace TableConfig in blink-planner module.

Jing Zhang created FLINK-12348: -- Summary: Use TableConfig in api module to replace TableConfig in blink-planner module. Key: FLINK-12348 URL: https://issues.apache.org/jira/browse/FLINK-12348 Project:

[jira] [Assigned] (FLINK-12347) flink-table-runtime-blink is missing scala suffix

[ https://issues.apache.org/jira/browse/FLINK-12347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan reassigned FLINK-12347: Assignee: Liya Fan > flink-table-runtime-blink is missing scala suffix >

[jira] [Updated] (FLINK-12345) Add support for generating optimized logical plan for stream window aggregate

[ https://issues.apache.org/jira/browse/FLINK-12345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12345: --- Description: Add support for generating optimized logical plan for stream window aggregate

[jira] [Updated] (FLINK-12343) Allow set hdfs.replication in Yarn Configuration

[ https://issues.apache.org/jira/browse/FLINK-12343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-12343: -- Summary: Allow set hdfs.replication in Yarn Configuration (was: Allow set hdfs.replication

[jira] [Commented] (FLINK-12343) Allow set hdfs.replication in FlinkYarnSessionCli

[ https://issues.apache.org/jira/browse/FLINK-12343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827782#comment-16827782 ] Zhenqiu Huang commented on FLINK-12343: --- [~rmetzger] I think configuration option should be

[jira] [Updated] (FLINK-10441) Log initial creation of upload directory on INFO

[ https://issues.apache.org/jira/browse/FLINK-10441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10441: - Summary: Log initial creation of upload directory on INFO (was: Don't log warning

[jira] [Closed] (FLINK-10441) Log initial creation of upload directory on INFO

[ https://issues.apache.org/jira/browse/FLINK-10441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10441. Resolution: Fixed Fix Version/s: 1.9.0 master:

[GitHub] [flink] zentol merged pull request #8219: [FLINK-10441]Don't log warning when creating upload directory

zentol merged pull request #8219: [FLINK-10441]Don't log warning when creating upload directory URL: https://github.com/apache/flink/pull/8219 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] bowenli86 edited a comment on issue #8281: [FLINK-12337] [TableSQL/Planner] InsertInto method should configure TableSink

bowenli86 edited a comment on issue #8281: [FLINK-12337] [TableSQL/Planner] InsertInto method should configure TableSink URL: https://github.com/apache/flink/pull/8281#issuecomment-487312328 Agree with @hequn8128 . That's how ANSI SQL supports column list specification in INSERT

[jira] [Closed] (FLINK-12339) Wrong variable name in TopSpeedWindowing example

[ https://issues.apache.org/jira/browse/FLINK-12339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12339. Resolution: Fixed Fix Version/s: 1.9.0 master:

[jira] [Updated] (FLINK-12339) Wrong variable name in TopSpeedWindowing example

[ https://issues.apache.org/jira/browse/FLINK-12339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12339: - Summary: Wrong variable name in TopSpeedWindowing example (was: Modify the wrong

[jira] [Updated] (FLINK-12339) Modify the wrong variable name of topSeed in example

[ https://issues.apache.org/jira/browse/FLINK-12339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12339: - Issue Type: Improvement (was: Test) > Modify the wrong variable name of topSeed in

[jira] [Updated] (FLINK-12339) Modify the wrong variable name of topSeed in example

[ https://issues.apache.org/jira/browse/FLINK-12339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12339: --- Labels: pull-request-available (was: ) > Modify the wrong variable name of topSeed in

[GitHub] [flink] zentol merged pull request #8284: [FLINK-12339][example] Fix variable name

zentol merged pull request #8284: [FLINK-12339][example] Fix variable name URL: https://github.com/apache/flink/pull/8284 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] zentol merged pull request #8291: [hotfix][tests] Replace mock ConsumerRecords with ConsumerRecords.empty

zentol merged pull request #8291: [hotfix][tests] Replace mock ConsumerRecords with ConsumerRecords.empty URL: https://github.com/apache/flink/pull/8291 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] bowenli86 edited a comment on issue #8281: [FLINK-12337] [TableSQL/Planner] InsertInto method should configure TableSink

bowenli86 edited a comment on issue #8281: [FLINK-12337] [TableSQL/Planner] InsertInto method should configure TableSink URL: https://github.com/apache/flink/pull/8281#issuecomment-487312328 Agree with @hequn8128 . Hive supports column list in the similar way. Thanks @art4ul for

[GitHub] [flink] bowenli86 commented on issue #8281: [FLINK-12337] [TableSQL/Planner] InsertInto method should configure TableSink

bowenli86 commented on issue #8281: [FLINK-12337] [TableSQL/Planner] InsertInto method should configure TableSink URL: https://github.com/apache/flink/pull/8281#issuecomment-487312328 Agree with @hequn8128 . Hive supports column list in the similar way. Thanks @art4ul for bringing

[GitHub] [flink] zentol merged pull request #8292: [hotfix][tests] Remove mockito usage in ExecutionGraphTestUtils

zentol merged pull request #8292: [hotfix][tests] Remove mockito usage in ExecutionGraphTestUtils URL: https://github.com/apache/flink/pull/8292 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot commented on issue #8292: [hotfix][tests] Remove mockito usage in ExecutionGraphTestUtils

flinkbot commented on issue #8292: [hotfix][tests] Remove mockito usage in ExecutionGraphTestUtils URL: https://github.com/apache/flink/pull/8292#issuecomment-487304729 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] TisonKun opened a new pull request #8292: [hotfix][tests] Remove mockito usage in ExecutionGraphTestUtils

TisonKun opened a new pull request #8292: [hotfix][tests] Remove mockito usage in ExecutionGraphTestUtils URL: https://github.com/apache/flink/pull/8292 ## What is the purpose of the change Remove mockito usage in ExecutionGraphTestUtils ... along with code clean up in

[GitHub] [flink] flinkbot commented on issue #8291: [hotfix][tests] Replace mock ConsumerRecords with ConsumerRecords.empty

flinkbot commented on issue #8291: [hotfix][tests] Replace mock ConsumerRecords with ConsumerRecords.empty URL: https://github.com/apache/flink/pull/8291#issuecomment-487302941 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] TisonKun opened a new pull request #8291: [hotfix][tests] Replace mock ConsumerRecords with ConsumerRecords.empty

TisonKun opened a new pull request #8291: [hotfix][tests] Replace mock ConsumerRecords with ConsumerRecords.empty URL: https://github.com/apache/flink/pull/8291 ## What is the purpose of the change Replace mock `ConsumerRecords` with `ConsumerRecords.empty` in order to reduce

[jira] [Commented] (FLINK-11935) Remove DateTimeUtils pull-in and fix datetime casting problem

[ https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827666#comment-16827666 ] Rong Rong commented on FLINK-11935: --- I dug a little deeper: I think there are something problematic in

[GitHub] [flink] hequn8128 commented on issue #8228: [FLINK-12271][table] Display input field name list when throw Cannot resolve field exception

hequn8128 commented on issue #8228: [FLINK-12271][table] Display input field name list when throw Cannot resolve field exception URL: https://github.com/apache/flink/pull/8228#issuecomment-487299803 @dawidwys Thanks a lot for the review. I have updated the PR and Travis turns green now.

[jira] [Closed] (FLINK-12344) Remove legacy runtime messages

[ https://issues.apache.org/jira/browse/FLINK-12344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12344. Resolution: Fixed master: cefebf80410821704cbc153615c551f1117d2872 > Remove legacy

[GitHub] [flink] zentol merged pull request #8287: [FLINK-12344][coordinator] Remove legacy runtime messages

zentol merged pull request #8287: [FLINK-12344][coordinator] Remove legacy runtime messages URL: https://github.com/apache/flink/pull/8287 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot commented on issue #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

flinkbot commented on issue #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#issuecomment-487296924 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] StephanEwen opened a new pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

StephanEwen opened a new pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290 ## What is the purpose of the change This PR changes the implementation of the bounded blocking result partitions (batch

[jira] [Updated] (FLINK-12070) Make blocking result partitions consumable multiple times

[ https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12070: --- Labels: pull-request-available (was: ) > Make blocking result partitions consumable

[GitHub] [flink] flinkbot commented on issue #8289: [FLINK-12346][travis][build] Account for timestampts in scala-suffix check

flinkbot commented on issue #8289: [FLINK-12346][travis][build] Account for timestampts in scala-suffix check URL: https://github.com/apache/flink/pull/8289#issuecomment-487293974 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-12346) Scala-suffix check broken on Travis

[ https://issues.apache.org/jira/browse/FLINK-12346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12346: --- Labels: pull-request-available (was: ) > Scala-suffix check broken on Travis >

[GitHub] [flink] zentol opened a new pull request #8289: [FLINK-12346][travis][build] Account for timestampts in scala-suffix check

zentol opened a new pull request #8289: [FLINK-12346][travis][build] Account for timestampts in scala-suffix check URL: https://github.com/apache/flink/pull/8289 ## What is the purpose of the change The scala-suffix check currently does not work on travis since the maven output is

[jira] [Created] (FLINK-12347) flink-table-runtime-blink is missing scala suffix

Chesnay Schepler created FLINK-12347: Summary: flink-table-runtime-blink is missing scala suffix Key: FLINK-12347 URL: https://issues.apache.org/jira/browse/FLINK-12347 Project: Flink

[jira] [Created] (FLINK-12346) Scala-suffix check broken on Travis

Chesnay Schepler created FLINK-12346: Summary: Scala-suffix check broken on Travis Key: FLINK-12346 URL: https://issues.apache.org/jira/browse/FLINK-12346 Project: Flink Issue Type: Bug

[GitHub] [flink] zentol commented on issue #8287: [FLINK-12344][coordinator] Remove legacy runtime messages

zentol commented on issue #8287: [FLINK-12344][coordinator] Remove legacy runtime messages URL: https://github.com/apache/flink/pull/8287#issuecomment-487284975 will merge this one travis is green. This is an automated

[jira] [Updated] (FLINK-12345) Add support for generating optimized logical plan for stream window aggregate

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

[GitHub] [flink] godfreyhe opened a new pull request #8288: [FLINK-12345] [table-planner-blink] Add support for generating optimized logical plan for stream window aggregate

godfreyhe opened a new pull request #8288: [FLINK-12345] [table-planner-blink] Add support for generating optimized logical plan for stream window aggregate URL: https://github.com/apache/flink/pull/8288 ## What is the purpose of the change *Add support for generating optimized

[GitHub] [flink] flinkbot commented on issue #8288: [FLINK-12345] [table-planner-blink] Add support for generating optimized logical plan for stream window aggregate

flinkbot commented on issue #8288: [FLINK-12345] [table-planner-blink] Add support for generating optimized logical plan for stream window aggregate URL: https://github.com/apache/flink/pull/8288#issuecomment-487281798 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Updated] (FLINK-12345) Add support for generating optimized logical plan for stream window aggregate

[ https://issues.apache.org/jira/browse/FLINK-12345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12345: --- Issue Type: New Feature (was: Bug) > Add support for generating optimized logical plan for stream

[jira] [Created] (FLINK-12345) Add support for generating optimized logical plan for stream window aggregate

godfrey he created FLINK-12345: -- Summary: Add support for generating optimized logical plan for stream window aggregate Key: FLINK-12345 URL: https://issues.apache.org/jira/browse/FLINK-12345 Project:

[GitHub] [flink] flinkbot commented on issue #8287: [FLINK-12344][coordinator] Remove legacy runtime messages

flinkbot commented on issue #8287: [FLINK-12344][coordinator] Remove legacy runtime messages URL: https://github.com/apache/flink/pull/8287#issuecomment-487275671 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-12344) Remove legacy runtime messages

[ https://issues.apache.org/jira/browse/FLINK-12344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12344: --- Labels: pull-request-available (was: ) > Remove legacy runtime messages >

[GitHub] [flink] TisonKun opened a new pull request #8287: [FLINK-12344][coordinator] Remove legacy runtime messages

TisonKun opened a new pull request #8287: [FLINK-12344][coordinator] Remove legacy runtime messages URL: https://github.com/apache/flink/pull/8287 ## What is the purpose of the change Remove legacy runtime messages that only used in pre-FLP-6 codebase. ## Verifying this

[jira] [Created] (FLINK-12344) Remove legacy runtime messages

TisonKun created FLINK-12344: Summary: Remove legacy runtime messages Key: FLINK-12344 URL: https://issues.apache.org/jira/browse/FLINK-12344 Project: Flink Issue Type: Sub-task

[GitHub] [flink] Xeli commented on issue #8259: [FLINK-12325][metrics] Fix bug in statsd exporter when using negative values

Xeli commented on issue #8259: [FLINK-12325][metrics] Fix bug in statsd exporter when using negative values URL: https://github.com/apache/flink/pull/8259#issuecomment-487275106 Hi @zentol, I've added Gauge support by checking if the type is (a subclass of) `Numeric`. You

[GitHub] [flink] leesf commented on issue #8227: [FLINK-12180][Tests] Port ExecutionVertexCancelTest to new codebase

leesf commented on issue #8227: [FLINK-12180][Tests] Port ExecutionVertexCancelTest to new codebase URL: https://github.com/apache/flink/pull/8227#issuecomment-487273062 @tillrohrmann Thanks for your review. Rebased and addressed your comments.

  1   2   >