[jira] [Closed] (FLINK-7482) StringWriter to support compression

2017-08-21 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-7482. - Resolution: Not A Bug Hi [~felixcheung]. This is a great question for the dev or user [mailing

[jira] [Commented] (FLINK-7465) Add build-in BloomFilterCount on TableAPI

2017-08-21 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136062#comment-16136062 ] sunjincheng commented on FLINK-7465: [~fhueske] I want add accuracy and maxElement as function

[jira] [Commented] (FLINK-7454) update 'Monitoring Current Event Time' section of Flink doc

2017-08-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136025#comment-16136025 ] ASF GitHub Bot commented on FLINK-7454: --- Github user bowenli86 commented on the issue:

[GitHub] flink issue #4547: [FLINK-7454][docs] update 'Monitoring Current Event Time'...

2017-08-21 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4547 any feedback? --- 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-7465) Add build-in BloomFilterCount on TableAPI

2017-08-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136174#comment-16136174 ] Jark Wu commented on FLINK-7465: Hi [~sunjincheng121], Regarding to the when to configure the accuracy, I

[jira] [Created] (FLINK-7488) TaskManagerHeapSizeCalculationJavaBashTest sometimes fails

2017-08-21 Thread Ted Yu (JIRA)
Ted Yu created FLINK-7488: - Summary: TaskManagerHeapSizeCalculationJavaBashTest sometimes fails Key: FLINK-7488 URL: https://issues.apache.org/jira/browse/FLINK-7488 Project: Flink Issue Type: Test

[GitHub] flink pull request #4570: [FLINK-7438][DataStream API]Remove useless import,...

2017-08-21 Thread yew1eb
GitHub user yew1eb opened a pull request: https://github.com/apache/flink/pull/4570 [FLINK-7438][DataStream API]Remove useless import, avoid warnings ## What is the purpose of the change Avoid warnings,details: [ISSUE

[GitHub] flink issue #4525: [FLINK-7423] Always reuse an instance to get elements fro...

2017-08-21 Thread XuPingyong
Github user XuPingyong commented on the issue: https://github.com/apache/flink/pull/4525 Thanks @StephanEwen , so I think `null` values can be returned from `InputFormat#nextRecord` anytime, even not end. Can `null` values be passed to `InputFormat#nextRecord`, or

[jira] [Commented] (FLINK-7423) Always reuse an instance to get elements from the inputFormat

2017-08-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136247#comment-16136247 ] ASF GitHub Bot commented on FLINK-7423: --- Github user XuPingyong commented on the issue:

[jira] [Commented] (FLINK-7398) Table API operators/UDFs must not store Logger

2017-08-21 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136280#comment-16136280 ] Haohui Mai commented on FLINK-7398: --- +1 on logging trait. I'll submit a PR. Adding a checkstyle rule is

[jira] [Updated] (FLINK-7488) TaskManagerHeapSizeCalculationJavaBashTest sometimes fails

2017-08-21 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7488: -- Description: {code}

[GitHub] flink issue #4522: [FLINK-7366][kinesis connector] Upgrade kinesis producer ...

2017-08-21 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4522 @tzulitai any more feedbacks? We have a ticket on my company for this task, and I'd like to mark it as finished if possible :) --- If your project is set up for it, you can reply to this email

[GitHub] flink pull request #4522: [FLINK-7366][kinesis connector] Upgrade kinesis pr...

2017-08-21 Thread bowenli86
Github user bowenli86 closed the pull request at: https://github.com/apache/flink/pull/4522 --- 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 #4522: [FLINK-7366][kinesis connector] Upgrade kinesis pr...

2017-08-21 Thread bowenli86
GitHub user bowenli86 reopened a pull request: https://github.com/apache/flink/pull/4522 [FLINK-7366][kinesis connector] Upgrade kinesis producer library in flink-connector-kinesis ## What is the purpose of the change We need to upgrade KPL and KCL to pick up the enhanced

[jira] [Commented] (FLINK-7366) Upgrade kinesis producer library in flink-connector-kinesis

2017-08-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136166#comment-16136166 ] ASF GitHub Bot commented on FLINK-7366: --- GitHub user bowenli86 reopened a pull request:

