[
https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15624238#comment-15624238
]
ASF GitHub Bot commented on FLINK-4174:
---
GitHub user soniclavier opened a pull reque
GitHub user soniclavier opened a pull request:
https://github.com/apache/flink/pull/2736
[FLINK-4174] Enhance evictor functionality
The PR implements
[FLINK-4174](https://issues.apache.org/jira/browse/FLINK-4174) Enhance window
evictor as proposed in
[FLIP-4](https://cwiki.apache.
Mike Dias created FLINK-4988:
Summary: Elasticsearch 5.x support
Key: FLINK-4988
URL: https://issues.apache.org/jira/browse/FLINK-4988
Project: Flink
Issue Type: New Feature
Reporter:
[
https://issues.apache.org/jira/browse/FLINK-4885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mike Dias closed FLINK-4885.
Resolution: Invalid
I just realized that these optimizations aren't doable because:
- The missing construct
[
https://issues.apache.org/jira/browse/FLINK-4923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15624170#comment-15624170
]
ASF GitHub Bot commented on FLINK-4923:
---
Github user zhuhaifengleon commented on a d
Github user zhuhaifengleon commented on a diff in the pull request:
https://github.com/apache/flink/pull/2727#discussion_r85869851
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskIOMetricGroup.java
---
@@ -80,18 +76,25 @@ public Meter getNumBytesO
Till Rohrmann created FLINK-4987:
Summary: Harden slot pool logic
Key: FLINK-4987
URL: https://issues.apache.org/jira/browse/FLINK-4987
Project: Flink
Issue Type: Sub-task
Reporte
Till Rohrmann created FLINK-4986:
Summary: Harden JobMaster logic
Key: FLINK-4986
URL: https://issues.apache.org/jira/browse/FLINK-4986
Project: Flink
Issue Type: Sub-task
Component
GitHub user kalmanchapman opened a pull request:
https://github.com/apache/flink/pull/2735
[FLINK-2094] implements Word2Vec for FlinkML
This pr implements Word2Vec for FlinkML - addressing Jira Issue
[Flink-2094](https://issues.apache.org/jira/browse/FLINK-2094)
Word2Vec is
[
https://issues.apache.org/jira/browse/FLINK-2094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15623730#comment-15623730
]
ASF GitHub Bot commented on FLINK-2094:
---
GitHub user kalmanchapman opened a pull req
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15623168#comment-15623168
]
ASF GitHub Bot commented on FLINK-4861:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2664
I need to rework this since additional classes are being pulled into the
uber jar.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. I
[
https://issues.apache.org/jira/browse/FLINK-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15623110#comment-15623110
]
ASF GitHub Bot commented on FLINK-4826:
---
GitHub user vijikarthi opened a pull reques
GitHub user vijikarthi opened a pull request:
https://github.com/apache/flink/pull/2734
Keytab & TLS support for Flink on Mesos Setup
This PR addresses below issues
- FLINK-4826 (Keytab support on Mesos environment)
- FLINK-4918 (TLS support for Mesos Artifact Server)
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2718
Thanks @mxm !
---
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-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15623082#comment-15623082
]
ASF GitHub Bot commented on FLINK-3617:
---
Github user chermenin commented on a diff i
Github user chermenin commented on a diff in the pull request:
https://github.com/apache/flink/pull/2723#discussion_r85812829
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/OptionSerializer.scala
---
@@ -65,7 +65,7 @@ class OptionSerializer[A](val elemSe
[
https://issues.apache.org/jira/browse/FLINK-4977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sean Winard updated FLINK-4977:
---
Description:
Enums produce serialization failures whether they are by themselves or part of
a POJO in
[
https://issues.apache.org/jira/browse/FLINK-4980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-4980:
--
Comment: was deleted
(was: Should we make this part of FLINK-4861 which is still in review?)
> Include
[
https://issues.apache.org/jira/browse/FLINK-4984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reassigned FLINK-4984:
---
Assignee: Stephan Ewen
> Add Cancellation Barriers to BarrierTracker and BarrierBuffer
>
Stephan Ewen created FLINK-4985:
---
Summary: Report Declined/Canceled Checkpoints to Checkpoint
Coordinator
Key: FLINK-4985
URL: https://issues.apache.org/jira/browse/FLINK-4985
Project: Flink
I
Stephan Ewen created FLINK-4984:
---
Summary: Add Cancellation Barriers to BarrierTracker and
BarrierBuffer
Key: FLINK-4984
URL: https://issues.apache.org/jira/browse/FLINK-4984
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-4980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15623002#comment-15623002
]
Greg Hogan commented on FLINK-4980:
---
Should we make this part of FLINK-4861 which is sti
[
https://issues.apache.org/jira/browse/FLINK-4979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622972#comment-15622972
]
Ufuk Celebi commented on FLINK-4979:
I also noticed this and agree that the checkbox i
[
https://issues.apache.org/jira/browse/FLINK-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622962#comment-15622962
]
Stephan Ewen commented on FLINK-4982:
-
The output is in the standard out file of the T
[
https://issues.apache.org/jira/browse/FLINK-4659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4659.
---
> Potential resource leak due to unclosed InputStream in
> SecurityContext#populateSystemSecurityProperti
[
https://issues.apache.org/jira/browse/FLINK-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4932.
---
> Don't let ExecutionGraph fail when in state Restarting
> ---
[
https://issues.apache.org/jira/browse/FLINK-4933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4933.
-
Resolution: Fixed
Fixed in
- 1.2.0 via 649f9578bce56e118ec973218271262286c534a9
- 1.1.4 via d
[
https://issues.apache.org/jira/browse/FLINK-4933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4933.
---
> ExecutionGraph.scheduleOrUpdateConsumers can fail the ExecutionGraph
> -
[
https://issues.apache.org/jira/browse/FLINK-4894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622938#comment-15622938
]
Stephan Ewen commented on FLINK-4894:
-
Merged additional patch in 3e85fc6138b555a6a559
[
https://issues.apache.org/jira/browse/FLINK-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4932.
-
Resolution: Fixed
Fixed in
- 1.2.0 via 18507de3c068795c93c5c689388a22857f2f817c
- 1.1.4 via ac
[
https://issues.apache.org/jira/browse/FLINK-4659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4659.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed via 649f9578bce56e118ec973218271262286c534a9
Mischa Krüger created FLINK-4983:
Summary: Web UI: Add favicon
Key: FLINK-4983
URL: https://issues.apache.org/jira/browse/FLINK-4983
Project: Flink
Issue Type: Improvement
Component
Mischa Krüger created FLINK-4982:
Summary: quickstart example: Can't see the output
Key: FLINK-4982
URL: https://issues.apache.org/jira/browse/FLINK-4982
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622929#comment-15622929
]
ASF GitHub Bot commented on FLINK-4894:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622927#comment-15622927
]
ASF GitHub Bot commented on FLINK-4659:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622930#comment-15622930
]
ASF GitHub Bot commented on FLINK-4933:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2665
---
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 enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2700
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622928#comment-15622928
]
ASF GitHub Bot commented on FLINK-4932:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2716
---
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 enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2710
---
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 enab
Mischa Krüger created FLINK-4981:
Summary: Job Plan view: Not very readable and informative
Key: FLINK-4981
URL: https://issues.apache.org/jira/browse/FLINK-4981
Project: Flink
Issue Type: Im
Jamie Grier created FLINK-4980:
--
Summary: Include example source code in Flink binary distribution
Key: FLINK-4980
URL: https://issues.apache.org/jira/browse/FLINK-4980
Project: Flink
Issue Type
Mischa Krüger created FLINK-4978:
Summary: Present dropdown list with possible entry points for job
Key: FLINK-4978
URL: https://issues.apache.org/jira/browse/FLINK-4978
Project: Flink
Issue
Mischa Krüger created FLINK-4979:
Summary: Submit Job view: Replace checkboxes for job entry with a
link on the job name
Key: FLINK-4979
URL: https://issues.apache.org/jira/browse/FLINK-4979
Project:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2718
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-4896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-4896:
--
Fix Version/s: 1.2.0
> PageRank algorithm for directed graphs
> --
>
[
https://issues.apache.org/jira/browse/FLINK-4193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622902#comment-15622902
]
Stefan Richter commented on FLINK-4193:
---
I fixed some concurrency issues in the Rock
[
https://issues.apache.org/jira/browse/FLINK-4896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622894#comment-15622894
]
ASF GitHub Bot commented on FLINK-4896:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2733
[FLINK-4896] [gelly] PageRank algorithm for directed graphs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/greghogan/flink
4896_pagerank_alg
[
https://issues.apache.org/jira/browse/FLINK-4272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622880#comment-15622880
]
ASF GitHub Bot commented on FLINK-4272:
---
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2732
[FLINK-4272] Create a JobClient for job control and monitoring
Also includes: [FLINK-4274] Expose new JobClient in the DataSet/DataStream
API
- rename JobClient class to JobClientActorUtils
[
https://issues.apache.org/jira/browse/FLINK-4977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sean Winard updated FLINK-4977:
---
Description:
Enums produce serialization failures whether they are by themselves or part of
a POJO in
[
https://issues.apache.org/jira/browse/FLINK-4977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622869#comment-15622869
]
Sean Winard commented on FLINK-4977:
Cleaned up the test program
> Enum serialization
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2465
Hey @greghogan Do you think you have time to add the note you mentioned and
then merge this?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as wel
Sean Winard created FLINK-4977:
--
Summary: Enum serialization does not work properly
Key: FLINK-4977
URL: https://issues.apache.org/jira/browse/FLINK-4977
Project: Flink
Issue Type: Bug
Affec
[
https://issues.apache.org/jira/browse/FLINK-4447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622825#comment-15622825
]
ASF GitHub Bot commented on FLINK-4447:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622787#comment-15622787
]
Gyula Fora commented on FLINK-4193:
---
Yes, still an issue that we could not figure out. W
[
https://issues.apache.org/jira/browse/FLINK-4221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622781#comment-15622781
]
ASF GitHub Bot commented on FLINK-4221:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2724
Thank you for the review @zentol. I addressed your comments and rebased to
master again.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as we
[
https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622756#comment-15622756
]
ASF GitHub Bot commented on FLINK-3617:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2723#discussion_r85785788
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/OptionSerializer.scala
---
@@ -65,7 +65,7 @@ class OptionSerializer[A](val elemSeri
[
https://issues.apache.org/jira/browse/FLINK-4623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622733#comment-15622733
]
ASF GitHub Bot commented on FLINK-4623:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622732#comment-15622732
]
ASF GitHub Bot commented on FLINK-4623:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2720#discussion_r85783220
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/StreamTableEnvironment.scala
---
@@ -311,14 +313,24 @@ abstract class StreamT
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2720#discussion_r85783793
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/stream/ExplainStreamTest.scala
---
@@ -40,9 +40,12 @@ class ExplainStreamTest
Github user chermenin commented on a diff in the pull request:
https://github.com/apache/flink/pull/2723#discussion_r85782914
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/OptionSerializer.scala
---
@@ -65,7 +65,7 @@ class OptionSerializer[A](val elemSe
[
https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622715#comment-15622715
]
ASF GitHub Bot commented on FLINK-3617:
---
Github user chermenin commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-4974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-4974.
-
Resolution: Fixed
Fixed trough 094b747
> RescalingITCase.testSavepointRescalingInPartitionedOpera
Stephan Ewen created FLINK-4976:
---
Summary: Add a way to abort in flight checkpoints
Key: FLINK-4976
URL: https://issues.apache.org/jira/browse/FLINK-4976
Project: Flink
Issue Type: New Feature
Stephan Ewen created FLINK-4975:
---
Summary: Add a limit for how much data may be buffered during
checkpoint alignment
Key: FLINK-4975
URL: https://issues.apache.org/jira/browse/FLINK-4975
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622680#comment-15622680
]
Stephan Ewen commented on FLINK-4193:
-
[~gyfora] Is this issue still valid?
> Task ma
[
https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622677#comment-15622677
]
ASF GitHub Bot commented on FLINK-3617:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2723#discussion_r85779839
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/OptionSerializer.scala
---
@@ -65,7 +65,7 @@ class OptionSerializer[A](val elemSeri
Robert Metzger created FLINK-4974:
-
Summary:
RescalingITCase.testSavepointRescalingInPartitionedOperatorState unstable
Key: FLINK-4974
URL: https://issues.apache.org/jira/browse/FLINK-4974
Project: Fl
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2712
Very much agree Stephan! I don't know what sounds better to native speakers
and more intuitive to users though... unresumed state or non restored state?
;-) @greghogan @jgrier do you have any input on th
[
https://issues.apache.org/jira/browse/FLINK-4445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622672#comment-15622672
]
ASF GitHub Bot commented on FLINK-4445:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622668#comment-15622668
]
ASF GitHub Bot commented on FLINK-4743:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2686
I got a bit lost in the discussion, but if I understood @wuchong's options
right, I prefer the first option. Automatically converting `DECIMAL` to
`DOUBLE` can result in rounding errors. However, the
[
https://issues.apache.org/jira/browse/FLINK-4445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622651#comment-15622651
]
ASF GitHub Bot commented on FLINK-4445:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2712
Looks good to me, except the name `ignoreUnmappedState` ;-)
As usual, the three most difficult things in computer science are (1)
finding good names, and (2) off-by-one errors.
What d
[
https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622639#comment-15622639
]
ASF GitHub Bot commented on FLINK-3617:
---
Github user chermenin commented on a diff i
Github user chermenin commented on a diff in the pull request:
https://github.com/apache/flink/pull/2723#discussion_r85776021
--- Diff:
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/CaseClassComparatorTest.scala
---
@@ -34,7 +34,7 @@ import org.mockito.Mockito
[
https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622637#comment-15622637
]
ASF GitHub Bot commented on FLINK-3617:
---
Github user chermenin commented on a diff i
Github user chermenin commented on a diff in the pull request:
https://github.com/apache/flink/pull/2723#discussion_r85775790
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/OptionSerializer.scala
---
@@ -65,7 +65,7 @@ class OptionSerializer[A](val elemSe
[
https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622624#comment-15622624
]
Stephan Ewen commented on FLINK-4973:
-
I think the fix should remove the dedicated thr
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2723#discussion_r85770344
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/OptionSerializer.scala
---
@@ -65,7 +65,7 @@ class OptionSerializer[A](val elemSeri
[
https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622565#comment-15622565
]
ASF GitHub Bot commented on FLINK-3617:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622566#comment-15622566
]
ASF GitHub Bot commented on FLINK-3617:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2723#discussion_r85770866
--- Diff:
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/CaseClassComparatorTest.scala
---
@@ -34,7 +34,7 @@ import org.mockito.Mockito
[
https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622526#comment-15622526
]
ASF GitHub Bot commented on FLINK-4315:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-3813:
-
Affects Version/s: 1.2.0
> YARNSessionFIFOITCase.testDetachedMode failed on Travis
> -
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2637#discussion_r85768134
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/operator/JoinOperatorTest.java
---
@@ -1211,7 +1210,6 @@ public String toString() {
[
https://issues.apache.org/jira/browse/FLINK-3813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622525#comment-15622525
]
Till Rohrmann commented on FLINK-3813:
--
Two more instances:
https://s3.amazonaws.com/
[
https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622516#comment-15622516
]
ASF GitHub Bot commented on FLINK-4743:
---
Github user tonycox commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622515#comment-15622515
]
ASF GitHub Bot commented on FLINK-4315:
---
Github user fhueske commented on the issue:
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2686
@wuchong if choosing second option, why not to solve this issue
https://issues.apache.org/jira/browse/CALCITE-1468 instead of solve on flink
side ?
---
If your project is set up for it, you can rep
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2637
Thanks for the update @kenmy. We are trying to keep the Java and Scala APIs
as close as possible. Could you convert the Scala `FlinkHadoopEnvironment` into
a `HadoopInputs` class as well?
I
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2637#discussion_r85765311
--- Diff:
flink-tests/src/test/scala/org/apache/flink/api/scala/hadoop/mapred/WordCountMapredITCase.scala
---
@@ -42,8 +42,8 @@ class WordCountMapredITCase e
1 - 100 of 217 matches
Mail list logo
