[jira] [Created] (FLINK-8019) Flink streaming job stopped at consuming Kafka data

2017-11-07 Thread Weihua Jiang (JIRA)
Weihua Jiang created FLINK-8019: --- Summary: Flink streaming job stopped at consuming Kafka data Key: FLINK-8019 URL: https://issues.apache.org/jira/browse/FLINK-8019 Project: Flink Issue Type:

[GitHub] flink pull request #4979: RMQSource support disabling queue declaration

2017-11-07 Thread sihuazhou
GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/4979 RMQSource support disabling queue declaration ## What is the purpose of the change This PR fixs [FLINK-8018](https://issues.apache.org/jira/browse/FLINK-8018), RabbitMQ connector should

[jira] [Created] (FLINK-8018) RMQ does not support disabling queueDeclare, when the user has no declaration permissions, it cannot connect

2017-11-07 Thread Sihua Zhou (JIRA)
Sihua Zhou created FLINK-8018: - Summary: RMQ does not support disabling queueDeclare, when the user has no declaration permissions, it cannot connect Key: FLINK-8018 URL:

[jira] [Commented] (FLINK-7704) Port JobPlanHandler to new REST endpoint

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16243348#comment-16243348 ] ASF GitHub Bot commented on FLINK-7704: --- GitHub user yew1eb opened a pull request:

[jira] [Updated] (FLINK-8019) Flink streaming job stopped at consuming Kafka data

2017-11-07 Thread Weihua Jiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Jiang updated FLINK-8019: Attachment: jstack-20171108-2.log > Flink streaming job stopped at consuming Kafka data >

[jira] [Commented] (FLINK-8018) RMQ does not support disabling queueDeclare, when the user has no declaration permissions, it cannot connect

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16243453#comment-16243453 ] ASF GitHub Bot commented on FLINK-8018: --- GitHub user sihuazhou opened a pull request:

[jira] [Commented] (FLINK-7704) Port JobPlanHandler to new REST endpoint

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16243422#comment-16243422 ] ASF GitHub Bot commented on FLINK-7704: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #4967: [FLINK-8001] [kafka] Prevent PeriodicWatermarkEmitter fro...

2017-11-07 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4967 Merging .. ---

[GitHub] flink issue #4978: [FLINK-7704][hotfix][flip6] Fix JobPlanInfoTest package p...

2017-11-07 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4978 LGTM 👍 ---

[GitHub] flink issue #4959: [FLINK-7998] private scope is changed to public to resolv...

2017-11-07 Thread naeioi
Github user naeioi commented on the issue: https://github.com/apache/flink/pull/4959 Also can you replace `params.get("order")` with `params.get("orders")` in TPCHQuery3.scala for consistency with java and the input hint? ---

[jira] [Commented] (FLINK-8017) High availability cluster-id option incorrect in documentation

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16243227#comment-16243227 ] ASF GitHub Bot commented on FLINK-8017: --- GitHub user dkelley-accretive opened a pull request:

[jira] [Commented] (FLINK-8001) Mark Kafka Consumer as idle if it doesn't have partitions

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16243419#comment-16243419 ] ASF GitHub Bot commented on FLINK-8001: --- Github user tzulitai commented on the issue:

[jira] [Commented] (FLINK-7998) Make case classes in TPCHQuery3.java public to allow dynamic instantiation

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16243230#comment-16243230 ] ASF GitHub Bot commented on FLINK-7998: --- Github user naeioi commented on the issue:

[GitHub] flink issue #4883: [FLINK-4809] Operators should tolerate checkpoint failure...

2017-11-07 Thread PangZhi
Github user PangZhi commented on the issue: https://github.com/apache/flink/pull/4883 @StefanRRichter do we have any update on this PR? ---

[jira] [Comment Edited] (FLINK-8008) PojoTypeInfo should sort fields fields based on boolean

