[
https://issues.apache.org/jira/browse/FLINK-5739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860888#comment-15860888
]
ASF GitHub Bot commented on FLINK-5739:
---
GitHub user clarkyzl opened a pull request:
GitHub user clarkyzl opened a pull request:
https://github.com/apache/flink/pull/3292
[FLINK-5739] [client] fix NullPointerException in CliFrontend
Type: Bug
Priority: Major
Problem Definition: CliFrontEnd throws a NullPointerException
Design:
see
[
https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860886#comment-15860886
]
shijinkui commented on FLINK-4252:
--
org.apache.flink.table.examples.java.WordCountTable.java also can be
[
https://issues.apache.org/jira/browse/FLINK-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860870#comment-15860870
]
ASF GitHub Bot commented on FLINK-5571:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3176#discussion_r100483661
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/UserDefinedFunction.scala
---
@@ -24,4 +24,19 @@ package
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3278#discussion_r100482362
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBaseTest.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-5701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860859#comment-15860859
]
ASF GitHub Bot commented on FLINK-5701:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5739:
Description:
I've run a simple program on a local cluster. It always fails with code
Version:
Github user godfreyhe commented on a diff in the pull request:
https://github.com/apache/flink/pull/3176#discussion_r100478286
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/UserDefinedFunction.scala
---
@@ -24,4 +24,19 @@ package
[
https://issues.apache.org/jira/browse/FLINK-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860828#comment-15860828
]
ASF GitHub Bot commented on FLINK-5571:
---
Github user godfreyhe commented on a diff in the pull
zhangrucong1982 created FLINK-5770:
--
Summary: Flink yarn session stop in non-detached model
Key: FLINK-5770
URL: https://issues.apache.org/jira/browse/FLINK-5770
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-5517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-5517.
Resolution: Fixed
Assignee: Ted Yu
Fix Version/s: 1.3.0
Resolved
[
https://issues.apache.org/jira/browse/FLINK-5517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860781#comment-15860781
]
ASF GitHub Bot commented on FLINK-5517:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3235
---
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
[
https://issues.apache.org/jira/browse/FLINK-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860696#comment-15860696
]
ASF GitHub Bot commented on FLINK-5571:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3176#discussion_r100470762
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/UserDefinedFunction.scala
---
@@ -24,4 +24,19 @@ package
Github user godfreyhe commented on a diff in the pull request:
https://github.com/apache/flink/pull/3176#discussion_r100469073
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/UserDefinedFunction.scala
---
@@ -24,4 +24,19 @@ package
[
https://issues.apache.org/jira/browse/FLINK-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860677#comment-15860677
]
ASF GitHub Bot commented on FLINK-5571:
---
Github user godfreyhe commented on a diff in the pull
Shaoxuan Wang created FLINK-5768:
Summary: Apply new aggregation functions and aggregate DataStream
API for streaming tables
Key: FLINK-5768
URL: https://issues.apache.org/jira/browse/FLINK-5768
Shaoxuan Wang created FLINK-5769:
Summary: Apply new aggregation functions for dataset tables
Key: FLINK-5769
URL: https://issues.apache.org/jira/browse/FLINK-5769
Project: Flink
Issue Type:
Shaoxuan Wang created FLINK-5767:
Summary: Add a new aggregate function interface
Key: FLINK-5767
URL: https://issues.apache.org/jira/browse/FLINK-5767
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-5546:
-
Affects Version/s: (was: 1.3.0)
(was: 1.2.0)
> java.io.tmpdir setted as
[
https://issues.apache.org/jira/browse/FLINK-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-5546:
-
Fix Version/s: 1.2.1
> java.io.tmpdir setted as project build directory in surefire plugin
>
[
https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui reassigned FLINK-4562:
Assignee: shijinkui
> table examples make an divided module in flink-examples
>
[
https://issues.apache.org/jira/browse/FLINK-5217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-5217:
-
Fix Version/s: 1.2.1
Description:
package org.apache.flink.streaming.api.checkpoint;
@Deprecated
[
https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-4562:
-
Fix Version/s: 1.2.1
> table examples make an divided module in flink-examples
>
[
https://issues.apache.org/jira/browse/FLINK-5640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-5640:
-
Affects Version/s: (was: 1.2.1)
Fix Version/s: 1.2.1
> configure the explicit Unit Test file
[
https://issues.apache.org/jira/browse/FLINK-5650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-5650:
-
Affects Version/s: 1.2.0
Priority: Critical (was: Major)
Fix Version/s: 1.2.1
>
[
https://issues.apache.org/jira/browse/FLINK-5705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-5705:
-
Fix Version/s: 1.2.1
> webmonitor's request/response use UTF-8 explicitly
>
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860633#comment-15860633
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user wuchong commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui reassigned FLINK-5705:
Assignee: shijinkui
> webmonitor's request/response use UTF-8 explicitly
>
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/3273
updated!
---
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
[
https://issues.apache.org/jira/browse/FLINK-5754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860629#comment-15860629
]
shijinkui commented on FLINK-5754:
--
I need checkout a branch from 1.2.0 tag. And work on this branch
[
https://issues.apache.org/jira/browse/FLINK-5749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860563#comment-15860563
]
ASF GitHub Bot commented on FLINK-5749:
---
Github user wenlong88 commented on the issue:
Github user wenlong88 commented on the issue:
https://github.com/apache/flink/pull/3288
hi @StephanEwen, the cases in flink-filesystem-connector will fail first in
our building machine. I have go through the cases in flink-fs-tests, I think
they will fail too if I remove the change
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860549#comment-15860549
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user wuchong commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860547#comment-15860547
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3273#discussion_r100458026
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/CsvTableSource.scala
---
@@ -138,4 +141,160 @@ class CsvTableSource(
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860548#comment-15860548
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3273#discussion_r100458059
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/CsvTableSource.scala
---
@@ -44,15 +47,15 @@ import
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/3273
Thank you for your advice. I will update the PR soon.
---
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 user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3273#discussion_r100458044
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/CsvTableSource.scala
---
@@ -138,4 +141,160 @@ class CsvTableSource(
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860546#comment-15860546
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860543#comment-15860543
]
Zhijiang Wang commented on FLINK-5132:
--
Thank you, [~StephanEwen]. Yeah, it also makes sense to check
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860518#comment-15860518
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user KurtYoung commented on a diff in the pull
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3273#discussion_r100455645
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/CsvTableSource.scala
---
@@ -138,4 +141,160 @@ class CsvTableSource(
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860515#comment-15860515
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user KurtYoung commented on a diff in the pull
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3273#discussion_r100455433
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/CsvTableSource.scala
---
@@ -44,15 +47,15 @@ import
[
https://issues.apache.org/jira/browse/FLINK-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860513#comment-15860513
]
ASF GitHub Bot commented on FLINK-1526:
---
Github user xccui commented on a diff in the pull request:
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/3284#discussion_r100455274
--- Diff: docs/dev/libs/gelly/library_methods.md ---
@@ -242,6 +242,28 @@ The algorithm takes a directed, vertex (and possibly
edge) attributed graph as i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3273#discussion_r100454106
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/CsvTableSource.scala
---
@@ -138,4 +141,160 @@ class CsvTableSource(
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860504#comment-15860504
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user KurtYoung commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860495#comment-15860495
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user KurtYoung commented on a diff in the pull
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3273#discussion_r100453644
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/CsvTableSource.scala
---
@@ -138,4 +141,160 @@ class CsvTableSource(
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860490#comment-15860490
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user KurtYoung commented on a diff in the pull
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3273#discussion_r100452676
--- Diff: docs/dev/table_api.md ---
@@ -253,56 +253,51 @@ Table result =
tableEnvironment.ingest("kafka-source");
The `CsvTableSource` is
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860488#comment-15860488
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user KurtYoung commented on a diff in the pull
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3273#discussion_r100452526
--- Diff: docs/dev/table_api.md ---
@@ -253,56 +253,51 @@ Table result =
tableEnvironment.ingest("kafka-source");
The `CsvTableSource` is
[
https://issues.apache.org/jira/browse/FLINK-5751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860369#comment-15860369
]
Patrick Lucas commented on FLINK-5751:
--
I've identified the links as these using wget. It doesn't
[
https://issues.apache.org/jira/browse/FLINK-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860330#comment-15860330
]
Riccardo Diomedi commented on FLINK-5611:
-
Hi [~uce], I would like to contribute with this
[
https://issues.apache.org/jira/browse/FLINK-4896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860296#comment-15860296
]
ASF GitHub Bot commented on FLINK-4896:
---
Github user greghogan commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2733
@vasia Running on a c4.xlarge with 4 slots and a 4 GB preallocated
TaskManager heap. EdgeList measures the time to simplify the graph since the
library PageRank using Scatter-Gather ("PageRankSG")
[
https://issues.apache.org/jira/browse/FLINK-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860271#comment-15860271
]
ASF GitHub Bot commented on FLINK-1526:
---
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/3284#discussion_r100421801
--- Diff: docs/dev/libs/gelly/library_methods.md ---
@@ -242,6 +242,28 @@ The algorithm takes a directed, vertex (and possibly
edge) attributed graph as i
[
https://issues.apache.org/jira/browse/FLINK-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860265#comment-15860265
]
ASF GitHub Bot commented on FLINK-1526:
---
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/3284#discussion_r100421089
--- Diff: docs/dev/libs/gelly/library_methods.md ---
@@ -242,6 +242,28 @@ The algorithm takes a directed, vertex (and possibly
edge) attributed graph as i
[
https://issues.apache.org/jira/browse/FLINK-5751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860222#comment-15860222
]
Patrick Lucas commented on FLINK-5751:
--
I've actually run into quite a few broken links in the docs
[
https://issues.apache.org/jira/browse/FLINK-5731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860217#comment-15860217
]
Haohui Mai commented on FLINK-5731:
---
One related but off-topic questions: Are there any reasons to
[
https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai updated FLINK-5624:
--
Issue Type: Improvement (was: Bug)
> Support tumbling window on streaming tables in the SQL API
>
[
https://issues.apache.org/jira/browse/FLINK-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582930#comment-15582930
]
Ted Yu edited comment on FLINK-4848 at 2/9/17 8:04 PM:
---
There is similar issue with
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860047#comment-15860047
]
Haohui Mai commented on FLINK-5654:
---
I may not fully get the question -- Is it possible to do something
[
https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860036#comment-15860036
]
Haohui Mai commented on FLINK-5710:
---
Just FYI: FLINK-5624 implements the {{rowTime()}} function. The
[
https://issues.apache.org/jira/browse/FLINK-1579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859955#comment-15859955
]
ASF GitHub Bot commented on FLINK-1579:
---
Github user uce commented on the issue:
Stephan Ewen created FLINK-5766:
---
Summary: Unify NoAvailableResourceException handling on
ExecutionGraph
Key: FLINK-5766
URL: https://issues.apache.org/jira/browse/FLINK-5766
Project: Flink
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3286
Thanks for this PR. I think it's super cool (and long overdue) to finally
have this. I think the general approach is sound and has good things going for
it.
But I see two problems with
[
https://issues.apache.org/jira/browse/FLINK-5762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859874#comment-15859874
]
ASF GitHub Bot commented on FLINK-5762:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3291
I think this works for now.
What would be great is in the long run to actually start the timer service
only in/after open() so that timers that are registered cannot fire.
That
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3251
Thanks for the screenshots. My job was simple too narrow (not enough
operators). After trying with a job that has more operators, I could reproduce
the fix. Initially, I though that redrawing meant
[
https://issues.apache.org/jira/browse/FLINK-2908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859831#comment-15859831
]
ASF GitHub Bot commented on FLINK-2908:
---
Github user uce commented on the issue:
Ufuk Celebi created FLINK-5765:
--
Summary: Add noindex meta tag for older docs
Key: FLINK-5765
URL: https://issues.apache.org/jira/browse/FLINK-5765
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-5764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859817#comment-15859817
]
Ufuk Celebi commented on FLINK-5764:
Furthermore, we should look into explicitly removing the old docs
Ufuk Celebi created FLINK-5764:
--
Summary: Don't serve ancient docs
Key: FLINK-5764
URL: https://issues.apache.org/jira/browse/FLINK-5764
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-5183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859800#comment-15859800
]
ASF GitHub Bot commented on FLINK-5183:
---
Github user GEOFBOT commented on the issue:
Github user GEOFBOT commented on the issue:
https://github.com/apache/flink/pull/3232
It may have worked with a smaller file, but there may be issues with
heavier jobs. When I ran a more computationally intensive and time consuming
job, the first job of the Python file ran
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859785#comment-15859785
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ramkrish86 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859782#comment-15859782
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ramkrish86 commented on the issue:
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/3149
> Results :
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0
This is what I get as test result.
---
If your project is set up for it, you can reply to this email and have your
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/3149
It is CentOS Linux release 7.0.1406 (Core).
---
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
[
https://issues.apache.org/jira/browse/FLINK-5762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859763#comment-15859763
]
ASF GitHub Bot commented on FLINK-5762:
---
GitHub user kl0u opened a pull request:
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/3291
[FLINK-5762] Protect initializeState() and open() by the same lock
The description is in the related jira:
https://issues.apache.org/jira/browse/FLINK-5762
You can merge this pull request
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2733
Running on a c4.xlarge with 4 slots and a 4 GB preallocated TaskManager
heap. EdgeList measures the time to simplify the graph since the library
PageRank using Scatter-Gather ("PageRankSG")
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859758#comment-15859758
]
radu commented on FLINK-5654:
-
I have another dilemma for the implementation. When we build the window
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859753#comment-15859753
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user tonycox commented on the issue:
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
@ramkrish86 what is your environment?
---
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
[
https://issues.apache.org/jira/browse/FLINK-5759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859733#comment-15859733
]
ASF GitHub Bot commented on FLINK-5759:
---
GitHub user StephanEwen opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859749#comment-15859749
]
ASF GitHub Bot commented on FLINK-4896:
---
Github user greghogan commented on the issue:
Ufuk Celebi created FLINK-5763:
--
Summary: Make savepoints self-contained and relocatable
Key: FLINK-5763
URL: https://issues.apache.org/jira/browse/FLINK-5763
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-5623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859736#comment-15859736
]
Greg Hogan commented on FLINK-5623:
---
The error does not occur when the graph is simplified before
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/3149
I tried even that. The test runs fine for me. No OOME I get.
---
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
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/3290
[FLINK-5759] [jobmanager] Set UncaughtExceptionHandlers for JobManager's
Future and I/O thread pools
Currently, the thread pools of the `JobManager` do not have any
`UncaughtExceptionHandler`.
1 - 100 of 213 matches
Mail list logo
