[jira] [Comment Edited] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer

2016-11-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629801#comment-15629801 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4022 at 11/2/16 5:48 PM: -

[jira] [Commented] (FLINK-4850) FlinkML - SVM predict Operation for Vector and not LaveledVector

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629649#comment-15629649 ] ASF GitHub Bot commented on FLINK-4850: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #2658: [FLINK-4850] [ml] FlinkML - SVM predict Operation for Vec...

2016-11-02 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2658 Thanks for your contribution @thvasilo. Changes look good. Will merge your PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Commented] (FLINK-4623) Create Physical Execution Plan of a DataStream

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629676#comment-15629676 ] ASF GitHub Bot commented on FLINK-4623: --- Github user fhueske commented on the issue:

[GitHub] flink issue #2720: [FLINK-4623] Create Physical Execution Plan of a DataStre...

2016-11-02 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2720 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

[GitHub] flink issue #2686: [FLINK-4743] The sqrt/power function not accept the real ...

2016-11-02 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2686 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 #2704: [FLINK-4943] ConfigConstants: YYARN -> YARN

2016-11-02 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2704 Thanks for the fix @Makman2! 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

[jira] [Comment Edited] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer

2016-11-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629801#comment-15629801 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4022 at 11/2/16 5:47 PM: -

[jira] [Commented] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer

2016-11-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629801#comment-15629801 ] Tzu-Li (Gordon) Tai commented on FLINK-4022: Hi [~StephanEwen], Right now, for subtasks that

[GitHub] flink issue #2637: [FLINK-4315] Deprecate Hadoop dependent methods in flink-...

2016-11-02 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2637 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-4315) Deprecate Hadoop dependent methods in flink-java

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629654#comment-15629654 ] ASF GitHub Bot commented on FLINK-4315: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629680#comment-15629680 ] ASF GitHub Bot commented on FLINK-4743: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-4943) flink-mesos/ConfigConstants: Typo: YYARN -> YARN

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629675#comment-15629675 ] ASF GitHub Bot commented on FLINK-4943: --- Github user fhueske commented on the issue:

[GitHub] flink issue #2684: Add EvaluateDataSet Operation for LabeledVector - This cl...

2016-11-02 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2684 Thanks for your contribution @tfournier314. I'm wondering whether we should introduce a new `EvaluateDataSetOperation` for the special case of a `LabeledVector`. Can't you easily

[jira] [Comment Edited] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer

2016-11-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629801#comment-15629801 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4022 at 11/2/16 5:48 PM: -

[GitHub] flink pull request #2658: [FLINK-4850] [ml] FlinkML - SVM predict Operation ...

2016-11-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2658 --- 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 issue #2743: [FLINK-4996] [core] Make CrossHint @Public

2016-11-02 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2743 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-4850) FlinkML - SVM predict Operation for Vector and not LaveledVector

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

[jira] [Resolved] (FLINK-4850) FlinkML - SVM predict Operation for Vector and not LaveledVector

2016-11-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4850. -- Resolution: Fixed Fixed via da991aebb038b13a2d34344cf456c32feb4222dd > FlinkML - SVM predict

[jira] [Commented] (FLINK-4996) Make CrossHint @Public

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629658#comment-15629658 ] ASF GitHub Bot commented on FLINK-4996: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-5000) Rename Methods in ManagedInitializationContext

2016-11-02 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15629745#comment-15629745 ] Aljoscha Krettek commented on FLINK-5000: - CC: [~srichter] > Rename Methods in

[jira] [Created] (FLINK-5000) Rename Methods in ManagedInitializationContext

2016-11-02 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5000: --- Summary: Rename Methods in ManagedInitializationContext Key: FLINK-5000 URL: https://issues.apache.org/jira/browse/FLINK-5000 Project: Flink Issue

[GitHub] flink pull request #2637: [FLINK-4315] Deprecate Hadoop dependent methods in...

