Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3417#discussion_r103197368
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/io/RowCsvInputFormatTest.java
---
@@ -311,7 +317,7 @@ public void
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3417#discussion_r103200986
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/io/RowCsvInputFormat.java ---
@@ -197,6 +197,14 @@ protected boolean parseRecord(Object[]
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3417#discussion_r103197216
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/io/CsvInputFormatTest.java
---
@@ -400,7 +400,7 @@ public void readMixedQuotedStringFields() {
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3417#discussion_r103203254
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/GenericCsvInputFormat.java
---
@@ -392,12 +395,17 @@ protected boolean
[
https://issues.apache.org/jira/browse/FLINK-5844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885810#comment-15885810
]
lining commented on FLINK-5844:
---
I just update version ！ My problem is why restart fail in 1.1.3？
>
[
https://issues.apache.org/jira/browse/FLINK-5917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15887094#comment-15887094
]
Xiaogang Shi commented on FLINK-5917:
-
[~StephanEwen] We just use the cache to avoid the costly
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15887161#comment-15887161
]
ASF GitHub Bot commented on FLINK-4422:
---
Github user jinmingjian commented on a diff in the pull
Github user jinmingjian commented on a diff in the pull request:
https://github.com/apache/flink/pull/3420#discussion_r103196536
--- Diff:
flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueue.java
---
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15887162#comment-15887162
]
ASF GitHub Bot commented on FLINK-4422:
---
Github user jinmingjian commented on a diff in the pull
Github user jinmingjian commented on a diff in the pull request:
https://github.com/apache/flink/pull/3420#discussion_r103195631
--- Diff:
flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KillerWatchDog.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui reassigned FLINK-5818:
Assignee: Tao Wang
> change checkpoint dir permission to 700 for security reason
>
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/3426
Hi @haohui , the code looks very good to me. Thanks for investigating this,
waiting for the CI pass.
@twalthr , I think you would like to have a look.
---
If your project is set up for it,
[
https://issues.apache.org/jira/browse/FLINK-5414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15887104#comment-15887104
]
ASF GitHub Bot commented on FLINK-5414:
---
Github user wuchong commented on the issue:
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3389#discussion_r103361639
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -140,6 +138,24 @@ object
[
https://issues.apache.org/jira/browse/FLINK-5881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15887126#comment-15887126
]
ASF GitHub Bot commented on FLINK-5881:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15887127#comment-15887127
]
ASF GitHub Bot commented on FLINK-5881:
---
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/3389#discussion_r103366163
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/ScalarSqlFunction.scala
---
@@ -114,7 +114,9 @@ object
[
https://issues.apache.org/jira/browse/FLINK-5752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ramkrishna.s.vasudevan updated FLINK-5752:
--
Description:
This is after the discussion to create
[
https://issues.apache.org/jira/browse/FLINK-5803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15887374#comment-15887374
]
ASF GitHub Bot commented on FLINK-5803:
---
Github user sunjincheng121 commented on the issue:
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3397
@fhueske thanks for the PR(#3425). I have rebased the code, and add
timeMode check. I'm appreciated if you can look at this PR.
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-5921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15887417#comment-15887417
]
Haohui Mai commented on FLINK-5921:
---
My understanding is that there should be no need for code
Github user clarkyzl commented on a diff in the pull request:
https://github.com/apache/flink/pull/3389#discussion_r103369181
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -140,6 +138,24 @@ object
[
https://issues.apache.org/jira/browse/FLINK-5881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15887167#comment-15887167
]
ASF GitHub Bot commented on FLINK-5881:
---
Github user clarkyzl commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15887370#comment-15887370
]
ASF GitHub Bot commented on FLINK-5921:
---
Github user sunjincheng121 commented on a diff in the pull
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3425#discussion_r103384285
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/FunctionGenerator.scala
---
@@ -327,6 +329,15 @@ object
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3418
@fhueske thanks for your review. I have updated the PR.
IMO. The main purpose of doing this PR is to enhance the function of
Flat/MapRunner. In addition, my next plan is:
Use CODE-GEN
[
https://issues.apache.org/jira/browse/FLINK-5776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15887474#comment-15887474
]
ASF GitHub Bot commented on FLINK-5776:
---
Github user sunjincheng121 commented on the issue:
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3417#discussion_r103224327
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/io/CsvInputFormatTest.java
---
@@ -957,6 +964,42 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-5907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885898#comment-15885898
]
ASF GitHub Bot commented on FLINK-5907:
---
Github user KurtYoung commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3418#discussion_r103206651
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/FlatMapRunner.scala
---
@@ -43,7 +45,13 @@ class FlatMapRunner[IN,
[
https://issues.apache.org/jira/browse/FLINK-5586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885923#comment-15885923
]
ASF GitHub Bot commented on FLINK-5586:
---
Github user KurtYoung commented on the issue:
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3417#discussion_r103225144
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/io/RowCsvInputFormatTest.java
---
@@ -311,7 +317,7 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-5808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-5808:
Fix Version/s: 1.2.1
1.3.0
> Missing verification for setParallelism and
[
https://issues.apache.org/jira/browse/FLINK-5907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885908#comment-15885908
]
ASF GitHub Bot commented on FLINK-5907:
---
Github user KurtYoung commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885909#comment-15885909
]
ASF GitHub Bot commented on FLINK-5907:
---
Github user KurtYoung commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885926#comment-15885926
]
ASF GitHub Bot commented on FLINK-5524:
---
Github user KurtYoung commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886022#comment-15886022
]
ASF GitHub Bot commented on FLINK-5928:
---
GitHub user uce opened a pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/3424
[FLINK-5928] [checkpoints] Use custom metadata file for externalized
checkpoints
- Adds a checkpoint coordinator test for externalized checkpoints. This was
covered only in unit tests for the involved
[
https://issues.apache.org/jira/browse/FLINK-5907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885895#comment-15885895
]
ASF GitHub Bot commented on FLINK-5907:
---
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/3417#discussion_r103224286
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/io/CsvInputFormatTest.java
---
@@ -400,7 +400,7 @@ public void readMixedQuotedStringFields()
[
https://issues.apache.org/jira/browse/FLINK-5808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-5808:
Affects Version/s: 1.2.0
> Missing verification for setParallelism and setMaxParallelism
>
[
https://issues.apache.org/jira/browse/FLINK-5907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885904#comment-15885904
]
ASF GitHub Bot commented on FLINK-5907:
---
Github user KurtYoung commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885917#comment-15885917
]
ASF GitHub Bot commented on FLINK-5776:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885915#comment-15885915
]
ASF GitHub Bot commented on FLINK-5776:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885916#comment-15885916
]
ASF GitHub Bot commented on FLINK-5776:
---
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/3418#discussion_r103226511
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1562,6 +1561,39 @@ class CodeGenerator(
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3418#discussion_r103206923
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/MapRunner.scala
---
@@ -41,7 +43,13 @@ class MapRunner[IN, OUT](
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/3340
@StephanEwen , thanks for professional reviews!
I attached the design doc in this jira for the implementation
consideration.
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885891#comment-15885891
]
Jaromir Vanek commented on FLINK-3674:
--
Hi,
I am wondering what was the intention behind not
Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/3372
hey @twalthr, any more comments or this can be merged
---
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 shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3423
I think we could further remove AggregateMapFunction and
DataSetWindowAggregateMapFunction for windowedDataSet and DataSet, and let
reduce function directly accumulator the input values. But
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3417#discussion_r103226814
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/GenericCsvInputFormat.java
---
@@ -392,12 +395,17 @@ protected boolean
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3417#discussion_r103225729
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/io/RowCsvInputFormat.java ---
@@ -197,6 +197,14 @@ protected boolean parseRecord(Object[]
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885864#comment-15885864
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user shaoxuan-wang commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885951#comment-15885951
]
Aljoscha Krettek commented on FLINK-3674:
-
The main reason was not wanting to expose to much
[
https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886378#comment-15886378
]
Shannon Carey commented on FLINK-5929:
--
Just to clarify, you're referring to the state from
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3417
Thanks for the fast update @KurtYoung.
+1 to merge
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
[
https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886378#comment-15886378
]
Shannon Carey edited comment on FLINK-5929 at 2/27/17 7:40 PM:
---
Just to
[
https://issues.apache.org/jira/browse/FLINK-5931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886438#comment-15886438
]
Haohui Mai commented on FLINK-5931:
---
I have confirmed with [~gtCarrera9] (a YARN committer and Hadoop
[
https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886445#comment-15886445
]
ASF GitHub Bot commented on FLINK-3679:
---
Github user haohui commented on the issue:
Github user haohui commented on the issue:
https://github.com/apache/flink/pull/3314
@rmetzger ping...
just wondering what do you think about all the approaches we have discussed
here? Your comments are appreciated.
---
If your project is set up for it, you can reply to this
Seth Wiesman created FLINK-5930:
---
Summary: Allow Access to Job Id from Runtime Context
Key: FLINK-5930
URL: https://issues.apache.org/jira/browse/FLINK-5930
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886220#comment-15886220
]
Bill Liu edited comment on FLINK-5668 at 2/27/17 5:55 PM:
--
[~rmetzger]
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886220#comment-15886220
]
Bill Liu commented on FLINK-5668:
-
[~rmetzger]
[~wheat9]] and I are working on implementing a flink job
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886342#comment-15886342
]
Haohui Mai edited comment on FLINK-5668 at 2/27/17 7:37 PM:
[~rmetzger] --
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886342#comment-15886342
]
Haohui Mai edited comment on FLINK-5668 at 2/27/17 7:37 PM:
[~rmetzger] --
Haohui Mai created FLINK-5931:
-
Summary: Make Flink highly available even if defaultFS is
unavailable
Key: FLINK-5931
URL: https://issues.apache.org/jira/browse/FLINK-5931
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886419#comment-15886419
]
Shannon Carey commented on FLINK-5929:
--
If I understand correctly, I agree this would be useful.
[
https://issues.apache.org/jira/browse/FLINK-5931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai updated FLINK-5931:
--
Description:
In order to use Flink in mission-critical environments, Flink must be available
even if
[
https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886446#comment-15886446
]
Seth Wiesman commented on FLINK-5929:
-
[~aljoscha] Yes this does look like what we were discussing.
[
https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886450#comment-15886450
]
Seth Wiesman commented on FLINK-5929:
-
[~rehevkor5] Yes, state for individual window panes.
> Allow
[
https://issues.apache.org/jira/browse/FLINK-5907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886379#comment-15886379
]
ASF GitHub Bot commented on FLINK-5907:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886404#comment-15886404
]
Haohui Mai commented on FLINK-5668:
---
[~bill.liu8904] I believe that the title of the jira is confusing.
[
https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886378#comment-15886378
]
Shannon Carey edited comment on FLINK-5929 at 2/27/17 7:38 PM:
---
Just to
[
https://issues.apache.org/jira/browse/FLINK-5706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886417#comment-15886417
]
Seth Wiesman commented on FLINK-5706:
-
[~StephanEwen] To expand on our conversation from the mailing
Aljoscha Krettek created FLINK-5929:
---
Summary: Allow Access to Per-Window State in ProcessWindowFunction
Key: FLINK-5929
URL: https://issues.apache.org/jira/browse/FLINK-5929
Project: Flink
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3378
Thanks for the review @rmetzger!
For the moving of `open()` to before `run()`, I've included that as the
commit tagged with FLINK-5849.
For the star import fix, I'm going to include that
[
https://issues.apache.org/jira/browse/FLINK-5930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seth Wiesman updated FLINK-5930:
Affects Version/s: (was: 1.2.1)
(was: 1.3.0)
> Allow Access to Job
[
https://issues.apache.org/jira/browse/FLINK-5849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886122#comment-15886122
]
ASF GitHub Bot commented on FLINK-5849:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886214#comment-15886214
]
ASF GitHub Bot commented on FLINK-5849:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886157#comment-15886157
]
Stephan Ewen commented on FLINK-5917:
-
Doesn't the cache compromise the "out-of-core" capabilities of
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886220#comment-15886220
]
Bill Liu edited comment on FLINK-5668 at 2/27/17 6:00 PM:
--
[~rmetzger]
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885870#comment-15885870
]
ASF GitHub Bot commented on FLINK-4364:
---
Github user zhijiangW commented on the issue:
Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/3339
hey @fhueske can you take a look at this?
---
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-2922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885949#comment-15885949
]
Aljoscha Krettek commented on FLINK-2922:
-
By the way, it would be as easy as adding
{code}
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3391
@barcahead Thansk for contributing this.
I can try and get to this later this week. Big pull request backlog right
now ;-)
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-5849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886210#comment-15886210
]
ASF GitHub Bot commented on FLINK-5849:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3378
Tests pass, 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
enabled and wishes
[
https://issues.apache.org/jira/browse/FLINK-5849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-5849.
Resolution: Fixed
Fix Version/s: 1.3.0
Resolved for {{master}} via
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3378
---
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-5703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885860#comment-15885860
]
ASF GitHub Bot commented on FLINK-5703:
---
Github user zhijiangW commented on the issue:
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/3151
Hi, @tillrohrmann , thanks for so detail reviews! I got all the points and
may submit the modifications tomorrow, then I will ping you!
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-5808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-5808:
Priority: Blocker (was: Major)
> Missing verification for setParallelism and
[
https://issues.apache.org/jira/browse/FLINK-5907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885905#comment-15885905
]
ASF GitHub Bot commented on FLINK-5907:
---
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/3417#discussion_r103226821
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/GenericCsvInputFormat.java
---
@@ -358,24 +358,27 @@ protected boolean
[
https://issues.apache.org/jira/browse/FLINK-5758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886235#comment-15886235
]
ASF GitHub Bot commented on FLINK-5758:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886298#comment-15886298
]
Nico Kruber commented on FLINK-5923:
I guess the following error may also originate from that race
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886342#comment-15886342
]
Haohui Mai commented on FLINK-5668:
---
[~rmetzger] -- just want to clarify FLINK-5631 here.
YARN
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/3385
hi @StephanEwen , thank for you review, I modify it according to your
comments, add getJobSchedulingStatus to it and add tests.
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885338#comment-15885338
]
ASF GitHub Bot commented on FLINK-5501:
---
Github user shuai-xu commented on the issue:
101 - 200 of 265 matches
Mail list logo