2017-11-07 Thread Muhammad Imran Tariq (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16243362#comment-16243362 ] Muhammad Imran Tariq edited comment on FLINK-8008 at 11/8/17 4:40 AM: --

[GitHub] flink pull request #4978: [FLINK-7704][hotfix][flip6] Fix JobPlanInfoTest pa...

2017-11-07 Thread yew1eb
GitHub user yew1eb opened a pull request: https://github.com/apache/flink/pull/4978 [FLINK-7704][hotfix][flip6] Fix JobPlanInfoTest package path This PR fix the package path of `JobPlanInfoTest`, consistent with the JobPlanInfo `org.apache.flink.runtime.rest.messages`. You

[GitHub] flink pull request #4977: [FLINK-7996] [table] Add support for (left.time = ...

2017-11-07 Thread xccui
GitHub user xccui opened a pull request: https://github.com/apache/flink/pull/4977 [FLINK-7996] [table] Add support for (left.time = right.time) predicates to window join ## What is the purpose of the change This PR adds `left.time = right.time` predicates support for

[jira] [Commented] (FLINK-7996) Add support for (left.time = right.time) predicates to window join.

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16243292#comment-16243292 ] ASF GitHub Bot commented on FLINK-7996: --- GitHub user xccui opened a pull request:

[jira] [Created] (FLINK-8017) High availability cluster-id option incorrect in documentation

2017-11-07 Thread Dan Kelley (JIRA)
Dan Kelley created FLINK-8017: - Summary: High availability cluster-id option incorrect in documentation Key: FLINK-8017 URL: https://issues.apache.org/jira/browse/FLINK-8017 Project: Flink

[GitHub] flink issue #4729: [FLINK-7076] [ResourceManager] implement YARN stopWorker ...

2017-11-07 Thread suez1224
Github user suez1224 commented on the issue: https://github.com/apache/flink/pull/4729 @tillrohrmann Updated the PR that addresses your comments. Could you please take another look when you have time? ---

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16243264#comment-16243264 ] ASF GitHub Bot commented on FLINK-7076: --- Github user suez1224 commented on the issue:

[GitHub] flink pull request #4976: [FLINK-8017] Fix High availability cluster-id key ...

2017-11-07 Thread dkelley-accretive
GitHub user dkelley-accretive opened a pull request: https://github.com/apache/flink/pull/4976 [FLINK-8017] Fix High availability cluster-id key in documentation *Thank you very much for contributing to Apache Flink - we are happy that you want to help us improve Flink. To help the

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

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

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

2017-11-07 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r149540088 --- Diff: flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java --- @@ -0,0 +1,354 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-4809) Operators should tolerate checkpoint failures

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242917#comment-16242917 ] ASF GitHub Bot commented on FLINK-4809: --- Github user PangZhi commented on the issue:

[jira] [Commented] (FLINK-4809) Operators should tolerate checkpoint failures

2017-11-07 Thread Jing Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242916#comment-16242916 ] Jing Fan commented on FLINK-4809: - Do we have any update on the PR? It has been handing for weeks. >

[jira] [Comment Edited] (FLINK-4809) Operators should tolerate checkpoint failures

2017-11-07 Thread Jing Fan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242916#comment-16242916 ] Jing Fan edited comment on FLINK-4809 at 11/7/17 9:26 PM: -- Do we have any update

[jira] [Commented] (FLINK-8004) Sample code in Debugging & Monitoring Metrics documentation section is not valid java

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242875#comment-16242875 ] ASF GitHub Bot commented on FLINK-8004: --- Github user greghogan commented on the issue:

[GitHub] flink issue #4965: [FLINK-8004][metrics][docs] Fix usage examples

2017-11-07 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4965 LGTM. ---

[jira] [Commented] (FLINK-8010) Bump remaining flink-shaded dependencies

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242873#comment-16242873 ] ASF GitHub Bot commented on FLINK-8010: --- Github user zentol commented on the issue:

[GitHub] flink issue #4971: [FLINK-8010][build] Bump remaining flink-shaded versions

