[jira] [Commented] (FLINK-6328) Savepoints must not be counted as retained checkpoints

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

[GitHub] flink pull request #3965: [FLINK-6328] [chkPts] Don't add savepoints to Comp...

2017-05-22 Thread tony810430
Github user tony810430 commented on a diff in the pull request: https://github.com/apache/flink/pull/3965#discussion_r117902054 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -864,22 +864,28 @@ private void

[jira] [Assigned] (FLINK-6494) Migrate ResourceManager configuration options

2017-05-22 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6494: Assignee: Fang Yong > Migrate ResourceManager configuration options >

[jira] [Commented] (FLINK-6494) Migrate ResourceManager configuration options

2017-05-22 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16020675#comment-16020675 ] Fang Yong commented on FLINK-6494: -- Should configurations of yarn and mesos be moved to

[jira] [Resolved] (FLINK-6421) Unchecked reflection calls in PojoSerializer

2017-05-22 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-6421. --- Resolution: Not A Problem > Unchecked reflection calls in PojoSerializer >

[jira] [Updated] (FLINK-6422) Unreachable code in FileInputFormat#createInputSplits

2017-05-22 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6422: -- Description: Here is related code: {code} if (minNumSplits < 1) { throw new

[jira] [Commented] (FLINK-6467) Potential lack of synchronization w.r.t. newSstFiles in RocksDBKeyedStateBackend#releaseResources()

2017-05-22 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16020613#comment-16020613 ] Ted Yu commented on FLINK-6467: --- Alright. > Potential lack of synchronization w.r.t. newSstFiles in >

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

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

[jira] [Commented] (FLINK-6669) [Build] Scala style check errror on Windows

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

[GitHub] flink pull request #3967: [FLINK-6669] set inputEncoding to UTF-8 in scalast...

2017-05-22 Thread lingjinjiang
GitHub user lingjinjiang opened a pull request: https://github.com/apache/flink/pull/3967 [FLINK-6669] set inputEncoding to UTF-8 in scalastyle-maven-plugin When build the source code on Windows, a scala style check error happend. It may be caused by the Windows default

[jira] [Updated] (FLINK-6669) [Build] Scala style check errror on Windows

2017-05-22 Thread Jinjiang Ling (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jinjiang Ling updated FLINK-6669: - Attachment: FLINK-6669.patch > [Build] Scala style check errror on Windows >

[jira] [Created] (FLINK-6669) [Build] Scala style check errror on Windows

2017-05-22 Thread Jinjiang Ling (JIRA)
Jinjiang Ling created FLINK-6669: Summary: [Build] Scala style check errror on Windows Key: FLINK-6669 URL: https://issues.apache.org/jira/browse/FLINK-6669 Project: Flink Issue Type: Bug

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

2017-05-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16020414#comment-16020414 ] 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-05-22 Thread zohar-mizrahi
Github user zohar-mizrahi commented on the issue: https://github.com/apache/flink/pull/3838 In the last change, I've rebased locally on top of origin/master, so I did `git push -f` to the master branch in my fork. --- If your project is set up for it, you can reply to this email and

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

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

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

2017-05-22 Thread zohar-mizrahi
Github user zohar-mizrahi commented on a diff in the pull request: https://github.com/apache/flink/pull/3838#discussion_r117864592 --- Diff: flink-libraries/flink-streaming-python/pom.xml --- @@ -0,0 +1,99 @@ + +http://maven.apache.org/POM/4.0.0;

[jira] [Commented] (FLINK-6668) Add flink history server to DCOS

2017-05-22 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16020261#comment-16020261 ] Eron Wright commented on FLINK-6668: - [~skonto] I see this as related to the dispatcher work

[jira] [Commented] (FLINK-6668) Add flink history server to DCOS

2017-05-22 Thread Stavros Kontopoulos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16020233#comment-16020233 ] Stavros Kontopoulos commented on FLINK-6668: [~eronwright] what do you think? I created a

[jira] [Created] (FLINK-6668) Add flink history server to DCOS

2017-05-22 Thread Stavros Kontopoulos (JIRA)
Stavros Kontopoulos created FLINK-6668: -- Summary: Add flink history server to DCOS Key: FLINK-6668 URL: https://issues.apache.org/jira/browse/FLINK-6668 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-6660) expand the streaming connectors overview page

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

[GitHub] flink pull request #3964: [FLINK-6660][docs] expand the connectors overview ...

2017-05-22 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3964#discussion_r117838617 --- Diff: docs/dev/connectors/index.md --- @@ -25,22 +25,54 @@ specific language governing permissions and limitations under the License. -->

[jira] [Commented] (FLINK-6603) Enable checkstyle on test sources

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

[GitHub] flink issue #3941: [FLINK-6603] [streaming] Enable checkstyle on test source...

2017-05-22 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3941 @greghogan +1, feel free to merge it :) --- 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] [Commented] (FLINK-6659) RocksDBMergeIteratorTest, SavepointITCase leave temporary directories behind