[jira] [Commented] (FLINK-7366) Upgrade kinesis producer library in flink-connector-kinesis

2017-08-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136162#comment-16136162 ] ASF GitHub Bot commented on FLINK-7366: --- Github user bowenli86 commented on the issue:

[jira] [Commented] (FLINK-7366) Upgrade kinesis producer library in flink-connector-kinesis

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

[GitHub] flink issue #4473: [FLINK-7367][kinesis connector] Parameterize more configs...

2017-08-21 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4473 @tzulitai any more feedbacks? We have a ticket on my company for this task, and I'd like to mark it as finished if possible :) --- If your project is set up for it, you can reply to this email

[jira] [Commented] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc)

2017-08-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136167#comment-16136167 ] ASF GitHub Bot commented on FLINK-7367: --- Github user bowenli86 commented on the issue:

[jira] [Commented] (FLINK-4422) Convert all time interval measurements to System.nanoTime()

2017-08-21 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136194#comment-16136194 ] Hai Zhou commented on FLINK-4422: - Hi [~StephanEwen], This is still a issue? If yes, I would like to work

[GitHub] flink issue #4563: [FLINK-7479] [cep] Support to retrieve the past event by ...

2017-08-21 Thread dianfu
Github user dianfu commented on the issue: https://github.com/apache/flink/pull/4563 @dawidwys Have updated the PR according to your comments. --- 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] [Commented] (FLINK-7479) Support to retrieve the past event by physical offset

2017-08-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136210#comment-16136210 ] ASF GitHub Bot commented on FLINK-7479: --- Github user dianfu commented on the issue:

[jira] [Comment Edited] (FLINK-7398) Table API operators/UDFs must not store Logger

2017-08-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136140#comment-16136140 ] Jark Wu edited comment on FLINK-7398 at 8/22/17 1:47 AM: - +1 Logging trait. BTW,

[jira] [Commented] (FLINK-7398) Table API operators/UDFs must not store Logger

2017-08-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136140#comment-16136140 ] Jark Wu commented on FLINK-7398: +1 Logging trait. BTW, I think to avoid the misusage of {{LOG}} by

[jira] [Commented] (FLINK-7438) Some classes are eclipsed by classes in package scala

2017-08-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136217#comment-16136217 ] ASF GitHub Bot commented on FLINK-7438: --- GitHub user yew1eb opened a pull request:

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[GitHub] flink issue #4358: [FLINK-7068][blob] change BlobService sub-classes for per...

2017-08-21 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4358 sorry for the mess, but let me also drag in #4568 and adapt the code in here (which is moved from `BlobCache` to `PermanentBlobCache` by this PR) --- If your project is set up for it, you can reply

[jira] [Comment Edited] (FLINK-7438) Some classes are eclipsed by classes in package scala

2017-08-21 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16135076#comment-16135076 ] Hai Zhou edited comment on FLINK-7438 at 8/21/17 12:01 PM: --- I think the reason

[GitHub] flink issue #4568: [FLINK-7483][blob] prevent cleanup of re-registered jobs

2017-08-21 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4568 @tedyu this fixes the two issues you found in #4238. Could you have a quick look, also? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-7483) BlobCache cleanup timer not reset after job re-registration

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

[jira] [Commented] (FLINK-5886) Python API for streaming applications

2017-08-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16135018#comment-16135018 ] ASF GitHub Bot commented on FLINK-5886: --- Github user zohar-mizrahi commented on the issue:

[GitHub] flink issue #3838: [FLINK-5886] Python API for streaming applications

2017-08-21 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3838 The check failed because the spotbugs plugin found something; this plugin isn't run by default when calling `mvn verify`. You can run the spotbugs locally by adding `-Dspotbugs` to the maven

[jira] [Commented] (FLINK-5886) Python API for streaming applications

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

[jira] [Commented] (FLINK-7438) Some classes are eclipsed by classes in package scala

2017-08-21 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16135076#comment-16135076 ] Hai Zhou commented on FLINK-7438: - I think the reason for this problem is

[jira] [Commented] (FLINK-7438) Some classes are eclipsed by classes in package scala

2017-08-21 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16135084#comment-16135084 ] Hai Zhou commented on FLINK-7438: - Hi [~aljoscha] I would like to work on this issue.:D > Some classes

