[GitHub] flink pull request #6144: [hotfix][javadoc]Fix the incorrect java doc for Op...

2018-06-09 Thread sihuazhou
GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/6144 [hotfix][javadoc]Fix the incorrect java doc for OptionsFactory. ## What is the purpose of the change *This PR simply fixes the incorrect java doc of `OptionsFactory`.* ## Brief ch

[jira] [Closed] (FLINK-9561) Lack of the api to set RocksDB Option by flink config

2018-06-09 Thread aitozi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aitozi closed FLINK-9561. - Resolution: Not A Problem > Lack of the api to set RocksDB Option by flink config > -

[jira] [Commented] (FLINK-9561) Lack of the api to set RocksDB Option by flink config

2018-06-09 Thread aitozi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16507250#comment-16507250 ] aitozi commented on FLINK-9561: --- Get it, thanks.  i will close this issue. > Lack of the a

[jira] [Commented] (FLINK-9561) Lack of the api to set RocksDB Option by flink config

2018-06-09 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16507249#comment-16507249 ] Sihua Zhou commented on FLINK-9561: --- Hi [~aitozi] I think flink already supported this,

[GitHub] flink pull request #6143: [hotfix] [docs] Fixed scala variable declaration w...

2018-06-09 Thread 2start
GitHub user 2start opened a pull request: https://github.com/apache/flink/pull/6143 [hotfix] [docs] Fixed scala variable declaration without initialization ## What is the purpose of the change This pull request fixes an error in the Scala example for periodic watermarks.

[jira] [Commented] (FLINK-8554) Upgrade AWS SDK

2018-06-09 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16507192#comment-16507192 ] Ted Yu commented on FLINK-8554: --- Or use this JIRA for the next upgrade of AWS SDK. > Upgra

[jira] [Commented] (FLINK-9340) ScheduleOrUpdateConsumersTest may fail with Address already in use

2018-06-09 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16507191#comment-16507191 ] Ted Yu commented on FLINK-9340: --- I wonder if it is easier to reproduce the error when runni

[jira] [Commented] (FLINK-9091) Failure while enforcing releasability in building flink-json module

2018-06-09 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16507190#comment-16507190 ] Ted Yu commented on FLINK-9091: --- What should be the next step ? Thanks > Failure while en

[jira] [Updated] (FLINK-9562) Wrong wording in flink-optimizer module

2018-06-09 Thread Alexandr Arkhipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandr Arkhipov updated FLINK-9562: - Description: There are some wrong wording in flink-optimizer module. Especialy with the

[jira] [Commented] (FLINK-8468) Make the connector to take advantage of AMQP features (routing key, exchange and message properties)

2018-06-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16507162#comment-16507162 ] ASF GitHub Bot commented on FLINK-8468: --- Github user pduveau commented on a diff in

[GitHub] flink pull request #5410: [FLINK-8468] [RabbitMQ Connector] Take advantage o...

2018-06-09 Thread pduveau
Github user pduveau commented on a diff in the pull request: https://github.com/apache/flink/pull/5410#discussion_r194239264 --- Diff: flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java --- @@ -105,7 +155,24 @@ publi

[jira] [Updated] (FLINK-9562) Wrong wording in flink-optimizer module

2018-06-09 Thread Alexandr Arkhipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandr Arkhipov updated FLINK-9562: - Description: There are some wrong wording in flink-optimizer module. Especialy with the

[jira] [Created] (FLINK-9563) Migrate integration tests for CEP

2018-06-09 Thread Deepak Sharma (JIRA)
Deepak Sharma created FLINK-9563: Summary: Migrate integration tests for CEP Key: FLINK-9563 URL: https://issues.apache.org/jira/browse/FLINK-9563 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-9562) Wrong wording in flink-optimizer module

2018-06-09 Thread Alexandr Arkhipov (JIRA)
Alexandr Arkhipov created FLINK-9562: Summary: Wrong wording in flink-optimizer module Key: FLINK-9562 URL: https://issues.apache.org/jira/browse/FLINK-9562 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9561) Lack of the api to set RocksDB Option by flink config

2018-06-09 Thread aitozi (JIRA)
aitozi created FLINK-9561: - Summary: Lack of the api to set RocksDB Option by flink config Key: FLINK-9561 URL: https://issues.apache.org/jira/browse/FLINK-9561 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-9551) FlinkCEP Scala Combining Patterns table has a missing pattern

2018-06-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16507010#comment-16507010 ] ASF GitHub Bot commented on FLINK-9551: --- Github user medcv commented on the issue:

[GitHub] flink issue #6139: [FLINK-9551][DOCS]FlinkCEP Scala Combining Patterns table...

2018-06-09 Thread medcv
Github user medcv commented on the issue: https://github.com/apache/flink/pull/6139 @zentol Please review ---

[jira] [Commented] (FLINK-8256) Cannot use Scala functions to filter in 1.4 - java.lang.ClassCastException

2018-06-09 Thread Alexandr Arkhipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16506959#comment-16506959 ] Alexandr Arkhipov commented on FLINK-8256: -- Folks, I think you can close this an

[jira] [Comment Edited] (FLINK-6977) Add MD5/SHA1/SHA2 supported in TableAPI

2018-06-09 Thread Alexandr Arkhipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16506944#comment-16506944 ] Alexandr Arkhipov edited comment on FLINK-6977 at 6/9/18 12:10 PM:

[jira] [Commented] (FLINK-6977) Add MD5/SHA1/SHA2 supported in TableAPI

2018-06-09 Thread Alexandr Arkhipov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16506944#comment-16506944 ] Alexandr Arkhipov commented on FLINK-6977: -- I have investigated the code and it

[jira] [Assigned] (FLINK-9537) JobManager isolation in session mode

2018-06-09 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-9537: --- Assignee: (was: mingleizhang) > JobManager isolation in session mode > -

[jira] [Updated] (FLINK-9559) The type of a union of CHAR columns of different lengths should be VARCHAR

2018-06-09 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-9559: -- Issue Type: Sub-task (was: Improvement) Parent: FLINK-9134 > The type of a union of CHAR colum