2017-05-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16020110#comment-16020110 ] Chesnay Schepler commented on FLINK-6659: - + to remove the method. > RocksDBMergeIteratorTest,

[jira] [Commented] (FLINK-6659) RocksDBMergeIteratorTest, SavepointITCase leave temporary directories behind

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

[GitHub] flink issue #3962: [FLINK-6659] fix (some) unit tests leaving temporary data...

2017-05-22 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3962 +1. --- 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

[jira] [Commented] (FLINK-6446) Various improvements to the Web Frontend

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

[GitHub] flink pull request #3946: [FLINK-6446] Fix some small issues in the web UI

2017-05-22 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/3946 --- 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-6495) Migrate Akka configuration options

2017-05-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6495. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 302c6741f862f13c6ea3d5490a31fadc20e976c8

[jira] [Closed] (FLINK-6448) Web UI TaskManager view: Rename 'Free Memory' to 'JVM Heap'

2017-05-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6448. --- Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 1.3:

[jira] [Closed] (FLINK-6451) Web UI: Rename 'Metrics' view to 'Task Metrics'

2017-05-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6451. --- Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 1.3:

[jira] [Closed] (FLINK-6610) WebServer could not be created,when set the "jobmanager.web.submit.enable" to false

2017-05-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6610. --- Resolution: Fixed 1.3: f72b8737912f5546aa97c3cfcde86d9d1aebc60e 1.4:

[jira] [Closed] (FLINK-6450) Web UI Subtasks view for TaskManagers has a misleading name

2017-05-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6450. --- Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 1.3:

[jira] [Updated] (FLINK-6610) WebServer could not be created,when set the "jobmanager.web.submit.enable" to false

2017-05-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6610: Affects Version/s: 1.4.0 > WebServer could not be created,when set the

[jira] [Commented] (FLINK-6610) WebServer could not be created,when set the "jobmanager.web.submit.enable" to false

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

[jira] [Commented] (FLINK-6495) Migrate Akka configuration options

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

[GitHub] flink pull request #3935: [FLINK-6495] Migrate Akka configuration options

2017-05-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3935 --- 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 #3947: [FLINK-6610][web] Allow uploadDir to be null in We...

2017-05-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3947 --- 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] [Updated] (FLINK-3610) Scala DataStream#addSink returns Java DataStreamSink

2017-05-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-3610: Issue Type: Sub-task (was: Bug) Parent: FLINK-3957 > Scala DataStream#addSink

[jira] [Assigned] (FLINK-3448) WebRuntimeMonitor: Move initialization of handlers to start() method

2017-05-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-3448: --- Assignee: Chesnay Schepler (was: Maximilian Michels) > WebRuntimeMonitor: Move

[jira] [Commented] (FLINK-6320) Flakey JobManagerHAJobGraphRecoveryITCase

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

[GitHub] flink issue #3966: [FLINK-6320] fix unit test failing sometimes when deletin...

2017-05-22 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3966 +1 to merge. --- 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

[jira] [Commented] (FLINK-6537) Umbrella issue for fixes to incremental snapshots

2017-05-22 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1601#comment-1601 ] Gyula Fora commented on FLINK-6537: --- You can look at all the logs I have posted. For example:

[jira] [Created] (FLINK-6667) Pass a callback type to the RestartStrategy, rather than the full ExecutionGraph