[GitHub] flink issue #3838: [FLINK-5886] Python API for streaming applications

2017-08-21 Thread zohar-mizrahi
Github user zohar-mizrahi commented on the issue: https://github.com/apache/flink/pull/3838 I'm trying to track down the root cause for the checks failures without a success. Obviously, the given project (flink-libraries/flink-streaming-python) in master branch passes the `verify`

[jira] [Commented] (FLINK-7484) com.esotericsoftware.kryo.KryoException: java.lang.IndexOutOfBoundsException: Index: 7, Size: 5

2017-08-21 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16135046#comment-16135046 ] Hai Zhou commented on FLINK-7484: - Hi [~shashank734] Can you upload your code? >

[jira] [Created] (FLINK-7485) Using DataView interface to improve (MIN/MAX)WithRetractAggFunction.

2017-08-21 Thread sunjincheng (JIRA)
sunjincheng created FLINK-7485: -- Summary: Using DataView interface to improve (MIN/MAX)WithRetractAggFunction. Key: FLINK-7485 URL: https://issues.apache.org/jira/browse/FLINK-7485 Project: Flink

[jira] [Commented] (FLINK-7484) com.esotericsoftware.kryo.KryoException: java.lang.IndexOutOfBoundsException: Index: 7, Size: 5

2017-08-21 Thread Shashank Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16135101#comment-16135101 ] Shashank Agarwal commented on FLINK-7484: - Hi [~yew1eb] It's very big code base, With lot of

[jira] [Commented] (FLINK-5253) Remove special treatment of "dynamic properties"

2017-08-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16134818#comment-16134818 ] ASF GitHub Bot commented on FLINK-5253: --- Github user tillrohrmann commented on the issue:

[GitHub] flink pull request #4563: [FLINK-7479] [cep] Support to retrieve the past ev...

2017-08-21 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4563#discussion_r134157916 --- Diff: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/pattern/Pattern.scala --- @@ -359,7 +362,7 @@ class Pattern[T , F <:

[GitHub] flink pull request #4563: [FLINK-7479] [cep] Support to retrieve the past ev...

2017-08-21 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4563#discussion_r134158000 --- Diff: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/pattern/Pattern.scala --- @@ -449,7 +452,7 @@ class Pattern[T , F <:

[GitHub] flink pull request #4563: [FLINK-7479] [cep] Support to retrieve the past ev...

2017-08-21 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4563#discussion_r134157868 --- Diff: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/pattern/Pattern.scala --- @@ -329,7 +332,7 @@ class Pattern[T , F <:

[GitHub] flink pull request #4563: [FLINK-7479] [cep] Support to retrieve the past ev...

2017-08-21 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4563#discussion_r134157849 --- Diff: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/pattern/Pattern.scala --- @@ -317,9 +322,7 @@ class Pattern[T , F <:

[GitHub] flink pull request #4563: [FLINK-7479] [cep] Support to retrieve the past ev...

2017-08-21 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4563#discussion_r134157958 --- Diff: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/pattern/Pattern.scala --- @@ -413,7 +416,7 @@ class Pattern[T , F <:

[GitHub] flink pull request #4563: [FLINK-7479] [cep] Support to retrieve the past ev...

2017-08-21 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4563#discussion_r134157991 --- Diff: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/pattern/Pattern.scala --- @@ -437,7 +440,7 @@ class Pattern[T , F <:

[GitHub] flink pull request #4563: [FLINK-7479] [cep] Support to retrieve the past ev...

2017-08-21 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4563#discussion_r134157941 --- Diff: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/pattern/Pattern.scala --- @@ -390,7 +393,7 @@ class Pattern[T , F <:

[GitHub] flink pull request #4563: [FLINK-7479] [cep] Support to retrieve the past ev...

2017-08-21 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4563#discussion_r134157969 --- Diff: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/pattern/Pattern.scala --- @@ -426,7 +429,7 @@ class Pattern[T , F <:

[jira] [Commented] (FLINK-7479) Support to retrieve the past event by physical offset

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

[jira] [Commented] (FLINK-7479) Support to retrieve the past event by physical offset

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

