[jira] [Commented] (FLINK-10724) Refactor failure handling in check point coordinator

2018-12-10 Thread Yun Tang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715194#comment-16715194 ] Yun Tang commented on FLINK-10724: -- [~yanghua] I think CheckpointSubsumed should not be counted as

[jira] [Commented] (FLINK-11041) ReinterpretDataStreamAsKeyedStreamITCase.testReinterpretAsKeyedStream failed on Travis

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715174#comment-16715174 ] ASF GitHub Bot commented on FLINK-11041: StefanRRichter opened a new pull request #7268:

[jira] [Updated] (FLINK-11041) ReinterpretDataStreamAsKeyedStreamITCase.testReinterpretAsKeyedStream failed on Travis

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11041: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] StefanRRichter opened a new pull request #7268: [FLINK-11041][test] ReinterpretDataStreamAsKeyedStreamITCase source s…

2018-12-10 Thread GitBox
StefanRRichter opened a new pull request #7268: [FLINK-11041][test] ReinterpretDataStreamAsKeyedStreamITCase source s… URL: https://github.com/apache/flink/pull/7268 ## What is the purpose of the change This test fixes the flaky behavior of

[GitHub] walterddr commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

2018-12-10 Thread GitBox
walterddr commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#discussion_r240322027 ## File path:

[GitHub] walterddr commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

2018-12-10 Thread GitBox
walterddr commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#discussion_r240320208 ## File path:

[jira] [Commented] (FLINK-11074) Improve the harness test to make it possible test with state backend

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715297#comment-16715297 ] ASF GitHub Bot commented on FLINK-11074: walterddr commented on a change in pull request #7253:

[jira] [Commented] (FLINK-11074) Improve the harness test to make it possible test with state backend

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715298#comment-16715298 ] ASF GitHub Bot commented on FLINK-11074: walterddr commented on a change in pull request #7253:

[GitHub] walterddr commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

2018-12-10 Thread GitBox
walterddr commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#discussion_r240321103 ## File path:

[GitHub] azagrebin commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead…

2018-12-10 Thread GitBox
azagrebin commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead… URL: https://github.com/apache/flink/pull/7255#discussion_r240313527 ## File path:

[GitHub] azagrebin commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead…

2018-12-10 Thread GitBox
azagrebin commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead… URL: https://github.com/apache/flink/pull/7255#discussion_r240310923 ## File path:

[GitHub] azagrebin commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead…

2018-12-10 Thread GitBox
azagrebin commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead… URL: https://github.com/apache/flink/pull/7255#discussion_r240312767 ## File path:

[GitHub] azagrebin commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead…

2018-12-10 Thread GitBox
azagrebin commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead… URL: https://github.com/apache/flink/pull/7255#discussion_r240321678 ## File path:

[GitHub] azagrebin commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead…

2018-12-10 Thread GitBox
azagrebin commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead… URL: https://github.com/apache/flink/pull/7255#discussion_r240311956 ## File path:

[jira] [Commented] (FLINK-10945) Avoid resource deadlocks for finite stream jobs when resources are limited

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715277#comment-16715277 ] ASF GitHub Bot commented on FLINK-10945: azagrebin commented on a change in pull request #7255:

[jira] [Commented] (FLINK-10945) Avoid resource deadlocks for finite stream jobs when resources are limited

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715278#comment-16715278 ] ASF GitHub Bot commented on FLINK-10945: azagrebin commented on a change in pull request #7255:

[jira] [Commented] (FLINK-10945) Avoid resource deadlocks for finite stream jobs when resources are limited

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715276#comment-16715276 ] ASF GitHub Bot commented on FLINK-10945: azagrebin commented on a change in pull request #7255:

[jira] [Commented] (FLINK-10945) Avoid resource deadlocks for finite stream jobs when resources are limited

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715275#comment-16715275 ] ASF GitHub Bot commented on FLINK-10945: azagrebin commented on a change in pull request #7255:

[jira] [Commented] (FLINK-10945) Avoid resource deadlocks for finite stream jobs when resources are limited

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715279#comment-16715279 ] ASF GitHub Bot commented on FLINK-10945: azagrebin commented on a change in pull request #7255:

[jira] [Commented] (FLINK-11074) Improve the harness test to make it possible test with state backend

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715299#comment-16715299 ] ASF GitHub Bot commented on FLINK-11074: walterddr commented on a change in pull request #7253:

[jira] [Comment Edited] (FLINK-11070) Add stream-stream non-window cross join

2018-12-10 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715884#comment-16715884 ] Hequn Cheng edited comment on FLINK-11070 at 12/11/18 1:06 AM: --- [~fhueske]

[jira] [Commented] (FLINK-11039) LogicalExchange and HashPartitioner realization

2018-12-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715635#comment-16715635 ] Fabian Hueske commented on FLINK-11039: --- Hi [~ambition], I still don't understand the purpose of

[jira] [Commented] (FLINK-10974) Add FlatMap to TableAPI

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715703#comment-16715703 ] ASF GitHub Bot commented on FLINK-10974: sunjincheng121 commented on issue #7196: [FLINK-10974]

[GitHub] sunjincheng121 commented on issue #7196: [FLINK-10974] [table] Add support for flatMap to table API

2018-12-10 Thread GitBox
sunjincheng121 commented on issue #7196: [FLINK-10974] [table] Add support for flatMap to table API URL: https://github.com/apache/flink/pull/7196#issuecomment-446002606 Thanks for the update! @dianfu LGTM. +1 to merged

[GitHub] sunjincheng121 opened a new pull request #7269: [FLINK-11123][docs] fix the import of the class is missing in ml quic…

2018-12-10 Thread GitBox
sunjincheng121 opened a new pull request #7269: [FLINK-11123][docs] fix the import of the class is missing in ml quic… URL: https://github.com/apache/flink/pull/7269 ## What is the purpose of the change *This PR fix the import of the class is missing in ml quick start document.*

[jira] [Updated] (FLINK-11123) Improve ml quick start doc

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11123: --- Labels: pull-request-available (was: ) > Improve ml quick start doc >

[jira] [Commented] (FLINK-11123) Improve ml quick start doc

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715871#comment-16715871 ] ASF GitHub Bot commented on FLINK-11123: sunjincheng121 opened a new pull request #7269:

[jira] [Created] (FLINK-11123) Improve ml quick start doc

2018-12-10 Thread sunjincheng (JIRA)
sunjincheng created FLINK-11123: --- Summary: Improve ml quick start doc Key: FLINK-11123 URL: https://issues.apache.org/jira/browse/FLINK-11123 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-11117) Migrate connector classes to flink-table-spi

2018-12-10 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716330#comment-16716330 ] Timo Walther commented on FLINK-7: -- [~yanghua] This issue is a duplicate of FLINK-10688. >

[jira] [Commented] (FLINK-10774) connection leak when partition discovery is disabled and open throws exception

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716328#comment-16716328 ] ASF GitHub Bot commented on FLINK-10774: stevenzwu commented on issue #7020: [FLINK-10774]

[jira] [Commented] (FLINK-11081) Support binding port range for REST server

2018-12-10 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716331#comment-16716331 ] vinoyang commented on FLINK-11081: -- [~walterddr]  Thank you for recognizing the value of this issue. In

[GitHub] samsai commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-10 Thread GitBox
samsai commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-446041717 i got the same problem too: val format = new SimpleDateFormat("-MM-dd HH:mm:ssZ") val

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715949#comment-16715949 ] ASF GitHub Bot commented on FLINK-11010: samsai commented on issue #7180: [FLINK-11010] [TABLE]

[jira] [Commented] (FLINK-11070) Add stream-stream non-window cross join

2018-12-10 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716015#comment-16716015 ] Hequn Cheng commented on FLINK-11070: - [~fhueske] Thanks for your quick reply! Ok, I got your

