[jira] [Commented] (FLINK-6437) Move history server configuration to a separate file

[ https://issues.apache.org/jira/browse/FLINK-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578778#comment-16578778 ] ASF GitHub Bot commented on FLINK-6437: --- zentol commented on issue #6542: [FLINK-6437][History

[GitHub] asfgit closed pull request #6500: [FLINK-10066] Keep only archived version of previous executions

asfgit closed pull request #6500: [FLINK-10066] Keep only archived version of previous executions URL: https://github.com/apache/flink/pull/6500 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As

[GitHub] fhueske commented on a change in pull request #6535: [FLINK-9977] [table][doc] Refine the SQL/Table built-in function docs

fhueske commented on a change in pull request #6535: [FLINK-9977] [table][doc] Refine the SQL/Table built-in function docs URL: https://github.com/apache/flink/pull/6535#discussion_r209687761 ## File path: docs/dev/table/functions.md ## @@ -24,7 +24,7 @@ under the

[jira] [Commented] (FLINK-9977) Refine the docs for Table/SQL built-in functions

[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578625#comment-16578625 ] ASF GitHub Bot commented on FLINK-9977: --- fhueske commented on a change in pull request #6535:

[GitHub] NicoK commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options

NicoK commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options URL: https://github.com/apache/flink/pull/6355#discussion_r209690587 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyClient.java

[jira] [Commented] (FLINK-9878) IO worker threads BLOCKED on SSL Session Cache while CMS full gc

[ https://issues.apache.org/jira/browse/FLINK-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578643#comment-16578643 ] ASF GitHub Bot commented on FLINK-9878: --- NicoK commented on a change in pull request #6355:

[jira] [Commented] (FLINK-9878) IO worker threads BLOCKED on SSL Session Cache while CMS full gc

[ https://issues.apache.org/jira/browse/FLINK-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578644#comment-16578644 ] ASF GitHub Bot commented on FLINK-9878: --- NicoK commented on a change in pull request #6355:

[jira] [Closed] (FLINK-10066) Keep only archived version of previous executions

[ https://issues.apache.org/jira/browse/FLINK-10066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-10066. -- Resolution: Fixed Merged in: master: 160dc56fdf release-1.6: 74323d50b0 release-1.5:

[jira] [Commented] (FLINK-10133) finished job's jobgraph never been cleaned up in zookeeper for standalone clusters (HA mode with multiple masters)

[ https://issues.apache.org/jira/browse/FLINK-10133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578792#comment-16578792 ] Elias Levy commented on FLINK-10133: [~Frefreak] this is likely the same issue as FLINK-10011.  If

[GitHub] NicoK commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options

NicoK commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options URL: https://github.com/apache/flink/pull/6355#discussion_r209682805 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java ## @@

[jira] [Commented] (FLINK-9878) IO worker threads BLOCKED on SSL Session Cache while CMS full gc

[ https://issues.apache.org/jira/browse/FLINK-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578629#comment-16578629 ] ASF GitHub Bot commented on FLINK-9878: --- NicoK commented on a change in pull request #6355:

[jira] [Commented] (FLINK-9977) Refine the docs for Table/SQL built-in functions

[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578630#comment-16578630 ] ASF GitHub Bot commented on FLINK-9977: --- fhueske commented on issue #6535: [FLINK-9977]

[GitHub] fhueske commented on issue #6535: [FLINK-9977] [table][doc] Refine the SQL/Table built-in function docs

fhueske commented on issue #6535: [FLINK-9977] [table][doc] Refine the SQL/Table built-in function docs URL: https://github.com/apache/flink/pull/6535#issuecomment-412593462 Thanks for the update @xccui. +1 to merge

[jira] [Commented] (FLINK-10066) Keep only archived version of previous executions

[ https://issues.apache.org/jira/browse/FLINK-10066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578712#comment-16578712 ] ASF GitHub Bot commented on FLINK-10066: asfgit closed pull request #6500: [FLINK-10066] Keep

[GitHub] bowenli86 commented on a change in pull request #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition

bowenli86 commented on a change in pull request #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition URL: https://github.com/apache/flink/pull/6544#discussion_r209712274 ## File path:

[GitHub] bowenli86 commented on a change in pull request #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition

bowenli86 commented on a change in pull request #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition URL: https://github.com/apache/flink/pull/6544#discussion_r209712274 ## File path:

[jira] [Commented] (FLINK-8532) RebalancePartitioner should use Random value for its first partition

[ https://issues.apache.org/jira/browse/FLINK-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578760#comment-16578760 ] ASF GitHub Bot commented on FLINK-8532: --- bowenli86 commented on a change in pull request #6544:

[jira] [Commented] (FLINK-8532) RebalancePartitioner should use Random value for its first partition

[ https://issues.apache.org/jira/browse/FLINK-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578757#comment-16578757 ] ASF GitHub Bot commented on FLINK-8532: --- bowenli86 commented on a change in pull request #6544:

[jira] [Commented] (FLINK-6437) Move history server configuration to a separate file

[ https://issues.apache.org/jira/browse/FLINK-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578759#comment-16578759 ] ASF GitHub Bot commented on FLINK-6437: --- StephanEwen commented on issue #6542: [FLINK-6437][History

[GitHub] StephanEwen commented on issue #6542: [FLINK-6437][History Server] Move history server configuration to a separate file

StephanEwen commented on issue #6542: [FLINK-6437][History Server] Move history server configuration to a separate file URL: https://github.com/apache/flink/pull/6542#issuecomment-412618428 Sure, so the compatibility story needs a more detailed design, and that needs to be discussed

[GitHub] NicoK commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options

NicoK commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options URL: https://github.com/apache/flink/pull/6355#discussion_r209690309 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyClient.java

[GitHub] NicoK commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options

NicoK commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options URL: https://github.com/apache/flink/pull/6355#discussion_r209690309 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyClient.java

[GitHub] Guibo-Pan commented on issue #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition

Guibo-Pan commented on issue #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition URL: https://github.com/apache/flink/pull/6544#issuecomment-412602068 @yanghua thanks for your suggestion, I have made an update.

[jira] [Commented] (FLINK-10019) Fix Composite getResultType of UDF cannot be chained with other operators

[ https://issues.apache.org/jira/browse/FLINK-10019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578793#comment-16578793 ] Rong Rong commented on FLINK-10019: --- Dug a little deeper in Calcite and found that in:

[jira] [Comment Edited] (FLINK-10019) Fix Composite getResultType of UDF cannot be chained with other operators

[ https://issues.apache.org/jira/browse/FLINK-10019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578793#comment-16578793 ] Rong Rong edited comment on FLINK-10019 at 8/13/18 7:00 PM: Dug a little

[jira] [Commented] (FLINK-9878) IO worker threads BLOCKED on SSL Session Cache while CMS full gc

[ https://issues.apache.org/jira/browse/FLINK-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578646#comment-16578646 ] ASF GitHub Bot commented on FLINK-9878: --- NicoK commented on a change in pull request #6355:

[jira] [Commented] (FLINK-8532) RebalancePartitioner should use Random value for its first partition

[ https://issues.apache.org/jira/browse/FLINK-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578678#comment-16578678 ] ASF GitHub Bot commented on FLINK-8532: --- Guibo-Pan commented on issue #6544: [FLINK-8532]

[jira] [Commented] (FLINK-9999) Add ISNUMERIC supported in Table API/SQL

[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578781#comment-16578781 ] ASF GitHub Bot commented on FLINK-: --- walterddr commented on a change in pull request #6473:

[GitHub] walterddr commented on a change in pull request #6473: [FLINK-9999] [table] Add ISNUMERIC supported in Table API/SQL

walterddr commented on a change in pull request #6473: [FLINK-] [table] Add ISNUMERIC supported in Table API/SQL URL: https://github.com/apache/flink/pull/6473#discussion_r209719307 ## File path:

[GitHub] NicoK commented on issue #6355: [FLINK-9878][network][ssl] add more low-level ssl options

NicoK commented on issue #6355: [FLINK-9878][network][ssl] add more low-level ssl options URL: https://github.com/apache/flink/pull/6355#issuecomment-412597634 I pushed a rework of this PR which has a lighter footprint on the changes in SSLUtils by using a wrapper around `SSLContext` as

[jira] [Commented] (FLINK-9878) IO worker threads BLOCKED on SSL Session Cache while CMS full gc

[ https://issues.apache.org/jira/browse/FLINK-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578653#comment-16578653 ] ASF GitHub Bot commented on FLINK-9878: --- NicoK commented on issue #6355: [FLINK-9878][network][ssl]

[GitHub] zentol commented on issue #6542: [FLINK-6437][History Server] Move history server configuration to a separate file

zentol commented on issue #6542: [FLINK-6437][History Server] Move history server configuration to a separate file URL: https://github.com/apache/flink/pull/6542#issuecomment-412622673 well I still like the idea of separate config files, but the JIRA discussion happened more than a

[jira] [Created] (FLINK-10135) The JobManager doesn't report the cluster-level metrics

Joey Echeverria created FLINK-10135: --- Summary: The JobManager doesn't report the cluster-level metrics Key: FLINK-10135 URL: https://issues.apache.org/jira/browse/FLINK-10135 Project: Flink

[GitHub] TisonKun commented on issue #6339: [FLINK-9859] [runtime] More Akka config

TisonKun commented on issue #6339: [FLINK-9859] [runtime] More Akka config URL: https://github.com/apache/flink/pull/6339#issuecomment-412743884 ping @tillrohrmann :-) This is an automated message from the Apache Git

[jira] [Commented] (FLINK-9859) More Akka config

[ https://issues.apache.org/jira/browse/FLINK-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579207#comment-16579207 ] ASF GitHub Bot commented on FLINK-9859: --- TisonKun commented on issue #6339: [FLINK-9859] [runtime]

[jira] [Commented] (FLINK-10127) Add TypeInformation and serializers for JDK8 Instant

[ https://issues.apache.org/jira/browse/FLINK-10127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578935#comment-16578935 ] ASF GitHub Bot commented on FLINK-10127: alexeyt820 opened a new pull request #6549:

[jira] [Updated] (FLINK-10127) Add TypeInformation and serializers for JDK8 Instant

[ https://issues.apache.org/jira/browse/FLINK-10127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10127: --- Labels: pull-request-available (was: ) > Add TypeInformation and serializers for JDK8

[jira] [Assigned] (FLINK-10135) The JobManager doesn't report the cluster-level metrics

[ https://issues.apache.org/jira/browse/FLINK-10135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10135: Assignee: vinoyang > The JobManager doesn't report the cluster-level metrics >

[GitHub] alexeyt820 opened a new pull request #6549: [FLINK-10127] Add Instant to basic types

alexeyt820 opened a new pull request #6549: [FLINK-10127] Add Instant to basic types URL: https://github.com/apache/flink/pull/6549 ## What is the purpose of the change This pull requests add JDK8 Instant type as basic type to Flink type system ## Brief change log -

[GitHub] xccui commented on issue #6535: [FLINK-9977] [table][doc] Refine the SQL/Table built-in function docs

xccui commented on issue #6535: [FLINK-9977] [table][doc] Refine the SQL/Table built-in function docs URL: https://github.com/apache/flink/pull/6535#issuecomment-412717935 Thanks for the review, @fhueske. Will merge this.

[jira] [Commented] (FLINK-9977) Refine the docs for Table/SQL built-in functions

[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579094#comment-16579094 ] ASF GitHub Bot commented on FLINK-9977: --- xccui commented on issue #6535: [FLINK-9977] [table][doc]

[jira] [Commented] (FLINK-6437) Move history server configuration to a separate file

[ https://issues.apache.org/jira/browse/FLINK-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579156#comment-16579156 ] ASF GitHub Bot commented on FLINK-6437: --- yanghua commented on issue #6542: [FLINK-6437][History

[jira] [Commented] (FLINK-6437) Move history server configuration to a separate file

[ https://issues.apache.org/jira/browse/FLINK-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579157#comment-16579157 ] ASF GitHub Bot commented on FLINK-6437: --- yanghua edited a comment on issue #6542:

[GitHub] yanghua edited a comment on issue #6542: [FLINK-6437][History Server] Move history server configuration to a separate file

yanghua edited a comment on issue #6542: [FLINK-6437][History Server] Move history server configuration to a separate file URL: https://github.com/apache/flink/pull/6542#issuecomment-412736043 hi @StephanEwen @zentol , Currently, the history server runs as a single JVM process,

[GitHub] yanghua commented on issue #6542: [FLINK-6437][History Server] Move history server configuration to a separate file

yanghua commented on issue #6542: [FLINK-6437][History Server] Move history server configuration to a separate file URL: https://github.com/apache/flink/pull/6542#issuecomment-412736043 hi @StephanEwen @zentol , Currently, the history server runs as a standalone JVM process, which

[jira] [Created] (FLINK-10134) UTF-16 support for TextInputFormat

David Dreyfus created FLINK-10134: - Summary: UTF-16 support for TextInputFormat Key: FLINK-10134 URL: https://issues.apache.org/jira/browse/FLINK-10134 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-10133) finished job's jobgraph never been cleaned up in zookeeper for standalone clusters (HA mode with multiple masters)

[ https://issues.apache.org/jira/browse/FLINK-10133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579248#comment-16579248 ] Xiangyu Zhu commented on FLINK-10133: - [~Wosinsan] [~elevy] I have uploaded the logs with some

[jira] [Updated] (FLINK-10133) finished job's jobgraph never been cleaned up in zookeeper for standalone clusters (HA mode with multiple masters)

[ https://issues.apache.org/jira/browse/FLINK-10133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiangyu Zhu updated FLINK-10133: Attachment: client.log namenode.log zookeeper.log

[jira] [Commented] (FLINK-10074) Allowable number of checkpoint failures

[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579269#comment-16579269 ] Thomas Weise commented on FLINK-10074: -- I think configuring the behavior as a count of allowable

[jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579276#comment-16579276 ] Fred Teunissen commented on FLINK-8500: --- I've rebased this PR with the latest master branch

[jira] [Commented] (FLINK-10018) Want to have stop command with checkpointing

[ https://issues.apache.org/jira/browse/FLINK-10018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577875#comment-16577875 ] Keshav Lodhi commented on FLINK-10018: -- My scenarios are: * I have implemented *StoppableFunction*

[GitHub] GJL opened a new pull request #6545: [hotfix][kubernetes] Fix broken hyperlink in README.md

GJL opened a new pull request #6545: [hotfix][kubernetes] Fix broken hyperlink in README.md URL: https://github.com/apache/flink/pull/6545 Fix broken hyperlink. @tillrohrmann This is an automated message from the

[GitHub] tillrohrmann closed pull request #6545: [hotfix][kubernetes] Fix broken hyperlink in README.md

tillrohrmann closed pull request #6545: [hotfix][kubernetes] Fix broken hyperlink in README.md URL: https://github.com/apache/flink/pull/6545 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As

[jira] [Commented] (FLINK-9891) Flink cluster is not shutdown in YARN mode when Flink client is stopped

[ https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577908#comment-16577908 ] Till Rohrmann commented on FLINK-9891: -- Would it be an option to use `yarn application -kill` to

[GitHub] zentol commented on issue #6542: [FLINK-6437][History Server] Move history server configuration to a separate file

zentol commented on issue #6542: [FLINK-6437][History Server] Move history server configuration to a separate file URL: https://github.com/apache/flink/pull/6542#issuecomment-412430748 I don't think we should do this _now_. It seems like there's little to gain at this point, since we

[jira] [Commented] (FLINK-10123) Use ExecutorThreadFactory instead of DefaultThreadFactory in RestServer/Client

[ https://issues.apache.org/jira/browse/FLINK-10123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577911#comment-16577911 ] ASF GitHub Bot commented on FLINK-10123: tillrohrmann commented on a change in pull request

[jira] [Commented] (FLINK-9964) Add a CSV table format factory

[ https://issues.apache.org/jira/browse/FLINK-9964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577862#comment-16577862 ] buptljy commented on FLINK-9964: [~twalthr] Could you review my PR ? > Add a CSV table format factory >

[jira] [Commented] (FLINK-10126) There should be a Scala DataSource

[ https://issues.apache.org/jira/browse/FLINK-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577867#comment-16577867 ] vinoyang commented on FLINK-10126: -- Hi [~wind_ljy] I just looked at it roughly and found that the

[jira] [Commented] (FLINK-10104) Job super slow to start

[ https://issues.apache.org/jira/browse/FLINK-10104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577887#comment-16577887 ] Gary Yao commented on FLINK-10104: -- Hi [~fsimond], I assume you are using Hortonworks HDP 2.5. I was

[jira] [Comment Edited] (FLINK-10104) Job super slow to start

[ https://issues.apache.org/jira/browse/FLINK-10104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577887#comment-16577887 ] Gary Yao edited comment on FLINK-10104 at 8/13/18 6:38 AM: --- Hi [~fsimond], I

[jira] [Comment Edited] (FLINK-10128) Timeout on transfering jars on travis-ci

[ https://issues.apache.org/jira/browse/FLINK-10128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577895#comment-16577895 ] Dawid Wysakowicz edited comment on FLINK-10128 at 8/13/18 7:03 AM: ---

[jira] [Closed] (FLINK-10128) Timeout on transfering jars on travis-ci

[ https://issues.apache.org/jira/browse/FLINK-10128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-10128. Resolution: Not A Problem > Timeout on transfering jars on travis-ci >

[jira] [Commented] (FLINK-10107) SQL Client end-to-end test fails for releases

[ https://issues.apache.org/jira/browse/FLINK-10107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577905#comment-16577905 ] ASF GitHub Bot commented on FLINK-10107: zentol edited a comment on issue #6534: [FLINK-10107]

[jira] [Commented] (FLINK-5232) Add a Thread default uncaught exception handler on the JobManager

[ https://issues.apache.org/jira/browse/FLINK-5232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577899#comment-16577899 ] ASF GitHub Bot commented on FLINK-5232: --- tillrohrmann commented on issue #6334: [FLINK-5232] Add a

[jira] [Updated] (FLINK-10050) Support 'allowedLateness' in CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] eugen yushin updated FLINK-10050: - Affects Version/s: 1.6.0 > Support 'allowedLateness' in CoGroupedStreams >

[jira] [Commented] (FLINK-10107) SQL Client end-to-end test fails for releases

[ https://issues.apache.org/jira/browse/FLINK-10107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577904#comment-16577904 ] ASF GitHub Bot commented on FLINK-10107: zentol commented on issue #6534: [FLINK-10107]

[GitHub] zentol edited a comment on issue #6534: [FLINK-10107] [sql-client] Relocate Flink Kafka connectors for SQL JARs

zentol edited a comment on issue #6534: [FLINK-10107] [sql-client] Relocate Flink Kafka connectors for SQL JARs URL: https://github.com/apache/flink/pull/6534#issuecomment-412429668 > This PR tries to solve the problem of having SQL jars that interfere with each other. If it's not

[GitHub] zentol commented on issue #6534: [FLINK-10107] [sql-client] Relocate Flink Kafka connectors for SQL JARs

zentol commented on issue #6534: [FLINK-10107] [sql-client] Relocate Flink Kafka connectors for SQL JARs URL: https://github.com/apache/flink/pull/6534#issuecomment-412429668 > This PR tries to solve the problem of having SQL jars that interfere with each other. If it's not between

[jira] [Updated] (FLINK-10018) Want to have stop command with checkpointing

[ https://issues.apache.org/jira/browse/FLINK-10018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Keshav Lodhi updated FLINK-10018: - Attachment: Flink stop command.png > Want to have stop command with checkpointing >

[jira] [Commented] (FLINK-10126) There should be a Scala DataSource

[ https://issues.apache.org/jira/browse/FLINK-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577877#comment-16577877 ] buptljy commented on FLINK-10126: - [~yanghua] Ok, it makes sense to me. > There should be a Scala

[jira] [Created] (FLINK-10129) Flink job IDs are not getting deleted automatically from zookeeper metadata after canceling flink job in flink HA cluster

Keshav Lodhi created FLINK-10129: Summary: Flink job IDs are not getting deleted automatically from zookeeper metadata after canceling flink job in flink HA cluster Key: FLINK-10129 URL:

[jira] [Commented] (FLINK-10128) Timeout on transfering jars on travis-ci

[ https://issues.apache.org/jira/browse/FLINK-10128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577895#comment-16577895 ] Dawid Wysakowicz commented on FLINK-10128: -- This is a travis problem. All builds with {{sudo:

[GitHub] tillrohrmann commented on issue #6334: [FLINK-5232] Add a Thread default uncaught exception handler on the JobManager

tillrohrmann commented on issue #6334: [FLINK-5232] Add a Thread default uncaught exception handler on the JobManager URL: https://github.com/apache/flink/pull/6334#issuecomment-412427923 I'll close this PR when merging #6539

[jira] [Commented] (FLINK-9919) Remove unit from fullRestarts metric docs

[ https://issues.apache.org/jira/browse/FLINK-9919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577912#comment-16577912 ] ASF GitHub Bot commented on FLINK-9919: --- zentol closed pull request #6543: [FLINK-9919] Remove unit

[jira] [Closed] (FLINK-9919) Remove unit from fullRestarts metric docs

[ https://issues.apache.org/jira/browse/FLINK-9919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9919. --- Resolution: Fixed Fix Version/s: 1.7.0 master:

[GitHub] tillrohrmann commented on a change in pull request #6539: [FLINK-10123] Use ExecutorThreadFactory instead of DefaultThreadFactory in RestServer/Client

tillrohrmann commented on a change in pull request #6539: [FLINK-10123] Use ExecutorThreadFactory instead of DefaultThreadFactory in RestServer/Client URL: https://github.com/apache/flink/pull/6539#discussion_r209512211 ## File path:

[jira] [Commented] (FLINK-6437) Move history server configuration to a separate file

[ https://issues.apache.org/jira/browse/FLINK-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577910#comment-16577910 ] ASF GitHub Bot commented on FLINK-6437: --- zentol commented on issue #6542: [FLINK-6437][History

[jira] [Comment Edited] (FLINK-10104) Job super slow to start

[ https://issues.apache.org/jira/browse/FLINK-10104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577989#comment-16577989 ] Florian edited comment on FLINK-10104 at 8/13/18 10:22 AM: --- Hi [~gjy], Thanks

[GitHub] yanghua commented on issue #6475: [FLINK-10012] Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API

yanghua commented on issue #6475: [FLINK-10012] Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API URL: https://github.com/apache/flink/pull/6475#issuecomment-412493074 @StefanRRichter OK, I respect this decision, but since Flink already provides the Python API, I

[GitHub] StefanRRichter commented on issue #6475: [FLINK-10012] Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API

StefanRRichter commented on issue #6475: [FLINK-10012] Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API URL: https://github.com/apache/flink/pull/6475#issuecomment-412493850 @yanghua I somewhat disagree. It is not a regression that we would need to fix, and why

[jira] [Resolved] (FLINK-10006) Improve logging in BarrierBuffer

[ https://issues.apache.org/jira/browse/FLINK-10006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-10006. - Resolution: Fixed Fix Version/s: 1.7.0 1.6.1 1.5.3

[jira] [Created] (FLINK-10131) Improve logging around ResultSubpartition

Nico Kruber created FLINK-10131: --- Summary: Improve logging around ResultSubpartition Key: FLINK-10131 URL: https://issues.apache.org/jira/browse/FLINK-10131 Project: Flink Issue Type:

[GitHub] zentol commented on issue #6536: Fix Javadoc links in documentation

zentol commented on issue #6536: Fix Javadoc links in documentation URL: https://github.com/apache/flink/pull/6536#issuecomment-412477213 ah, you mean the snapshot javadocs aren't working for the snapshot branches as well. Still, can't we fix this trivially in `update_branch_version.sh` by

[jira] [Commented] (FLINK-10066) Keep only archived version of previous executions

[ https://issues.apache.org/jira/browse/FLINK-10066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578138#comment-16578138 ] ASF GitHub Bot commented on FLINK-10066: StefanRRichter commented on issue #6500: [FLINK-10066]

[GitHub] StefanRRichter commented on issue #6475: [FLINK-10012] Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API

StefanRRichter commented on issue #6475: [FLINK-10012] Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API URL: https://github.com/apache/flink/pull/6475#issuecomment-412491024 @yanghua I had a few discussions with PMC members and the plans for Flink's Python

[jira] [Commented] (FLINK-10012) Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API

[ https://issues.apache.org/jira/browse/FLINK-10012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578151#comment-16578151 ] ASF GitHub Bot commented on FLINK-10012: StefanRRichter commented on issue #6475: [FLINK-10012]

[jira] [Commented] (FLINK-10012) Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API

[ https://issues.apache.org/jira/browse/FLINK-10012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578157#comment-16578157 ] ASF GitHub Bot commented on FLINK-10012: yanghua commented on issue #6475: [FLINK-10012] Add

[jira] [Commented] (FLINK-10012) Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API

[ https://issues.apache.org/jira/browse/FLINK-10012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578165#comment-16578165 ] ASF GitHub Bot commented on FLINK-10012: StefanRRichter commented on issue #6475: [FLINK-10012]

[GitHub] azagrebin commented on a change in pull request #5304: [FLINK-8290]Modify clientId to groupId in flink-connector-kafka-0.8

azagrebin commented on a change in pull request #5304: [FLINK-8290]Modify clientId to groupId in flink-connector-kafka-0.8 URL: https://github.com/apache/flink/pull/5304#discussion_r209553402 ## File path:

[jira] [Commented] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8

[ https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578043#comment-16578043 ] ASF GitHub Bot commented on FLINK-8290: --- azagrebin commented on a change in pull request #5304:

[jira] [Commented] (FLINK-9913) Improve output serialization only once in RecordWriter

[ https://issues.apache.org/jira/browse/FLINK-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578048#comment-16578048 ] ASF GitHub Bot commented on FLINK-9913: --- zhijiangW commented on issue #6417: [FLINK-9913][runtime]

[GitHub] zhijiangW commented on issue #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter

zhijiangW commented on issue #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter URL: https://github.com/apache/flink/pull/6417#issuecomment-412469613 @pnowojski , thanks for your reviews! I basically agree with your idea of separating current

[jira] [Updated] (FLINK-10006) Improve logging in BarrierBuffer

[ https://issues.apache.org/jira/browse/FLINK-10006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10006: Component/s: Logging > Improve logging in BarrierBuffer > > >

[GitHub] zentol commented on issue #6536: Fix Javadoc links in documentation

zentol commented on issue #6536: Fix Javadoc links in documentation URL: https://github.com/apache/flink/pull/6536#issuecomment-412476867 `update_release_branch` doesn't exist. `update_branch_version.sh` is applied to master, but the commit is also contained in the `release-X.Y` branches,

[jira] [Commented] (FLINK-10129) Flink job IDs are not getting deleted automatically from zookeeper metadata after canceling flink job in flink HA cluster

[ https://issues.apache.org/jira/browse/FLINK-10129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578134#comment-16578134 ] Till Rohrmann commented on FLINK-10129: --- Hi [~keshav.lo...@widas.in], thanks for reporting this

[GitHub] StefanRRichter commented on issue #6500: [FLINK-10066] Keep only archived version of previous executions

StefanRRichter commented on issue #6500: [FLINK-10066] Keep only archived version of previous executions URL: https://github.com/apache/flink/pull/6500#issuecomment-412489962 CC @tillrohrmann This is an automated message

[jira] [Assigned] (FLINK-2995) Set default number of retries to larger than 0

[ https://issues.apache.org/jira/browse/FLINK-2995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-2995: --- Assignee: vinoyang > Set default number of retries to larger than 0 >

[GitHub] twalthr commented on a change in pull request #6337: [FLINK-9853] [table] Add HEX support

twalthr commented on a change in pull request #6337: [FLINK-9853] [table] Add HEX support URL: https://github.com/apache/flink/pull/6337#discussion_r209582385 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarFunctionsTest.scala

[GitHub] twalthr commented on a change in pull request #6337: [FLINK-9853] [table] Add HEX support

twalthr commented on a change in pull request #6337: [FLINK-9853] [table] Add HEX support URL: https://github.com/apache/flink/pull/6337#discussion_r209582133 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/mathExpressions.scala

[jira] [Commented] (FLINK-9853) add hex support in table api and sql

[ https://issues.apache.org/jira/browse/FLINK-9853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578170#comment-16578170 ] ASF GitHub Bot commented on FLINK-9853: --- twalthr commented on a change in pull request #6337:

  1   2   3   4   >