[jira] [Commented] (FLINK-7479) Support to retrieve the past event by physical offset

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

[jira] [Commented] (FLINK-7479) Support to retrieve the past event by physical offset

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

[jira] [Commented] (FLINK-7479) Support to retrieve the past event by physical offset

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

[jira] [Commented] (FLINK-7479) Support to retrieve the past event by physical offset

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

[jira] [Commented] (FLINK-7479) Support to retrieve the past event by physical offset

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

[jira] [Commented] (FLINK-7479) Support to retrieve the past event by physical offset

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

[GitHub] flink pull request #4563: [FLINK-7479] [cep] Support to retrieve the past ev...

2017-08-21 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4563#discussion_r134157821 --- Diff: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/pattern/Pattern.scala --- @@ -292,9 +301,7 @@ class Pattern[T , F <:

[GitHub] flink pull request #4563: [FLINK-7479] [cep] Support to retrieve the past ev...

2017-08-21 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4563#discussion_r134157928 --- Diff: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/pattern/Pattern.scala --- @@ -372,7 +375,7 @@ class Pattern[T , F <:

[GitHub] flink pull request #4563: [FLINK-7479] [cep] Support to retrieve the past ev...

2017-08-21 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4563#discussion_r134157810 --- Diff: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/pattern/Pattern.scala --- @@ -280,9 +291,7 @@ class Pattern[T , F <:

[GitHub] flink pull request #4563: [FLINK-7479] [cep] Support to retrieve the past ev...

2017-08-21 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4563#discussion_r134157831 --- Diff: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/pattern/Pattern.scala --- @@ -305,9 +312,7 @@ class Pattern[T , F <:

[jira] [Commented] (FLINK-7479) Support to retrieve the past event by physical offset

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

[jira] [Commented] (FLINK-7479) Support to retrieve the past event by physical offset

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

[jira] [Commented] (FLINK-7479) Support to retrieve the past event by physical offset

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

[jira] [Commented] (FLINK-7479) Support to retrieve the past event by physical offset

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

[jira] [Commented] (FLINK-7479) Support to retrieve the past event by physical offset

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

[jira] [Commented] (FLINK-7479) Support to retrieve the past event by physical offset

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

[GitHub] flink pull request #4563: [FLINK-7479] [cep] Support to retrieve the past ev...

2017-08-21 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4563#discussion_r134157893 --- Diff: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/pattern/Pattern.scala --- @@ -347,7 +350,7 @@ class Pattern[T , F <:

[jira] [Commented] (FLINK-7474) Flink supports consuming data from and sink data to Azure eventhubs

2017-08-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16134850#comment-16134850 ] ASF GitHub Bot commented on FLINK-7474: --- Github user zhuganghuaonnet commented on the issue:

[jira] [Closed] (FLINK-7382) Broken links in `Apache Flink Documentation` page

2017-08-21 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou closed FLINK-7382. --- > Broken links in `Apache Flink Documentation` page > -- > >

[GitHub] flink pull request #3829: [FLINK-6442] [table] Extend TableAPI Support Sink ...

2017-08-21 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/3829#discussion_r134160516 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala --- @@ -502,26 +513,140 @@ abstract class

[jira] [Assigned] (FLINK-7227) OR expression with more than 2 predicates is not pushed into a TableSource

2017-08-21 Thread Usman Younas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Usman Younas reassigned FLINK-7227: --- Assignee: Usman Younas > OR expression with more than 2 predicates is not pushed into a

[GitHub] flink issue #4513: [FLINK-6938][FLINK-6939] [cep] Not store IterativeConditi...

2017-08-21 Thread dianfu
Github user dianfu commented on the issue: https://github.com/apache/flink/pull/4513 Thanks @dawidwys for the remind. Yes, you're right and that make sense to me. I will update the the PR and remove ConditionRegistry related changes. --- If your project is set up for it, you can

[jira] [Commented] (FLINK-4831) Implement a slf4j metric reporter

2017-08-21 Thread Sumit Sarin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16135012#comment-16135012 ] Sumit Sarin commented on FLINK-4831: Hey Chesner, After going through slf4j and log4j documentation

[jira] [Created] (FLINK-7484) com.esotericsoftware.kryo.KryoException: java.lang.IndexOutOfBoundsException: Index: 7, Size: 5