2017-05-22 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-6667: --- Summary: Pass a callback type to the RestartStrategy, rather than the full ExecutionGraph Key: FLINK-6667 URL: https://issues.apache.org/jira/browse/FLINK-6667

[jira] [Created] (FLINK-6666) RestartStrategy should differentiate between types of recovery (global / local / resource missing)

2017-05-22 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-: --- Summary: RestartStrategy should differentiate between types of recovery (global / local / resource missing) Key: FLINK- URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Created] (FLINK-6665) Pass a ScheduledExecutorService to the RestartStrategy

2017-05-22 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-6665: --- Summary: Pass a ScheduledExecutorService to the RestartStrategy Key: FLINK-6665 URL: https://issues.apache.org/jira/browse/FLINK-6665 Project: Flink Issue

[jira] [Created] (FLINK-6664) Extend Restart Strategy for Fine-grained Recovery and missing Resources

2017-05-22 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-6664: --- Summary: Extend Restart Strategy for Fine-grained Recovery and missing Resources Key: FLINK-6664 URL: https://issues.apache.org/jira/browse/FLINK-6664 Project: Flink

[jira] [Commented] (FLINK-4112) Replace SuppressRestartException with disabling RestartStrategy

2017-05-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16019956#comment-16019956 ] Stephan Ewen commented on FLINK-4112: - Is this still relevant? Just asking, because the Exception is

[jira] [Commented] (FLINK-6654) missing maven dependency on "flink-shaded-hadoop2-uber" in flink-dist

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

[GitHub] flink issue #3960: [FLINK-6654][build] let 'flink-dist' properly depend on '...

2017-05-22 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3960 Thanks. The exclusion should not be necessary, since the `flink-shaded-hadoop2-uber` dependency shades everything into one jar and has no further dependencies. --- If your project is set up

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

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

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

2017-05-22 Thread zohar-mizrahi
Github user zohar-mizrahi commented on a diff in the pull request: https://github.com/apache/flink/pull/3838#discussion_r117807878 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java --- @@ -233,6 +234,20 @@ boolean holdsStillReference(String

[jira] [Commented] (FLINK-6662) ClassNotFoundException: o.a.f.r.j.t.JobSnapshottingSettings recovering job

2017-05-22 Thread Jared Stehler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16019914#comment-16019914 ] Jared Stehler commented on FLINK-6662: -- Yup, was just booting a new flink on 1.3 over an existing 1.2

[jira] [Commented] (FLINK-6662) ClassNotFoundException: o.a.f.r.j.t.JobSnapshottingSettings recovering job

2017-05-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16019911#comment-16019911 ] Stephan Ewen commented on FLINK-6662: - [~trohrm...@apache.org] What do you think about this issue? >

[jira] [Commented] (FLINK-6662) ClassNotFoundException: o.a.f.r.j.t.JobSnapshottingSettings recovering job

2017-05-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16019909#comment-16019909 ] Stephan Ewen commented on FLINK-6662: - Are you trying to let a Flink 1.3 recover a pending Job from an

[jira] [Commented] (FLINK-6659) RocksDBMergeIteratorTest, SavepointITCase leave temporary directories behind

2017-05-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16019905#comment-16019905 ] Stephan Ewen commented on FLINK-6659: - Should we just drop the

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

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

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

2017-05-22 Thread zohar-mizrahi
Github user zohar-mizrahi commented on a diff in the pull request: https://github.com/apache/flink/pull/3838#discussion_r117806756 --- Diff: flink-libraries/flink-streaming-python/src/main/java/org/apache/flink/streaming/python/api/environment/PythonStreamExecutionEnvironment.java

[jira] [Commented] (FLINK-6656) Migrate CEP PriorityQueue to MapState

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

[GitHub] flink issue #3961: [FLINK-6656] [cep] Change element PriorityQueue to MapSta...

2017-05-22 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/3961 Thanks for clarification! Z pozdrowieniami! / Cheers! Dawid Wysakowicz *Data/Software Engineer* Skype: dawid_wys | Twitter: @OneMoreCoder

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

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

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

