[jira] [Commented] (FLINK-8071) Akka shading sometimes produces invalid code

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

[GitHub] flink pull request #5014: [FLINK-8071][build] Bump shade-plugin asm version ...

2017-11-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5014 ---

[GitHub] flink pull request #4981: [FLINK-7419][build][avro] Relocate jackson in flin...

2017-11-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4981 ---

[jira] [Closed] (FLINK-8071) Akka shading sometimes produces invalid code

2017-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8071. --- Resolution: Fixed 1.4: 195e3da8a78b80116ef00e65d771daa5a0a1d7a3 1.5:

[jira] [Created] (FLINK-8075) Redundant clone() in Configuration ctor

2017-11-14 Thread Ted Yu (JIRA)
Ted Yu created FLINK-8075: - Summary: Redundant clone() in Configuration ctor Key: FLINK-8075 URL: https://issues.apache.org/jira/browse/FLINK-8075 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-8075) Lack of synchronization calling clone() in Configuration ctor

2017-11-14 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8075: -- Summary: Lack of synchronization calling clone() in Configuration ctor (was: Redundant clone() in

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

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

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

2017-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7419. --- Resolution: Fixed 1.4: 5c6eaabfcd541ffb35d911c6d9d2f6f12f207cd8 1.5:

[GitHub] flink issue #4963: [FLINK-7475] [core][DataStream API] support update() in L...

2017-11-14 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4963 @yunfan123 @aljoscha @StefanRRichter I chose the "shallow" simulation. What do you guys think? The build failure seems to be because one build profile timed out. ---

[jira] [Commented] (FLINK-7475) support update() in ListState

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

[jira] [Commented] (FLINK-8069) Support empty watermark strategy for TableSources

2017-11-14 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16252794#comment-16252794 ] Xingcan Cui commented on FLINK-8069: Thanks for the explanation [~twalthr] > Support empty watermark

[jira] [Comment Edited] (FLINK-7490) UDF Agg throws Exception when flink-table is loaded with AppClassLoader

2017-11-14 Thread Colin Williams (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16252789#comment-16252789 ] Colin Williams edited comment on FLINK-7490 at 11/15/17 1:44 AM: - I'm

[jira] [Assigned] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column

2017-11-14 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-7923: - Assignee: Shuyi Chen > SQL parser exception when accessing subfields of a Composite element in

[jira] [Updated] (FLINK-7917) The return of taskInformationOrBlobKey should be placed inside synchronized in ExecutionJobVertex

2017-11-14 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7917: -- Description: Currently: {code} } return taskInformationOrBlobKey; {code} The return should be placed

[GitHub] flink issue #4936: [FLINK-7962] Add built-in support for min/max aggregation...

2017-11-14 Thread dianfu
Github user dianfu commented on the issue: https://github.com/apache/flink/pull/4936 @wuchong Thanks a lot for your review. @fhueske It would be great if you can also give some feedback. ---

[jira] [Commented] (FLINK-7962) Add built-in support for min/max aggregation for Timestamp

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

[jira] [Commented] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column

2017-11-14 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16252876#comment-16252876 ] Shuyi Chen commented on FLINK-7923: --- Already sent out PR for Calcite-2016 to modify the Calcite parser.

[jira] [Updated] (FLINK-7795) Utilize error-prone to discover common coding mistakes

2017-11-14 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7795: -- Description: http://errorprone.info/ is a tool which detects common coding mistakes. We should incorporate

[jira] [Assigned] (FLINK-7934) Upgrade Calcite dependency to 1.15

2017-11-14 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-7934: - Assignee: Shuyi Chen > Upgrade Calcite dependency to 1.15 > -- >

[jira] [Created] (FLINK-8076) Upgrade KinesisProducer to 0.10.6 to set properties approperiately

2017-11-14 Thread Bowen Li (JIRA)
Bowen Li created FLINK-8076: --- Summary: Upgrade KinesisProducer to 0.10.6 to set properties approperiately Key: FLINK-8076 URL: https://issues.apache.org/jira/browse/FLINK-8076 Project: Flink

[GitHub] flink pull request #5016: [FLINK-8069] [table] Support empty watermark strat...

2017-11-14 Thread xccui
GitHub user xccui opened a pull request: https://github.com/apache/flink/pull/5016 [FLINK-8069] [table] Support empty watermark strategy for TableSources ## What is the purpose of the change This PR enables an empty watermark strategy for `RowtimeAttributeDescriptor`.

[GitHub] flink pull request #5017: [FLINK-8076] Upgrade KinesisProducer to 0.10.6 to ...

2017-11-14 Thread bowenli86
GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/5017 [FLINK-8076] Upgrade KinesisProducer to 0.10.6 to set properties approperiately ## What is the purpose of the change https://github.com/awslabs/amazon-kinesis-producer/issues/124 has

[jira] [Commented] (FLINK-8076) Upgrade KinesisProducer to 0.10.6 to set properties approperiately

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

[jira] [Commented] (FLINK-8069) Support empty watermark strategy for TableSources

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

[jira] [Commented] (FLINK-7943) OptionalDataException when launching Flink jobs concurrently

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

[GitHub] flink issue #4921: [FLINK-7943] Make ParameterTool thread safe

2017-11-14 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4921 LGTM +1 ---

[GitHub] flink issue #4893: [FLINK-7856][flip6] Port JobVertexBackPressureHandler to ...

2017-11-14 Thread zjureel
Github user zjureel commented on the issue: https://github.com/apache/flink/pull/4893 @tillrohrmann Thank you for your review, I have fixed the problems of this PR, thanks ---

[jira] [Commented] (FLINK-7856) Port JobVertexBackPressureHandler to REST endpoint

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

[jira] [Commented] (FLINK-8069) Support empty watermark strategy for TableSources

2017-11-14 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251320#comment-16251320 ] Timo Walther commented on FLINK-8069: - Hi [~xccui], we just had a use case where we are forced to

[jira] [Commented] (FLINK-8062) QueryableStateClient#getKvState(...N Namespace,...) not documented

2017-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251340#comment-16251340 ] Chesnay Schepler commented on FLINK-8062: - I would make it private if there is currently no use

[jira] [Commented] (FLINK-7036) Type cast in ExpressionReducer's reduce broke CodeGen's compile stage

2017-11-14 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251343#comment-16251343 ] Timo Walther commented on FLINK-7036: - [~Aegeaner] Flink internally processes {{Date}} as integer

[jira] [Created] (FLINK-8071) Akka shading sometimes produces invalid code

2017-11-14 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8071: --- Summary: Akka shading sometimes produces invalid code Key: FLINK-8071 URL: https://issues.apache.org/jira/browse/FLINK-8071 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8046) ContinuousFileMonitoringFunction wrongly ignores files with exact same timestamp

2017-11-14 Thread Juan Miguel Cejuela (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251363#comment-16251363 ] Juan Miguel Cejuela commented on FLINK-8046: Hi [~kkl0u] ! I also copy here my answer to you

[jira] [Assigned] (FLINK-8063) Client blocks indefinitely when querying a non-existing state

2017-11-14 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-8063: - Assignee: Kostas Kloudas > Client blocks indefinitely when querying a non-existing state

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

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

[jira] [Commented] (FLINK-7942) NPE when apply FilterJoinRule

2017-11-14 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251353#comment-16251353 ] Timo Walther commented on FLINK-7942: - [~lincoln.86xy] if it is ok, I would try to fix this issue?

[jira] [Commented] (FLINK-8069) Support empty watermark strategy for TableSources

2017-11-14 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251300#comment-16251300 ] Xingcan Cui commented on FLINK-8069: Hi [~twalthr], thanks for raising this. Since the

[jira] [Assigned] (FLINK-7036) Type cast in ExpressionReducer's reduce broke CodeGen's compile stage

2017-11-14 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-7036: --- Assignee: Timo Walther > Type cast in ExpressionReducer's reduce broke CodeGen's compile

[jira] [Assigned] (FLINK-8065) Extend exception message if QS client is already shut down

2017-11-14 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-8065: - Assignee: Kostas Kloudas > Extend exception message if QS client is already shut down >

[jira] [Assigned] (FLINK-8062) QueryableStateClient#getKvState(...N Namespace,...) not documented

2017-11-14 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-8062: - Assignee: Kostas Kloudas > QueryableStateClient#getKvState(...N Namespace,...) not

[GitHub] flink pull request #5011: [FLINK-8013] [table] Support aggregate functions w...

2017-11-14 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/5011 [FLINK-8013] [table] Support aggregate functions with generic arrays ## What is the purpose of the change Adds supports for aggregate functions with generic arrays and fixes other bugs.

[jira] [Commented] (FLINK-8062) QueryableStateClient#getKvState(...N Namespace,...) not documented

2017-11-14 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251326#comment-16251326 ] Kostas Kloudas commented on FLINK-8062: --- This was intentional. The reason is that user-defined

[jira] [Commented] (FLINK-8046) ContinuousFileMonitoringFunction wrongly ignores files with exact same timestamp

2017-11-14 Thread Juan Miguel Cejuela (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251364#comment-16251364 ] Juan Miguel Cejuela commented on FLINK-8046: Note: I can also a limit of max. num. of entries

[jira] [Updated] (FLINK-8071) Akka shading sometimes produces invalid code

2017-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8071: Fix Version/s: (was: 1.5.0) 1.4.0 > Akka shading sometimes produces

[jira] [Commented] (FLINK-8063) Client blocks indefinitely when querying a non-existing state

2017-11-14 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251054#comment-16251054 ] Ufuk Celebi commented on FLINK-8063: I think this is a regression from the previous state of queryable

[GitHub] flink issue #4939: [FLINK-4228][yarn/s3a] fix yarn resource upload s3a defau...

2017-11-14 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4939 Shouldn't we already have the problem of the sleeper failure by excluding Hadoop's dependency? Agreed that a dependency management entry would require comments to explain it, but so

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

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

[jira] [Commented] (FLINK-4228) YARN artifact upload does not work with S3AFileSystem

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

[jira] [Commented] (FLINK-8056) Default flink-conf.yaml uses deprecated keys

2017-11-14 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251057#comment-16251057 ] Ufuk Celebi commented on FLINK-8056: Good catch :-) > Default flink-conf.yaml uses deprecated keys >

[GitHub] flink pull request #5007: [FLINK-7845] Make NettyMessage public

2017-11-14 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/5007#discussion_r150759972 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java --- @@ -52,8 +52,10 @@ /** * A simple

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

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

[GitHub] flink pull request #5007: [FLINK-7845] Make NettyMessage public

2017-11-14 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/5007#discussion_r150775237 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java --- @@ -52,8 +52,10 @@ /** * A simple and

[jira] [Assigned] (FLINK-8056) Default flink-conf.yaml uses deprecated keys

2017-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-8056: --- Assignee: Chesnay Schepler > Default flink-conf.yaml uses deprecated keys >

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

2017-11-14 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.5.0) 1.4.0 > Set dist flink-python dependency

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

2017-11-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4968 merging. ---

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

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

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

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

[jira] [Updated] (FLINK-8068) Failed single-job Flink cluster on YARN shows as SUCCEEDED

2017-11-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8068: Fix Version/s: 1.4.0 > Failed single-job Flink cluster on YARN shows as SUCCEEDED >

[jira] [Commented] (FLINK-8064) Extend dependecy section to list flink-core

2017-11-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251233#comment-16251233 ] Aljoscha Krettek commented on FLINK-8064: - The alternative would be a proper dependency on

[GitHub] flink pull request #5005: [FLINK-8053] Default to asynchronous snapshots for...

2017-11-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5005 ---

[jira] [Commented] (FLINK-8053) Default to asynchronous snapshots for FsStateBackend

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

[jira] [Commented] (FLINK-4228) YARN artifact upload does not work with S3AFileSystem

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

[jira] [Updated] (FLINK-8068) Failed single-job Flink cluster on YARN shows as SUCCEEDED

2017-11-14 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-8068: --- Description: A single-job Flink cluster with a failing program, e.g. a non-existing input file as in

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

2017-11-14 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reopened FLINK-7973: we still have problems if (via the classpath) some hadoop JNI library is loaded. Then,

[GitHub] flink issue #5005: [FLINK-8053] Default to asynchronous snapshots for FsStat...

2017-11-14 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5005 @StefanRRichter Will you merge this? ---

[jira] [Commented] (FLINK-8053) Default to asynchronous snapshots for FsStateBackend

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

[GitHub] flink issue #5005: [FLINK-8053] Default to asynchronous snapshots for FsStat...

2017-11-14 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5005 Sure, I can merge it immediately if you want. ---

[jira] [Updated] (FLINK-8063) Client blocks indefinitely when querying a non-existing state

2017-11-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8063: Fix Version/s: 1.4.0 > Client blocks indefinitely when querying a non-existing state >

[jira] [Commented] (FLINK-8066) Changed configuration of taskmanagers should recreate them

2017-11-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251232#comment-16251232 ] Aljoscha Krettek commented on FLINK-8066: - [~till.rohrmann] could you please have a look at this,

[jira] [Commented] (FLINK-8064) Extend dependecy section to list flink-core

2017-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251244#comment-16251244 ] Chesnay Schepler commented on FLINK-8064: - that's true; thing is that the client module is in this

[GitHub] flink issue #4939: [FLINK-4228][yarn/s3a] fix yarn resource upload s3a defau...

2017-11-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4939 yes there could be a sleeper failure in hadoop, but there's nothing we can do to fix that besides relocation jackson in either hadoop or aws, which is probably not possible. ---

[jira] [Created] (FLINK-8067) User code ClassLoader not set before calling ProcessingTimeCallback

2017-11-14 Thread Gary Yao (JIRA)
Gary Yao created FLINK-8067: --- Summary: User code ClassLoader not set before calling ProcessingTimeCallback Key: FLINK-8067 URL: https://issues.apache.org/jira/browse/FLINK-8067 Project: Flink

[jira] [Commented] (FLINK-7811) Add support for Scala 2.12

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

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

2017-11-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4973 merging. ---

[GitHub] flink issue #4995: [hotfix] [docs] Fix broken link to FLINK-7811

2017-11-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4995 merging. ---

[jira] [Created] (FLINK-8068) Failed single-job Flink cluster on YARN shows as SUCCEEDED

2017-11-14 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-8068: -- Summary: Failed single-job Flink cluster on YARN shows as SUCCEEDED Key: FLINK-8068 URL: https://issues.apache.org/jira/browse/FLINK-8068 Project: Flink Issue

[jira] [Closed] (FLINK-8053) Default to asynchronous snapshots for FsStateBackend

2017-11-14 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8053. - Resolution: Fixed Merged in 2906698b4a. > Default to asynchronous snapshots for FsStateBackend >

[GitHub] flink issue #5010: [FLINK-8056][dist] Use 'web.port' instead of 'jobmanager....

2017-11-14 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5010 LGTM! 👍 ---

[GitHub] flink pull request #5010: [FLINK-8056][dist] Use 'web.port' instead of 'jobm...

2017-11-14 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5010 [FLINK-8056][dist] Use 'web.port' instead of 'jobmanager.web.port' ## What is the purpose of the change This PR modfiies the default `flink-conf.yaml` to no longer use the deprecated

[GitHub] flink issue #5007: [FLINK-7845] Make NettyMessage public

2017-11-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5007 merging. ---

[GitHub] flink issue #5002: [hotfix][docs] Remove the caveat about Cassandra connecto...

2017-11-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5002 merging. ---

[GitHub] flink issue #5000: [hotfix][docs] Fix typos in deployment AWS documentation

2017-11-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5000 merging. ---

[GitHub] flink issue #4999: [hotfix][docs][javadocs] Remove double "of"

2017-11-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4999 merging. ---

[jira] [Created] (FLINK-8069) Support empty watermark strategy for TableSources

2017-11-14 Thread Timo Walther (JIRA)
Timo Walther created FLINK-8069: --- Summary: Support empty watermark strategy for TableSources Key: FLINK-8069 URL: https://issues.apache.org/jira/browse/FLINK-8069 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8053) Default to asynchronous snapshots for FsStateBackend

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

[jira] [Commented] (FLINK-8056) Default flink-conf.yaml uses deprecated keys

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

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

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

[jira] [Commented] (FLINK-8056) Default flink-conf.yaml uses deprecated keys

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

[jira] [Created] (FLINK-8070) YarnTestBase should print prohibited string

2017-11-14 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8070: --- Summary: YarnTestBase should print prohibited string Key: FLINK-8070 URL: https://issues.apache.org/jira/browse/FLINK-8070 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8066) Changed configuration of taskmanagers should recreate them

2017-11-14 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16251258#comment-16251258 ] Till Rohrmann commented on FLINK-8066: -- In Flip-6 this will work a bit differently since idling TMs

[jira] [Assigned] (FLINK-8069) Support empty watermark strategy for TableSources

2017-11-14 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-8069: -- Assignee: Xingcan Cui > Support empty watermark strategy for TableSources >

[jira] [Created] (FLINK-8072) Travis job mark as failed for no apparent reason

2017-11-14 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8072: --- Summary: Travis job mark as failed for no apparent reason Key: FLINK-8072 URL: https://issues.apache.org/jira/browse/FLINK-8072 Project: Flink Issue

[jira] [Updated] (FLINK-8072) Travis job marked as failed for no apparent reason

2017-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8072: Summary: Travis job marked as failed for no apparent reason (was: Travis job mark as

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

2017-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8006. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: fcc79c0ed76818e147381117ea735f5796be6066

[jira] [Updated] (FLINK-7692) Support user-defined variables in Metrics

2017-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7692: Fix Version/s: (was: 1.4.0) 1.5.0 > Support user-defined variables

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

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

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

2017-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-7998: - > Make case classes in TPCHQuery3.java public to allow dynamic instantiation >

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

2017-11-14 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150856825 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java --- @@ -483,27 +511,31 @@

[GitHub] flink issue #5014: [FLINK-8071][build] Bump shade-plugin asm version to 5.1

2017-11-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5014 Will rebase the PR and merge it once travis is green. ---

[jira] [Updated] (FLINK-8071) Akka shading sometimes produces invalid code

2017-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8071: Description: On 2 separate occasions on separate machines I hit the exception below when

  1   2   >