[
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 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-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
>
[
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 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-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:
[
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
[
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-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
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-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
[
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
---
@@
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-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_r103361639
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -140,6 +138,24 @@ object
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
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:
[
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-5907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5907.
Resolution: Fixed
Fix Version/s: 1.2.1
1.3.0
Fixed for 1.2.1 with
[
https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-3475.
Resolution: Implemented
Fix Version/s: 1.3.0
Implemented for 1.3.0 with
[
https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886763#comment-15886763
]
ASF GitHub Bot commented on FLINK-3475:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3417
---
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-5907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886762#comment-15886762
]
ASF GitHub Bot commented on FLINK-5907:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3111
---
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 haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/3314#discussion_r103339489
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/RichKeyedDeserializationSchema.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886750#comment-15886750
]
ASF GitHub Bot commented on FLINK-3679:
---
Github user haohui commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-5133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886691#comment-15886691
]
ASF GitHub Bot commented on FLINK-5133:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3303
I have merged this to my local repository.
There were some issues left, partly in the commented out code.
In particular `checkNotNull(variable !=null) does not work, because
[
https://issues.apache.org/jira/browse/FLINK-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886688#comment-15886688
]
ASF GitHub Bot commented on FLINK-5501:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3385
One test case seemed to be failing in this PR:
I have merged the PR to my local repository, fixed the test, and added some
fixes/cleanups on top.
Will merge back to Flink master
[
https://issues.apache.org/jira/browse/FLINK-5414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886650#comment-15886650
]
ASF GitHub Bot commented on FLINK-5414:
---
GitHub user haohui opened a pull request:
GitHub user haohui opened a pull request:
https://github.com/apache/flink/pull/3426
[FLINK-5414] [table] Bump up Calcite version to 1.11
This PR resembles #3338 except that it canonizes the nullable types.
@wuchong can you please take a look?
You can merge this pull
[
https://issues.apache.org/jira/browse/FLINK-5803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886579#comment-15886579
]
ASF GitHub Bot commented on FLINK-5803:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3397
Hi @sunjincheng121, I opened PR #3425, which adds custom data types for
`proctime()` and `rowtime()` and replaces the functions during translation with
constants.
You can rebase your commit
[
https://issues.apache.org/jira/browse/FLINK-5921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886575#comment-15886575
]
ASF GitHub Bot commented on FLINK-5921:
---
GitHub user fhueske opened a pull request:
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/3425
[FLINK-5921] [table] Add custom data types for rowtime and proctime.
We add a custom data type for the result of the `rowtime()` and
`proctime()` marker functions to easier identify the chosen time
[
https://issues.apache.org/jira/browse/FLINK-5907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886552#comment-15886552
]
ASF GitHub Bot commented on FLINK-5907:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3417
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 so, or if the
[
https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886551#comment-15886551
]
ASF GitHub Bot commented on FLINK-3475:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3111
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 so, or if the
[
https://issues.apache.org/jira/browse/FLINK-5570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886524#comment-15886524
]
Haohui Mai commented on FLINK-5570:
---
Thanks [~fhueske] for the pointer. Just took a very quick skim --
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3424
Thanks, good and critical fix!
Looking 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
[
https://issues.apache.org/jira/browse/FLINK-5928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886521#comment-15886521
]
ASF GitHub Bot commented on FLINK-5928:
---
Github user StephanEwen commented on the issue:
[
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
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
[
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:
[
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-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=15886419#comment-15886419
]
Shannon Carey commented on FLINK-5929:
--
If I understand correctly, I agree this would be useful.
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-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
[
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:40 PM:
---
Just to
[
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-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-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-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] --
[
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
[
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-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:
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-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-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-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: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-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:
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:comment-tabpanel=15886210#comment-15886210
]
ASF GitHub Bot commented on FLINK-5849:
---
Github user tzulitai commented on the issue:
[
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
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-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:
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
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
[
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-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-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}
[
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:
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
[
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 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
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,
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(
[
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
[
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
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 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-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
[
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
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[]
1 - 100 of 265 matches
Mail list logo