2016-11-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2637 --- 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-4996) Make CrossHint @Public

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

[jira] [Commented] (FLINK-4943) flink-mesos/ConfigConstants: Typo: YYARN -> YARN

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

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

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

[jira] [Commented] (FLINK-4315) Deprecate Hadoop dependent methods in flink-java

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

[jira] [Commented] (FLINK-4623) Create Physical Execution Plan of a DataStream

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

[GitHub] flink pull request #2743: [FLINK-4996] [core] Make CrossHint @Public

2016-11-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2743 --- 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] [Closed] (FLINK-4996) Make CrossHint @Public

2016-11-02 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4996. Resolution: Fixed Fix Version/s: 1.1.4 Fixed for 1.2.0 with

[GitHub] flink pull request #2686: [FLINK-4743] The sqrt/power function not accept th...

2016-11-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2686 --- 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] [Created] (FLINK-5001) Ensure that the Kafka 0.9+ connector is compatible with kafka-consumer-groups.sh

2016-11-02 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5001: - Summary: Ensure that the Kafka 0.9+ connector is compatible with kafka-consumer-groups.sh Key: FLINK-5001 URL: https://issues.apache.org/jira/browse/FLINK-5001

[GitHub] flink pull request #2720: [FLINK-4623] Create Physical Execution Plan of a D...

2016-11-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2720 --- 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 #2704: [FLINK-4943] ConfigConstants: YYARN -> YARN

2016-11-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2704 --- 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] [Created] (FLINK-4993) Don't Allow Trigger.onMerge() to return TriggerResult

2016-11-02 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4993: --- Summary: Don't Allow Trigger.onMerge() to return TriggerResult Key: FLINK-4993 URL: https://issues.apache.org/jira/browse/FLINK-4993 Project: Flink

[GitHub] flink pull request #2686: [FLINK-4743] The sqrt/power function not accept th...

2016-11-02 Thread tonycox
Github user tonycox commented on a diff in the pull request: https://github.com/apache/flink/pull/2686#discussion_r86108721 --- Diff: flink-libraries/flink-table/src/main/java/org/apache/flink/api/table/functions/utils/MathFunctions.java --- @@ -0,0 +1,29 @@ +/* + *

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628465#comment-15628465 ] ASF GitHub Bot commented on FLINK-4743: --- Github user tonycox commented on a diff in the pull

[GitHub] flink issue #2737: [FLINK-4983] Web UI: Add favicon

2016-11-02 Thread Makman2
Github user Makman2 commented on the issue: https://github.com/apache/flink/pull/2737 > Could we enhance the favicon itself? Maybe we can use the grayscale / black-white version of the flink logo, could fit more into the default dashboard design^^ > Not sure how this

[jira] [Commented] (FLINK-4983) Web UI: Add favicon

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628490#comment-15628490 ] ASF GitHub Bot commented on FLINK-4983: --- Github user Makman2 commented on the issue:

[GitHub] flink issue #2734: Keytab & TLS support for Flink on Mesos Setup

2016-11-02 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2734 Thanks for your PR @vijikarthi! I'll try to check it out as soon as possible. --- 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] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628529#comment-15628529 ] ASF GitHub Bot commented on FLINK-4939: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink issue #2706: [FLINK-4945] KafkaConsumer logs wrong warning about confi...

2016-11-02 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2706 Thank you for fixing this. I'll merge the change. --- 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-4983) Web UI: Add favicon

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628667#comment-15628667 ] ASF GitHub Bot commented on FLINK-4983: --- Github user greghogan commented on the issue:

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628774#comment-15628774 ] ASF GitHub Bot commented on FLINK-4743: --- Github user wuchong commented on the issue:

[jira] [Commented] (FLINK-4398) Unstable test KvStateServerHandlerTest.testSimpleQuery

2016-11-02 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628492#comment-15628492 ] Ufuk Celebi commented on FLINK-4398: Adjusted the logging in 2b369d3 (master) and triggered some more

