[jira] [Commented] (FLINK-6966) Add maxParallelism and UIDs to all operators generated by the Table API / SQL

2017-06-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16060425#comment-16060425 ] Jark Wu commented on FLINK-6966: Yes, I agree with you [~sunjincheng121]. > Add maxParallelism and UIDs

[jira] [Commented] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16060404#comment-16060404 ] ASF GitHub Bot commented on FLINK-6649: --- Github user sunjincheng121 commented on the issue:

[GitHub] flink issue #4157: [FLINK-6649][table]Improve Non-window group aggregate wit...

2017-06-22 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4157 I have update the PR. The change is Move setAggregationResults from processElement method to onTimer method. Benefits are: * Reduce the delay. * Reduce row copy. Welcome

[jira] [Created] (FLINK-6992) add support for IN, NOT IN in tableAPI

2017-06-22 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-6992: - Summary: add support for IN, NOT IN in tableAPI Key: FLINK-6992 URL: https://issues.apache.org/jira/browse/FLINK-6992 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-6991) Inaccessible link under Gelly document

2017-06-22 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-6991: Component/s: Documentation > Inaccessible link under Gelly document >

[jira] [Assigned] (FLINK-6991) Inaccessible link under Gelly document

2017-06-22 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-6991: --- Assignee: (was: mingleizhang) > Inaccessible link under Gelly document >

[jira] [Updated] (FLINK-6991) Inaccessible link under Gelly document

2017-06-22 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-6991: Description: When I visited the web

[jira] [Created] (FLINK-6991) Inaccessible link under Gelly document

2017-06-22 Thread mingleizhang (JIRA)
mingleizhang created FLINK-6991: --- Summary: Inaccessible link under Gelly document Key: FLINK-6991 URL: https://issues.apache.org/jira/browse/FLINK-6991 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-6937) Fix link markdown in Production Readiness Checklist doc

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16060320#comment-16060320 ] ASF GitHub Bot commented on FLINK-6937: --- Github user juanpaulo commented on the issue:

[GitHub] flink issue #4134: [FLINK-6937] Fix link markdown in Production Readiness Ch...

2017-06-22 Thread juanpaulo
Github user juanpaulo commented on the issue: https://github.com/apache/flink/pull/4134 > I will fix it this time for you :) cool. thanks! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not

[jira] [Commented] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16060289#comment-16060289 ] ASF GitHub Bot commented on FLINK-6649: --- Github user sunjincheng121 commented on a diff in the pull

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

2017-06-22 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r123656803 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@

[jira] [Commented] (FLINK-6358) Write job details for Gelly examples

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16060274#comment-16060274 ] ASF GitHub Bot commented on FLINK-6358: --- GitHub user greghogan opened a pull request:

[GitHub] flink pull request #4170: [FLINK-6358] [gelly] Write job details for Gelly e...

2017-06-22 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/4170 [FLINK-6358] [gelly] Write job details for Gelly examples Add an option to write job details to a file in JSON format. Job details include: job ID, runtime, parameters with values, and

[jira] [Commented] (FLINK-6964) Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore

2017-06-22 Thread Cliff Resnick (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16060027#comment-16060027 ] Cliff Resnick commented on FLINK-6964: -- [~srichter] I tried your fix. After resuming from a

[jira] [Created] (FLINK-6990) Poor performance with Sliding Time Windows

2017-06-22 Thread Brice Bingman (JIRA)
Brice Bingman created FLINK-6990: Summary: Poor performance with Sliding Time Windows Key: FLINK-6990 URL: https://issues.apache.org/jira/browse/FLINK-6990 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6923) Kafka connector needs to expose information about in-flight record in AbstractFetcher base class

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059867#comment-16059867 ] ASF GitHub Bot commented on FLINK-6923: --- Github user zhenzhongxu commented on the issue:

[GitHub] flink issue #4149: [FLINK-6923] [Kafka Connector] Expose in-processing/in-fl...

2017-06-22 Thread zhenzhongxu
Github user zhenzhongxu commented on the issue: https://github.com/apache/flink/pull/4149 Hi @tzulitai, in this particular case, we actually disabled Flink checkpointing (because we do not want to rely on fixed interval barrier to trigger sink flush/offset commit). As a workaround,

[GitHub] flink issue #4167: Test PR, please ignore

2017-06-22 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4167 @greghogan Sure, I'll try that in the second run! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Commented] (FLINK-6389) Upgrade hbase dependency to 1.3.1

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059813#comment-16059813 ] ASF GitHub Bot commented on FLINK-6389: --- Github user zentol commented on the issue:

[GitHub] flink issue #4151: [FLINK-6389] [connector] Upgrade hbase dependency to 1.3....

2017-06-22 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4151 merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[GitHub] flink issue #4034: [FLINK-6786] [metrics] Deduplicate QueryScopeIntoTest

2017-06-22 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4034 merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Commented] (FLINK-6786) Remove duplicate QueryScopeInfoTest

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059811#comment-16059811 ] ASF GitHub Bot commented on FLINK-6786: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-6956) Table examples broken

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059806#comment-16059806 ] ASF GitHub Bot commented on FLINK-6956: --- Github user zentol commented on the issue:

[GitHub] flink issue #4148: [FLINK-6956] Make table example POJO classes public

2017-06-22 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4148 Will fix the typo while merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and

[jira] [Commented] (FLINK-6967) Fully separate batch and storm examples

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059803#comment-16059803 ] ASF GitHub Bot commented on FLINK-6967: --- Github user zentol commented on the issue:

[GitHub] flink issue #4159: [FLINK-6967] Remove batch-examples dependency from storm ...

2017-06-22 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4159 merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Commented] (FLINK-6988) Add Apache Kafka 0.11 connector

2017-06-22 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059774#comment-16059774 ] Tzu-Li (Gordon) Tai commented on FLINK-6988: We did have an offline discussion with

[jira] [Created] (FLINK-6989) Refactor examples with Output interface

2017-06-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-6989: - Summary: Refactor examples with Output interface Key: FLINK-6989 URL: https://issues.apache.org/jira/browse/FLINK-6989 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-6988) Add Apache Kafka 0.11 connector

2017-06-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059735#comment-16059735 ] Chesnay Schepler commented on FLINK-6988: - This would increase our number of supported kafka

[jira] [Comment Edited] (FLINK-6988) Add Apache Kafka 0.11 connector

2017-06-22 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059699#comment-16059699 ] Piotr Nowojski edited comment on FLINK-6988 at 6/22/17 5:15 PM:

[jira] [Updated] (FLINK-6988) Add Apache Kafka 0.11 connector

2017-06-22 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-6988: -- Description: Kafka 0.11 (it will be released very soon) add supports for transactions. Thanks

[jira] [Commented] (FLINK-6988) Add Apache Kafka 0.11 connector

2017-06-22 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059699#comment-16059699 ] Piotr Nowojski commented on FLINK-6988: --- Unfortunately KafkaProducer's API is very limited.

[jira] [Updated] (FLINK-6988) Add Apache Kafka 0.11 connector

2017-06-22 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-6988: -- Description: Kafka 0.11 (it will be released very soon) add supports for transactions. Thanks

[jira] [Created] (FLINK-6988) Add Apache Kafka 0.11 connector

2017-06-22 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-6988: - Summary: Add Apache Kafka 0.11 connector Key: FLINK-6988 URL: https://issues.apache.org/jira/browse/FLINK-6988 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

