[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15271841#comment-15271841
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user gallenvara commented on the pull request:
Github user gallenvara commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-217070480
Thanks a lot, @greghogan @vasia .
My limited understand on the tips your have mentioned :
1) The PR implemented HITS by dividing hub updating into two
phases.
Greg Hogan created FLINK-3877:
-
Summary: Create TranslateFunction interface for Graph translators
Key: FLINK-3877
URL: https://issues.apache.org/jira/browse/FLINK-3877
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15271314#comment-15271314
]
Gna Phetsarath commented on FLINK-3655:
---
What's the progress on this ticket, [~tianli]?
> Allow
[
https://issues.apache.org/jira/browse/FLINK-1827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-1827.
Resolution: Done
Fix Version/s: 1.1.0
Done for 1.1.0 with
[
https://issues.apache.org/jira/browse/FLINK-3519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-3519.
Resolution: Done
Fix Version/s: 1.1.0
Done for 1.1.0 with
[
https://issues.apache.org/jira/browse/FLINK-1996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-1996.
Resolution: Implemented
Fix Version/s: 1.1.0
Implemented for 1.1.0 with
[
https://issues.apache.org/jira/browse/FLINK-3691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-3691.
Resolution: Implemented
Fix Version/s: 1.1.0
Thanks for the contribution, [~Gna Phetsarath]!
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1724
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1915
---
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-3519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15271259#comment-15271259
]
ASF GitHub Bot commented on FLINK-3519:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-1996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15271260#comment-15271260
]
ASF GitHub Bot commented on FLINK-1996:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-1827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15271258#comment-15271258
]
ASF GitHub Bot commented on FLINK-1827:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1961
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1920
---
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-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15271172#comment-15271172
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user greghogan commented on the pull request:
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-216961955
@vasia likely has additional opinions and insight for the following ...
1) The algorithm should return both the hub score and authority score. This
requires
[
https://issues.apache.org/jira/browse/FLINK-3876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-3876:
--
Fix Version/s: (was: 1.0.3)
> Improve documentation of Scala Shell
>
[
https://issues.apache.org/jira/browse/FLINK-3876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-3876.
-
Resolution: Fixed
Fixed in 8ec47f17be0b20e5204d309f72b0bec9b234a7fb
> Improve
[
https://issues.apache.org/jira/browse/FLINK-3876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-3876:
--
Affects Version/s: (was: 1.0.3)
> Improve documentation of Scala Shell
>
Maximilian Michels created FLINK-3876:
-
Summary: Improve documentation of Scala Shell
Key: FLINK-3876
URL: https://issues.apache.org/jira/browse/FLINK-3876
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270971#comment-15270971
]
Dawid Wysakowicz commented on FLINK-3842:
-
I checked your changes with my changes and it does
Fabian Hueske created FLINK-3875:
Summary: Add a TableSink for Elasticsearch
Key: FLINK-3875
URL: https://issues.apache.org/jira/browse/FLINK-3875
Project: Flink
Issue Type: New Feature
Fabian Hueske created FLINK-3874:
Summary: Add a Kafka TableSink with JSON serialization
Key: FLINK-3874
URL: https://issues.apache.org/jira/browse/FLINK-3874
Project: Flink
Issue Type: New
Fabian Hueske created FLINK-3873:
Summary: Add a Kafka TableSink with Avro serialization
Key: FLINK-3873
URL: https://issues.apache.org/jira/browse/FLINK-3873
Project: Flink
Issue Type: New
Fabian Hueske created FLINK-3871:
Summary: Add Kafka TableSource with Avro serialization
Key: FLINK-3871
URL: https://issues.apache.org/jira/browse/FLINK-3871
Project: Flink
Issue Type: New
Fabian Hueske created FLINK-3872:
Summary: Add Kafka TableSource with JSON serialization
Key: FLINK-3872
URL: https://issues.apache.org/jira/browse/FLINK-3872
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-3865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan resolved FLINK-3865.
---
Resolution: Duplicate
> ExecutionConfig NullPointerException with second execution
>
Dawid Wysakowicz created FLINK-3870:
---
Summary: Add IntelliJ code style file
Key: FLINK-3870
URL: https://issues.apache.org/jira/browse/FLINK-3870
Project: Flink
Issue Type: New Feature
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1920#issuecomment-216896832
Merging
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
[
https://issues.apache.org/jira/browse/FLINK-3519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270795#comment-15270795
]
ASF GitHub Bot commented on FLINK-3519:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-3825.
--
Resolution: Fixed
Added via 97470aac7c25a1c6f20638afc64fd343239847fb
> Update CEP
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1960
---
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-3825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270813#comment-15270813
]
ASF GitHub Bot commented on FLINK-3825:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-1827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270797#comment-15270797
]
ASF GitHub Bot commented on FLINK-1827:
---
Github user fhueske commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1915#issuecomment-216896889
Merging
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1724#issuecomment-216896787
Merging
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
[
https://issues.apache.org/jira/browse/FLINK-1996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270787#comment-15270787
]
ASF GitHub Bot commented on FLINK-1996:
---
Github user fhueske commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1961#issuecomment-216895081
Thanks @yjshen. Integration with SQL would be very nice!
I'll then go ahead and merge this PR.
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-3825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270784#comment-15270784
]
ASF GitHub Bot commented on FLINK-3825:
---
Github user tillrohrmann commented on the pull request:
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1960#issuecomment-216893981
Additions look good. Thanks for your contribution @StefanRRichter. Will
merge this PR.
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270778#comment-15270778
]
ASF GitHub Bot commented on FLINK-3856:
---
Github user fhueske commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1959#issuecomment-216893377
Just a few minor comments. What do you think about moving the types to a
`SqlTimeTypeInfo` class, @twalthr? @StephanEwen would that be OK for you?
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270777#comment-15270777
]
ASF GitHub Bot commented on FLINK-3856:
---
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/1959#discussion_r62054682
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/DateComparator.java
---
@@ -59,15 +55,37 @@ public boolean
[
https://issues.apache.org/jira/browse/FLINK-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270774#comment-15270774
]
ASF GitHub Bot commented on FLINK-3856:
---
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/1959#discussion_r62054394
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/SqlTimestampSerializerTest.java
---
@@ -0,0 +1,55 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270772#comment-15270772
]
ASF GitHub Bot commented on FLINK-3856:
---
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/1959#discussion_r62054304
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/SqlTimestampComparatorTest.java
---
@@ -0,0 +1,48 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-1996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270677#comment-15270677
]
ASF GitHub Bot commented on FLINK-1996:
---
Github user yjshen commented on the pull request:
Github user yjshen commented on the pull request:
https://github.com/apache/flink/pull/1961#issuecomment-216877262
Hi @fhueske , thanks for the explanation. If I get it correctly, the
current `toSink` API is a general one to allow write table content to a large
variety of `Sinks`
Aljoscha Krettek created FLINK-3869:
---
Summary: WindowedStream.apply with FoldFunction is too restrictive
Key: FLINK-3869
URL: https://issues.apache.org/jira/browse/FLINK-3869
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270670#comment-15270670
]
ASF GitHub Bot commented on FLINK-3857:
---
Github user sbcd90 commented on the pull request:
Github user sbcd90 commented on the pull request:
https://github.com/apache/flink/pull/1962#issuecomment-216874916
Hello @fhueske , The tests do not fail because of the changes made in the
PR. I tested the Junits for elasticsearch connector & all of them runs fine.
Can you kindly
Greg Hogan created FLINK-3868:
-
Summary: Specialized CopyableValue serializers and comparators
Key: FLINK-3868
URL: https://issues.apache.org/jira/browse/FLINK-3868
Project: Flink
Issue Type:
Andreas Kempa-Liehr created FLINK-3867:
--
Summary: Provide virtualized Flink architecture for testing
purposes
Key: FLINK-3867
URL: https://issues.apache.org/jira/browse/FLINK-3867
Project: Flink
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1856#discussion_r62025502
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/functions/SelectByMinFunction.java
---
@@ -72,8 +73,8 @@ public T reduce(T value1, T value2)
[
https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270503#comment-15270503
]
ASF GitHub Bot commented on FLINK-3650:
---
Github user ramkrish86 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-3860.
--
Resolution: Fixed
Fix Version/s: 1.0.3
1.1.0
Fixed in 4d3dcb1 (release-1.0),
[
https://issues.apache.org/jira/browse/FLINK-3860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270498#comment-15270498
]
ASF GitHub Bot commented on FLINK-3860:
---
Github user asfgit closed the pull request at:
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r62024853
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/split/GenericSplitsGenerator.java
---
@@ -0,0 +1,41 @@
+/**
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1964
---
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-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270497#comment-15270497
]
Maximilian Michels commented on FLINK-2821:
---
Awww, that's unfortunate :( I wonder, would it make
Github user fpompermaier commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r62022375
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
---
@@ -157,14 +203,25 @@ public
[
https://issues.apache.org/jira/browse/FLINK-3860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270486#comment-15270486
]
ASF GitHub Bot commented on FLINK-3860:
---
Github user aljoscha commented on the pull request:
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1964#issuecomment-216830662
LGTM
---
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
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r62021965
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
---
@@ -157,14 +203,25 @@ public boolean
Github user fpompermaier commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r62021375
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
---
@@ -157,14 +203,25 @@ public
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r62019090
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
---
@@ -139,12 +184,13 @@ public void
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r62019194
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java
---
@@ -95,32 +95,32 @@ private void
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r62019420
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/split/NumericColumnSplitsGenerator.java
---
@@ -0,0 +1,63 @@
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1941#issuecomment-216825461
Thanks for the update @fpompermaier. I added a few comments and suggestions.
---
If your project is set up for it, you can reply to this email and have your
reply
Github user fpompermaier commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r62019523
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
---
@@ -157,14 +203,25 @@ public
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r62019142
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
---
@@ -314,7 +262,8 @@ public static
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r62019506
--- Diff:
flink-batch-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/example/JDBCFullTest.java
---
@@ -0,0 +1,93 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r62019163
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java
---
@@ -95,32 +95,32 @@ private void
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r62018585
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
---
@@ -157,14 +203,25 @@ public boolean
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r62018617
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
---
@@ -157,14 +203,25 @@ public boolean
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r62018432
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
---
@@ -139,12 +184,13 @@ public void
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r62018300
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
---
@@ -81,25 +127,36 @@ public void
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r62018256
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
---
@@ -81,25 +127,36 @@ public void
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r62018227
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
---
@@ -21,57 +21,103 @@
import
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r62018169
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/split/JDBCInputSplitsGenerator.java
---
@@ -15,17 +15,14 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r62018058
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/split/JDBCInputSplitsGenerator.java
---
@@ -15,17 +15,14 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r62017855
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/QueryParamInputSplit.java
---
@@ -0,0 +1,53 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270411#comment-15270411
]
ASF GitHub Bot commented on FLINK-3701:
---
Github user tillrohrmann commented on the pull request:
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1913#issuecomment-216816200
What happens if the Akka communication is local? Would that mean that the
list of registered Kryo types is shared between the `JobManager` and the
`Client`? This
[
https://issues.apache.org/jira/browse/FLINK-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270372#comment-15270372
]
ASF GitHub Bot commented on FLINK-3701:
---
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/1913#discussion_r62011352
--- Diff:
flink-core/src/main/java/org/apache/flink/util/SerializableCacheableValue.java
---
@@ -0,0 +1,127 @@
+/*
+ * Licensed to the Apache
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1915#issuecomment-216793718
Thanks for the update @stefanobortoli.
PR is good to merge once tests pass.
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-3865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270360#comment-15270360
]
Till Rohrmann commented on FLINK-3865:
--
Hi Greg, I think your issue is a duplicate of FLINK-3701.
>
[
https://issues.apache.org/jira/browse/FLINK-3662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270358#comment-15270358
]
Robert Metzger commented on FLINK-3662:
---
I think the whole project died for now because Akka 2.4
[
https://issues.apache.org/jira/browse/FLINK-3864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-3864:
--
Description: {{YarnTestBase.runWithArgs(...)}} provides a parameter for
strings which
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/1964
[FLINK-3860] [connector-wikiedits] Add retry loop to
WikipediaEditsSourceTest
Add a retry loop to `WikipediaEditsSourceTest` and checks connection to IRC
server before running the test. The test is
[
https://issues.apache.org/jira/browse/FLINK-3864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-3864:
--
Summary: Yarn tests don't check for prohibited strings in log output (was:
Yarn
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1920#issuecomment-216789910
Thanks for the update @gna-phetsarath. Good to merge, IMO.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-1827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270342#comment-15270342
]
ASF GitHub Bot commented on FLINK-1827:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-3864:
--
Description:
{{YarnTestBase.runWithArgs(...)}} provides a parameter for strings which
[
https://issues.apache.org/jira/browse/FLINK-3860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270334#comment-15270334
]
ASF GitHub Bot commented on FLINK-3860:
---
GitHub user uce opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-3864:
--
Summary: Yarn per-job cluster sets parallelism to 1 instead of
#taskmanagers * #slots
1 - 100 of 105 matches
Mail list logo
