[jira] [Commented] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API

[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15695133#comment-15695133 ] Alexander Shoshin commented on FLINK-3133: -- [~mxm], hi. Can you answer my previous question

[jira] [Commented] (FLINK-5002) Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers

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

[GitHub] flink pull request #2865: [FLINK-5002] Renamed getNumberOfUsedBuffers() meth...

GitHub user MayerRoman opened a pull request: https://github.com/apache/flink/pull/2865 [FLINK-5002] Renamed getNumberOfUsedBuffers() method to bestEffortGetNumOfUsedBuffers(), add a test to check that it does not return a negative value [FLINK-5002] Lack of synchronization in

[jira] [Assigned] (FLINK-1536) Graph partitioning operators for Gelly

[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-1536: - Assignee: Ivan Mushketyk > Graph partitioning operators for Gelly >

[jira] [Commented] (FLINK-4649) Implement bipartite graph metrics

[ https://issues.apache.org/jira/browse/FLINK-4649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15694318#comment-15694318 ] Ivan Mushketyk commented on FLINK-4649: --- Implemented here:

[jira] [Resolved] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

[ https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-3702. --- Resolution: Fixed Fix Version/s: 1.2.0 Fixed via 1f04542 and 870e219. > DataStream

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

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

[GitHub] flink pull request #2094: [FLINK-3702] Make FieldAccessors support nested fi...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2094 --- 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 #2804: [FLINK-5067] Make Flink compile with 1.8 Java compiler

Github user melentye commented on the issue: https://github.com/apache/flink/pull/2804 @StephanEwen it seems that the semantics is different when java.version is just defined in pom.xml versus being overriden with -Djava.version=x.y.z argument passed to mvn.

[jira] [Commented] (FLINK-5067) Make Flink compile with 1.8 Java compiler

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

[jira] [Commented] (FLINK-4913) Per-job Yarn clusters: include user jar in system class loader

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

[GitHub] flink issue #2795: Revert "[FLINK-4913][yarn] include user jars in system cl...

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2795 Rebased and pushed to travis again: https://travis-ci.org/rmetzger/flink/builds/178664750 --- 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 #2856: Removed excessive tests.

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2856 --- 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-5055) Security feature crashes JM for certain Hadoop versions even though using no Kerberos

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

[GitHub] flink pull request #2864: [FLINK-5055][security] skip Hadoop UGI login if un...

GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2864 [FLINK-5055][security] skip Hadoop UGI login if unsecured The new Kerberos authentication code in Flink assumed that it's running against vanilla Hadoop. Original Hadoop's behavior is to skip a secure

[jira] [Commented] (FLINK-4541) Support for SQL NOT IN operator

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

[GitHub] flink issue #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user AlexanderShoshin commented on the issue: https://github.com/apache/flink/pull/2811 Sure, I will do it tomorrow :) --- 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-5051) Backwards compatibility for serializers in backend state

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

[GitHub] flink issue #2863: [FLINK-5051] Backwards compatibility for serializers in b...

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/2863 R @aljoscha and whoever is interested. --- 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-5051) Backwards compatibility for serializers in backend state

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

[GitHub] flink pull request #2863: [FLINK-5051] Backwards compatibility for serialize...

GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/2863 [FLINK-5051] Backwards compatibility for serializers in backend state This PR sits on top of PR #2781 and introduces backwards compatibility for state serializers in keyed backends. We do so

[jira] [Commented] (FLINK-4541) Support for SQL NOT IN operator

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

[GitHub] flink issue #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2811 It's true, the requirements of this issue have evolved quite a bit and we should adapt the JIRA issue for that ;-) +1 for creating an issue to support arbitrary inner joins with a single row

[GitHub] flink issue #2664: [FLINK-4861] [build] Package optional project artifacts

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2664 I had the same thought. We could add the maven assembly plugin / shade plugin to each connector / library to build a fat jar, and then add some logic to flink-dist to collect these fat jars into

[jira] [Commented] (FLINK-4861) Package optional project artifacts

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

[jira] [Assigned] (FLINK-5158) Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator

[ https://issues.apache.org/jira/browse/FLINK-5158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-5158: Assignee: Till Rohrmann > Handle ZooKeeperCompletedCheckpointStore exceptions in

[jira] [Created] (FLINK-5158) Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator

Till Rohrmann created FLINK-5158: Summary: Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator Key: FLINK-5158 URL: https://issues.apache.org/jira/browse/FLINK-5158 Project:

[GitHub] flink issue #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user AlexanderShoshin commented on the issue: https://github.com/apache/flink/pull/2811 I think, that calling a JoinFunction inside a RichMapRunner make sence. I would also prefer not to touch the code generation if it's possible. But shouldn't we separate the support of

[jira] [Commented] (FLINK-4541) Support for SQL NOT IN operator

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

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15693565#comment-15693565 ] Ivan Mushketyk commented on FLINK-2254: --- Hi [~vkalavri] Thank you for your advice I've implemented

[jira] [Comment Edited] (FLINK-2254) Add Bipartite Graph Support for Gelly

[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15693565#comment-15693565 ] Ivan Mushketyk edited comment on FLINK-2254 at 11/24/16 3:40 PM: - Hi

[jira] [Commented] (FLINK-4741) WebRuntimeMonitor does not shut down all of it's threads (EventLoopGroups) on exit.

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

[GitHub] flink pull request #2862: [FLINK-4741] Fix for the proper shutdown the Serve...

GitHub user MayerRoman opened a pull request: https://github.com/apache/flink/pull/2862 [FLINK-4741] Fix for the proper shutdown the ServerBootstrap in the process of stopping the WebRuntumeMonitor [FLINK-4741] WebRuntimeMonitor does not shut down all of it's threads

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

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

[GitHub] flink issue #2564: [FLINK-2254] Add BipartiateGraph class

Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2564 @vasia I don't think anybody is shepherding this PR :) --- 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

[GitHub] flink issue #2664: [FLINK-4861] [build] Package optional project artifacts

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2664 How about just building a fat jar for each connector / library? That way it becomes quite easy for users - they simply refer to one jar. --- If your project is set up for it, you can reply

[jira] [Commented] (FLINK-4861) Package optional project artifacts

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

[jira] [Created] (FLINK-5157) Extending AllWindow Function Metadata

Ventura Del Monte created FLINK-5157: Summary: Extending AllWindow Function Metadata Key: FLINK-5157 URL: https://issues.apache.org/jira/browse/FLINK-5157 Project: Flink Issue Type: New

[GitHub] flink issue #2856: Removed excessive tests.

Github user chermenin commented on the issue: https://github.com/apache/flink/pull/2856 Done. --- 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-4712) Implementing ranking predictions for ALS

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

[GitHub] flink pull request #2838: [FLINK-4712] [FLINK-4713] [ml] Ranking recommendat...

Github user gaborhermann commented on a diff in the pull request: https://github.com/apache/flink/pull/2838#discussion_r89503899 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/pipeline/Predictor.scala --- @@ -72,14 +77,142 @@ trait Predictor[Self] extends

[jira] [Commented] (FLINK-4450) update storm version to 1.0.0

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

[jira] [Commented] (FLINK-5055) Security feature crashes JM for certain Hadoop versions even though using no Kerberos

[ https://issues.apache.org/jira/browse/FLINK-5055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15693362#comment-15693362 ] Maximilian Michels commented on FLINK-5055: --- That seems like a logical explanation. However,

[jira] [Commented] (FLINK-4712) Implementing ranking predictions for ALS

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

[GitHub] flink issue #2838: [FLINK-4712] [FLINK-4713] [ml] Ranking recommendation & e...

Github user gaborhermann commented on the issue: https://github.com/apache/flink/pull/2838 Thanks again for taking a look at our PR! I've just realized from a developer mailing list thread that the FlinkML API is still not carved into stone even until 2.0, and it's nice to

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2439 Thanks! You can squash commits by rebasing. Have a look here: http://gitready.com/advanced/2009/02/10/squashing-commits-with-rebase.html --- If your project is set up for it, you can

[jira] [Assigned] (FLINK-5055) Security feature crashes JM for certain Hadoop versions even though using no Kerberos

[ https://issues.apache.org/jira/browse/FLINK-5055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-5055: - Assignee: Maximilian Michels > Security feature crashes JM for certain Hadoop

[jira] [Commented] (FLINK-4450) update storm version to 1.0.0

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

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

Github user liuyuzhong commented on the issue: https://github.com/apache/flink/pull/2439 Complie error is fixed. But how to squash all commits into one commit? --- 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] [Created] (FLINK-5156) Consolidate streaming FieldAccessor functionality

Márton Balassi created FLINK-5156: - Summary: Consolidate streaming FieldAccessor functionality Key: FLINK-5156 URL: https://issues.apache.org/jira/browse/FLINK-5156 Project: Flink Issue

[jira] [Commented] (FLINK-4997) Extending Window Function Metadata

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

[GitHub] flink issue #2756: [FLINK-4997] Extending Window Function Metadata

Github user VenturaDelMonte commented on the issue: https://github.com/apache/flink/pull/2756 @manuzhang thank you for your feedback and no problem! @aljoscha 👍 --- 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-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

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

[GitHub] flink issue #2094: [FLINK-3702] Make FieldAccessors support nested field exp...

Github user mbalassi commented on the issue: https://github.com/apache/flink/pull/2094 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

[jira] [Commented] (FLINK-4712) Implementing ranking predictions for ALS

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

[GitHub] flink pull request #2838: [FLINK-4712] [FLINK-4713] [ml] Ranking recommendat...

Github user gaborhermann commented on a diff in the pull request: https://github.com/apache/flink/pull/2838#discussion_r89489117 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/pipeline/Predictor.scala --- @@ -72,14 +77,142 @@ trait Predictor[Self] extends

[jira] [Commented] (FLINK-4541) Support for SQL NOT IN operator

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

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89461812 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowCrossRule.scala --- @@ -0,0 +1,83 @@

[jira] [Commented] (FLINK-4541) Support for SQL NOT IN operator

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

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89486698 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowCrossRule.scala --- @@ -0,0 +1,83 @@

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89480684 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala --- @@ -0,0 +1,180 @@ +/*

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89480767 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala --- @@ -0,0 +1,180 @@ +/*

[jira] [Commented] (FLINK-4541) Support for SQL NOT IN operator

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

[jira] [Commented] (FLINK-4541) Support for SQL NOT IN operator

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

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89465992 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala --- @@ -0,0 +1,180 @@ +/*

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89483310 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala --- @@ -0,0 +1,180 @@ +/*

[jira] [Commented] (FLINK-4541) Support for SQL NOT IN operator

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

[jira] [Commented] (FLINK-4541) Support for SQL NOT IN operator

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

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89483428 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/RichMapRunner.scala --- @@ -0,0 +1,52 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-4541) Support for SQL NOT IN operator

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

[jira] [Commented] (FLINK-4541) Support for SQL NOT IN operator

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

[jira] [Commented] (FLINK-4541) Support for SQL NOT IN operator

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

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89462392 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/RichMapRunner.scala --- @@ -0,0 +1,52 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-4541) Support for SQL NOT IN operator

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

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89480259 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala --- @@ -0,0 +1,180 @@ +/*

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89482516 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala --- @@ -0,0 +1,180 @@ +/*

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89483891 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/RichMapRunner.scala --- @@ -0,0 +1,52 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-4541) Support for SQL NOT IN operator

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

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89466031 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowCrossRule.scala --- @@ -0,0 +1,83 @@

[jira] [Commented] (FLINK-4541) Support for SQL NOT IN operator

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

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89461025 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowCrossRule.scala --- @@ -0,0 +1,83 @@

[GitHub] flink pull request #2811: [FLINK-4541] Support for SQL NOT IN operator

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89465952 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala --- @@ -0,0 +1,180 @@ +/*

[jira] [Closed] (FLINK-5154) Duplicate TypeSerializer when writing RocksDB Snapshot

[ https://issues.apache.org/jira/browse/FLINK-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5154. --- Resolution: Not A Problem > Duplicate TypeSerializer when writing RocksDB Snapshot >

[jira] [Updated] (FLINK-5155) Deprecate ValueStateDescriptor constructors with default value

[ https://issues.apache.org/jira/browse/FLINK-5155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5155: Description: Having the default value in the descriptor is problematic with some

[jira] [Created] (FLINK-5155) Deprecate ValueStateDescriptor constructors with default value

Aljoscha Krettek created FLINK-5155: --- Summary: Deprecate ValueStateDescriptor constructors with default value Key: FLINK-5155 URL: https://issues.apache.org/jira/browse/FLINK-5155 Project: Flink

[jira] [Commented] (FLINK-4861) Package optional project artifacts

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

[GitHub] flink issue #2664: [FLINK-4861] [build] Package optional project artifacts

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2664 I thought that transitive dependencies are resolved in the scope of assembly descriptors. But I'm not so sure about that anymore. --- If your project is set up for it, you can reply to this email

[jira] [Created] (FLINK-5154) Duplicate TypeSerializer when writing RocksDB Snapshot

Aljoscha Krettek created FLINK-5154: --- Summary: Duplicate TypeSerializer when writing RocksDB Snapshot Key: FLINK-5154 URL: https://issues.apache.org/jira/browse/FLINK-5154 Project: Flink

[jira] [Commented] (FLINK-5096) Make the RollingSink rescalable.

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

[GitHub] flink issue #2845: [FLINK-5096] Make the RollingSink rescalable.

Github user kl0u commented on the issue: https://github.com/apache/flink/pull/2845 Thanks for the review @zentol ! I integrated your comments and rebased to the master. Let's see what travis has to say and then merge it if you have no further comments ;) --- If your project is

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15693008#comment-15693008 ] Fabian Hueske commented on FLINK-4565: -- Great! Looking forward to it. > Support for SQL IN operator

[GitHub] flink issue #2856: Removed excessive tests.

Github user chermenin commented on the issue: https://github.com/apache/flink/pull/2856 I removed a method from ITCase only. There is `testJavaArraysAsList` method in `KryoCollectionsSerializerTest` class to check it. Yep, before merging #2623, they have not been successful. --- If

[jira] [Commented] (FLINK-5075) Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite

[ https://issues.apache.org/jira/browse/FLINK-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15692971#comment-15692971 ] Tzu-Li (Gordon) Tai commented on FLINK-5075: Resolved for {{master}} via

[jira] [Updated] (FLINK-5075) Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite

[ https://issues.apache.org/jira/browse/FLINK-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-5075: --- Fix Version/s: 1.1.4 > Kinesis consumer incorrectly determines shards as newly

[jira] [Resolved] (FLINK-5075) Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite

[ https://issues.apache.org/jira/browse/FLINK-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-5075. Resolution: Fixed > Kinesis consumer incorrectly determines shards as newly

[jira] [Updated] (FLINK-5075) Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite

[ https://issues.apache.org/jira/browse/FLINK-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-5075: --- Fix Version/s: 1.2.0 > Kinesis consumer incorrectly determines shards as newly

[GitHub] flink issue #2822: [FLINK-5075] [kinesis] Make Kinesis consumer fail-proof t...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2822 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

[jira] [Commented] (FLINK-5075) Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite

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

[GitHub] flink pull request #2822: [FLINK-5075] [kinesis] Make Kinesis consumer fail-...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2822 --- 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-5075) Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite

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

  1   2   >