2017-06-22 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6493: -- Description: {code} && ((partitionStateSerializer == null && ((Snapshot)

[jira] [Updated] (FLINK-6838) RescalingITCase fails in master branch

2017-06-22 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6838: -- Description: {code} Tests in error: RescalingITCase.testSavepointRescalingInKeyedState[1] » JobExecution Job

[jira] [Commented] (FLINK-6357) ParameterTool get unrequested parameters

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059683#comment-16059683 ] ASF GitHub Bot commented on FLINK-6357: --- GitHub user greghogan opened a pull request:

[GitHub] flink pull request #4169: [FLINK-6357] [java] ParameterTool get unrequested ...

2017-06-22 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/4169 [FLINK-6357] [java] ParameterTool get unrequested parameters Adds ParameterTool#getUnrequestedParameters returning a Set of parameter arguments names not yet requested by ParameterTool#has or any

[jira] [Commented] (FLINK-6987) TextInputFormatTest fails when run in path containing spaces

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059669#comment-16059669 ] ASF GitHub Bot commented on FLINK-6987: --- Github user zhangminglei commented on the issue:

[GitHub] flink issue #4168: [FLINK-6987] Fix erroneous when path containing spaces

2017-06-22 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/4168 Oops. I might be wrong. I will check again. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Commented] (FLINK-6987) TextInputFormatTest fails when run in path containing spaces

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059657#comment-16059657 ] ASF GitHub Bot commented on FLINK-6987: --- Github user zhangminglei commented on the issue:

[GitHub] flink issue #4168: [FLINK-6987] Fix erroneous when path containing spaces

2017-06-22 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/4168 I dont think it has an underlying issue as below line of code throw an error, and it is not relavant to the ```TextInputFormat``` class . ```tmpDir``` has spaces and then trigger that problem.

[jira] [Assigned] (FLINK-6969) Add support for deferred computation for group window aggregates

2017-06-22 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-6969: -- Assignee: sunjincheng > Add support for deferred computation for group window aggregates >

[GitHub] flink issue #4167: Test PR, please ignore

2017-06-22 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4167 May also be able to revert `-Dflink.forkCountTestPackage=1` to 2 in `tools/travis_mvn_watchdog.sh` with memory increased from 4 GB to 7.5 GB (https://docs.travis-ci.com/user/ci-environment/).

[GitHub] flink issue #4168: [FLINK-6987] Fix erroneous when path containing spaces

2017-06-22 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4168 I doubt this fixes the underlying issue, it just masks it by storing the input files in paths containing spaces. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-6987) TextInputFormatTest fails when run in path containing spaces

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059621#comment-16059621 ] ASF GitHub Bot commented on FLINK-6987: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-6987) TextInputFormatTest fails when run in path containing spaces

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059606#comment-16059606 ] ASF GitHub Bot commented on FLINK-6987: --- Github user zhangminglei commented on the issue:

[GitHub] flink issue #4168: [FLINK-6987] Fix erroneous when path containing spaces

2017-06-22 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/4168 Hi @twalthr , you can test it again. I think it works fine now. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[jira] [Commented] (FLINK-6987) TextInputFormatTest fails when run in path containing spaces

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059598#comment-16059598 ] ASF GitHub Bot commented on FLINK-6987: --- GitHub user zhangminglei opened a pull request:

[GitHub] flink pull request #4168: [FLINK-6987] Fix erroneous when path containing sp...

2017-06-22 Thread zhangminglei
GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/4168 [FLINK-6987] Fix erroneous when path containing spaces Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

[jira] [Assigned] (FLINK-6987) TextInputFormatTest fails when run in path containing spaces

2017-06-22 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-6987: --- Assignee: mingleizhang > TextInputFormatTest fails when run in path containing spaces >

[jira] [Commented] (FLINK-6987) TextInputFormatTest fails when run in path containing spaces

2017-06-22 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059584#comment-16059584 ] mingleizhang commented on FLINK-6987: - I just test on my windows 7. Also happened. I will give a PR to

[jira] [Updated] (FLINK-6750) Table API / SQL Docs: Table Sources & Sinks Page

2017-06-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6750: -- Fix Version/s: (was: 1.3.1) 1.3.2 > Table API / SQL Docs: Table Sources

[jira] [Updated] (FLINK-6954) Flink 1.3 checkpointing failing with KeyedCEPPatternOperator

2017-06-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6954: -- Fix Version/s: (was: 1.3.1) 1.3.2 > Flink 1.3 checkpointing failing with

[jira] [Updated] (FLINK-6898) Limit size of operator component in metric name

2017-06-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6898: -- Fix Version/s: (was: 1.3.1) 1.3.2 > Limit size of operator component in

[jira] [Updated] (FLINK-6900) Limit size of indiivual components in DropwizardReporter

2017-06-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6900: -- Fix Version/s: (was: 1.3.1) 1.3.2 > Limit size of indiivual components

[GitHub] flink pull request #4167: Test PR, please ignore

2017-06-22 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4167 Test PR, please ignore I'm using this PR to test changes to the travis setup. You can safely ignore this, and I will close it once I'm done. You can merge this pull request into a Git

[jira] [Commented] (FLINK-6960) Add E() supported in SQL

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059526#comment-16059526 ] ASF GitHub Bot commented on FLINK-6960: --- Github user sunjincheng121 commented on the issue:

[GitHub] flink issue #4152: [FLINK-6960][table] Add E supported in SQL.

2017-06-22 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4152 Hi @fhueske thanks for your review and I like your suggestion. :) Hi @wuchong I have updated the PR. please take look at the changes. :) --- If your project is set up for it, you can

[jira] [Commented] (FLINK-6925) Add CONCAT/CONCAT_WS supported in SQL

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059523#comment-16059523 ] ASF GitHub Bot commented on FLINK-6925: --- Github user sunjincheng121 commented on the issue:

[GitHub] flink issue #4138: [FLINK-6925][table]Add CONCAT/CONCAT_WS supported in SQL

2017-06-22 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4138 @shaoxuan-wang @wuchong --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and

[jira] [Commented] (FLINK-4587) Yet another java.lang.NoSuchFieldError: INSTANCE

2017-06-22 Thread Razvan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059508#comment-16059508 ] Razvan commented on FLINK-4587: --- @[~RenkaiGe] I have the same issue. Using Flink 1.2 and created an

[jira] [Updated] (FLINK-6810) Add Some built-in Scalar Function supported

2017-06-22 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6810: --- Labels: starter (was: ) > Add Some built-in Scalar Function supported >

[jira] [Comment Edited] (FLINK-6966) Add maxParallelism and UIDs to all operators generated by the Table API / SQL

2017-06-22 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059493#comment-16059493 ] sunjincheng edited comment on FLINK-6966 at 6/22/17 2:53 PM: - Hi [~fhueske]

[jira] [Commented] (FLINK-6966) Add maxParallelism and UIDs to all operators generated by the Table API / SQL

2017-06-22 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059493#comment-16059493 ] sunjincheng commented on FLINK-6966: Hi [~fhueske] That's true. I got it. In our side we already meet

[jira] [Updated] (FLINK-6987) TextInputFormatTest fails when run in path containing spaces

2017-06-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6987: Summary: TextInputFormatTest fails when run in path containing spaces (was: Flink does not

[jira] [Updated] (FLINK-6987) Flink does not build if path contains spaces

2017-06-22 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-6987: Affects Version/s: 1.3.1 > Flink does not build if path contains spaces >

[jira] [Created] (FLINK-6987) Flink does not build if path contains spaces

2017-06-22 Thread Timo Walther (JIRA)
Timo Walther created FLINK-6987: --- Summary: Flink does not build if path contains spaces Key: FLINK-6987 URL: https://issues.apache.org/jira/browse/FLINK-6987 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-6925) Add CONCAT/CONCAT_WS supported in SQL

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059454#comment-16059454 ] ASF GitHub Bot commented on FLINK-6925: --- Github user sunjincheng121 commented on the issue:

[GitHub] flink issue #4138: [FLINK-6925][table]Add CONCAT/CONCAT_WS supported in SQL

2017-06-22 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4138 I have updated the PR. Welcome anyone to review. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Created] (FLINK-6986) Broken links to Photoshop images

2017-06-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-6986: - Summary: Broken links to Photoshop images Key: FLINK-6986 URL: https://issues.apache.org/jira/browse/FLINK-6986 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-6785) Ineffective checks in MetricRegistryTest

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059396#comment-16059396 ] ASF GitHub Bot commented on FLINK-6785: --- Github user NicoK commented on the issue:

[GitHub] flink issue #4035: [FLINK-6785] [metrics] Fix ineffective asserts in MetricR...

