[
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
>
[
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-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
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-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-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-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-4551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjing reassigned FLINK-4551:
Assignee: zhangjing
> Heartbeat Manager integration with JobMaster
>
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-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:
[
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
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-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
>
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-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-4585.
---
Resolution: Fixed
Resolved in
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
[
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
[
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
> --
>
>
[
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:
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-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
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-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Pivovarov updated FLINK-4585:
---
Flags: Patch
> Fix broken links in index.md
>
>
>
[
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
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:
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-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 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
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
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) {
[
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
[
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 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-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
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
[
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 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-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 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
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-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
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
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
[
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
[
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 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=15470472#comment-15470472
]
Simone Robutti commented on FLINK-4565:
---
That's exactly why I'm asking it: I had no idea what to use
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-4506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirill Morozov reassigned FLINK-4506:
-
Assignee: Kirill Morozov
> CsvOutputFormat defaults allowNullValues to false, even
[
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-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
[
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-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
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
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
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
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
[
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
>
[
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 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
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-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-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() {
[
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:
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
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-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-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
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
[
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
[
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=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: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=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-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
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-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
[
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
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
90 matches
Mail list logo