[jira] [Commented] (FLINK-10473) State TTL incremental cleanup using Heap backend key iterator

2018-12-21 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16727261#comment-16727261 ] Hequn Cheng commented on FLINK-10473: - [~karmagyz]  Thank you for sharing your ideas

[jira] [Commented] (FLINK-11139) stream non window join support state ttl

2018-12-21 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16727258#comment-16727258 ] Hequn Cheng commented on FLINK-11139: - [~fhueske] Thanks for the reminder. Yes it wi

[jira] [Commented] (FLINK-11188) Bounded over should not enable state retention time

2018-12-21 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16727251#comment-16727251 ] Hequn Cheng commented on FLINK-11188: - [~fhueske] Hi, thanks for your reply. I think

[jira] [Commented] (FLINK-10076) Upgrade Calcite dependency to 1.18

2018-12-21 Thread xuqianjin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16727202#comment-16727202 ] xuqianjin commented on FLINK-10076: --- hi [~fhueske] Well, thank you very much. Let me v

[jira] [Updated] (FLINK-11120) The bug of timestampadd handles time

2018-12-21 Thread xuqianjin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuqianjin updated FLINK-11120: -- Description: The error occur when {{timestampadd(MINUTE, 1, time '01:00:00')}} is executed: java.lang

[jira] [Commented] (FLINK-11142) Undefined behavior in the conversion from DataStream/DataSet to Table

2018-12-21 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16727187#comment-16727187 ] Hequn Cheng commented on FLINK-11142: - Hi all, thanks for the discussion and valuabl

[jira] [Commented] (FLINK-11208) Decrease build/testing time of modules

2018-12-21 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16727180#comment-16727180 ] vinoyang commented on FLINK-11208: -- Hi [~till.rohrmann] about reducing the time duratio

[jira] [Updated] (FLINK-11142) Undefined behavior in the conversion from DataStream/DataSet to Table

2018-12-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-11142: -- Issue Type: Improvement (was: Bug) > Undefined behavior in the conversion from DataStream/Dat

[GitHub] zicfan commented on issue #7330: [FLINK-11193] [state] repair rocksDb config Covered

2018-12-21 Thread GitBox
zicfan commented on issue #7330: [FLINK-11193] [state] repair rocksDb config Covered URL: https://github.com/apache/flink/pull/7330#issuecomment-449533565 > @zicfan thank you for your contribution, there are some tests failed Recently busy, will solve today Thanks for reminding -

[jira] [Commented] (FLINK-11202) Split log file per job

2018-12-21 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16727156#comment-16727156 ] vinoyang commented on FLINK-11202: -- [~chauncy]  When I finish the documentation, I will

[jira] [Commented] (FLINK-10076) Upgrade Calcite dependency to 1.18

2018-12-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16727154#comment-16727154 ] Fabian Hueske commented on FLINK-10076: --- Calcite 1.18 was just released! > Upgrad

[jira] [Updated] (FLINK-11142) Undefined behavior in the conversion from DataStream/DataSet to Table

2018-12-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-11142: -- Affects Version/s: 1.6.2 > Undefined behavior in the conversion from DataStream/DataSet to Tab

[jira] [Updated] (FLINK-11142) Undefined behavior in the conversion from DataStream/DataSet to Table

2018-12-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-11142: -- Affects Version/s: 1.5.5 > Undefined behavior in the conversion from DataStream/DataSet to Tab

[jira] [Commented] (FLINK-11142) Undefined behavior in the conversion from DataStream/DataSet to Table

2018-12-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16727153#comment-16727153 ] Fabian Hueske commented on FLINK-11142: --- OK, improving the documentation is always

[jira] [Commented] (FLINK-11142) Undefined behavior in the conversion from DataStream/DataSet to Table