2017-06-22 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4035 change looks good but fails the new checkstyle rules: ``` [INFO] There are 4 errors reported by Checkstyle 6.19 with /tools/maven/strict-checkstyle.xml ruleset. [ERROR]

[jira] [Commented] (FLINK-6857) Add global default Kryo serializer configuration to StreamExecutionEnvironment

2017-06-22 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059211#comment-16059211 ] mingleizhang commented on FLINK-6857: - Hi, [~tzulitai] I have gave a PR to this issue. Could you take

[jira] [Commented] (FLINK-6857) Add global default Kryo serializer configuration to StreamExecutionEnvironment

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059208#comment-16059208 ] ASF GitHub Bot commented on FLINK-6857: --- GitHub user zhangminglei opened a pull request:

[GitHub] flink pull request #4166: [FLINK-6857] [types] Add global default Kryo seria...

2017-06-22 Thread zhangminglei
GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/4166 [FLINK-6857] [types] Add global default Kryo serializer configuration… … to StreamExecutionEnvironment Thanks for contributing to Apache Flink. Before you open your pull request,

[jira] [Commented] (FLINK-6897) Re-add support for Java 8 lambdas in CEP library

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059137#comment-16059137 ] ASF GitHub Bot commented on FLINK-6897: --- GitHub user dawidwys opened a pull request:

[GitHub] flink pull request #4165: [FLINK-6897][cep] Re-add support for Java 8 lambda...

2017-06-22 Thread dawidwys
GitHub user dawidwys opened a pull request: https://github.com/apache/flink/pull/4165 [FLINK-6897][cep] Re-add support for Java 8 lambdas in CEP library Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[jira] [Commented] (FLINK-6762) Cannot rescale externalized incremental checkpoints

2017-06-22 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059133#comment-16059133 ] Gyula Fora commented on FLINK-6762: --- In any case the job should fail at recovery instead of the first

[jira] [Commented] (FLINK-6943) Improve exceptions within TypeExtractionUtils#getSingleAbstractMethod

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059127#comment-16059127 ] ASF GitHub Bot commented on FLINK-6943: --- Github user dawidwys commented on the issue:

[GitHub] flink issue #4140: [FLINK-6943] Improve exceptions within TypeExtractionUtil...

2017-06-22 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/4140 Great, thanks! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or

[jira] [Commented] (FLINK-6966) Add maxParallelism and UIDs to all operators generated by the Table API / SQL

2017-06-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059121#comment-16059121 ] Jark Wu commented on FLINK-6966: We can add an entry to the {{QueryConfig}} to set the max parallelism,

[jira] [Commented] (FLINK-6925) Add CONCAT/CONCAT_WS supported in SQL

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059118#comment-16059118 ] ASF GitHub Bot commented on FLINK-6925: --- Github user sunjincheng121 commented on the issue:

[GitHub] flink issue #4138: [FLINK-6925][table]Add CONCAT/CONCAT_WS supported in SQL

2017-06-22 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4138 Need add SQL doc, And a `concat_ws` bug need be fix. Updated the PR. later. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Closed] (FLINK-6952) Add link to Javadocs

2017-06-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-6952. -- Resolution: Fixed Fix Version/s: 1.4.0 1.3.1 1.2.2 Fixed

[jira] [Closed] (FLINK-6985) Remove bugfix version from docs title

2017-06-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-6985. -- Resolution: Fixed Fix Version/s: 1.2.0 1.3.0 1.4.0 Fixed

[GitHub] flink pull request #4163: [FLINK-6952] [FLINK-6985] [docs] Add Javadocs link...

2017-06-22 Thread uce
Github user uce closed the pull request at: https://github.com/apache/flink/pull/4163 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #4164: [FLINK-6952] [FLINK-6985] [docs] Add Javadocs link...

2017-06-22 Thread uce
Github user uce closed the pull request at: https://github.com/apache/flink/pull/4164 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6952) Add link to Javadocs

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059107#comment-16059107 ] ASF GitHub Bot commented on FLINK-6952: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-6952) Add link to Javadocs

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059109#comment-16059109 ] ASF GitHub Bot commented on FLINK-6952: --- Github user uce closed the pull request at:

[jira] [Commented] (FLINK-6952) Add link to Javadocs

2017-06-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059108#comment-16059108 ] ASF GitHub Bot commented on FLINK-6952: --- Github user uce closed the pull request at:

[GitHub] flink pull request #4162: [FLINK-6952] [FLINK-6985] [docs] Add Javadocs link...

2017-06-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4162 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6958) Async I/O timeout not work

2017-06-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059106#comment-16059106 ] Jark Wu commented on FLINK-6958: I have dug into this issue. When the source is a bounded source, such as

[jira] [Assigned] (FLINK-6958) Async I/O timeout not work

2017-06-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-6958: -- Assignee: Jark Wu > Async I/O timeout not work > -- > > Key:

[jira] [Commented] (FLINK-6932) Update the inaccessible Dataflow Model paper link

2017-06-22 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059098#comment-16059098 ] mingleizhang commented on FLINK-6932: - You are very welcome [~tzulitai]. > Update the inaccessible

[jira] [Closed] (FLINK-6937) Fix link markdown in Production Readiness Checklist doc

2017-06-22 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-6937. -- > Fix link markdown in Production Readiness Checklist doc >

[jira] [Resolved] (FLINK-6937) Fix link markdown in Production Readiness Checklist doc

2017-06-22 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6937. Resolution: Fixed Fix Version/s: 1.3.2 1.4.0 Fixed for

[jira] [Commented] (FLINK-6932) Update the inaccessible Dataflow Model paper link

2017-06-22 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059091#comment-16059091 ] Tzu-Li (Gordon) Tai commented on FLINK-6932: Fixed for master via

[jira] [Commented] (FLINK-6806) rocksdb is not listed as state backend in doc

2017-06-22 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059089#comment-16059089 ] Tzu-Li (Gordon) Tai commented on FLINK-6806: Thanks for the contribution [~phoenixjiangnan]!

  1   2   >