[jira] [Commented] (FLINK-6539) Add automated end-to-end tests

2017-05-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16030087#comment-16030087 ] ASF GitHub Bot commented on FLINK-6539: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #3911: [FLINK-6539] Add end-to-end tests

2017-05-30 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3911 I think the last kinks are now ironed out. Could you please take another look? (anyone interested) --- If your project is set up for it, you can reply to this email and have your reply appear on

[GitHub] flink pull request #4020: [FLINK-6747] [table] [docs] Time attributes sectio...

2017-05-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4020#discussion_r119222676 --- Diff: docs/dev/table/streaming.md --- @@ -39,17 +39,293 @@ Dynamic table Time Attributes --- -### Event-time +Flink

[GitHub] flink pull request #4020: [FLINK-6747] [table] [docs] Time attributes sectio...

2017-05-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4020#discussion_r119222374 --- Diff: docs/dev/table/streaming.md --- @@ -39,17 +39,293 @@ Dynamic table Time Attributes --- -### Event-time +Flink

[GitHub] flink pull request #4020: [FLINK-6747] [table] [docs] Time attributes sectio...

2017-05-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4020#discussion_r119226851 --- Diff: docs/dev/table/streaming.md --- @@ -39,17 +39,293 @@ Dynamic table Time Attributes --- -### Event-time +Flink

[GitHub] flink pull request #4020: [FLINK-6747] [table] [docs] Time attributes sectio...

2017-05-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4020#discussion_r119221597 --- Diff: docs/dev/table/streaming.md --- @@ -39,17 +39,293 @@ Dynamic table Time Attributes --- -### Event-time +Flink

[GitHub] flink pull request #4020: [FLINK-6747] [table] [docs] Time attributes sectio...

2017-05-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4020#discussion_r119226503 --- Diff: docs/dev/table/streaming.md --- @@ -39,17 +39,293 @@ Dynamic table Time Attributes --- -### Event-time +Flink

[GitHub] flink pull request #4020: [FLINK-6747] [table] [docs] Time attributes sectio...

2017-05-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4020#discussion_r119227179 --- Diff: docs/dev/table/streaming.md --- @@ -39,17 +39,293 @@ Dynamic table Time Attributes --- -### Event-time +Flink

[GitHub] flink pull request #4020: [FLINK-6747] [table] [docs] Time attributes sectio...

2017-05-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4020#discussion_r119227533 --- Diff: docs/dev/table/streaming.md --- @@ -39,17 +39,293 @@ Dynamic table Time Attributes --- -### Event-time +Flink

[GitHub] flink pull request #4020: [FLINK-6747] [table] [docs] Time attributes sectio...

2017-05-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4020#discussion_r119223115 --- Diff: docs/dev/table/streaming.md --- @@ -39,17 +39,293 @@ Dynamic table Time Attributes --- -### Event-time +Flink

[GitHub] flink pull request #4020: [FLINK-6747] [table] [docs] Time attributes sectio...

2017-05-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4020#discussion_r119227410 --- Diff: docs/dev/table/streaming.md --- @@ -39,17 +39,293 @@ Dynamic table Time Attributes --- -### Event-time +Flink

[jira] [Created] (FLINK-6777) Activate strict checkstyle for flink-scala-shell

2017-05-30 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-6777: - Summary: Activate strict checkstyle for flink-scala-shell Key: FLINK-6777 URL: https://issues.apache.org/jira/browse/FLINK-6777 Project: Flink Issue Type:

[jira] [Created] (FLINK-6779) Activate strict checkstyle in flink-scala

2017-05-30 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-6779: - Summary: Activate strict checkstyle in flink-scala Key: FLINK-6779 URL: https://issues.apache.org/jira/browse/FLINK-6779 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-6731) Activate strict checkstyle for flink-tests

2017-05-30 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reassigned FLINK-6731: - Assignee: Greg Hogan > Activate strict checkstyle for flink-tests >

[jira] [Closed] (FLINK-6426) Update the document of group-window table API