2018-12-21 Thread Yangze Guo (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16727150#comment-16727150 ] Yangze Guo commented on FLINK-11142: Hi [~fhueske], Agree with that this is quite e

[jira] [Commented] (FLINK-10473) State TTL incremental cleanup using Heap backend key iterator

2018-12-21 Thread Yangze Guo (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16727145#comment-16727145 ] Yangze Guo commented on FLINK-10473: Hi, [~azagrebin] . I now understand it will wor

[jira] [Commented] (FLINK-11139) stream non window join support state ttl

2018-12-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16727100#comment-16727100 ] Fabian Hueske commented on FLINK-11139: --- Without knowing the details about the joi

[GitHub] yxu-valleytider commented on a change in pull request #6968: [FLINK-4582] [kinesis] Consuming data from DynamoDB streams to flink

2018-12-21 Thread GitBox
yxu-valleytider commented on a change in pull request #6968: [FLINK-4582] [kinesis] Consuming data from DynamoDB streams to flink URL: https://github.com/apache/flink/pull/6968#discussion_r243702564 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/fli

[jira] [Commented] (FLINK-11188) Bounded over should not enable state retention time

2018-12-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16727068#comment-16727068 ] Fabian Hueske commented on FLINK-11188: --- Thanks for creating the issue [~hequn8128

[jira] [Commented] (FLINK-11142) Undefined behavior in the conversion from DataStream/DataSet to Table

2018-12-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16727046#comment-16727046 ] Fabian Hueske commented on FLINK-11142: --- Hi [~karmagyz], I'm not sure if this rea

[jira] [Commented] (FLINK-10473) State TTL incremental cleanup using Heap backend key iterator

2018-12-21 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16727043#comment-16727043 ] Andrey Zagrebin commented on FLINK-10473: - Hi [~karmagyz], what is the problem w

[GitHub] tweise commented on issue #6968: [FLINK-4582] [kinesis] Consuming data from DynamoDB streams to flink

2018-12-21 Thread GitBox
tweise commented on issue #6968: [FLINK-4582] [kinesis] Consuming data from DynamoDB streams to flink URL: https://github.com/apache/flink/pull/6968#issuecomment-449461104 Dependency diff shows the following: ``` < [INFO] | | +- com.fasterxml.jackson.core:jackson-databind:jar:2.6.7

[jira] [Commented] (FLINK-11105) Add a new implementation of the HighAvailabilityServices using etcd

2018-12-21 Thread Shengyang Sha (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16726872#comment-16726872 ] Shengyang Sha commented on FLINK-11105: --- Hi, I'm [~fly_in_gis] 's colleague and pr

[GitHub] Myasuka commented on issue #7009: [FLINK-10712] Support to restore state when using RestartPipelinedRegionStrategy

2018-12-21 Thread GitBox
Myasuka commented on issue #7009: [FLINK-10712] Support to restore state when using RestartPipelinedRegionStrategy URL: https://github.com/apache/flink/pull/7009#issuecomment-449415836 @StefanRRichter Would you please take a look at the new commit? I really appreciate any help you can prov

[jira] [Comment Edited] (FLINK-11162) Provide a rest API to list all logical operators

2018-12-21 Thread lining (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725476#comment-16725476 ] lining edited comment on FLINK-11162 at 12/21/18 2:48 PM: -- [~Ze

[jira] [Commented] (FLINK-11201) flink-test-utils dependency issue

2018-12-21 Thread eugen yushin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16726719#comment-16726719 ] eugen yushin commented on FLINK-11201: -- thx guys for a quick turnaround > flink-te

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

2018-12-21 Thread GitBox
libenchao opened a new pull request #7349: [hotfix] [docs] Fix typo in Joining documentation URL: https://github.com/apache/flink/pull/7349 RT. This is an automated message from the Apache Git Service. To respond to the messa

[GitHub] mxm commented on issue #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

2018-12-21 Thread GitBox
mxm commented on issue #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#issuecomment-449331562 That was a tough one. Thanks for considering all of our comments!

[GitHub] wuxizao commented on issue #7345: [FLINK-11163][tests] Use random port in RestClusterClientTest

2018-12-21 Thread GitBox
wuxizao commented on issue #7345: [FLINK-11163][tests] Use random port in RestClusterClientTest URL: https://github.com/apache/flink/pull/7345#issuecomment-449330409 hi,flink on yarn mode,how to specify jobmanager http ip range(rest.port) --

[GitHub] TisonKun commented on issue #7340: [FLINK-11174] [prometheus] Flink Metrics Prometheus label values supp…

2018-12-21 Thread GitBox
TisonKun commented on issue #7340: [FLINK-11174] [prometheus] Flink Metrics Prometheus label values supp… URL: https://github.com/apache/flink/pull/7340#issuecomment-449320499 @zentol for the future side, Prometheus would still support UTF-8 as above. for current status, [official docum

[GitHub] yxu-valleytider commented on a change in pull request #6968: [FLINK-4582] [kinesis] Consuming data from DynamoDB streams to flink

2018-12-21 Thread GitBox
yxu-valleytider commented on a change in pull request #6968: [FLINK-4582] [kinesis] Consuming data from DynamoDB streams to flink URL: https://github.com/apache/flink/pull/6968#discussion_r243515474 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/fli

[jira] [Commented] (FLINK-10334) Move RetrievableStateStorageHelper out of ZooKeeperStateHandleStore

2018-12-21 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16726535#comment-16726535 ] TisonKun commented on FLINK-10334: -- Hi [~till.rohrmann], I am drafting an overall desig