[jira] [Created] (FLINK-11124) Add private[flink] to TemporalTableFunction.create()

2018-12-10 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-11124: --- Summary: Add private[flink] to TemporalTableFunction.create() Key: FLINK-11124 URL: https://issues.apache.org/jira/browse/FLINK-11124 Project: Flink Issue

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

2018-12-10 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716101#comment-16716101 ] sunjincheng commented on FLINK-10543: - Hi [~fhueske] from the point of compatibility I agree this

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

2018-12-10 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716116#comment-16716116 ] Hequn Cheng commented on FLINK-10543: - [~fhueske] Hi, would be nice if you can take a look at the

[jira] [Created] (FLINK-11125) Remove useless import

2018-12-10 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-11125: --- Summary: Remove useless import Key: FLINK-11125 URL: https://issues.apache.org/jira/browse/FLINK-11125 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-10943) Flink runtime test failed caused by curator dependency conflicts

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716150#comment-16716150 ] ASF GitHub Bot commented on FLINK-10943: link3280 closed pull request #7148:

[jira] [Commented] (FLINK-11090) Unused parameter in WindowedStream.aggregate()

2018-12-10 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716146#comment-16716146 ] Hequn Cheng commented on FLINK-11090: - Hi [~aljoscha] thanks for telling the differences between

[jira] [Commented] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716154#comment-16716154 ] ASF GitHub Bot commented on FLINK-11048: tweise commented on a change in pull request #7249:

[GitHub] tweise commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

2018-12-10 Thread GitBox
tweise commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r240470550 ## File path:

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716215#comment-16716215 ] ASF GitHub Bot commented on FLINK-9083: --- jparkie commented on a change in pull request #6782:

[GitHub] jparkie commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

2018-12-10 Thread GitBox
jparkie commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r240476864 ## File path:

[jira] [Commented] (FLINK-11060) Unable to set number of task manager and slot per task manager in scala shell local mode

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716285#comment-16716285 ] ASF GitHub Bot commented on FLINK-11060: zjffdu commented on issue #7229:

[GitHub] zjffdu commented on issue #6236: [FLINK-9699] [table] Add api to replace registered table

2018-12-10 Thread GitBox
zjffdu commented on issue #6236: [FLINK-9699] [table] Add api to replace registered table URL: https://github.com/apache/flink/pull/6236#issuecomment-446082836 @hequn8128 @yanghua PR is updated, could you help review it ? Thanks

[GitHub] stevenzwu commented on issue #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an…

2018-12-10 Thread GitBox
stevenzwu commented on issue #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an… URL: https://github.com/apache/flink/pull/7020#issuecomment-446086480 @tillrohrmann Thanks a lot for the feedbacks. I made the changes according to your comments. please take

[GitHub] tzulitai commented on issue #7270: [hotfix][docs] Fix typo in Joining documentation

2018-12-10 Thread GitBox
tzulitai commented on issue #7270: [hotfix][docs] Fix typo in Joining documentation URL: https://github.com/apache/flink/pull/7270#issuecomment-446090988 LGTM, merging. This is an automated message from the Apache Git