[GitHub] flink pull request #2683: [FLINK-4888][metrics] instantiated job manager met...

2016-11-02 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2683#discussion_r86119642 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1828,6 +1828,33 @@ class JobManager(

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628519#comment-15628519 ] ASF GitHub Bot commented on FLINK-4743: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the c...

2016-11-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2707#discussion_r86106408 --- Diff: flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java --- @@

[GitHub] flink pull request #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the c...

2016-11-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2707#discussion_r86106025 --- Diff: flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java --- @@

[jira] [Closed] (FLINK-4845) Fix Job Exceptions page

2016-11-02 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4845. --- Resolution: Fixed Fixed in d1fea26461c45cde6b03a2dfc5e3f41f18b4a2c5 > Fix Job Exceptions

[GitHub] flink pull request #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the c...

2016-11-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2707#discussion_r86109229 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java --- @@ -142,46 +184,62 @@ private void

[GitHub] flink pull request #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the c...

2016-11-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2707#discussion_r86108910 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java --- @@ -77,63 +86,96 @@ public

[jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628528#comment-15628528 ] ASF GitHub Bot commented on FLINK-4939: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628536#comment-15628536 ] ASF GitHub Bot commented on FLINK-4939: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the c...

2016-11-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2707#discussion_r86104959 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/CheckpointCommitter.java --- @@ -98,17 +89,19 @@ public void

[GitHub] flink pull request #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the c...

2016-11-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2707#discussion_r86109164 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java --- @@ -142,46 +184,62 @@ private void

[jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628534#comment-15628534 ] ASF GitHub Bot commented on FLINK-4939: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the c...

2016-11-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2707#discussion_r86108131 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java --- @@ -77,63 +86,96 @@ public

[GitHub] flink pull request #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the c...

2016-11-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2707#discussion_r86109187 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java --- @@ -142,46 +184,62 @@ private void

[jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628530#comment-15628530 ] ASF GitHub Bot commented on FLINK-4939: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the c...

2016-11-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2707#discussion_r86107282 --- Diff: flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java --- @@

[jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628531#comment-15628531 ] ASF GitHub Bot commented on FLINK-4939: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628538#comment-15628538 ] ASF GitHub Bot commented on FLINK-4939: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628525#comment-15628525 ] ASF GitHub Bot commented on FLINK-4939: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628522#comment-15628522 ] ASF GitHub Bot commented on FLINK-4939: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628532#comment-15628532 ] ASF GitHub Bot commented on FLINK-4939: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628527#comment-15628527 ] ASF GitHub Bot commented on FLINK-4939: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628535#comment-15628535 ] ASF GitHub Bot commented on FLINK-4939: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628524#comment-15628524 ] ASF GitHub Bot commented on FLINK-4939: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628526#comment-15628526 ] ASF GitHub Bot commented on FLINK-4939: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628539#comment-15628539 ] ASF GitHub Bot commented on FLINK-4939: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the c...

2016-11-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2707#discussion_r86109500 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java --- @@ -142,46 +184,62 @@ private void

[GitHub] flink pull request #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the c...

2016-11-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2707#discussion_r86107589 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java --- @@ -27,27 +26,30 @@ import

[GitHub] flink pull request #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the c...

2016-11-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2707#discussion_r86111394 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java --- @@ -77,63 +86,96 @@ public

[GitHub] flink pull request #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the c...

2016-11-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2707#discussion_r86109608 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java --- @@ -142,46 +184,62 @@ private void

[GitHub] flink pull request #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the c...

2016-11-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2707#discussion_r86108509 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java --- @@ -77,63 +86,96 @@ public

[GitHub] flink pull request #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the c...

2016-11-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2707#discussion_r86104979 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/CheckpointCommitter.java --- @@ -98,17 +89,19 @@ public void

[GitHub] flink pull request #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the c...

2016-11-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2707#discussion_r86110695 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java --- @@ -201,27 +259,83 @@ public void

[GitHub] flink pull request #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the c...

2016-11-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2707#discussion_r86110136 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java --- @@ -57,18 +59,25 @@ private

[GitHub] flink pull request #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the c...

2016-11-02 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2707#discussion_r86109012 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java --- @@ -77,63 +86,96 @@ public

[jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628523#comment-15628523 ] ASF GitHub Bot commented on FLINK-4939: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628533#comment-15628533 ] ASF GitHub Bot commented on FLINK-4939: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628537#comment-15628537 ] ASF GitHub Bot commented on FLINK-4939: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #2686: [FLINK-4743] The sqrt/power function not accept th...

2016-11-02 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2686#discussion_r86111954 --- Diff: flink-libraries/flink-table/src/main/java/org/apache/flink/api/table/functions/utils/MathFunctions.java --- @@ -0,0 +1,29 @@ +/* + *

[jira] [Closed] (FLINK-4398) Unstable test KvStateServerHandlerTest.testSimpleQuery

2016-11-02 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4398. -- Resolution: Fixed Fix Version/s: 1.2.0 Fixed in {{b4bf99d}} (master). > Unstable test

[jira] [Commented] (FLINK-4888) instantiated job manager metrics missing important job statistics

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628644#comment-15628644 ] ASF GitHub Bot commented on FLINK-4888: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink issue #2633: [FLINK-4497] CassadraSink support for scala tuples/case c...

2016-11-02 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2633 @StephanEwen I integrated all of your suggestions. --- 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-4497) Add support for Scala tuples and case classes to Cassandra sink

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628645#comment-15628645 ] ASF GitHub Bot commented on FLINK-4497: --- Github user zentol commented on the issue:

[GitHub] flink pull request #2686: [FLINK-4743] The sqrt/power function not accept th...

2016-11-02 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/2686#discussion_r86127428 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/table/expressions/ScalarFunctionsTest.scala --- @@ -377,11 +378,79 @@ class

[GitHub] flink issue #2737: [FLINK-4983] Web UI: Add favicon

2016-11-02 Thread siliconcat
Github user siliconcat commented on the issue: https://github.com/apache/flink/pull/2737 I just re-used the one in the main Flink site. No artist myself :) Not sure how this could break the build either? --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-4983) Web UI: Add favicon

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628385#comment-15628385 ] ASF GitHub Bot commented on FLINK-4983: --- Github user siliconcat commented on the issue:

[jira] [Commented] (FLINK-4923) Expose input/output buffers and bufferPool usage as a metric for a Task

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

[jira] [Commented] (FLINK-4845) Fix Job Exceptions page

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

[jira] [Closed] (FLINK-4923) Expose input/output buffers and bufferPool usage as a metric for a Task

2016-11-02 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4923. --- Resolution: Fixed Implemented in 344fe94db96ea44fa7714e105631eb192bb382e4 and

[GitHub] flink pull request #2722: [FLINK-4845] [runtime-web] Fix Job Exception page

2016-11-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2722 --- 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 #2727: [FLINK-4923] [Metrics] Initializes patch for Expos...

2016-11-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2727 --- 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-4945) KafkaConsumer logs wrong warning about confirmation for unknown checkpoint

2016-11-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15628604#comment-15628604 ] ASF GitHub Bot commented on FLINK-4945: --- Github user rmetzger commented on the issue:

[GitHub] flink issue #2737: [FLINK-4983] Web UI: Add favicon

2016-11-02 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2737 The Travis CI tests have never been stable. There are five parallel builds each split into two jobs and 9 of 10 passed for the latest commit on this PR. The tests are significantly more stable

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

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

[jira] [Closed] (FLINK-4943) flink-mesos/ConfigConstants: Typo: YYARN -> YARN

2016-11-02 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4943. Resolution: Fixed Assignee: Mischa Krüger Fix Version/s: 1.2.0 Fixed for 1.2.0 with

  1   2   3   >