2017-05-30 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-6426. -- Resolution: Duplicate Restructure the table api doc. > Update the document of group-window table API >

[jira] [Commented] (FLINK-6745) Table API / SQL Docs: Overview Page

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

[GitHub] flink pull request #4013: [FLINK-6745] [docs] Updated Table API / SQL docs: ...

2017-05-30 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4013#discussion_r119245259 --- Diff: docs/dev/tableApi.md --- @@ -61,21 +45,38 @@ The following dependency must be added to your project in order to use the Table {%

[jira] [Commented] (FLINK-6780) ExternalTableSource fails to add the processing time and the event time attribute in the row type

2017-05-30 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16030519#comment-16030519 ] sunjincheng commented on FLINK-6780: HI, [~wheat9] If I understand you correctly, your meant currently

[jira] [Created] (FLINK-6780) ExternalTableSource fails to add the processing time and the event time attribute in the row type

2017-05-30 Thread Haohui Mai (JIRA)
Haohui Mai created FLINK-6780: - Summary: ExternalTableSource fails to add the processing time and the event time attribute in the row type Key: FLINK-6780 URL: https://issues.apache.org/jira/browse/FLINK-6780

[jira] [Commented] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

2017-05-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16028769#comment-16028769 ] ASF GitHub Bot commented on FLINK-6301: --- GitHub user vidhu5269 opened a pull request:

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

2017-05-30 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2332 @nragon I agree. But your use case does it have increments/appends? --- 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

[jira] [Updated] (FLINK-6770) Add excludeSerializersInCheckpoints to ExecutionConfig

2017-05-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6770: --- Description: A {{excludeSerializersInCheckpoints}} setting should be added to the

[GitHub] flink pull request #4016: [FLINK-6638] Allow overriding default for primitiv...

2017-05-30 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4016 [FLINK-6638] Allow overriding default for primitive ConfigOption You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink 6638overdef

[jira] [Commented] (FLINK-6638) Allow overriding default value for all types when retrieving ConfigOption

2017-05-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16029183#comment-16029183 ] ASF GitHub Bot commented on FLINK-6638: --- GitHub user zentol opened a pull request:

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2017-05-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16029197#comment-16029197 ] ASF GitHub Bot commented on FLINK-2055: --- Github user ramkrish86 commented on the issue:

[jira] [Commented] (FLINK-6771) Create committer guide

2017-05-30 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16029199#comment-16029199 ] Aljoscha Krettek commented on FLINK-6771: - Beam has this:

[jira] [Created] (FLINK-6772) Incorrect ordering of matched state events in Flink CEP

2017-05-30 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6772: -- Summary: Incorrect ordering of matched state events in Flink CEP Key: FLINK-6772 URL: https://issues.apache.org/jira/browse/FLINK-6772 Project: Flink

[jira] [Updated] (FLINK-6773) Use compression (e.g. snappy) for full check/savepoints

2017-05-30 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-6773: -- Description: We could use compression (e.g. snappy stream compression) to decrease the size of

[jira] [Updated] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

