Github user chobeat commented on a diff in the pull request:
https://github.com/apache/flink/pull/2149#discussion_r7389
--- Diff: docs/apis/cli.md ---
@@ -187,6 +187,8 @@ Action "run" compiles and runs a program.
[
https://issues.apache.org/jira/browse/FLINK-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15469960#comment-15469960
]
ASF GitHub Bot commented on FLINK-3042:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15469963#comment-15469963
]
ASF GitHub Bot commented on FLINK-4084:
---
Github user chobeat commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470051#comment-15470051
]
ASF GitHub Bot commented on FLINK-4547:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2455#discussion_r77782622
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaInvocationHandler.java
---
@@ -189,7 +191,49 @@ public void stop() {
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2452
@liuyuzhong Let's wait a couple more days for the community to respond. You
don't have to close the PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470412#comment-15470412
]
Simone Robutti commented on FLINK-4565:
---
The resulting API should look like `ds1.join(ds2).where('a
[
https://issues.apache.org/jira/browse/FLINK-4506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirill Morozov reassigned FLINK-4506:
-
Assignee: Kirill Morozov
> CsvOutputFormat defaults allowNullValues to false, even
GitHub user kirill-morozov-epam opened a pull request:
https://github.com/apache/flink/pull/2477
[FLINK-4506] CsvOutputFormat defaults allowNullValues to false, even â¦
You can merge this pull request into a Git repository by running:
$ git pull
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470437#comment-15470437
]
Fabian Hueske commented on FLINK-4565:
--
I thought rather of something like this: {{ds1.where('a in
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470472#comment-15470472
]
Simone Robutti commented on FLINK-4565:
---
That's exactly why I'm asking it: I had no idea what to use
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470536#comment-15470536
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2443#discussion_r77821528
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
---
@@ -105,7 +106,9 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470419#comment-15470419
]
ramkrishna.s.vasudevan commented on FLINK-3322:
---
I am able to handle cases for the iterative
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2443#discussion_r77814628
--- Diff:
flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/MeterView.java
---
@@ -0,0 +1,70 @@
+/*
+ * Licensed to the
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2443
Overall a good change.
Once my two comments are addressed, +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
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470566#comment-15470566
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user rmetzger commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470488#comment-15470488
]
ASF GitHub Bot commented on FLINK-4506:
---
GitHub user kirill-morozov-epam opened a pull request:
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2443#discussion_r77815865
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
---
@@ -105,7 +106,9 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470554#comment-15470554
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470397#comment-15470397
]
ASF GitHub Bot commented on FLINK-4589:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/2476
[FLINK-4589] Fix Merging of Covering Window in MergingWindowSet
This also adds two new test cases for that problem.
R: @StephanEwen
You can merge this pull request into a Git repository
Timo Walther created FLINK-4591:
---
Summary: Select star does not work with grouping
Key: FLINK-4591
URL: https://issues.apache.org/jira/browse/FLINK-4591
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470653#comment-15470653
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user rmetzger commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2463#discussion_r77787126
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/LeaderIdRegistry.java
---
@@ -15,11 +15,27 @@
* See the License
[
https://issues.apache.org/jira/browse/FLINK-4538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470114#comment-15470114
]
ASF GitHub Bot commented on FLINK-4538:
---
Github user tillrohrmann commented on a diff in the pull
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2452
@mxm OK.
---
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
Aljoscha Krettek created FLINK-4588:
---
Summary: Fix Merging of Covering Window in MergingWindowSet
Key: FLINK-4588
URL: https://issues.apache.org/jira/browse/FLINK-4588
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4579:
-
Issue Type: Improvement (was: Bug)
> Add StateBackendFactory for RocksDB Backend
>
Aljoscha Krettek created FLINK-4589:
---
Summary: Fix Merging of Covering Window in MergingWindowSet
Key: FLINK-4589
URL: https://issues.apache.org/jira/browse/FLINK-4589
Project: Flink
Issue
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2337#discussion_r7227
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/TypeInformation.java
---
@@ -122,14 +123,25 @@
public abstract Class
Github user beyond1920 commented on the issue:
https://github.com/apache/flink/pull/2455
@tillrohrmann @StephanEwen , thanks for your review. I changed the code
based on your comment, including two points:
1. Change the JIRA and the PR subject line to better reflect the actual
[
https://issues.apache.org/jira/browse/FLINK-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15469997#comment-15469997
]
ASF GitHub Bot commented on FLINK-4547:
---
Github user beyond1920 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470065#comment-15470065
]
ASF GitHub Bot commented on FLINK-4538:
---
Github user mxm commented on a diff in the pull request:
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2463#discussion_r77783497
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/LeaderIdRegistry.java
---
@@ -15,11 +15,27 @@
* See the License for the
[
https://issues.apache.org/jira/browse/FLINK-4376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-4376.
-
Resolution: Duplicate
I think this is duplicated with https://issues.apache.org/jira/browse/FLINK-4408
>
[
https://issues.apache.org/jira/browse/FLINK-4406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-4406:
--
Assignee: (was: Kurt Young)
> Implement job master registration at resource manager
>
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2337#discussion_r77827675
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/TypeInfoFactory.java
---
@@ -0,0 +1,55 @@
+/*
+ * Licensed to the Apache
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2443#discussion_r77825932
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
---
@@ -105,7 +106,9 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470728#comment-15470728
]
ASF GitHub Bot commented on FLINK-3042:
---
Github user greghogan commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470881#comment-15470881
]
ASF GitHub Bot commented on FLINK-3042:
---
Github user greghogan commented on a diff in the pull
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2337#discussion_r77842627
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -792,12 +832,40 @@ else if (t instanceof Class) {
Timo Walther created FLINK-4592:
---
Summary: Fix flaky test ScalarFunctionsTest.testCurrentTimePoint
Key: FLINK-4592
URL: https://issues.apache.org/jira/browse/FLINK-4592
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470705#comment-15470705
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user zentol commented on a diff in the pull request:
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2443#discussion_r77829590
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
---
@@ -105,7 +106,9 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470749#comment-15470749
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user rmetzger commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2440#discussion_r77856665
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupRangeAssignment.java
---
@@ -0,0 +1,97 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-4585.
---
Resolution: Fixed
Resolved in
GitHub user apivovarov opened a pull request:
https://github.com/apache/flink/pull/2478
[FLINK-4595] Close FileOutputStream in ParameterTool
https://issues.apache.org/jira/browse/FLINK-4595
You can merge this pull request into a Git repository by running:
$ git pull
[
https://issues.apache.org/jira/browse/FLINK-4595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15471823#comment-15471823
]
ASF GitHub Bot commented on FLINK-4595:
---
GitHub user apivovarov opened a pull request:
Alexander Pivovarov created FLINK-4595:
--
Summary: Close FileOutputStream in ParameterTool
Key: FLINK-4595
URL: https://issues.apache.org/jira/browse/FLINK-4595
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Johannes updated FLINK-4586:
Attachment: FLINK4586Test.scala
Scala unit test
> NumberSequenceIterator and Accumulator threading issue
>
[
https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Johannes updated FLINK-4586:
Attachment: (was: FLINK4586Test.scala)
> NumberSequenceIterator and Accumulator threading issue
>
[
https://issues.apache.org/jira/browse/FLINK-3755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15471287#comment-15471287
]
ASF GitHub Bot commented on FLINK-3755:
---
Github user StefanRRichter commented on a diff in the pull
Robert Metzger created FLINK-4590:
-
Summary: Some Table API tests are failing when debug lvl is set to
DEBUG
Key: FLINK-4590
URL: https://issues.apache.org/jira/browse/FLINK-4590
Project: Flink
Nagarjun Guraja created FLINK-4596:
--
Summary: Class not found exception when RESTART_STRATEGY is
configured with fully qualified class name in the yaml
Key: FLINK-4596
URL:
[
https://issues.apache.org/jira/browse/FLINK-4537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15472525#comment-15472525
]
ASF GitHub Bot commented on FLINK-4537:
---
GitHub user beyond1920 opened a pull request:
GitHub user beyond1920 opened a pull request:
https://github.com/apache/flink/pull/2479
[FLINK-4537] [cluster management] ResourceManager registration with
JobManager
This pull request is to implement ResourceManager registration with
JobManager, which including:
1. Check
[
https://issues.apache.org/jira/browse/FLINK-4551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjing reassigned FLINK-4551:
Assignee: zhangjing
> Heartbeat Manager integration with JobMaster
>
[
https://issues.apache.org/jira/browse/FLINK-4427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-4427:
--
Summary: Implement container releasing logic (Standalone / Yarn / Mesos)
(was: Add slot / Implement
[
https://issues.apache.org/jira/browse/FLINK-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15472586#comment-15472586
]
Olga Golovneva commented on FLINK-1526:
---
Hi,
I was wondering what is the current state for this
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15425389#comment-15425389
]
Josep Rubió edited comment on FLINK-1707 at 9/8/16 3:49 AM:
Hi [~vkalavri],
I
[
https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15472401#comment-15472401
]
Jark Wu commented on FLINK-4591:
It seems that {{GROUP BY *}} is not allowed in SQL. Maybe we can throw a
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2463#discussion_r77943543
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -52,15 +58,28 @@
*
*/
public
[
https://issues.apache.org/jira/browse/FLINK-4538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15472686#comment-15472686
]
ASF GitHub Bot commented on FLINK-4538:
---
Github user beyond1920 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15472703#comment-15472703
]
ASF GitHub Bot commented on FLINK-4408:
---
GitHub user KurtYoung opened a pull request:
GitHub user KurtYoung opened a pull request:
https://github.com/apache/flink/pull/2480
[FLINK-4408][JobManager] Introduce JobMasterRunner and implement job
submission & setting up the ExecutionGraph
Introduce JobMasterRunner to deal with job level leader election and make
[
https://issues.apache.org/jira/browse/FLINK-3755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15471057#comment-15471057
]
ASF GitHub Bot commented on FLINK-3755:
---
Github user tillrohrmann commented on a diff in the pull
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2440
I don't think that this is giving us the correct inverse for
```computeOperatorIndexForKeyGroup(...)```. Our test
```CheckpointCoordinatorTest::testCreateKeyGroupPartitions()```generates
[
https://issues.apache.org/jira/browse/FLINK-4572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15471566#comment-15471566
]
ASF GitHub Bot commented on FLINK-4572:
---
Github user greghogan commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2469
Do you have a second use case in mind for adding this function to
`MathUtils`? My thought would be to keep this separate to avoid confusion
between signed and unsigned downcasts.
---
If your
Greg Hogan created FLINK-4594:
-
Summary: Validate lower bound in MathUtils.checkedDownCast
Key: FLINK-4594
URL: https://issues.apache.org/jira/browse/FLINK-4594
Project: Flink
Issue Type: Bug
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2469
Looks good. Does it make sense to add to extend the
`MathUtils.checkedDownCast(...)` function, or add a
`MathUtils.checkedSignedDownCast(...)` function?
---
If your project is set up for it,
[
https://issues.apache.org/jira/browse/FLINK-4572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15471484#comment-15471484
]
ASF GitHub Bot commented on FLINK-4572:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Pivovarov updated FLINK-4593:
---
Flags: Patch
> Fix PageRank algorithm example
> --
>
>
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2440#discussion_r77870173
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupRangeAssignment.java
---
@@ -0,0 +1,97 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-3755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15471283#comment-15471283
]
ASF GitHub Bot commented on FLINK-3755:
---
Github user StefanRRichter commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Pivovarov updated FLINK-4585:
---
Flags: Patch
> Fix broken links in index.md
>
>
>
Alexander Pivovarov created FLINK-4593:
--
Summary: Fix PageRank algorithm example
Key: FLINK-4593
URL: https://issues.apache.org/jira/browse/FLINK-4593
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Pivovarov updated FLINK-4593:
---
Description:
This page https://flink.apache.org/features.html shows the code which
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2463#discussion_r77768256
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java
---
@@ -89,32 +93,37 @@ public
[
https://issues.apache.org/jira/browse/FLINK-4538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15469776#comment-15469776
]
ASF GitHub Bot commented on FLINK-4538:
---
Github user beyond1920 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15469797#comment-15469797
]
Simone Robutti commented on FLINK-4565:
---
Actually the confusing part is that the translation to the
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2463#discussion_r77769044
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java
---
@@ -89,32 +93,37 @@ public
[
https://issues.apache.org/jira/browse/FLINK-4538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15469801#comment-15469801
]
ASF GitHub Bot commented on FLINK-4538:
---
Github user beyond1920 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15469836#comment-15469836
]
Fabian Hueske commented on FLINK-4565:
--
SQL {{IN}} does not require a special implementation because
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Simone Robutti reassigned FLINK-4565:
-
Assignee: Simone Robutti
> Support for SQL IN operator
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15469851#comment-15469851
]
Simone Robutti commented on FLINK-4565:
---
I imagined it could happen that way and I was going to open
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15469873#comment-15469873
]
Timo Walther commented on FLINK-4565:
-
Calcite translates the IN operator in
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15469879#comment-15469879
]
Timo Walther commented on FLINK-4565:
-
It seems my answer was to late. Yes, I would also go for the
90 matches
Mail list logo