2017-05-22 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3838#discussion_r117802052 --- Diff: flink-libraries/flink-streaming-python/src/main/java/org/apache/flink/streaming/python/api/datastream/PythonObjectInputStream2.java --- @@ -0,0

[jira] [Closed] (FLINK-6663) NPE on web startup when disabling web submissions

2017-05-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6663. --- Resolution: Duplicate > NPE on web startup when disabling web submissions >

[jira] [Updated] (FLINK-6662) ClassNotFoundException: o.a.f.r.j.t.JobSnapshottingSettings recovering job

2017-05-22 Thread Jared Stehler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jared Stehler updated FLINK-6662: - Description: Running flink mesos on 1.3-release branch, I'm seeing the following error on

[jira] [Updated] (FLINK-6663) NPE on web startup when disabling web submissions

2017-05-22 Thread Jared Stehler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jared Stehler updated FLINK-6663: - Description: The web frontend fails to start when I disable web submissions, with a null pointer

[jira] [Updated] (FLINK-6663) NPE on web startup when disabling web submissions

2017-05-22 Thread Jared Stehler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jared Stehler updated FLINK-6663: - Description: The web frontend fails to start when I disable web submissions, with a null pointer

[jira] [Created] (FLINK-6663) NPE on web startup when disabling web submissions

2017-05-22 Thread Jared Stehler (JIRA)
Jared Stehler created FLINK-6663: Summary: NPE on web startup when disabling web submissions Key: FLINK-6663 URL: https://issues.apache.org/jira/browse/FLINK-6663 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-6632) Fix parameter case sensitive error for test passing/rejecting filter API

2017-05-22 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-6632. - Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 Fixed in 1.4:

[GitHub] flink pull request #3944: [FLINK-6632][table]Improved the method BoolLiteral...

2017-05-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3944 --- 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-6632) Fix parameter case sensitive error for test passing/rejecting filter API

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

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

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

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

2017-05-22 Thread zohar-mizrahi
Github user zohar-mizrahi commented on a diff in the pull request: https://github.com/apache/flink/pull/3838#discussion_r117793843 --- Diff: flink-libraries/flink-streaming-python/src/main/java/org/apache/flink/streaming/python/api/environment/PythonStreamExecutionEnvironment.java

[jira] [Commented] (FLINK-6632) Fix parameter case sensitive error for test passing/rejecting filter API

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

[GitHub] flink issue #3944: [FLINK-6632][table]Improved the method BoolLiteral of Exp...

2017-05-22 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3944 Thanks @sunjincheng121. Yes, I think a keyword is a nicer approach. I will add it and merge your tests. --- If your project is set up for it, you can reply to this email and have your reply appear

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

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

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

2017-05-22 Thread zohar-mizrahi
Github user zohar-mizrahi commented on a diff in the pull request: https://github.com/apache/flink/pull/3838#discussion_r117788892 --- Diff: flink-libraries/flink-streaming-python/src/main/java/org/apache/flink/streaming/python/api/datastream/PythonObjectInputStream2.java --- @@

[jira] [Commented] (FLINK-6320) Flakey JobManagerHAJobGraphRecoveryITCase

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

[GitHub] flink pull request #3966: [FLINK-6320] fix unit test failing sometimes when ...

