[jira] [Commented] (FLINK-6094) Implement stream-stream proctime non-window inner join

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16275369#comment-16275369 ] ASF GitHub Bot commented on FLINK-6094: --- Github user hequn8128 commented on the issue:

[GitHub] flink issue #4471: [FLINK-6094] [table] Implement stream-stream proctime non...

2017-12-01 Thread hequn8128
Github user hequn8128 commented on the issue: https://github.com/apache/flink/pull/4471 hi @twalthr , Sorry for the late reply. The notification of github has been ignored mistakenly. I will give an update ASAP. Thanks very much. ---

[jira] [Commented] (FLINK-8141) Add AppendStreamTableSink for bucketed ORC files

2017-12-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16275158#comment-16275158 ] Till Rohrmann commented on FLINK-8141: -- Sorry, I mixed up the JIRA numbers. The merged PR fixed

[jira] [Commented] (FLINK-8141) Add AppendStreamTableSink for bucketed ORC files

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16275155#comment-16275155 ] ASF GitHub Bot commented on FLINK-8141: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-8184) Return raw JsonPlan instead of escaped string value in JobDetailsInfo

2017-12-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8184. Resolution: Fixed Fixed via ee9027e491ff50bf72f51c869a5095aef7092396 > Return raw JsonPlan instead

[GitHub] flink pull request #5109: [FLINK-8141] [flip6] Fix JsonPlan serialization in...

2017-12-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5109 ---

[jira] [Commented] (FLINK-8141) Add AppendStreamTableSink for bucketed ORC files

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16275149#comment-16275149 ] ASF GitHub Bot commented on FLINK-8141: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #5109: [FLINK-8141] [flip6] Fix JsonPlan serialization in JobDet...

2017-12-01 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5109 Merging this PR. ---

[jira] [Commented] (FLINK-8173) InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue.

