[GitHub] flink pull request #3896: [FLINK-6370] [webUI] Handle races for single file ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3896#discussion_r116500027 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/files/StaticFileServerHandler.java --- @@ -234,8 +237,17 @@ private void

[jira] [Commented] (FLINK-6580) Flink on YARN doesnt start with default parameters

[ https://issues.apache.org/jira/browse/FLINK-6580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010575#comment-16010575 ] ASF GitHub Bot commented on FLINK-6580: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3900: [FLINK-6580] Sync default heap sizes from code wit...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3900 --- 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] [Resolved] (FLINK-6580) Flink on YARN doesnt start with default parameters

[ https://issues.apache.org/jira/browse/FLINK-6580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-6580. --- Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 Resolved for 1.3 in

[jira] [Commented] (FLINK-6580) Flink on YARN doesnt start with default parameters

[ https://issues.apache.org/jira/browse/FLINK-6580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010554#comment-16010554 ] ASF GitHub Bot commented on FLINK-6580: --- Github user zentol commented on the issue:

[GitHub] flink issue #3900: [FLINK-6580] Sync default heap sizes from code with confi...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3900 +1 to merge after you've changed it back to 1024. --- 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] [Closed] (FLINK-5777) Pass savepoint information to CheckpointingOperation

[ https://issues.apache.org/jira/browse/FLINK-5777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5777. -- Resolution: Fixed Fix Version/s: 1.3.0 Fixed in 6e7a91741708a2b167a2bbca5dda5b2059df5e18. >

[jira] [Reopened] (FLINK-5763) Make savepoints self-contained and relocatable

[ https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-5763: --- Assignee: (was: Ufuk Celebi) Afaik this issue is not done yet because

[jira] [Commented] (FLINK-6581) Dynamic property parsing broken for YARN

[ https://issues.apache.org/jira/browse/FLINK-6581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010539#comment-16010539 ] ASF GitHub Bot commented on FLINK-6581: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #3903: [FLINK-6581] [cli] Correct dynamic property parsing for Y...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3903 Thanks for the review @zentol. I'll address your comment and then merge the PR once Travis gives green light. --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-6581) Dynamic property parsing broken for YARN

[ https://issues.apache.org/jira/browse/FLINK-6581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010537#comment-16010537 ] ASF GitHub Bot commented on FLINK-6581: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #3903: [FLINK-6581] [cli] Correct dynamic property parsin...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3903#discussion_r116494377 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java --- @@ -702,9 +702,15 @@ private void logAndSysout(String

[jira] [Commented] (FLINK-6582) Project from maven archetype is not buildable by default due to ${scala.binary.version}

[ https://issues.apache.org/jira/browse/FLINK-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010533#comment-16010533 ] Dawid Wysakowicz commented on FLINK-6582: - Just out of curiosity I tried to create the archetype

[jira] [Commented] (FLINK-6582) Project from maven archetype is not buildable by default due to ${scala.binary.version}

[ https://issues.apache.org/jira/browse/FLINK-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010534#comment-16010534 ] ASF GitHub Bot commented on FLINK-6582: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3910: [FLINK-6582] [docs] Project from maven archetype is not b...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3910 @rmetzger what is happening in `create_release_files.sh:deploy_to_maven`? Are we overwriting the 2.11 quickstart jars with 2.10 jars? Are we still looking to publish against Scala 2.10 rather than

[jira] [Created] (FLINK-6589) ListSerializer should deserialize as ArrayList with size + 1

Fabian Hueske created FLINK-6589: Summary: ListSerializer should deserialize as ArrayList with size + 1 Key: FLINK-6589 URL: https://issues.apache.org/jira/browse/FLINK-6589 Project: Flink

[jira] [Commented] (FLINK-6582) Project from maven archetype is not buildable by default due to ${scala.binary.version}

[ https://issues.apache.org/jira/browse/FLINK-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010531#comment-16010531 ] Greg Hogan commented on FLINK-6582: --- Interesting that the newer version of the plugin is working for

[jira] [Commented] (FLINK-6582) Project from maven archetype is not buildable by default due to ${scala.binary.version}

[ https://issues.apache.org/jira/browse/FLINK-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010527#comment-16010527 ] ASF GitHub Bot commented on FLINK-6582: --- GitHub user greghogan opened a pull request:

[GitHub] flink pull request #3910: [FLINK-6582] [docs] Project from maven archetype i...

GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3910 [FLINK-6582] [docs] Project from maven archetype is not buildable by default The pom.xml for flink-quickstart-java and flink-quickstart-scala must specify scala.version and scala.binary.version.

[jira] [Commented] (FLINK-6580) Flink on YARN doesnt start with default parameters

[ https://issues.apache.org/jira/browse/FLINK-6580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010524#comment-16010524 ] ASF GitHub Bot commented on FLINK-6580: --- Github user rmetzger commented on the issue:

[jira] [Commented] (FLINK-6580) Flink on YARN doesnt start with default parameters

[ https://issues.apache.org/jira/browse/FLINK-6580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010522#comment-16010522 ] ASF GitHub Bot commented on FLINK-6580: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink issue #3900: [FLINK-6580] Sync default heap sizes from code with confi...

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3900 @zentol do you agree to merge this now. Its the last thing I would like to get into RC1. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[GitHub] flink pull request #3900: [FLINK-6580] Sync default heap sizes from code wit...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/3900#discussion_r116492253 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java --- @@ -62,7 +62,7 @@ */ public static final

[jira] [Updated] (FLINK-6582) Project from maven archetype is not buildable by default due to ${scala.binary.version}

[ https://issues.apache.org/jira/browse/FLINK-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6582: -- Fix Version/s: 1.4.0 > Project from maven archetype is not buildable by default due to >

[jira] [Commented] (FLINK-6288) FlinkKafkaProducer's custom Partitioner is always invoked with number of partitions of default topic

[ https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010516#comment-16010516 ] ASF GitHub Bot commented on FLINK-6288: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #3901: [FLINK-6288] fix FlinkKafkaProducer's custom Partitioner ...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3901 @zjureel my main concern is the need of our own timeout when Kafka has the `max.block.ms` configuration. This seems to be the max timeout you're talking about? --- If your project is set up for

[jira] [Issue Comment Deleted] (FLINK-6166) Broken quickstart for snapshots

[ https://issues.apache.org/jira/browse/FLINK-6166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6166: -- Comment: was deleted (was: [~aljoscha] when setting the plugin version the user is requested to

[jira] [Commented] (FLINK-6255) Remove PatternStream.getSideOutput()

[ https://issues.apache.org/jira/browse/FLINK-6255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010506#comment-16010506 ] Kostas Kloudas commented on FLINK-6255: --- This is the PR to address it

[jira] [Commented] (FLINK-6371) Return matched patterns as Map<String, List> instead of Map<String, T>

[ https://issues.apache.org/jira/browse/FLINK-6371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010509#comment-16010509 ] Kostas Kloudas commented on FLINK-6371: --- This is the PR that addresses it:

[jira] [Comment Edited] (FLINK-5753) CEP timeout handler.

[ https://issues.apache.org/jira/browse/FLINK-5753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010495#comment-16010495 ] Kostas Kloudas edited comment on FLINK-5753 at 5/15/17 1:23 PM: Yes. You

[jira] [Assigned] (FLINK-6582) Project from maven archetype is not buildable by default due to ${scala.binary.version}

[ https://issues.apache.org/jira/browse/FLINK-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reassigned FLINK-6582: - Assignee: Greg Hogan > Project from maven archetype is not buildable by default due to >

[jira] [Commented] (FLINK-6552) Side outputs don't allow differing output types

[ https://issues.apache.org/jira/browse/FLINK-6552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010498#comment-16010498 ] ASF GitHub Bot commented on FLINK-6552: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #3885: [FLINK-6552] Allow differing types for side output...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3885#discussion_r116488176 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java --- @@ -318,9 +318,10 @@ public void

[jira] [Commented] (FLINK-5753) CEP timeout handler.

[ https://issues.apache.org/jira/browse/FLINK-5753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010495#comment-16010495 ] Kostas Kloudas commented on FLINK-5753: --- Yes. You should add the

[jira] [Commented] (FLINK-6580) Flink on YARN doesnt start with default parameters

[ https://issues.apache.org/jira/browse/FLINK-6580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010494#comment-16010494 ] ASF GitHub Bot commented on FLINK-6580: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #3900: [FLINK-6580] Sync default heap sizes from code wit...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3900#discussion_r116487520 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java --- @@ -62,7 +62,7 @@ */ public static final

[jira] [Updated] (FLINK-6578) SharedBuffer creates self-loops when having elements with same value/timestamp.

[ https://issues.apache.org/jira/browse/FLINK-6578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-6578: -- Priority: Blocker (was: Major) > SharedBuffer creates self-loops when having elements with

[GitHub] flink issue #3900: [FLINK-6580] Sync default heap sizes from code with confi...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3900 nvm, found the reference to FLINK-5904 in the JIRA. --- 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-6580) Flink on YARN doesnt start with default parameters

[ https://issues.apache.org/jira/browse/FLINK-6580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010490#comment-16010490 ] ASF GitHub Bot commented on FLINK-6580: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-6580) Flink on YARN doesnt start with default parameters

[ https://issues.apache.org/jira/browse/FLINK-6580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010486#comment-16010486 ] ASF GitHub Bot commented on FLINK-6580: --- Github user zentol commented on the issue:

[GitHub] flink issue #3900: [FLINK-6580] Sync default heap sizes from code with confi...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3900 Do we know the underlying reason that is causing YARN to fail now? None of the config values seem to have changed in a long time. --- If your project is set up for it, you can reply to this email

[jira] [Commented] (FLINK-6582) Project from maven archetype is not buildable by default due to ${scala.binary.version}

[ https://issues.apache.org/jira/browse/FLINK-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010484#comment-16010484 ] Dawid Wysakowicz commented on FLINK-6582: - [~greghogan] No, I don't see a message you posted. The

[jira] [Commented] (FLINK-6578) SharedBuffer creates self-loops when having elements with same value/timestamp.

[ https://issues.apache.org/jira/browse/FLINK-6578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010482#comment-16010482 ] ASF GitHub Bot commented on FLINK-6578: --- GitHub user kl0u opened a pull request:

[GitHub] flink pull request #3909: [FLINK-6578] Fix self-loop handling in SharedBuffe...

GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/3909 [FLINK-6578] Fix self-loop handling in SharedBuffer. This RP addresses: FLINK-6371, FLINK-6536, FLINK-6255, and FLINK-6578. R @dawidwys You can merge this pull request into a Git repository

[jira] [Comment Edited] (FLINK-6582) Project from maven archetype is not buildable by default due to ${scala.binary.version}

[ https://issues.apache.org/jira/browse/FLINK-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010474#comment-16010474 ] Dawid Wysakowicz edited comment on FLINK-6582 at 5/15/17 1:11 PM: -- As for

[jira] [Commented] (FLINK-6581) Dynamic property parsing broken for YARN

[ https://issues.apache.org/jira/browse/FLINK-6581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010475#comment-16010475 ] ASF GitHub Bot commented on FLINK-6581: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #3903: [FLINK-6581] [cli] Correct dynamic property parsin...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3903#discussion_r116485611 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java --- @@ -702,9 +702,15 @@ private void logAndSysout(String message) {

[jira] [Commented] (FLINK-6582) Project from maven archetype is not buildable by default due to ${scala.binary.version}

[ https://issues.apache.org/jira/browse/FLINK-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010474#comment-16010474 ] Dawid Wysakowicz commented on FLINK-6582: - As for relation to [FLINK-6166], I don't think there is

[jira] [Commented] (FLINK-6582) Project from maven archetype is not buildable by default due to ${scala.binary.version}

[ https://issues.apache.org/jira/browse/FLINK-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010473#comment-16010473 ] Greg Hogan commented on FLINK-6582: --- [~dawidwys] how are you attributing the error to

[jira] [Commented] (FLINK-6582) Project from maven archetype is not buildable by default due to ${scala.binary.version}

[ https://issues.apache.org/jira/browse/FLINK-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010466#comment-16010466 ] Greg Hogan commented on FLINK-6582: --- I now see that this was filed as {{major}} and [~aljoscha] had

[jira] [Commented] (FLINK-6582) Project from maven archetype is not buildable by default due to ${scala.binary.version}

[ https://issues.apache.org/jira/browse/FLINK-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010459#comment-16010459 ] Dawid Wysakowicz commented on FLINK-6582: - I am using the one from documentation of SNAPSHOT:

[jira] [Commented] (FLINK-6439) Unclosed InputStream in OperatorSnapshotUtil#readStateHandle()

[ https://issues.apache.org/jira/browse/FLINK-6439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010454#comment-16010454 ] ASF GitHub Bot commented on FLINK-6439: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-6439) Unclosed InputStream in OperatorSnapshotUtil#readStateHandle()

[ https://issues.apache.org/jira/browse/FLINK-6439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010453#comment-16010453 ] ASF GitHub Bot commented on FLINK-6439: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #3904: [FLINK-6439] Fix close OutputStream && InputStream...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3904#discussion_r116483406 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/util/OperatorSnapshotUtil.java --- @@ -46,111 +46,113 @@ public static String

[GitHub] flink pull request #3904: [FLINK-6439] Fix close OutputStream && InputStream...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3904#discussion_r116483708 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/util/OperatorSnapshotUtil.java --- @@ -46,111 +46,113 @@ public static String

[jira] [Commented] (FLINK-5340) Add a metric exposing jobs uptimes

[ https://issues.apache.org/jira/browse/FLINK-5340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010443#comment-16010443 ] ASF GitHub Bot commented on FLINK-5340: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #3908: [FLINK-5340] Document job uptime/downtime/restartT...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3908 [FLINK-5340] Document job uptime/downtime/restartTime/fullRestarts me…  You can

[jira] [Commented] (FLINK-6582) Project from maven archetype is not buildable by default due to ${scala.binary.version}

[ https://issues.apache.org/jira/browse/FLINK-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010439#comment-16010439 ] Greg Hogan commented on FLINK-6582: --- [~dawidwys] thank for reporting this. What command are you using? I

[jira] [Commented] (FLINK-6166) Broken quickstart for snapshots

[ https://issues.apache.org/jira/browse/FLINK-6166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010438#comment-16010438 ] Greg Hogan commented on FLINK-6166: --- [~aljoscha] when setting the plugin version the user is requested

[jira] [Updated] (FLINK-6582) Project from maven archetype is not buildable by default due to ${scala.binary.version}

[ https://issues.apache.org/jira/browse/FLINK-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6582: -- Priority: Major (was: Blocker) > Project from maven archetype is not buildable by default due to >

[jira] [Commented] (FLINK-5340) Add a metric exposing jobs uptimes

[ https://issues.apache.org/jira/browse/FLINK-5340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010423#comment-16010423 ] Chesnay Schepler commented on FLINK-5340: - I'm adding the documentation for this now. > Add a

[jira] [Created] (FLINK-6588) Rename NumberOfFullRestarts metric

Chesnay Schepler created FLINK-6588: --- Summary: Rename NumberOfFullRestarts metric Key: FLINK-6588 URL: https://issues.apache.org/jira/browse/FLINK-6588 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6452) Structure Metrics menu in Web UI

[ https://issues.apache.org/jira/browse/FLINK-6452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010402#comment-16010402 ] Chesnay Schepler commented on FLINK-6452: - We recently modified the metric view to sort the

[jira] [Created] (FLINK-6587) Java Table API cannot parse function names starting with keywords

Timo Walther created FLINK-6587: --- Summary: Java Table API cannot parse function names starting with keywords Key: FLINK-6587 URL: https://issues.apache.org/jira/browse/FLINK-6587 Project: Flink

[jira] [Commented] (FLINK-6370) FileAlreadyExistsException on startup

[ https://issues.apache.org/jira/browse/FLINK-6370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010400#comment-16010400 ] ASF GitHub Bot commented on FLINK-6370: --- Github user dernasherbrezon commented on a diff in the pull

[jira] [Updated] (FLINK-6582) Project from maven archetype is not buildable by default due to ${scala.binary.version}

[ https://issues.apache.org/jira/browse/FLINK-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6582: Fix Version/s: 1.3.0 > Project from maven archetype is not buildable by default due to >

[GitHub] flink pull request #3896: [FLINK-6370] [webUI] Handle races for single file ...

Github user dernasherbrezon commented on a diff in the pull request: https://github.com/apache/flink/pull/3896#discussion_r116474287 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/files/StaticFileServerHandler.java --- @@ -234,8 +237,17 @@ private

[jira] [Updated] (FLINK-6582) Project from maven archetype is not buildable by default due to ${scala.binary.version}

[ https://issues.apache.org/jira/browse/FLINK-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6582: Priority: Blocker (was: Major) > Project from maven archetype is not buildable by default

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

[ https://issues.apache.org/jira/browse/FLINK-6537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010393#comment-16010393 ] Gyula Fora commented on FLINK-6537: --- Hi Stefan! Thank you for all the work :) I have tested your

[jira] [Commented] (FLINK-6586) InputGateMetrics#refreshAndGetMin returns Integer.MAX_VALUE for local channels

[ https://issues.apache.org/jira/browse/FLINK-6586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010383#comment-16010383 ] ASF GitHub Bot commented on FLINK-6586: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #3907: [FLINK-6586] InputGateMetrics return 0 as minimum ...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3907 [FLINK-6586] InputGateMetrics return 0 as minimum for local channels Should be merged for 1.3 and 1.4. You can merge this pull request into a Git repository by running: $ git pull

[jira] [Created] (FLINK-6586) InputGateMetrics#refreshAndGetMin returns Integer.MAX_VALUE for local channels

Chesnay Schepler created FLINK-6586: --- Summary: InputGateMetrics#refreshAndGetMin returns Integer.MAX_VALUE for local channels Key: FLINK-6586 URL: https://issues.apache.org/jira/browse/FLINK-6586

[jira] [Resolved] (FLINK-6579) Add proper support for BasicArrayTypeInfo

[ https://issues.apache.org/jira/browse/FLINK-6579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-6579. - Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 Fixed in 1.4:

[jira] [Commented] (FLINK-6579) Add proper support for BasicArrayTypeInfo

[ https://issues.apache.org/jira/browse/FLINK-6579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010376#comment-16010376 ] ASF GitHub Bot commented on FLINK-6579: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3902: [FLINK-6579] [table] Add proper support for BasicA...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3902 --- 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-6416) Potential divide by zero issue in InputGateMetrics#refreshAndGetAvg()

[ https://issues.apache.org/jira/browse/FLINK-6416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6416: Fix Version/s: 1.4.0 1.3.0 > Potential divide by zero issue in

[jira] [Commented] (FLINK-6416) Potential divide by zero issue in InputGateMetrics#refreshAndGetAvg()

[ https://issues.apache.org/jira/browse/FLINK-6416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010371#comment-16010371 ] ASF GitHub Bot commented on FLINK-6416: --- GitHub user zentol opened a pull request:

[jira] [Updated] (FLINK-6416) Potential divide by zero issue in InputGateMetrics#refreshAndGetAvg()

[ https://issues.apache.org/jira/browse/FLINK-6416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6416: Affects Version/s: 1.4.0 1.3.0 > Potential divide by zero issue in

[GitHub] flink pull request #3906: [FLINK-6416] Fix divide-by-zero in InputGateMetric...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3906 [FLINK-6416] Fix divide-by-zero in InputGateMetrics You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink 6416_metrics_zero

[jira] [Updated] (FLINK-6416) Potential divide by zero issue in InputGateMetrics#refreshAndGetAvg()

[ https://issues.apache.org/jira/browse/FLINK-6416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6416: Component/s: Metrics > Potential divide by zero issue in

[GitHub] flink issue #3902: [FLINK-6579] [table] Add proper support for BasicArrayTyp...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3902 Thanks @fhueske. 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

[jira] [Commented] (FLINK-6579) Add proper support for BasicArrayTypeInfo

[ https://issues.apache.org/jira/browse/FLINK-6579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010365#comment-16010365 ] ASF GitHub Bot commented on FLINK-6579: --- Github user twalthr commented on the issue:

[jira] [Assigned] (FLINK-6416) Potential divide by zero issue in InputGateMetrics#refreshAndGetAvg()

[ https://issues.apache.org/jira/browse/FLINK-6416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6416: --- Assignee: Chesnay Schepler > Potential divide by zero issue in

[jira] [Commented] (FLINK-6585) Table examples are not runnable in IDE

[ https://issues.apache.org/jira/browse/FLINK-6585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010352#comment-16010352 ] ASF GitHub Bot commented on FLINK-6585: --- GitHub user twalthr opened a pull request:

[GitHub] flink pull request #3905: [FLINK-6585] [table] Table examples are not runnab...

GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/3905 [FLINK-6585] [table] Table examples are not runnable in IDE Fixes a Maven issue. You can merge this pull request into a Git repository by running: $ git pull https://github.com/twalthr/flink

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010344#comment-16010344 ] ASF GitHub Bot commented on FLINK-6232: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3715: [FLINK-6232][Table]Support proctime inner equi-join b...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3715 The initial PR should have one commit. Following changes should be put as commits on top of the initial commit. But you are right, we should update the contribution guidelines to make this more

[GitHub] flink issue #3715: [FLINK-6232][Table]Support proctime inner equi-join b...

Github user hongyuhong commented on the issue: https://github.com/apache/flink/pull/3715 Hi @fhueske, Thanks for your reminding, i'm sorry that i forgot to ping you. I thought a PR could have only one commit, so i squash them to one, i will notice that. Thanks very much.

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010339#comment-16010339 ] ASF GitHub Bot commented on FLINK-6232: --- Github user hongyuhong commented on the issue:

[jira] [Assigned] (FLINK-6585) Table examples are not runnable in IDE

[ https://issues.apache.org/jira/browse/FLINK-6585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-6585: --- Assignee: Timo Walther > Table examples are not runnable in IDE >

[jira] [Created] (FLINK-6585) Table examples are not runnable in IDE

Timo Walther created FLINK-6585: --- Summary: Table examples are not runnable in IDE Key: FLINK-6585 URL: https://issues.apache.org/jira/browse/FLINK-6585 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-6020) Blob Server cannot handle multiple job submits (with same content) parallelly

[ https://issues.apache.org/jira/browse/FLINK-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010300#comment-16010300 ] ASF GitHub Bot commented on FLINK-6020: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #3888: [FLINK-6020] Introduce BlobServer#readWriteLock to synchr...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3888 Thanks for the quick review @StefanRRichter. I will address your comment and also add a test case for the delete path. --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-6058) Don't read DEFAULT_PARALLELISM from GlobalConfiguration

[ https://issues.apache.org/jira/browse/FLINK-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010297#comment-16010297 ] ASF GitHub Bot commented on FLINK-6058: --- Github user fanyon closed the pull request at:

[GitHub] flink pull request #3561: [FLINK-6058] fix read DEFAULT_PARALLELISM from Con...

Github user fanyon closed the pull request at: https://github.com/apache/flink/pull/3561 --- 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-6579) Add proper support for BasicArrayTypeInfo

[ https://issues.apache.org/jira/browse/FLINK-6579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010294#comment-16010294 ] ASF GitHub Bot commented on FLINK-6579: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-6346) Migrate from Java serialization for GenericWriteAheadSink's state

[ https://issues.apache.org/jira/browse/FLINK-6346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010295#comment-16010295 ] ASF GitHub Bot commented on FLINK-6346: --- Github user fanyon closed the pull request at:

[jira] [Commented] (FLINK-6020) Blob Server cannot handle multiple job submits (with same content) parallelly

[ https://issues.apache.org/jira/browse/FLINK-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16010293#comment-16010293 ] ASF GitHub Bot commented on FLINK-6020: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink issue #3902: [FLINK-6579] [table] Add proper support for BasicArrayTyp...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3902 LGTM --- 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 pull request #3812: [FLINK-6346] Migrate from Java serialization for G...

Github user fanyon closed the pull request at: https://github.com/apache/flink/pull/3812 --- 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

<    1   2   3   4   5   >