[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

2018-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617106#comment-16617106 ] ASF GitHub Bot commented on FLINK-7243: --- HuangZhenQiu commented on issue #6483: [FL

[GitHub] HuangZhenQiu commented on issue #6483: [FLINK-7243][flink-formats] Add parquet input format

2018-09-16 Thread GitBox
HuangZhenQiu commented on issue #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#issuecomment-421894204 @lvhuyen For the Array handling issue, I figured it out. it is a List back compatibility issue. When I do internal testing a

[GitHub] zhijiangW commented on issue #6697: [hotfix][benchmarks] Add network broadcast benchmark

2018-09-16 Thread GitBox
zhijiangW commented on issue #6697: [hotfix][benchmarks] Add network broadcast benchmark URL: https://github.com/apache/flink/pull/6697#issuecomment-421886999 @pnowojski , I am supposed to cover the broadcast scenario benchmark later because of #6417, thanks for adding this timely. :)

[jira] [Commented] (FLINK-10348) Solve data skew when consuming data from kafka

2018-09-16 Thread Jiayi Liao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617054#comment-16617054 ] Jiayi Liao commented on FLINK-10348: [~elevy] 1. From my perspective, we use fetch

[jira] [Commented] (FLINK-10319) Too many requestPartitionState would crash JM

2018-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617034#comment-16617034 ] ASF GitHub Bot commented on FLINK-10319: TisonKun commented on issue #6680: [FLI

[jira] [Commented] (FLINK-10319) Too many requestPartitionState would crash JM

2018-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617035#comment-16617035 ] ASF GitHub Bot commented on FLINK-10319: TisonKun commented on issue #6680: [FLI

[GitHub] TisonKun commented on issue #6680: [FLINK-10319] [runtime] Too many requestPartitionState would crash JM

2018-09-16 Thread GitBox
TisonKun commented on issue #6680: [FLINK-10319] [runtime] Too many requestPartitionState would crash JM URL: https://github.com/apache/flink/pull/6680#issuecomment-421882421 @Clark Thanks for your review! This is an auto

[GitHub] TisonKun commented on issue #6680: [FLINK-10319] [runtime] Too many requestPartitionState would crash JM

2018-09-16 Thread GitBox
TisonKun commented on issue #6680: [FLINK-10319] [runtime] Too many requestPartitionState would crash JM URL: https://github.com/apache/flink/pull/6680#issuecomment-421882434 cc @StephanEwen @twalthr This is an automated mes

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

2018-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617017#comment-16617017 ] ASF GitHub Bot commented on FLINK-7243: --- lvhuyen commented on issue #6483: [FLINK-7

[GitHub] lvhuyen commented on issue #6483: [FLINK-7243][flink-formats] Add parquet input format

2018-09-16 Thread GitBox
lvhuyen commented on issue #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#issuecomment-421880581 @HuangZhenQiu Sorry for the late response. I was wrong. The problem should also be with PojoInputFormat as well.

[jira] [Commented] (FLINK-10341) Add option to print flink command when running bin/flink

2018-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16617014#comment-16617014 ] ASF GitHub Bot commented on FLINK-10341: Clark commented on issue #6690: [FL

[GitHub] Clarkkkkk commented on issue #6690: [FLINK-10341][shell script] Add option to print flink command when running bin/flink

2018-09-16 Thread GitBox
Clark commented on issue #6690: [FLINK-10341][shell script] Add option to print flink command when running bin/flink URL: https://github.com/apache/flink/pull/6690#issuecomment-421879448 +1 This is an automated message fr

[jira] [Updated] (FLINK-10240) Pluggable scheduling strategy for batch jobs

2018-09-16 Thread Zhu Zhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-10240: Summary: Pluggable scheduling strategy for batch jobs (was: Pluggable scheduling strategy for batch job)

[jira] [Commented] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

2018-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16616958#comment-16616958 ] ASF GitHub Bot commented on FLINK-10205: isunjin commented on issue #6684: [

[GitHub] isunjin commented on issue #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource…

2018-09-16 Thread GitBox
isunjin commented on issue #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource… URL: https://github.com/apache/flink/pull/6684#issuecomment-421858786 I have put the the document here, note that the document not only include this issue, but includes other failover i

[jira] [Commented] (FLINK-10259) Key validation for GroupWindowAggregate is broken

2018-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16616941#comment-16616941 ] ASF GitHub Bot commented on FLINK-10259: fhueske commented on issue #6641: [FLIN

[GitHub] fhueske commented on issue #6641: [FLINK-10259] [table] Fix key extraction for GroupWindows.

2018-09-16 Thread GitBox
fhueske commented on issue #6641: [FLINK-10259] [table] Fix key extraction for GroupWindows. URL: https://github.com/apache/flink/pull/6641#issuecomment-421851590 Thanks for the review @hequn8128! I've updated the PR. This

[jira] [Commented] (FLINK-10259) Key validation for GroupWindowAggregate is broken

2018-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16616938#comment-16616938 ] ASF GitHub Bot commented on FLINK-10259: fhueske commented on a change in pull r

[GitHub] fhueske commented on a change in pull request #6641: [FLINK-10259] [table] Fix key extraction for GroupWindows.

2018-09-16 Thread GitBox
fhueske commented on a change in pull request #6641: [FLINK-10259] [table] Fix key extraction for GroupWindows. URL: https://github.com/apache/flink/pull/6641#discussion_r217931616 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/In

[jira] [Commented] (FLINK-10348) Solve data skew when consuming data from kafka

2018-09-16 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16616933#comment-16616933 ] Elias Levy commented on FLINK-10348: I would suggest the strategy employed by Kafka

[jira] [Closed] (FLINK-10222) Table scalar function expression parses error when function name equals the exists keyword suffix

2018-09-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-10222. - Resolution: Fixed Assignee: vinoyang Fix Version/s: 1.5.5 1.6.

[jira] [Commented] (FLINK-10222) Table scalar function expression parses error when function name equals the exists keyword suffix

2018-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16616907#comment-16616907 ] ASF GitHub Bot commented on FLINK-10222: asfgit closed pull request #6622: [FLIN

[GitHub] asfgit closed pull request #6622: [FLINK-10222] [table] Table scalar function expression parses error when function name equals the exists keyword suffix

2018-09-16 Thread GitBox
asfgit closed pull request #6622: [FLINK-10222] [table] Table scalar function expression parses error when function name equals the exists keyword suffix URL: https://github.com/apache/flink/pull/6622 This is a PR merged from a forked repository. As GitHub hides the original diff on merge

[jira] [Commented] (FLINK-10348) Solve data skew when consuming data from kafka

2018-09-16 Thread Jiayi Liao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16616853#comment-16616853 ] Jiayi Liao commented on FLINK-10348: [~twalthr][~Zentol] What do you think of this f

[jira] [Closed] (FLINK-10350) Add assignTimestampsAndWatermarks in KeyedStream

2018-09-16 Thread Jiayi Liao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao closed FLINK-10350. -- Resolution: Invalid > Add assignTimestampsAndWatermarks in KeyedStream > -

[jira] [Created] (FLINK-10351) Ignore specific operator's state when restore from savepoint

2018-09-16 Thread Jiayi Liao (JIRA)
Jiayi Liao created FLINK-10351: -- Summary: Ignore specific operator's state when restore from savepoint Key: FLINK-10351 URL: https://issues.apache.org/jira/browse/FLINK-10351 Project: Flink Iss

[jira] [Issue Comment Deleted] (FLINK-6895) Add STR_TO_DATE supported in SQL

2018-09-16 Thread nando (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nando updated FLINK-6895: - Comment: was deleted (was: Do you mean the string to format? It can be a column reference, for example: {code:s

[jira] [Issue Comment Deleted] (FLINK-6895) Add STR_TO_DATE supported in SQL

2018-09-16 Thread nando (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nando updated FLINK-6895: - Comment: was deleted (was: Taking a look at this [MySQL STR_TO_DATE|https://dev.mysql.com/doc/refman/5.5/en/date

[jira] [Commented] (FLINK-10341) Add option to print flink command when running bin/flink

2018-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16616740#comment-16616740 ] ASF GitHub Bot commented on FLINK-10341: zjffdu commented on issue #6690: [FLINK

[GitHub] zjffdu commented on issue #6690: [FLINK-10341][shell script] Add option to print flink command when running bin/flink

2018-09-16 Thread GitBox
zjffdu commented on issue #6690: [FLINK-10341][shell script] Add option to print flink command when running bin/flink URL: https://github.com/apache/flink/pull/6690#issuecomment-421770262 Thanks for the review @TisonKun , @dawidwys `bash -x` do helps, but my sencairo is a little different.

[jira] [Commented] (FLINK-10349) Unify stopActor utils

2018-09-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16616699#comment-16616699 ] ASF GitHub Bot commented on FLINK-10349: TisonKun commented on issue #6701: [FLI

[GitHub] TisonKun commented on issue #6701: [FLINK-10349] Unify stopActor utils

2018-09-16 Thread GitBox
TisonKun commented on issue #6701: [FLINK-10349] Unify stopActor utils URL: https://github.com/apache/flink/pull/6701#issuecomment-421757683 cc @tillrohrmann @GJL This is an automated message from the Apache Git Service. To r