2017-12-01 Thread Tao Xia (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16275136#comment-16275136 ] Tao Xia commented on FLINK-8173: thanks for the fix. it is working now with 1.4 >

[jira] [Commented] (FLINK-8030) Start JobMasterRestEndpoint in JobClusterEntrypoint

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16275117#comment-16275117 ] ASF GitHub Bot commented on FLINK-8030: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #4988: [FLINK-8030] Instantiate JobMasterRestEndpoint in JobClus...

2017-12-01 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4988 Actually we cannot change it to `0.0.0.0`, because the address is also used by the client to connect to the rest server. Therefore, it must be a valid target address. ---

[jira] [Commented] (FLINK-8030) Start JobMasterRestEndpoint in JobClusterEntrypoint

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16275113#comment-16275113 ] ASF GitHub Bot commented on FLINK-8030: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #4988: [FLINK-8030] Instantiate JobMasterRestEndpoint in JobClus...

2017-12-01 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4988 Thanks for the review @shuai-xu. I'll change the default value of the rest address to `0.0.0.0`. ---

[jira] [Commented] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat

2017-12-01 Thread Sebastian Klemke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274913#comment-16274913 ] Sebastian Klemke commented on FLINK-8186: - [~twalthr] Thanks for looking into it. To summarize:

[jira] [Created] (FLINK-8189) move flink-statebackend-rocksdb out of flink-contrib

2017-12-01 Thread Bowen Li (JIRA)
Bowen Li created FLINK-8189: --- Summary: move flink-statebackend-rocksdb out of flink-contrib Key: FLINK-8189 URL: https://issues.apache.org/jira/browse/FLINK-8189 Project: Flink Issue Type:

[jira] [Updated] (FLINK-8175) remove flink-streaming-contrib and migrate its classes to flink-streaming-java/scala

2017-12-01 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8175: Issue Type: Sub-task (was: Improvement) Parent: FLINK-8188 > remove flink-streaming-contrib and

[jira] [Assigned] (FLINK-8175) remove flink-streaming-contrib and migrate its classes to flink-streaming-java/scala

2017-12-01 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-8175: --- Assignee: Bowen Li > remove flink-streaming-contrib and migrate its classes to >

[jira] [Created] (FLINK-8188) Clean up flink-contrib

2017-12-01 Thread Bowen Li (JIRA)
Bowen Li created FLINK-8188: --- Summary: Clean up flink-contrib Key: FLINK-8188 URL: https://issues.apache.org/jira/browse/FLINK-8188 Project: Flink Issue Type: Improvement Affects Versions:

[jira] [Commented] (FLINK-7294) mesos.resourcemanager.framework.role not working

2017-12-01 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274705#comment-16274705 ] Eron Wright commented on FLINK-7294: - [~bbayani] I too thought it would be fine but upon further

[jira] [Commented] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat

2017-12-01 Thread Sebastian Klemke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274656#comment-16274656 ] Sebastian Klemke commented on FLINK-8186: - With -Pbuild-jar, the job fat-jar includes avro,

[jira] [Commented] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat

2017-12-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274641#comment-16274641 ] Timo Walther commented on FLINK-8186: - Thanks, I will look into it again on Monday. > AvroInputFormat

[jira] [Updated] (FLINK-8173) InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue.

2017-12-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8173: Component/s: Table API & SQL > InvalidProgramException: Table program cannot be compiled. This is a

[jira] [Resolved] (FLINK-8173) InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue.

2017-12-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8173. - Resolution: Fixed Fix Version/s: 1.5.0 1.4.0 Fixed in 1.5:

[jira] [Updated] (FLINK-8173) InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue.

2017-12-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8173: Affects Version/s: 1.4.0 > InvalidProgramException: Table program cannot be compiled. This is a

[jira] [Commented] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat

2017-12-01 Thread Sebastian Klemke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274628#comment-16274628 ] Sebastian Klemke commented on FLINK-8186: - The error only occurs if job jar was built with

[jira] [Commented] (FLINK-8173) InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue.

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274613#comment-16274613 ] ASF GitHub Bot commented on FLINK-8173: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5111: [FLINK-8173] [table] Fix input unboxing and suppor...

2017-12-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5111 ---

[jira] [Commented] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat

2017-12-01 Thread Sebastian Klemke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274609#comment-16274609 ] Sebastian Klemke commented on FLINK-8186: - Regarding binaries: Yes, this is the runtime I'm using.

[jira] [Resolved] (FLINK-8151) [Table] Map equality check to use entrySet equality

2017-12-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8151. - Resolution: Fixed Fix Version/s: 1.5.0 Fixed in 1.5:

[jira] [Commented] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat

2017-12-01 Thread Sebastian Klemke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274601#comment-16274601 ] Sebastian Klemke commented on FLINK-8186: - What puzzles me is

[jira] [Commented] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException

2017-12-01 Thread Christos Hadjinikolis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274596#comment-16274596 ] Christos Hadjinikolis commented on FLINK-5506: -- Just to note that I have tried running the

[jira] [Commented] (FLINK-8151) [Table] Map equality check to use entrySet equality

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274595#comment-16274595 ] ASF GitHub Bot commented on FLINK-8151: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5070: [FLINK-8151][table]Map equality check to use entry...

2017-12-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5070 ---

[jira] [Commented] (FLINK-8173) InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue.

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274591#comment-16274591 ] ASF GitHub Bot commented on FLINK-8173: --- Github user fhueske commented on the issue:

[GitHub] flink issue #5111: [FLINK-8173] [table] Fix input unboxing and support Avro ...

2017-12-01 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5111 Thanks for the fix. +1 to merge ---

[jira] [Commented] (FLINK-8151) [Table] Map equality check to use entrySet equality

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274580#comment-16274580 ] ASF GitHub Bot commented on FLINK-8151: --- Github user twalthr commented on the issue:

[GitHub] flink issue #5070: [FLINK-8151][table]Map equality check to use entrySet equ...

2017-12-01 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5070 @walterddr I think the current solution is sufficient for now. I will merge this... ---

[jira] [Commented] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat

2017-12-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274567#comment-16274567 ] Timo Walther commented on FLINK-8186: - Is it possible that the error is only reproducible with your

[jira] [Commented] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat

2017-12-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274565#comment-16274565 ] Timo Walther commented on FLINK-8186: - Actually, the error is also very weird because

[jira] [Commented] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat

2017-12-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274561#comment-16274561 ] Timo Walther commented on FLINK-8186: - I'm sorry but I cannot reproduce your error. Are you using

[jira] [Updated] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat

2017-12-01 Thread Sebastian Klemke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebastian Klemke updated FLINK-8186: Summary: AvroInputFormat regression: fails to deserialize GenericRecords on standalone

[jira] [Commented] (FLINK-7574) Remove unused dependencies from flink-clients

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274516#comment-16274516 ] ASF GitHub Bot commented on FLINK-7574: --- Github user yew1eb commented on the issue:

[GitHub] flink issue #5076: [FLINK-7574][build] POM Cleanup flink-clients

2017-12-01 Thread yew1eb
Github user yew1eb commented on the issue: https://github.com/apache/flink/pull/5076 @zentol , Thanks for your suggestions, i will be very careful to clean up the dependencies. I will start with the top modules (not used by other modules), order as follow: > ├──

[jira] [Created] (FLINK-8187) Web client does not print errors

2017-12-01 Thread Timo Walther (JIRA)
Timo Walther created FLINK-8187: --- Summary: Web client does not print errors Key: FLINK-8187 URL: https://issues.apache.org/jira/browse/FLINK-8187 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on cluster with hadoop27 compat

2017-12-01 Thread Sebastian Klemke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274503#comment-16274503 ] Sebastian Klemke commented on FLINK-8186: - Invocation: {code} flink-1.4.0/bin/jobmanager.sh start

[jira] [Commented] (FLINK-8181) Kafka producer's FlinkFixedPartitioner returns different partitions when a target topic is rescaled

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274500#comment-16274500 ] ASF GitHub Bot commented on FLINK-8181: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #5108: [FLINK-8181] [kafka] Make FlinkFixedPartitioner in...

2017-12-01 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5108#discussion_r154368266 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java ---

[jira] [Updated] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on cluster with hadoop27 compat

2017-12-01 Thread Sebastian Klemke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebastian Klemke updated FLINK-8186: Attachment: pom.xml GenericRecordCount.java > AvroInputFormat regression:

[jira] [Commented] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on cluster with hadoop27 compat

2017-12-01 Thread Sebastian Klemke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274497#comment-16274497 ] Sebastian Klemke commented on FLINK-8186: - Hey [~twalthr], I used the flink-quickstart-java and

[jira] [Commented] (FLINK-8181) Kafka producer's FlinkFixedPartitioner returns different partitions when a target topic is rescaled

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274482#comment-16274482 ] ASF GitHub Bot commented on FLINK-8181: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #5108: [FLINK-8181] [kafka] Make FlinkFixedPartitioner in...

2017-12-01 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5108#discussion_r154363656 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java ---

[jira] [Commented] (FLINK-8181) Kafka producer's FlinkFixedPartitioner returns different partitions when a target topic is rescaled

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274480#comment-16274480 ] ASF GitHub Bot commented on FLINK-8181: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #5108: [FLINK-8181] [kafka] Make FlinkFixedPartitioner in...

2017-12-01 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5108#discussion_r154363505 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java ---

[jira] [Commented] (FLINK-8176) Dispatcher does not start SubmittedJobGraphStore

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274468#comment-16274468 ] ASF GitHub Bot commented on FLINK-8176: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-8176) Dispatcher does not start SubmittedJobGraphStore

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274469#comment-16274469 ] ASF GitHub Bot commented on FLINK-8176: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #5107: [FLINK-8176][flip6] Start SubmittedJobGraphStore i...

2017-12-01 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5107#discussion_r154357254 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java --- @@ -534,6 +536,40 @@ public void handleError(final

[GitHub] flink pull request #5107: [FLINK-8176][flip6] Start SubmittedJobGraphStore i...

2017-12-01 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5107#discussion_r154359352 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java --- @@ -117,84 +135,78 @@ public void

[jira] [Commented] (FLINK-8173) InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue.

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274465#comment-16274465 ] ASF GitHub Bot commented on FLINK-8173: --- GitHub user twalthr opened a pull request:

[GitHub] flink pull request #5111: [FLINK-8173] [table] Fix input unboxing and suppor...

2017-12-01 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/5111 [FLINK-8173] [table] Fix input unboxing and support Avro Utf8 ## What is the purpose of the change Fixes a code generation issue that caused problems with Avro types. It adds tests for

[jira] [Commented] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on cluster with hadoop27 compat

2017-12-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274452#comment-16274452 ] Timo Walther commented on FLINK-8186: - [~packet] we moved Avro out of the Flink core into a dedicated

[GitHub] flink pull request #5110: [hotfix][docs] Fix typo in Checkpointing doc

2017-12-01 Thread chuanlei
GitHub user chuanlei opened a pull request: https://github.com/apache/flink/pull/5110 [hotfix][docs] Fix typo in Checkpointing doc You can merge this pull request into a Git repository by running: $ git pull https://github.com/chuanlei/flink fix-typo-in-checkpointing-doc

[jira] [Commented] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on cluster with hadoop27 compat

2017-12-01 Thread Sebastian Klemke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274435#comment-16274435 ] Sebastian Klemke commented on FLINK-8186: - Test program runs with Flink 1.4 hadoop27 on YARN. Is

[jira] [Updated] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on cluster with hadoop27 compat

2017-12-01 Thread Sebastian Klemke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebastian Klemke updated FLINK-8186: Priority: Minor (was: Major) > AvroInputFormat regression: fails to deserialize

[jira] [Assigned] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException

2017-12-01 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reassigned FLINK-5506: - Assignee: Greg Hogan > Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException >

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274408#comment-16274408 ] ASF GitHub Bot commented on FLINK-7468: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274404#comment-16274404 ] ASF GitHub Bot commented on FLINK-7468: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274407#comment-16274407 ] ASF GitHub Bot commented on FLINK-7468: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274406#comment-16274406 ] ASF GitHub Bot commented on FLINK-7468: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274409#comment-16274409 ] ASF GitHub Bot commented on FLINK-7468: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274405#comment-16274405 ] ASF GitHub Bot commented on FLINK-7468: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

2017-12-01 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r154343510 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionView.java --- @@ -39,13 +39,15 @@ private

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

2017-12-01 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r154344889 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionView.java --- @@ -133,7 +135,7 @@ int

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

2017-12-01 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r154344924 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpilledSubpartitionView.java --- @@ -114,7 +116,7 @@ public void

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

2017-12-01 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r154344942 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/CancelPartitionRequestTest.java --- @@ -174,19 +175,21 @@ public

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

2017-12-01 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r154343587 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartitionView.java --- @@ -22,32 +22,57 @@ import

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

2017-12-01 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r154343656 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartitionView.java --- @@ -22,32 +22,57 @@ import

[jira] [Created] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on cluster with hadoop27 compat

2017-12-01 Thread Sebastian Klemke (JIRA)
Sebastian Klemke created FLINK-8186: --- Summary: AvroInputFormat regression: fails to deserialize GenericRecords on cluster with hadoop27 compat Key: FLINK-8186 URL:

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274364#comment-16274364 ] ASF GitHub Bot commented on FLINK-7416: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274368#comment-16274368 ] ASF GitHub Bot commented on FLINK-7416: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274373#comment-16274373 ] ASF GitHub Bot commented on FLINK-7416: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274375#comment-16274375 ] ASF GitHub Bot commented on FLINK-7416: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274377#comment-16274377 ] ASF GitHub Bot commented on FLINK-7416: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274369#comment-16274369 ] ASF GitHub Bot commented on FLINK-7416: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274372#comment-16274372 ] ASF GitHub Bot commented on FLINK-7416: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-12-01 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r154320189 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java --- @@ -244,54 +237,89 @@ public void

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-12-01 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r154321304 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java --- @@ -244,54 +237,89 @@ public void

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274379#comment-16274379 ] ASF GitHub Bot commented on FLINK-7416: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274367#comment-16274367 ] ASF GitHub Bot commented on FLINK-7416: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-12-01 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r154318950 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -280,94 +280,120 @@ public String

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-12-01 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r154338813 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java --- @@ -244,54 +237,89 @@ public void

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274378#comment-16274378 ] ASF GitHub Bot commented on FLINK-7416: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274366#comment-16274366 ] ASF GitHub Bot commented on FLINK-7416: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274376#comment-16274376 ] ASF GitHub Bot commented on FLINK-7416: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-12-01 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r154321125 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java --- @@ -244,54 +237,89 @@ public void

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-12-01 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r154321327 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java --- @@ -244,54 +237,89 @@ public void

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274365#comment-16274365 ] ASF GitHub Bot commented on FLINK-7416: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-12-01 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r154338695 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java --- @@ -244,54 +237,89 @@ public void

[GitHub] flink pull request #4533: [FLINK-7416][network] Implement Netty receiver out...

2017-12-01 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4533#discussion_r154315390 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java --- @@ -144,20 +147,19 @@ public void

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274371#comment-16274371 ] ASF GitHub Bot commented on FLINK-7416: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-12-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274374#comment-16274374 ] ASF GitHub Bot commented on FLINK-7416: --- Github user NicoK commented on a diff in the pull request:

  1   2   >