2017-05-30 Thread Rahul Yadav (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rahul Yadav updated FLINK-6301: --- Fix Version/s: 1.4.0 > Flink KafkaConnector09 leaks memory on reading compressed messages due to a >

[GitHub] flink issue #4015: [FLINK-6301] [flink-connector-kafka-0.10] Upgrading Kafka...

2017-05-30 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4015 Hi @vidhu5269, thanks for the PR! I agree that we should bump the Kafka 0.10 version, for various reasons (JAAS security feature enhancements, as well as the memory leak you mentioned in the

[jira] [Created] (FLINK-6771) Create committer guide

2017-05-30 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-6771: Summary: Create committer guide Key: FLINK-6771 URL: https://issues.apache.org/jira/browse/FLINK-6771 Project: Flink Issue Type: Wish Components:

[jira] [Created] (FLINK-6769) Replace usage of deprecated FileSystem#create(Path, boolean)

2017-05-30 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6769: --- Summary: Replace usage of deprecated FileSystem#create(Path, boolean) Key: FLINK-6769 URL: https://issues.apache.org/jira/browse/FLINK-6769 Project: Flink

[jira] [Commented] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

2017-05-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16028774#comment-16028774 ] ASF GitHub Bot commented on FLINK-6301: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #4015: [FLINK-6301] [flink-connector-kafka-0.10] Upgrading Kafka...

2017-05-30 Thread vidhu5269
Github user vidhu5269 commented on the issue: https://github.com/apache/flink/pull/4015 Hi @tzulitai Thanx for the quick reply. So far I have only gone through Kafka release notes for api compatibility check and worked with flink unit/integration tests to verify that nothing

[jira] [Assigned] (FLINK-6638) Allow overriding default value for all types when retrieving ConfigOption

2017-05-30 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6638: --- Assignee: Chesnay Schepler > Allow overriding default value for all types when

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2017-05-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16029212#comment-16029212 ] ASF GitHub Bot commented on FLINK-2055: --- Github user nragon commented on the issue:

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

2017-05-30 Thread nragon
Github user nragon commented on the issue: https://github.com/apache/flink/pull/2332 Indeed, I'm also not aware of how users use it. I would take a similiar approach than c*, already in made for streaming, seems to use a existing async api from datastax. But again, I couldn't find

[GitHub] flink pull request #4015: [FLINK-6301] [flink-connector-kafka-0.10] Upgradin...

2017-05-30 Thread vidhu5269
GitHub user vidhu5269 opened a pull request: https://github.com/apache/flink/pull/4015 [FLINK-6301] [flink-connector-kafka-0.10] Upgrading Kafka clients version to 0.10.2.0 You can merge this pull request into a Git repository by running: $ git pull

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

2017-05-30 Thread nragon
Github user nragon commented on the issue: https://github.com/apache/flink/pull/2332 No, only puts. Aggregation is coming from a reduce which by itself aggregates, keeping recent values on hbase, more like snapshots I think. During our analysis sending data to hbase was only reliable

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2017-05-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16028842#comment-16028842 ] ASF GitHub Bot commented on FLINK-2055: --- Github user nragon commented on the issue:

[jira] [Updated] (FLINK-6770) Add excludeSerializersInCheckpoints to ExecutionConfig

2017-05-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6770: --- Description: A {{excludeSerializersInCheckpoints}} setting should be added to the

[jira] [Commented] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

2017-05-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16029170#comment-16029170 ] ASF GitHub Bot commented on FLINK-6301: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #4015: [FLINK-6301] [flink-connector-kafka-0.10] Upgrading Kafka...

2017-05-30 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4015 Thanks for validating it on cluster execution. Please feel free to ping me on updates. Yes, I mean the dependencies that Maven pull in. Ideally, `mvn dependency:tree` should be identical

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

2017-05-30 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2332 So I think at a first level let us have put/delete mutations alone for Streaming ? Since am not aware of how flink users are currently interacting with HBase not sure on what HBase ops should be

[jira] [Comment Edited] (FLINK-6771) Create committer guide

2017-05-30 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16029207#comment-16029207 ] Till Rohrmann edited comment on FLINK-6771 at 5/30/17 9:26 AM: --- Thanks for

[jira] [Commented] (FLINK-6771) Create committer guide

2017-05-30 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16029207#comment-16029207 ] Till Rohrmann commented on FLINK-6771: -- Thanks for the pointer [~aljoscha]. That's exactly what I

[jira] [Created] (FLINK-6773) Use compression (e.g. snappy) for full check/savepoints

2017-05-30 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-6773: - Summary: Use compression (e.g. snappy) for full check/savepoints Key: FLINK-6773 URL: https://issues.apache.org/jira/browse/FLINK-6773 Project: Flink

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2017-05-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16028768#comment-16028768 ] ASF GitHub Bot commented on FLINK-2055: --- Github user ramkrish86 commented on the issue:

[jira] [Created] (FLINK-6768) Quadratic/Inefficient field lookup in PojoSerializer#ensureCompatibility

2017-05-30 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-6768: Summary: Quadratic/Inefficient field lookup in PojoSerializer#ensureCompatibility Key: FLINK-6768 URL: https://issues.apache.org/jira/browse/FLINK-6768 Project:

[jira] [Commented] (FLINK-6301) Flink KafkaConnector09 leaks memory on reading compressed messages due to a Kafka consumer bug

2017-05-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16028791#comment-16028791 ] ASF GitHub Bot commented on FLINK-6301: --- Github user vidhu5269 commented on the issue:

[jira] [Updated] (FLINK-6770) Add excludeSerializersInCheckpoints to ExecutionConfig

2017-05-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6770: --- Summary: Add excludeSerializersInCheckpoints to ExecutionConfig (was: Add

[jira] [Created] (FLINK-6770) Add excludeSerializersInCheckpoints to ExeuctionConfig

2017-05-30 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6770: -- Summary: Add excludeSerializersInCheckpoints to ExeuctionConfig Key: FLINK-6770 URL: https://issues.apache.org/jira/browse/FLINK-6770 Project: Flink

[jira] [Updated] (FLINK-6770) Add excludeSerializersInCheckpoints to ExecuctionConfig

2017-05-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6770: --- Summary: Add excludeSerializersInCheckpoints to ExecuctionConfig (was: Add

[GitHub] flink issue #4011: [FLINK-6766] Update documentation about async backends an...

2017-05-30 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4011 CC @rmetzger --- 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,

[jira] [Commented] (FLINK-6772) Incorrect ordering of matched state events in Flink CEP

2017-05-30 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16029288#comment-16029288 ] Dawid Wysakowicz commented on FLINK-6772: - Hmm, I could not reproduce this issue. I tried the

[jira] [Commented] (FLINK-6772) Incorrect ordering of matched state events in Flink CEP

2017-05-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16029303#comment-16029303 ] Tzu-Li (Gordon) Tai commented on FLINK-6772: So, for example, {code} public class

[jira] [Created] (FLINK-6774) build-helper-maven-plugin version not set

2017-05-30 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-6774: -- Summary: build-helper-maven-plugin version not set Key: FLINK-6774 URL: https://issues.apache.org/jira/browse/FLINK-6774 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-6774) build-helper-maven-plugin version not set

2017-05-30 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-6774: --- Issue Type: Bug (was: Improvement) > build-helper-maven-plugin version not set >

[jira] [Commented] (FLINK-6774) build-helper-maven-plugin version not set

2017-05-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16029418#comment-16029418 ] ASF GitHub Bot commented on FLINK-6774: --- GitHub user NicoK opened a pull request:

[GitHub] flink pull request #4017: [FLINK-6774][build] set missing build-helper-maven...

2017-05-30 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4017 [FLINK-6774][build] set missing build-helper-maven-plugin version this PR sets the version number on those sub-modules which did not set it yet You can merge this pull request into a Git repository

[jira] [Comment Edited] (FLINK-6772) Incorrect ordering of matched state events in Flink CEP

2017-05-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16029299#comment-16029299 ] Tzu-Li (Gordon) Tai edited comment on FLINK-6772 at 5/30/17 11:54 AM: --

[jira] [Comment Edited] (FLINK-6772) Incorrect ordering of matched state events in Flink CEP

2017-05-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16029299#comment-16029299 ] Tzu-Li (Gordon) Tai edited comment on FLINK-6772 at 5/30/17 11:54 AM: --

[jira] [Updated] (FLINK-6772) Incorrect ordering of matched state events in Flink CEP

2017-05-30 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-6772: -- Affects Version/s: 1.3.0 > Incorrect ordering of matched state events in Flink CEP >

[GitHub] flink pull request #4012: [FLINK-6746] [docs] Updated Table API / SQL docs: ...

2017-05-30 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4012#discussion_r119069469 --- Diff: docs/dev/table/common.md --- @@ -98,374 +89,767 @@ env.execute("Your Query") +**Note:** Table API and SQL queries can

[GitHub] flink pull request #4012: [FLINK-6746] [docs] Updated Table API / SQL docs: ...

2017-05-30 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4012#discussion_r119069339 --- Diff: docs/dev/table/common.md --- @@ -68,28 +63,24 @@ env.execute("Your Query"); {% highlight scala %} -val env =

[GitHub] flink pull request #4012: [FLINK-6746] [docs] Updated Table API / SQL docs: ...

2017-05-30 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4012#discussion_r119069314 --- Diff: docs/dev/table/common.md --- @@ -22,43 +22,38 @@ specific language governing permissions and limitations under the License. -->

[GitHub] flink pull request #4012: [FLINK-6746] [docs] Updated Table API / SQL docs: ...

2017-05-30 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4012#discussion_r119076101 --- Diff: docs/dev/table/common.md --- @@ -98,374 +89,767 @@ env.execute("Your Query") +**Note:** Table API and SQL queries can

[GitHub] flink pull request #4012: [FLINK-6746] [docs] Updated Table API / SQL docs: ...

2017-05-30 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4012#discussion_r119077032 --- Diff: docs/dev/table/common.md --- @@ -98,374 +89,767 @@ env.execute("Your Query") +**Note:** Table API and SQL queries can

[GitHub] flink pull request #4012: [FLINK-6746] [docs] Updated Table API / SQL docs: ...

2017-05-30 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4012#discussion_r118994536 --- Diff: docs/dev/table/common.md --- @@ -1,5 +1,5 @@ --- -title: "Concepts & Common API" +title: "Common Concepts & API" --- End

[GitHub] flink pull request #4012: [FLINK-6746] [docs] Updated Table API / SQL docs: ...

2017-05-30 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4012#discussion_r119071180 --- Diff: docs/dev/table/common.md --- @@ -98,374 +89,767 @@ env.execute("Your Query") +**Note:** Table API and SQL queries can

[GitHub] flink pull request #4012: [FLINK-6746] [docs] Updated Table API / SQL docs: ...

2017-05-30 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4012#discussion_r119070529 --- Diff: docs/dev/table/common.md --- @@ -98,374 +89,767 @@ env.execute("Your Query") +**Note:** Table API and SQL queries can

[GitHub] flink pull request #4012: [FLINK-6746] [docs] Updated Table API / SQL docs: ...

2017-05-30 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4012#discussion_r118994301 --- Diff: docs/dev/table/common.md --- @@ -22,43 +22,38 @@ specific language governing permissions and limitations under the License. -->

[jira] [Commented] (FLINK-6766) Update documentation with async backends and incremental checkpoints

2017-05-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16029345#comment-16029345 ] ASF GitHub Bot commented on FLINK-6766: --- Github user StefanRRichter commented on the issue:

[jira] [Commented] (FLINK-6772) Incorrect ordering of matched state events in Flink CEP

2017-05-30 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16029347#comment-16029347 ] Dawid Wysakowicz commented on FLINK-6772: - Ok I've tracked down the issue. It is caused by

[GitHub] flink issue #3911: [FLINK-6539] Add end-to-end tests

2017-05-30 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3911 @aljoscha why a hidden directory? --- 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

[jira] [Comment Edited] (FLINK-6772) Incorrect ordering of matched state events in Flink CEP

2017-05-30 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16029288#comment-16029288 ] Dawid Wysakowicz edited comment on FLINK-6772 at 5/30/17 11:35 AM: --- Hmm,

[jira] [Commented] (FLINK-6772) Incorrect ordering of matched state events in Flink CEP

2017-05-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16029299#comment-16029299 ] Tzu-Li (Gordon) Tai commented on FLINK-6772: Hmm, I've did another check on this, an had a

[jira] [Updated] (FLINK-6741) In yarn cluster model with high availableļ¼Œ the HDFS file is not deleted when cluster is shot down

2017-05-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6741: -- Component/s: YARN > In yarn cluster model with high availableļ¼Œ the HDFS file is not deleted

[jira] [Comment Edited] (FLINK-6772) Incorrect ordering of matched state events in Flink CEP

2017-05-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16029299#comment-16029299 ] Tzu-Li (Gordon) Tai edited comment on FLINK-6772 at 5/30/17 11:53 AM: --

[jira] [Comment Edited] (FLINK-6772) Incorrect ordering of matched state events in Flink CEP

2017-05-30 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16029299#comment-16029299 ] Tzu-Li (Gordon) Tai edited comment on FLINK-6772 at 5/30/17 11:53 AM: --

[GitHub] flink pull request #4012: [FLINK-6746] [docs] Updated Table API / SQL docs: ...

2017-05-30 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4012#discussion_r119067612 --- Diff: docs/dev/table/common.md --- @@ -22,43 +22,38 @@ specific language governing permissions and limitations under the License. -->

[jira] [Commented] (FLINK-6746) Table API / SQL Docs: Common Page

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

[jira] [Commented] (FLINK-6746) Table API / SQL Docs: Common Page

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

[GitHub] flink pull request #4012: [FLINK-6746] [docs] Updated Table API / SQL docs: ...

2017-05-30 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4012#discussion_r119079392 --- Diff: docs/dev/table/common.md --- @@ -98,374 +89,767 @@ env.execute("Your Query") +**Note:** Table API and SQL queries can

[GitHub] flink pull request #4012: [FLINK-6746] [docs] Updated Table API / SQL docs: ...

2017-05-30 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4012#discussion_r119078354 --- Diff: docs/dev/table/common.md --- @@ -98,374 +89,767 @@ env.execute("Your Query") +**Note:** Table API and SQL queries can

[jira] [Commented] (FLINK-6746) Table API / SQL Docs: Common Page

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

[GitHub] flink pull request #4012: [FLINK-6746] [docs] Updated Table API / SQL docs: ...

2017-05-30 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4012#discussion_r119077052 --- Diff: docs/dev/table/common.md --- @@ -98,374 +89,767 @@ env.execute("Your Query") +**Note:** Table API and SQL queries can

[GitHub] flink pull request #4012: [FLINK-6746] [docs] Updated Table API / SQL docs: ...

2017-05-30 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4012#discussion_r119077705 --- Diff: docs/dev/table/common.md --- @@ -98,374 +89,767 @@ env.execute("Your Query") +**Note:** Table API and SQL queries can

[jira] [Commented] (FLINK-6746) Table API / SQL Docs: Common Page

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

[GitHub] flink pull request #4012: [FLINK-6746] [docs] Updated Table API / SQL docs: ...

2017-05-30 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4012#discussion_r119066323 --- Diff: docs/dev/table/common.md --- @@ -22,43 +22,38 @@ specific language governing permissions and limitations under the License. -->

[jira] [Commented] (FLINK-6746) Table API / SQL Docs: Common Page

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

[GitHub] flink pull request #4012: [FLINK-6746] [docs] Updated Table API / SQL docs: ...

2017-05-30 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4012#discussion_r119078817 --- Diff: docs/dev/table/common.md --- @@ -98,374 +89,767 @@ env.execute("Your Query") +**Note:** Table API and SQL queries can

[jira] [Commented] (FLINK-6746) Table API / SQL Docs: Common Page

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

[jira] [Commented] (FLINK-6746) Table API / SQL Docs: Common Page

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

[jira] [Commented] (FLINK-6746) Table API / SQL Docs: Common Page

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

[jira] [Commented] (FLINK-6746) Table API / SQL Docs: Common Page

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

[jira] [Commented] (FLINK-6746) Table API / SQL Docs: Common Page

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

[jira] [Commented] (FLINK-6746) Table API / SQL Docs: Common Page

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

[jira] [Commented] (FLINK-6746) Table API / SQL Docs: Common Page

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

[jira] [Commented] (FLINK-6746) Table API / SQL Docs: Common Page

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

  1   2   >