[jira] [Updated] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-10 Thread lamber-ken (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-11010: --- Affects Version/s: 1.8.0 > Flink SQL timestamp is inconsistent with currentProcessingTime() >

[jira] [Updated] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-10 Thread lamber-ken (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-11010: --- Affects Version/s: 1.7.1 1.7.0 > Flink SQL timestamp is inconsistent with

[GitHub] zzchun opened a new pull request #7270: [hotfix][docs] Fix typo in Joining documentation

2018-12-10 Thread GitBox
zzchun opened a new pull request #7270: [hotfix][docs] Fix typo in Joining documentation URL: https://github.com/apache/flink/pull/7270 ## What is the purpose of the change Fix typo in Joining documentation ## Verifying this change This change is a trivial rework /

[GitHub] hequn8128 opened a new pull request #7271: [FLINK-11124][table] Add private[flink] to TemporalTableFunction.create() method

2018-12-10 Thread GitBox
hequn8128 opened a new pull request #7271: [FLINK-11124][table] Add private[flink] to TemporalTableFunction.create() method URL: https://github.com/apache/flink/pull/7271 ## What is the purpose of the change This pull request adds `private[flink]` to

[jira] [Commented] (FLINK-11124) Add private[flink] to TemporalTableFunction.create()

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716152#comment-16716152 ] ASF GitHub Bot commented on FLINK-11124: hequn8128 opened a new pull request #7271:

[jira] [Updated] (FLINK-11124) Add private[flink] to TemporalTableFunction.create()

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11124: --- Labels: pull-request-available (was: ) > Add private[flink] to

[jira] [Commented] (FLINK-11081) Support binding port range for REST server

2018-12-10 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716173#comment-16716173 ] Rong Rong commented on FLINK-11081: --- +1 to this feature. Very helpful actually for lots of our use

[jira] [Closed] (FLINK-11039) LogicalExchange and HashPartitioner realization

2018-12-10 Thread ambition (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ambition closed FLINK-11039. Resolution: Fixed > LogicalExchange and HashPartitioner realization >

[GitHub] ambition119 closed pull request #7202: [FLINK-11039] LogicalExchange and HashPartitioner realization

2018-12-10 Thread GitBox
ambition119 closed pull request #7202: [FLINK-11039] LogicalExchange and HashPartitioner realization URL: https://github.com/apache/flink/pull/7202 This is an automated message from the Apache Git Service. To respond to

[jira] [Commented] (FLINK-11039) LogicalExchange and HashPartitioner realization

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716238#comment-16716238 ] ASF GitHub Bot commented on FLINK-11039: ambition119 closed pull request #7202: [FLINK-11039]

[jira] [Commented] (FLINK-11125) Remove useless import

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716317#comment-16716317 ] ASF GitHub Bot commented on FLINK-11125: hequn8128 opened a new pull request #7272:

[jira] [Commented] (FLINK-11117) Migrate connector classes to flink-table-spi

2018-12-10 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716333#comment-16716333 ] vinoyang commented on FLINK-7: -- [~twalthr] oh, sorry, I will close it. > Migrate connector classes

[jira] [Closed] (FLINK-11117) Migrate connector classes to flink-table-spi

2018-12-10 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang closed FLINK-7. Resolution: Duplicate > Migrate connector classes to flink-table-spi >

[jira] [Updated] (FLINK-11118) Refactor and unify rowtime timestamp extractor interface

2018-12-10 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-8: - Issue Type: Task (was: Sub-task) Parent: (was: FLINK-7) > Refactor and unify rowtime

[GitHub] dianfu commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

2018-12-10 Thread GitBox
dianfu commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#discussion_r240445274 ## File path:

[GitHub] dianfu commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

2018-12-10 Thread GitBox
dianfu commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#discussion_r240445604 ## File path:

[jira] [Commented] (FLINK-11074) Improve the harness test to make it possible test with state backend

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715934#comment-16715934 ] ASF GitHub Bot commented on FLINK-11074: dianfu commented on a change in pull request #7253:

[jira] [Commented] (FLINK-11074) Improve the harness test to make it possible test with state backend

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715933#comment-16715933 ] ASF GitHub Bot commented on FLINK-11074: dianfu commented on a change in pull request #7253:

[GitHub] dianfu commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

2018-12-10 Thread GitBox
dianfu commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#discussion_r240445308 ## File path:

[jira] [Commented] (FLINK-11123) Improve ml quick start doc

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716125#comment-16716125 ] ASF GitHub Bot commented on FLINK-11123: asfgit closed pull request #7269: [FLINK-11123][docs]

[GitHub] asfgit closed pull request #7269: [FLINK-11123][docs] fix the import of the class is missing in ml quic…

2018-12-10 Thread GitBox
asfgit closed pull request #7269: [FLINK-11123][docs] fix the import of the class is missing in ml quic… URL: https://github.com/apache/flink/pull/7269 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[GitHub] tweise commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

2018-12-10 Thread GitBox
tweise commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r240470721 ## File path:

[jira] [Commented] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716158#comment-16716158 ] ASF GitHub Bot commented on FLINK-11048: tweise commented on a change in pull request #7249:

[jira] [Closed] (FLINK-11123) Improve ml quick start doc

2018-12-10 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11123. --- Resolution: Fixed Fix Version/s: 1.6.3 Fixed in master:

[GitHub] ramkrish86 commented on issue #3334: FLINK-4810 Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints

2018-12-10 Thread GitBox
ramkrish86 commented on issue #3334: FLINK-4810 Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints URL: https://github.com/apache/flink/pull/3334#issuecomment-446070175 @azagrebin - Thanks for the ping. Currently am not working on this. Pls feel free to

[jira] [Commented] (FLINK-4810) Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716171#comment-16716171 ] ASF GitHub Bot commented on FLINK-4810: --- ramkrish86 commented on issue #3334: FLINK-4810 Checkpoint

[jira] [Commented] (FLINK-11125) Remove useless import

2018-12-10 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716274#comment-16716274 ] TisonKun commented on FLINK-11125: -- @[~hequn8128] If the change is not big, it might be satisfied in a

[GitHub] zjffdu commented on issue #7229: [FLINK-11060][scala-shell] Unable to set number of task manager and slot per task manager in scala shell local mode

2018-12-10 Thread GitBox
zjffdu commented on issue #7229: [FLINK-11060][scala-shell] Unable to set number of task manager and slot per task manager in scala shell local mode URL: https://github.com/apache/flink/pull/7229#issuecomment-446082679 @yanghua @tillrohrmann Could you help review it ? Thanks

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716320#comment-16716320 ] ASF GitHub Bot commented on FLINK-11010: lamber-ken commented on a change in pull request #7180:

[GitHub] lamber-ken commented on a change in pull request #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-10 Thread GitBox
lamber-ken commented on a change in pull request #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#discussion_r240484482 ## File path:

[jira] [Commented] (FLINK-9699) Add api to replace registered table

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716286#comment-16716286 ] ASF GitHub Bot commented on FLINK-9699: --- zjffdu commented on issue #6236: [FLINK-9699] [table] Add

[jira] [Commented] (FLINK-10964) sql-client throws exception when paging through finished batch query

2018-12-10 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716340#comment-16716340 ] vinoyang commented on FLINK-10964: -- [~twalthr] when you have time, can you help to review the PR of

[jira] [Comment Edited] (FLINK-10964) sql-client throws exception when paging through finished batch query

2018-12-10 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716340#comment-16716340 ] vinoyang edited comment on FLINK-10964 at 12/11/18 6:36 AM: [~twalthr] when

[jira] [Commented] (FLINK-10724) Refactor failure handling in check point coordinator

2018-12-10 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716352#comment-16716352 ] vinoyang commented on FLINK-10724: -- [~yunta] From the source code point of view {{abortSubsumed}}, the

[GitHub] liu-zhaokun commented on issue #7257: [FLINK-11089]Log filecache directory removed messages

2018-12-10 Thread GitBox
liu-zhaokun commented on issue #7257: [FLINK-11089]Log filecache directory removed messages URL: https://github.com/apache/flink/pull/7257#issuecomment-446037623 @tillrohrmann Hi,are you available to help me to review this PR? Thanks! Look forwards to your reply.

[jira] [Commented] (FLINK-11089) Log filecache directory removed messages

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715910#comment-16715910 ] ASF GitHub Bot commented on FLINK-11089: liu-zhaokun commented on issue #7257: [FLINK-11089]Log

[jira] [Commented] (FLINK-11074) Improve the harness test to make it possible test with state backend

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715932#comment-16715932 ] ASF GitHub Bot commented on FLINK-11074: dianfu commented on a change in pull request #7253:

[jira] [Commented] (FLINK-10566) Flink Planning is exponential in the number of stages

2018-12-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715937#comment-16715937 ] Fabian Hueske commented on FLINK-10566: --- Hmmm, true. The stack trace was taken during a recursive

[jira] [Commented] (FLINK-11070) Add stream-stream non-window cross join

2018-12-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715954#comment-16715954 ] Fabian Hueske commented on FLINK-11070: --- Hmmm, I'm hesitant to enable cross joins by default. It

[jira] [Commented] (FLINK-10543) Leverage efficient timer deletion in relational operators

2018-12-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716027#comment-16716027 ] Fabian Hueske commented on FLINK-10543: --- Hi [~sunjincheng121], [~hequn8128], I had a quick look at

[GitHub] walterddr commented on a change in pull request #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-10 Thread GitBox
walterddr commented on a change in pull request #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#discussion_r240470904 ## File path:

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716164#comment-16716164 ] ASF GitHub Bot commented on FLINK-11010: walterddr commented on a change in pull request #7180:

[jira] [Commented] (FLINK-11070) Add stream-stream non-window cross join

2018-12-10 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715884#comment-16715884 ] Hequn Cheng commented on FLINK-11070: - [~fhueske] Hi, thanks for the feedback and sharing the

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716020#comment-16716020 ] ASF GitHub Bot commented on FLINK-11010: lamber-ken commented on issue #7180: [FLINK-11010]

[GitHub] lamber-ken commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

2018-12-10 Thread GitBox
lamber-ken commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-446050898 hi, @zentol cc This is an

[GitHub] link3280 closed pull request #7148: [FLINK-10943][tests] Fix test failures in flink runtime caused by curator dependency conflicts

2018-12-10 Thread GitBox
link3280 closed pull request #7148: [FLINK-10943][tests] Fix test failures in flink runtime caused by curator dependency conflicts URL: https://github.com/apache/flink/pull/7148 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed

[jira] [Commented] (FLINK-10943) Flink runtime test failed caused by curator dependency conflicts

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16716149#comment-16716149 ] ASF GitHub Bot commented on FLINK-10943: link3280 commented on issue #7148: [FLINK-10943][tests]

[GitHub] link3280 commented on issue #7148: [FLINK-10943][tests] Fix test failures in flink runtime caused by curator dependency conflicts

2018-12-10 Thread GitBox
link3280 commented on issue #7148: [FLINK-10943][tests] Fix test failures in flink runtime caused by curator dependency conflicts URL: https://github.com/apache/flink/pull/7148#issuecomment-446068042 @tillrohrmann Thanks for your review. You're right, it's caused by the relocation problem

[jira] [Closed] (FLINK-10943) Flink runtime test failed caused by curator dependency conflicts

2018-12-10 Thread Paul Lin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin closed FLINK-10943. Resolution: Not A Bug > Flink runtime test failed caused by curator dependency conflicts >

[jira] [Created] (FLINK-11126) Filter out AMRMToken in the TaskManager credentials

2018-12-10 Thread Paul Lin (JIRA)
Paul Lin created FLINK-11126: Summary: Filter out AMRMToken in the TaskManager credentials Key: FLINK-11126 URL: https://issues.apache.org/jira/browse/FLINK-11126 Project: Flink Issue Type:

[GitHub] hequn8128 opened a new pull request #7272: [FLINK-11125] remove unused import

2018-12-10 Thread GitBox
hequn8128 opened a new pull request #7272: [FLINK-11125] remove unused import URL: https://github.com/apache/flink/pull/7272 ## What is the purpose of the change This pull request removes some unused imports in tests and flink-table. ## Brief change log -

[jira] [Updated] (FLINK-11125) Remove useless import

2018-12-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11125: --- Labels: pull-request-available (was: ) > Remove useless import > -- >

  1   2   3   >