2017-11-07 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4971 scratch that, i have it in this one, here: ``` org.apache.flink flink-shaded-guava - 18.0-1.0 +

[GitHub] flink issue #4971: [FLINK-8010][build] Bump remaining flink-shaded versions

2017-11-07 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4971 @greghogan I also had this in another PR but not this one. ---

[jira] [Commented] (FLINK-8010) Bump remaining flink-shaded dependencies

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242872#comment-16242872 ] ASF GitHub Bot commented on FLINK-8010: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-7998) Make case classes in TPCHQuery3.java public to allow dynamic instantiation

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242834#comment-16242834 ] ASF GitHub Bot commented on FLINK-7998: --- Github user greghogan commented on the issue:

[GitHub] flink issue #4971: [FLINK-8010][build] Bump remaining flink-shaded versions

2017-11-07 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4971 Is anyone else seeing the red/green highlights shifted two lines up for this PR? I'm seeing this in multiple browsers and with plug-ins disabled but only on this PR. ---

[GitHub] flink issue #4959: [FLINK-7998] private scope is changed to public to resolv...

2017-11-07 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4959 Looks good but I have not tested. Can we also fix the parameter swap referenced in the JIRA? ---

[jira] [Commented] (FLINK-8010) Bump remaining flink-shaded dependencies

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242848#comment-16242848 ] ASF GitHub Bot commented on FLINK-8010: --- Github user greghogan commented on the issue:

[jira] [Updated] (FLINK-7897) Consider using nio.Files for file deletion in TransientBlobCleanupTask

2017-11-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7897: -- Description: nio.Files#delete() provides better clue as to why the deletion may fail:

[jira] [Commented] (FLINK-8006) flink-daemon.sh: line 103: binary operator expected

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242636#comment-16242636 ] ASF GitHub Bot commented on FLINK-8006: --- Github user elbaulp commented on the issue:

[GitHub] flink issue #4968: [FLINK-8006] [Startup Shell Scripts] Enclosing $pid in qu...

2017-11-07 Thread elbaulp
Github user elbaulp commented on the issue: https://github.com/apache/flink/pull/4968 @greghogan Done, sorry for ignoring the stop script. ---

[jira] [Commented] (FLINK-8006) flink-daemon.sh: line 103: binary operator expected

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242567#comment-16242567 ] ASF GitHub Bot commented on FLINK-8006: --- Github user elbaulp commented on the issue:

[GitHub] flink issue #4968: [FLINK-8006] [Startup Shell Scripts] Enclosing $pid in qu...

2017-11-07 Thread elbaulp
Github user elbaulp commented on the issue: https://github.com/apache/flink/pull/4968 @greghogan Didn't realized!, its failing too. I am going to fix it. ---

[jira] [Commented] (FLINK-7978) Kafka011 exactly-once Producer sporadically fails to commit under high parallelism

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242540#comment-16242540 ] ASF GitHub Bot commented on FLINK-7978: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #4955: [FLINK-7978][kafka] Ensure that transactional ids will ne...

2017-11-07 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4955 Thanks for fixing this! And thanks for the review! I merged, could you please close the PR? ---

[jira] [Closed] (FLINK-7978) Kafka011 exactly-once Producer sporadically fails to commit under high parallelism

2017-11-07 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7978. --- Resolution: Fixed Fixed on release-1.4 in 3cbf467ebdf639df4d7d4da78b7bc2929aa4b5d9

[jira] [Commented] (FLINK-8008) PojoTypeInfo should sort fields fields based on boolean

2017-11-07 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242512#comment-16242512 ] Aljoscha Krettek commented on FLINK-8008: - What method is this using for reading? > PojoTypeInfo

[jira] [Commented] (FLINK-7977) bump version of compatibility check for Flink 1.4

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242503#comment-16242503 ] ASF GitHub Bot commented on FLINK-7977: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #4945: [FLINK-7977][build] bump version of compatibility check f...

2017-11-07 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4945 @greghogan I commented on the issue. Yes this is the API compatibility check and the API should actually stay stable for all of the 1.x series. That's also why I'm wondering why we're comparing

[jira] [Commented] (FLINK-7973) Fix service shading relocation for S3 file systems

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

[GitHub] flink pull request #4961: [FLINK-7973] fix shading and relocating Hadoop for...

2017-11-07 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4961#discussion_r149449571 --- Diff: flink-filesystems/flink-s3-fs-hadoop/pom.xml --- @@ -33,6 +33,7 @@ under the License. jar + --- End diff --

[jira] [Commented] (FLINK-7977) bump version of compatibility check for Flink 1.4

2017-11-07 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242495#comment-16242495 ] Bowen Li commented on FLINK-7977: - [~greghogan] You're right, it should be API compatibility. Sorry that I

[jira] [Commented] (FLINK-8006) flink-daemon.sh: line 103: binary operator expected

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242480#comment-16242480 ] ASF GitHub Bot commented on FLINK-8006: --- Github user greghogan commented on the issue:

[GitHub] flink issue #4968: [FLINK-8006] [Startup Shell Scripts] Enclosing $pid in qu...

2017-11-07 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4968 Do we also need to quote within sub-expressions? Have you looked at the stop script? ---

[jira] [Commented] (FLINK-8009) flink-dist pulls in flink-runtime's transitive avro/jackson dependency

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242475#comment-16242475 ] ASF GitHub Bot commented on FLINK-8009: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #4972: [FLINK-8009][build][runtime] Remove transitive dependency...

2017-11-07 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4972 This looks good to go! I actually checked it out and manually ran the end-to-end tests because it's quicker than waiting for travis. 😅 ---

[jira] [Commented] (FLINK-7991) Cleanup kafka example jar filters

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242460#comment-16242460 ] ASF GitHub Bot commented on FLINK-7991: --- GitHub user zentol opened a pull request:

[jira] [Closed] (FLINK-7905) HadoopS3FileSystemITCase failed on travis

2017-11-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7905. --- Resolution: Fixed > HadoopS3FileSystemITCase failed on travis >

[GitHub] flink pull request #4975: [FLINK-7991][examples][kafka] Cleanup kafka10 exam...

2017-11-07 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4975 [FLINK-7991][examples][kafka] Cleanup kafka10 example jar ## What is the purpose of the change This PR cleans up the kafka example shading configuration, removing plenty of unnecessary

[jira] [Commented] (FLINK-8012) Table with time attribute cannot be written to CsvTableSink

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242458#comment-16242458 ] ASF GitHub Bot commented on FLINK-8012: --- GitHub user fhueske opened a pull request:

[GitHub] flink pull request #4974: [FLINK-8012] [table] Fix TableSink config for tabl...

2017-11-07 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/4974 [FLINK-8012] [table] Fix TableSink config for tables with time attributes. ## What is the purpose of the change Fix the configuration of TableSinks for Tables with time attributes

[jira] [Commented] (FLINK-5633) ClassCastException: X cannot be cast to X when re-submitting a job.

2017-11-07 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242418#comment-16242418 ] Stephan Ewen commented on FLINK-5633: - [~erikvanoosten] Okay, I assume that the reveres class loading

[jira] [Closed] (FLINK-7481) Binary search with integer overflow possibility

2017-11-07 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 closed FLINK-7481. - Resolution: Won't Fix > Binary search with integer overflow possibility >

[jira] [Commented] (FLINK-7977) bump version of compatibility check for Flink 1.4

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242409#comment-16242409 ] ASF GitHub Bot commented on FLINK-7977: --- Github user greghogan commented on the issue:

[GitHub] flink issue #4945: [FLINK-7977][build] bump version of compatibility check f...

2017-11-07 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4945 Isn't this API compatibility rather than checkpoint/savepoint compatibility? And if the former should not 1.4 be checked against 1.3 (which should be checked against 1.2, etc.)? ---

[jira] [Commented] (FLINK-8009) flink-dist pulls in flink-runtime's transitive avro/jackson dependency

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242407#comment-16242407 ] ASF GitHub Bot commented on FLINK-8009: --- Github user zentol commented on the issue:

[GitHub] flink issue #4972: [FLINK-8009][build][runtime] Remove transitive dependency...

2017-11-07 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4972 @aljoscha fixed ---

[jira] [Commented] (FLINK-7419) Shade jackson dependency in flink-avro

2017-11-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242398#comment-16242398 ] Chesnay Schepler commented on FLINK-7419: - We could still relocating it though. The avro

[jira] [Commented] (FLINK-8009) flink-dist pulls in flink-runtime's transitive avro/jackson dependency

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242350#comment-16242350 ] ASF GitHub Bot commented on FLINK-8009: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #4972: [FLINK-8009][build][runtime] Remove transitive dependency...

2017-11-07 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4972 Currently this fails because of missing entries in `dependencyManagement` in the root pom. ---

[jira] [Commented] (FLINK-7419) Shade jackson dependency in flink-avro

2017-11-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242337#comment-16242337 ] Chesnay Schepler commented on FLINK-7419: - I'm not entirely sure. Avro _does_ expose jackson in

[jira] [Commented] (FLINK-8009) flink-dist pulls in flink-runtime's transitive avro/jackson dependency

2017-11-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242328#comment-16242328 ] Chesnay Schepler commented on FLINK-8009: - yes, but they should only be pulled in by flink-avro

[jira] [Created] (FLINK-8016) Add documentation for KafkaJsonTableSink

2017-11-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8016: Summary: Add documentation for KafkaJsonTableSink Key: FLINK-8016 URL: https://issues.apache.org/jira/browse/FLINK-8016 Project: Flink Issue Type:

[jira] [Updated] (FLINK-8015) Add Kafka011JsonTableSink

2017-11-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-8015: - Issue Type: New Feature (was: Improvement) > Add Kafka011JsonTableSink >

[jira] [Created] (FLINK-8015) Add Kafka011JsonTableSink

2017-11-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8015: Summary: Add Kafka011JsonTableSink Key: FLINK-8015 URL: https://issues.apache.org/jira/browse/FLINK-8015 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8014) Add Kafka010JsonTableSink

2017-11-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8014: Summary: Add Kafka010JsonTableSink Key: FLINK-8014 URL: https://issues.apache.org/jira/browse/FLINK-8014 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8013) Check of AggregateFunction merge function signature is too strict.

2017-11-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8013: Summary: Check of AggregateFunction merge function signature is too strict. Key: FLINK-8013 URL: https://issues.apache.org/jira/browse/FLINK-8013 Project: Flink

[GitHub] flink pull request #4973: [FLINK-8011][dist] Set flink-python to provided

2017-11-07 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4973 [FLINK-8011][dist] Set flink-python to provided ## What is the purpose of the change Minor clean-up in the flink-dist pom. flink-python is now set to provided, similar to other libraries,

[jira] [Commented] (FLINK-8011) Set dist flink-python dependency to provided

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242290#comment-16242290 ] ASF GitHub Bot commented on FLINK-8011: --- GitHub user zentol opened a pull request:

[jira] [Updated] (FLINK-8011) Set dist flink-python dependency to provided

2017-11-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8011: Fix Version/s: (was: 1.4.0) > Set dist flink-python dependency to provided >

[jira] [Created] (FLINK-8012) Table with time attribute cannot be written to CsvTableSink

2017-11-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8012: Summary: Table with time attribute cannot be written to CsvTableSink Key: FLINK-8012 URL: https://issues.apache.org/jira/browse/FLINK-8012 Project: Flink

[jira] [Commented] (FLINK-8009) flink-dist pulls in flink-runtime's transitive avro/jackson dependency

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242278#comment-16242278 ] ASF GitHub Bot commented on FLINK-8009: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #4972: [FLINK-8009][build][runtime] Remove transitive dep...

2017-11-07 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4972 [FLINK-8009][build][runtime] Remove transitive dependency promotion ## What is the purpose of the change This PR replaces the dependency promotion from flink-runtime. The promotion appears

[jira] [Commented] (FLINK-8009) flink-dist pulls in flink-runtime's transitive avro/jackson dependency

2017-11-07 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242275#comment-16242275 ] Aljoscha Krettek commented on FLINK-8009: - Btw, with the recent changes by [~StephanEwen] Avro is

[jira] [Assigned] (FLINK-7073) Create RESTful JobManager endpoint

2017-11-07 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7073: Assignee: Till Rohrmann > Create RESTful JobManager endpoint >

[jira] [Commented] (FLINK-7419) Shade jackson dependency in flink-avro

2017-11-07 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242262#comment-16242262 ] Aljoscha Krettek commented on FLINK-7419: - Do you know if generated code uses the Jackson

[jira] [Updated] (FLINK-8009) flink-dist pulls in flink-runtime's transitive avro/jackson dependency

2017-11-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8009: Summary: flink-dist pulls in flink-runtime's transitive avro/jackson dependency (was:

[jira] [Assigned] (FLINK-8009) flink-dist contains flink-runtime's transitive hadoop dependencies

2017-11-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-8009: --- Assignee: Chesnay Schepler > flink-dist contains flink-runtime's transitive hadoop

[jira] [Commented] (FLINK-8009) flink-dist contains flink-runtime's transitive hadoop dependencies

2017-11-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242254#comment-16242254 ] Chesnay Schepler commented on FLINK-8009: - avro and jackson are still pulled in. The

[jira] [Commented] (FLINK-8008) PojoTypeInfo should sort fields fields based on boolean

2017-11-07 Thread Muhammad Imran Tariq (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242255#comment-16242255 ] Muhammad Imran Tariq commented on FLINK-8008: - I am using POJO way to read CSV file. Say a csv

[jira] [Commented] (FLINK-8008) PojoTypeInfo should sort fields fields based on boolean

2017-11-07 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242234#comment-16242234 ] Aljoscha Krettek commented on FLINK-8008: - What's the reason for not sorting the fields? This is

[jira] [Commented] (FLINK-8009) flink-dist contains flink-runtime's transitive hadoop dependencies

2017-11-07 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242231#comment-16242231 ] Aljoscha Krettek commented on FLINK-8009: - So they are included even though it's {{optional}}? >

[jira] [Commented] (FLINK-7765) Enable dependency convergence

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

[GitHub] flink pull request #4777: [FLINK-7765] Enable dependency convergence

2017-11-07 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4777#discussion_r149409270 --- Diff: pom.xml --- @@ -289,6 +289,48 @@ under the License. 1.8.2 +

[jira] [Commented] (FLINK-8000) Sort REST handler URLs in RestServerEndpoint

2017-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16242192#comment-16242192 ] ASF GitHub Bot commented on FLINK-8000: --- Github user zentol commented on the issue:

[GitHub] flink issue #4958: [FLINK-8000] Sort Rest handler URLS in RestServerEndpoint

2017-11-07 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4958 you can also remove the comment in the DispatcherRestEndpoint that says to register the stat file handler last. ---

[jira] [Updated] (FLINK-7991) Cleanup kafka example jar filters

2017-11-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7991: Affects Version/s: 1.5.0 > Cleanup kafka example jar filters >

[jira] [Updated] (FLINK-7991) Cleanup kafka example jar filters

2017-11-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7991: Fix Version/s: 1.5.0 > Cleanup kafka example jar filters >

[jira] [Assigned] (FLINK-7991) Cleanup kafka example jar filters

2017-11-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-7991: --- Assignee: Chesnay Schepler > Cleanup kafka example jar filters >

[GitHub] flink issue #4971: [FLINK-8010][build] Bump remaining flink-shaded versions

2017-11-07 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4971 +1 (once travis is green) ---

[jira] [Assigned] (FLINK-7419) Shade jackson dependency in flink-avro

2017-11-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-7419: --- Assignee: Chesnay Schepler (was: Fang Yong) > Shade jackson dependency in

  1   2   3   >