2017-08-21 Thread Shashank Agarwal (JIRA)
Shashank Agarwal created FLINK-7484: --- Summary: com.esotericsoftware.kryo.KryoException: java.lang.IndexOutOfBoundsException: Index: 7, Size: 5 Key: FLINK-7484 URL:

[jira] [Closed] (FLINK-7485) Using DataView interface to improve (MIN/MAX)WithRetractAggFunction.

2017-08-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-7485. -- Resolution: Duplicate > Using DataView interface to improve (MIN/MAX)WithRetractAggFunction. >

[GitHub] flink pull request #4355: [FLINK-7206] [table] Implementation of DataView to...

2017-08-21 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/4355#discussion_r134119014 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala --- @@ -162,13 +172,66 @@ class

[jira] [Closed] (FLINK-7345) Add BRANCH PATTERN.

2017-08-21 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-7345. --- Resolution: Duplicate > Add BRANCH PATTERN. > --- > > Key:

[jira] [Commented] (FLINK-7269) Refactor passing of dynamic properties

2017-08-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16134821#comment-16134821 ] ASF GitHub Bot commented on FLINK-7269: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #4415: [FLINK-7269] Refactor passing of dynamic properties

2017-08-21 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4415 @EronWright the driving rationale is that the static variable is an anti pattern which can cause problems which are hard to track and understand. E.g. it is really hard to find out where the

[jira] [Commented] (FLINK-7169) Support AFTER MATCH SKIP function in CEP library API

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

[jira] [Commented] (FLINK-7169) Support AFTER MATCH SKIP function in CEP library API

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

[jira] [Commented] (FLINK-7169) Support AFTER MATCH SKIP function in CEP library API

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

[GitHub] flink pull request #3829: [FLINK-6442] [table] Extend TableAPI Support Sink ...

2017-08-21 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/3829#discussion_r134158258 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/queryConfig.scala --- @@ -19,9 +19,21 @@ package

[jira] [Commented] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL

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

[jira] [Commented] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL

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

[GitHub] flink pull request #3829: [FLINK-6442] [table] Extend TableAPI Support Sink ...

2017-08-21 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/3829#discussion_r134158670 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala --- @@ -132,6 +132,44 @@ abstract class

[GitHub] flink pull request #3829: [FLINK-6442] [table] Extend TableAPI Support Sink ...

2017-08-21 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/3829#discussion_r134173572 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala --- @@ -800,6 +794,66 @@ class Table( } /**

[GitHub] flink pull request #3829: [FLINK-6442] [table] Extend TableAPI Support Sink ...

2017-08-21 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/3829#discussion_r134161822 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala --- @@ -502,26 +513,140 @@ abstract class

[jira] [Commented] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL

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

[jira] [Commented] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL

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

[jira] [Commented] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL

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

[jira] [Commented] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL

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

[jira] [Commented] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL

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

[GitHub] flink pull request #3829: [FLINK-6442] [table] Extend TableAPI Support Sink ...

2017-08-21 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/3829#discussion_r134177144 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala --- @@ -502,26 +513,140 @@ abstract class

[jira] [Commented] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL

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

[GitHub] flink pull request #3829: [FLINK-6442] [table] Extend TableAPI Support Sink ...

2017-08-21 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/3829#discussion_r134162144 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala --- @@ -502,26 +513,140 @@ abstract class

[GitHub] flink pull request #3829: [FLINK-6442] [table] Extend TableAPI Support Sink ...

2017-08-21 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/3829#discussion_r134173548 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala --- @@ -800,6 +794,66 @@ class Table( } /**

[GitHub] flink pull request #3829: [FLINK-6442] [table] Extend TableAPI Support Sink ...

2017-08-21 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/3829#discussion_r134180276 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/CsvSQLTableSink.scala --- @@ -0,0 +1,55 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-6938) IterativeCondition should support RichFunction interface

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

[jira] [Commented] (FLINK-7479) Support to retrieve the past event by physical offset

2017-08-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16134985#comment-16134985 ] ASF GitHub Bot commented on FLINK-7479: --- Github user dianfu commented on the issue:

  1   2   3   >