2017-05-22 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/3966 [FLINK-6320] fix unit test failing sometimes when deleting a temp dir use a JUnit rule with a `TemporaryFolder` instead which should fix this (alternatively, catching the exception may have fixed

[jira] [Comment Edited] (FLINK-6537) Umbrella issue for fixes to incremental snapshots

2017-05-22 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16019717#comment-16019717 ] Stefan Richter edited comment on FLINK-6537 at 5/22/17 4:19 PM: Which

[jira] [Updated] (FLINK-6662) ClassNotFoundException: o.a.f.r.j.t.JobSnapshottingSettings recovering job

2017-05-22 Thread Jared Stehler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jared Stehler updated FLINK-6662: - Description: Running flink mesos on 1.3-release branch, I'm seeing the following error on

[jira] [Created] (FLINK-6662) ClassNotFoundException: o.a.f.r.j.t.JobSnapshottingSettings recovering job

2017-05-22 Thread Jared Stehler (JIRA)
Jared Stehler created FLINK-6662: Summary: ClassNotFoundException: o.a.f.r.j.t.JobSnapshottingSettings recovering job Key: FLINK-6662 URL: https://issues.apache.org/jira/browse/FLINK-6662 Project:

[jira] [Updated] (FLINK-6662) ClassNotFoundException: o.a.f.r.j.t.JobSnapshottingSettings recovering job

2017-05-22 Thread Jared Stehler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jared Stehler updated FLINK-6662: - Affects Version/s: 1.3.0 > ClassNotFoundException: o.a.f.r.j.t.JobSnapshottingSettings recovering

[GitHub] flink issue #3961: [FLINK-6656] [cep] Change element PriorityQueue to MapSta...

2017-05-22 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/3961 Hi @dawidwys ! Your understanding is correct in the sense that it does not leverage to the fullest the fact of keys being returned in order. The reason is that this is valid only in RocksDB state

[jira] [Commented] (FLINK-6656) Migrate CEP PriorityQueue to MapState

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

[jira] [Commented] (FLINK-6482) Add nested serializers into configuration snapshots of composite serializers

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

[GitHub] flink issue #3937: [FLINK-6482] [core] Add nested serializers to config snap...

2017-05-22 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3937 Thanks a lot for the quick review and merge!! --- 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-6038) Add deep links to Apache Bahir Flink streaming connector documentations

2017-05-22 Thread David Anderson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16019728#comment-16019728 ] David Anderson commented on FLINK-6038: --- I can take this ticket if you like. I hope FLINK-6660 can

[jira] [Commented] (FLINK-6656) Migrate CEP PriorityQueue to MapState

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

[GitHub] flink issue #3961: [FLINK-6656] [cep] Change element PriorityQueue to MapSta...

2017-05-22 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/3961 Just a question from my side to understand this change better. Does it really leverage the fact of keys being returned in order? To evaluate `getSortedTimestamps` you need to iterate whole keySet

[jira] [Commented] (FLINK-6328) Savepoints must not be counted as retained checkpoints

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

[GitHub] flink pull request #3965: [FLINK-6328] [chkPts] Don't add savepoints to Comp...

2017-05-22 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/3965 [FLINK-6328] [chkPts] Don't add savepoints to CompletedCheckpointStore The lifecycle of savepoints is not managed by the CheckpointCoordinator and fully in the hand of the user. Therefore,

[jira] [Comment Edited] (FLINK-6537) Umbrella issue for fixes to incremental snapshots

2017-05-22 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16019717#comment-16019717 ] Stefan Richter edited comment on FLINK-6537 at 5/22/17 3:42 PM: Which

[jira] [Commented] (FLINK-6660) expand the streaming connectors overview page

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

[GitHub] flink pull request #3964: [FLINK-6660][docs] expand the connectors overview ...

2017-05-22 Thread alpinegizmo
GitHub user alpinegizmo opened a pull request: https://github.com/apache/flink/pull/3964 [FLINK-6660][docs] expand the connectors overview page Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

[jira] [Commented] (FLINK-6537) Umbrella issue for fixes to incremental snapshots

2017-05-22 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16019717#comment-16019717 ] Stefan Richter commented on FLINK-6537: --- Which exception is that exactly? And how does it happen all

[jira] [Created] (FLINK-6661) Merge "Subtasks" and "TaskManagers" view

2017-05-22 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6661: --- Summary: Merge "Subtasks" and "TaskManagers" view Key: FLINK-6661 URL: https://issues.apache.org/jira/browse/FLINK-6661 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-6482) Add nested serializers into configuration snapshots of composite serializers

2017-05-22 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6482. Resolution: Fixed Fixed for master via a7bc5de9b17dde793c6da0e7cb74af117148.

[jira] [Commented] (FLINK-6603) Enable checkstyle on test sources

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

[jira] [Commented] (FLINK-6446) Various improvements to the Web Frontend

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

[GitHub] flink issue #3941: [FLINK-6603] [streaming] Enable checkstyle on test source...

2017-05-22 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3941 @zentol added `EmptyLineSeparator` to the strict checkstyle. --- 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

  1   2   3   >