Suneel Marthi created FLINK-3657:
Summary: Change access of DataSetUtils.countElements() to 'public'
Key: FLINK-3657
URL: https://issues.apache.org/jira/browse/FLINK-3657
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15207407#comment-15207407
]
ASF GitHub Bot commented on FLINK-2997:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1776#discussion_r57078308
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CustomDistributionITCase.java
---
@@ -0,0 +1,184 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15207374#comment-15207374
]
ASF GitHub Bot commented on FLINK-3639:
---
Github user vasia commented on a diff in the pull request:
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1827#discussion_r57075247
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/java/table/TableEnvironment.scala
---
@@ -87,5 +90,72 @@ class TableEnvironment {
[
https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15207368#comment-15207368
]
ASF GitHub Bot commented on FLINK-3639:
---
Github user vasia commented on a diff in the pull request:
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1827#discussion_r57074776
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/scala/table/TableEnvironment.scala
---
@@ -72,5 +74,68 @@ class TableEnvironment {
[
https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15207361#comment-15207361
]
ASF GitHub Bot commented on FLINK-3639:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1827#discussion_r57073483
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/schema/TableTable.scala
---
@@ -0,0 +1,55 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15207336#comment-15207336
]
ASF GitHub Bot commented on FLINK-3639:
---
Github user vasia commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15207335#comment-15207335
]
ASF GitHub Bot commented on FLINK-3644:
---
Github user fhueske commented on the pull request:
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1827#discussion_r57070386
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/schema/TableTable.scala
---
@@ -0,0 +1,55 @@
+/*
+ * Licensed to
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1824#issuecomment-200032560
Hi @Astralidea, thanks for the PR. We are aware of some flaky tests. So
there is no need to trigger new builds.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15207328#comment-15207328
]
ASF GitHub Bot commented on FLINK-3639:
---
Github user vasia commented on a diff in the pull request:
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1827#discussion_r57069968
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/TranslationContext.scala
---
@@ -59,29 +64,55 @@ object
[
https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15207306#comment-15207306
]
ASF GitHub Bot commented on FLINK-3639:
---
Github user fhueske commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1827#issuecomment-200025666
Thanks for the PR! Looks good overall.
I think we can save a few LOCs by refactoring common parts a bit. Also I
spotted more opportunities to use Scala's String
[
https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15207298#comment-15207298
]
ASF GitHub Bot commented on FLINK-3639:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1827#discussion_r57068281
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/RegisterDataSetITCase.scala
---
@@ -0,0 +1,136 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15207280#comment-15207280
]
ASF GitHub Bot commented on FLINK-2909:
---
Github user greghogan commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15207277#comment-15207277
]
ASF GitHub Bot commented on FLINK-3639:
---
Github user fhueske commented on a diff in the pull
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/1807#discussion_r57067037
--- Diff:
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/generator/AbstractGraphTest.java
---
@@ -0,0 +1,33 @@
+/*
+ * Licensed
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1827#discussion_r57066925
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/schema/TableTable.scala
---
@@ -0,0 +1,55 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15207269#comment-15207269
]
ASF GitHub Bot commented on FLINK-3639:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1827#discussion_r57066656
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/schema/TableTable.scala
---
@@ -0,0 +1,55 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15207264#comment-15207264
]
ASF GitHub Bot commented on FLINK-3639:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1827#discussion_r57066078
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/scala/table/TableEnvironment.scala
---
@@ -72,5 +74,68 @@ class TableEnvironment {
[
https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15207262#comment-15207262
]
ASF GitHub Bot commented on FLINK-3639:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1827#discussion_r57065868
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/scala/table/TableEnvironment.scala
---
@@ -72,5 +74,68 @@ class TableEnvironment {
[
https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15207261#comment-15207261
]
ASF GitHub Bot commented on FLINK-3639:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1827#discussion_r57065751
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/java/table/TableEnvironment.scala
---
@@ -87,5 +90,72 @@ class TableEnvironment {
[
https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15207254#comment-15207254
]
ASF GitHub Bot commented on FLINK-3639:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1827#discussion_r57065169
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/FlinkRuleSets.scala
---
@@ -93,7 +93,10 @@ object FlinkRuleSets {
[
https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15207253#comment-15207253
]
ASF GitHub Bot commented on FLINK-3639:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15207249#comment-15207249
]
ASF GitHub Bot commented on FLINK-3639:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1827#discussion_r57065041
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/TranslationContext.scala
---
@@ -59,29 +64,55 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1827#discussion_r57064833
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/TranslationContext.scala
---
@@ -59,29 +64,55 @@ object
Vasia Kalavri created FLINK-3656:
Summary: Rework TableAPI tests
Key: FLINK-3656
URL: https://issues.apache.org/jira/browse/FLINK-3656
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15207188#comment-15207188
]
ASF GitHub Bot commented on FLINK-3547:
---
Github user vasia commented on the pull request:
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1820#issuecomment-19747
I have updated the PR. Thanks!
---
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
[
https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gna Phetsarath updated FLINK-3655:
--
Description:
Allow comma-separated or multiple directories to be specified for
FileInputFormat
[
https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gna Phetsarath updated FLINK-3655:
--
Summary: Allow comma-separated or multiple directories to be specified for
FileInputFormat
[
https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gna Phetsarath updated FLINK-3655:
--
Description:
Allow comma-separated directories to be specified for FileInputFormat so that a
[
https://issues.apache.org/jira/browse/FLINK-3613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15207054#comment-15207054
]
Todd Lisonbee edited comment on FLINK-3613 at 3/22/16 7:02 PM:
---
Attached is
[
https://issues.apache.org/jira/browse/FLINK-3613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Todd Lisonbee updated FLINK-3613:
-
Attachment: DataSet-Aggregation-Design-March2016-v1.txt
Attached is a design for improvements to
[
https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gna Phetsarath updated FLINK-3655:
--
Description:
Allow comma-separated directories to be specified for FileInputFormat so that a
[
https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gna Phetsarath updated FLINK-3655:
--
Summary: Allow comma-separated directories to be specified for
FileInputFormat (was: Allow
Gna Phetsarath created FLINK-3655:
-
Summary: Allow comma-separated multiple directories to be
specified for FileInputFormat
Key: FLINK-3655
URL: https://issues.apache.org/jira/browse/FLINK-3655
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206980#comment-15206980
]
Robert Metzger commented on FLINK-2821:
---
That sounds like a very good idea!
+1
> Change Akka
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206875#comment-15206875
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user mxm commented on the pull request:
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1741#issuecomment-199934108
Thanks a lot @tillrohrmann for taking the time to look into the bulk of
code. I have already eagerly addressed most of your comments in the additional
commits I pushed.
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1741#discussion_r57031901
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -312,59 +323,121 @@ class JobManager(
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206850#comment-15206850
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206835#comment-15206835
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user tillrohrmann commented on the pull request:
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1741#issuecomment-199920379
Great work @mxm! I really like the new architecture :-)
I had some minor comments. The only thing which is important to fix is that
the `JobManager` can
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206832#comment-15206832
]
ASF GitHub Bot commented on FLINK-3544:
---
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/1741#discussion_r57030485
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlinkResourceManager.java ---
@@ -0,0 +1,647 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206815#comment-15206815
]
ASF GitHub Bot commented on FLINK-3544:
---
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/1741#discussion_r57028233
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -312,59 +323,121 @@ class JobManager(
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206810#comment-15206810
]
Stephan Ewen commented on FLINK-2821:
-
How about the following solution (multiple steps):
- We make
[
https://issues.apache.org/jira/browse/FLINK-3654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-3654:
Component/s: (was: Sure)
Streaming
> Disable Write-Ahead-Log in
Aljoscha Krettek created FLINK-3654:
---
Summary: Disable Write-Ahead-Log in RocksDB State
Key: FLINK-3654
URL: https://issues.apache.org/jira/browse/FLINK-3654
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206777#comment-15206777
]
Robert Metzger commented on FLINK-3211:
---
Great, thank you. I'm looking forward reviewing it.
> Add
[
https://issues.apache.org/jira/browse/FLINK-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206770#comment-15206770
]
Tzu-Li (Gordon) Tai edited comment on FLINK-3211 at 3/22/16 4:52 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206770#comment-15206770
]
Tzu-Li (Gordon) Tai commented on FLINK-3211:
No problem :)
> Add AWS Kinesis streaming
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206764#comment-15206764
]
ASF GitHub Bot commented on FLINK-3579:
---
Github user ramkrish86 commented on the pull request:
Github user ramkrish86 commented on the pull request:
https://github.com/apache/flink/pull/1821#issuecomment-199900035
Updated PR. RexNodeTranslator had > 100 character line. That is now
corrected.
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206695#comment-15206695
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206755#comment-15206755
]
Robert Metzger commented on FLINK-3211:
---
Hi Tzu,
thank you for your response. I'm happy to see that
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206753#comment-15206753
]
ASF GitHub Bot commented on FLINK-3544:
---
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/1741#discussion_r57021932
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ResourceManagerITCase.java
---
@@ -0,0 +1,199 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206750#comment-15206750
]
ASF GitHub Bot commented on FLINK-3579:
---
Github user ramkrish86 commented on the pull request:
Github user ramkrish86 commented on the pull request:
https://github.com/apache/flink/pull/1821#issuecomment-199897376
@vasia
Thanks for the info. Let me check that and update 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-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206739#comment-15206739
]
Tzu-Li (Gordon) Tai commented on FLINK-3211:
Hi, thanks Roy.
I don't think using the actual
[
https://issues.apache.org/jira/browse/FLINK-2946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206731#comment-15206731
]
Dawid Wysakowicz commented on FLINK-2946:
-
Hi, I have started working on this issue and would be
[
https://issues.apache.org/jira/browse/FLINK-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206709#comment-15206709
]
Tzu-Li (Gordon) Tai commented on FLINK-3211:
Hi Roy & Robert
Apologies for the late reply.
I
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206703#comment-15206703
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206699#comment-15206699
]
Roy Ben-Alta commented on FLINK-3211:
-
Hi Robert,
I am the Business Development Manager for Amazon
[
https://issues.apache.org/jira/browse/FLINK-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206716#comment-15206716
]
Roy Ben-Alta commented on FLINK-3211:
-
Hi Tzu,
There is no Kinesis local exist but there is one I
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1741#discussion_r57017514
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlinkResourceManager.java ---
@@ -0,0 +1,647 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-3653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206705#comment-15206705
]
ASF GitHub Bot commented on FLINK-3653:
---
GitHub user stefanobaghino opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206704#comment-15206704
]
ASF GitHub Bot commented on FLINK-3544:
---
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/1741#discussion_r57018050
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationClient.scala ---
@@ -115,7 +115,7 @@ class ApplicationClient(
val
GitHub user stefanobaghino opened a pull request:
https://github.com/apache/flink/pull/1828
[FLINK-3653] recovery.zookeeper.storageDir is not documented on the
configuration page
Also: minor _hotfix_ to the `state.backend.fs.checkpointdir` option
description (punctuation, casing
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1741#discussion_r57018075
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationClient.scala ---
@@ -148,7 +148,7 @@ class ApplicationClient(
[
https://issues.apache.org/jira/browse/FLINK-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206677#comment-15206677
]
Robert Metzger commented on FLINK-3211:
---
Hi Roy,
I'll try to contact Tzu-Li via email to get an
Stefano Baghino created FLINK-3653:
--
Summary: recovery.zookeeper.storageDir is not documented on the
configuration page
Key: FLINK-3653
URL: https://issues.apache.org/jira/browse/FLINK-3653
Project:
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206658#comment-15206658
]
ASF GitHub Bot commented on FLINK-3544:
---
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/1741#discussion_r57015042
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnApplicationMasterRunner.java
---
@@ -0,0 +1,601 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-3547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206646#comment-15206646
]
ASF GitHub Bot commented on FLINK-3547:
---
Github user vasia commented on the pull request:
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1820#issuecomment-199881323
Thanks for the review! I'll see how we can share the common parts between
DataSet and DataStream translation. I will also open a JIRA for reworking the
tests.
---
If
Maximilian Michels created FLINK-3652:
-
Summary: Enable UnusedImports check for Scala checkstyle
Key: FLINK-3652
URL: https://issues.apache.org/jira/browse/FLINK-3652
Project: Flink
Github user mliesenberg commented on the pull request:
https://github.com/apache/flink/pull/1625#issuecomment-199878190
it's only the build job with with the `hadoop.profile=1` option. for the
others the tests are passing.
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206628#comment-15206628
]
ASF GitHub Bot commented on FLINK-2445:
---
Github user mliesenberg commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206625#comment-15206625
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206618#comment-15206618
]
ASF GitHub Bot commented on FLINK-3547:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206622#comment-15206622
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user tillrohrmann commented on a diff in the pull
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1741#discussion_r57011989
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnApplicationMasterRunner.java
---
@@ -0,0 +1,601 @@
+/*
+ * Licensed to the Apache Software
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1741#discussion_r57011773
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -39,24 +39,32 @@ import
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15206619#comment-15206619
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user tillrohrmann commented on a diff in the pull
1 - 100 of 303 matches
Mail list logo
