[jira] [Commented] (FLINK-6738) HBaseConnectorITCase is flaky

2017-10-06 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195565#comment-16195565 ] Ted Yu commented on FLINK-6738: --- Calcite 1.14 has been released. > HBaseConnectorITCase is flaky >

[jira] [Updated] (FLINK-7432) Unclosed HighAvailabilityServices instance in QueryableStateClient

2017-10-06 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7432: -- Description: {code} public QueryableStateClient(Configuration config) throws Exception { this(config,

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

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

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

2017-10-06 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/4471#discussion_r143320024 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala --- @@ -0,0 +1,93 @@ +/*

[jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

2017-10-06 Thread Vishnu Viswanath (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195159#comment-16195159 ] Vishnu Viswanath commented on FLINK-3655: - was looking for this feature. why wasn't this ever

[jira] [Commented] (FLINK-7312) activate checkstyle for flink/core/memory/*

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

[GitHub] flink issue #4447: [FLINK-7312][checkstyle] activate checkstyle for flink/co...

2017-10-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4447 #4445 contains this PR, yes. ---

[jira] [Resolved] (FLINK-7768) Load File Systems via Java Service abstraction

2017-10-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-7768. - Resolution: Fixed Assignee: Stephan Ewen Release Note: Implemented in

[jira] [Updated] (FLINK-7768) Load File Systems via Java Service abstraction

2017-10-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-7768: Description: We should change the discovery mechanism of file from static class name

[jira] [Updated] (FLINK-7768) Load File Systems via Java Service abstraction

2017-10-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-7768: Release Note: (was: We should change the discovery mechanism of file from static class name

[jira] [Closed] (FLINK-7768) Load File Systems via Java Service abstraction

2017-10-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-7768. --- > Load File Systems via Java Service abstraction > -- > >

[jira] [Commented] (FLINK-7312) activate checkstyle for flink/core/memory/*

2017-10-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195048#comment-16195048 ] ASF GitHub Bot commented on FLINK-7312: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #4447: [FLINK-7312][checkstyle] activate checkstyle for flink/co...

2017-10-06 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4447 This seems to be subsumed by #4445 - is that correct? ---

[GitHub] flink issue #4445: [FLINK-7310][core] always use the HybridMemorySegment

2017-10-06 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4445 Agree with @KurtYoung. Merging this... ---

[jira] [Commented] (FLINK-7310) always use HybridMemorySegment

2017-10-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195032#comment-16195032 ] ASF GitHub Bot commented on FLINK-7310: --- Github user StephanEwen commented on the issue:

[jira] [Updated] (FLINK-7495) AbstractUdfStreamOperator#initializeState() should be called in AsyncWaitOperator#initializeState()

2017-10-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7495: -- Component/s: State Backends, Checkpointing > AbstractUdfStreamOperator#initializeState() should

[jira] [Updated] (FLINK-7488) TaskManagerHeapSizeCalculationJavaBashTest sometimes fails

2017-10-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7488: -- Component/s: Tests > TaskManagerHeapSizeCalculationJavaBashTest sometimes fails >

[jira] [Updated] (FLINK-7775) Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs

2017-10-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7775: -- Component/s: Local Runtime > Remove unreferenced method

[jira] [Updated] (FLINK-7740) Add parameter support in CassandraInputFormat

2017-10-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7740: -- Component/s: Cassandra Connector > Add parameter support in CassandraInputFormat >

[jira] [Updated] (FLINK-7682) Invalid state size formatting

2017-10-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7682: -- Component/s: Webfrontend > Invalid state size formatting > - > >

[jira] [Updated] (FLINK-7642) Upgrade maven surefire plugin to 2.19.1

2017-10-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7642: -- Component/s: Build System > Upgrade maven surefire plugin to 2.19.1 >

[jira] [Commented] (FLINK-7493) Create Pinot Connector

2017-10-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195005#comment-16195005 ] Robert Metzger commented on FLINK-7493: --- I would suggest to contribute the connector to the Apache

[jira] [Commented] (FLINK-7492) Memsql Connector

2017-10-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195006#comment-16195006 ] Robert Metzger commented on FLINK-7492: --- I would suggest to contribute the connector to the Apache

[jira] [Updated] (FLINK-7679) Upgrade maven enforcer plugin to 3.0.0-M1

2017-10-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7679: -- Component/s: Build System > Upgrade maven enforcer plugin to 3.0.0-M1 >

[jira] [Updated] (FLINK-7493) Create Pinot Connector

2017-10-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7493: -- Component/s: Streaming Connectors > Create Pinot Connector > -- > >

[jira] [Updated] (FLINK-7743) Remove the restriction of minimum memory of JM

2017-10-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7743: -- Component/s: YARN > Remove the restriction of minimum memory of JM >

[jira] [Updated] (FLINK-7492) Memsql Connector

2017-10-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7492: -- Component/s: Streaming Connectors > Memsql Connector > > >

[jira] [Created] (FLINK-7775) Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs

2017-10-06 Thread Ted Yu (JIRA)
Ted Yu created FLINK-7775: - Summary: Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs Key: FLINK-7775 URL: https://issues.apache.org/jira/browse/FLINK-7775 Project: Flink Issue

[jira] [Commented] (FLINK-7744) Add missing top links to documentation

2017-10-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194963#comment-16194963 ] ASF GitHub Bot commented on FLINK-7744: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #4755: [hotfix] [docs] Fix broken links

2017-10-06 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4755 +1, merging this... ---

[GitHub] flink issue #4756: [FLINK-7744][docs] Add missing top links to documentation

2017-10-06 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4756 Good from my side. Since I am not very opinionated about docs/navigation, would be good to have a second opinion. @alpinegizmo what do you think? ---

[jira] [Commented] (FLINK-7768) Load File Systems via Java Service abstraction

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

[GitHub] flink pull request #4781: [FLINK-7768] [core] Load File Systems via Java Ser...

2017-10-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4781 ---

[GitHub] flink issue #4754: [FLINK-7742][hotfix] Fix array access might be out of bou...

2017-10-06 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4754 Good catches, thanks. Merging this... ---

[jira] [Commented] (FLINK-7742) Fix array access might be out of bounds

2017-10-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194953#comment-16194953 ] ASF GitHub Bot commented on FLINK-7742: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-7739) Improve Kafka*ITCase tests stability

2017-10-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194941#comment-16194941 ] ASF GitHub Bot commented on FLINK-7739: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #4775: [FLINK-7739] Fix KafkaXXITCase tests stability

2017-10-06 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4775 Thanks, will merge this without the added restart delay. If it is still unstable, we can add that back. ---

[jira] [Commented] (FLINK-7739) Improve Kafka*ITCase tests stability

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

[GitHub] flink pull request #4775: [FLINK-7739] Fix KafkaXXITCase tests stability

2017-10-06 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4775#discussion_r143254179 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java --- @@ -121,10

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

2017-10-06 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4777#discussion_r143253601 --- Diff: flink-core/pom.xml --- @@ -77,6 +88,12 @@ under the License. org.apache.commons

[jira] [Commented] (FLINK-7739) Improve Kafka*ITCase tests stability

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

[jira] [Commented] (FLINK-7739) Improve Kafka*ITCase tests stability

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

[jira] [Commented] (FLINK-7739) Improve Kafka*ITCase tests stability

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

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

2017-10-06 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4777#discussion_r143252870 --- Diff: flink-core/pom.xml --- @@ -63,9 +63,20 @@ under the License. com.esotericsoftware.kryo

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

2017-10-06 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4777#discussion_r143253445 --- Diff: pom.xml --- @@ -1181,7 +1204,7 @@ under the License. org.apache.maven.plugins

[jira] [Commented] (FLINK-7266) Don't attempt to delete parent directory on S3

2017-10-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194915#comment-16194915 ] Stephan Ewen commented on FLINK-7266: - True, this is a problem in 1.3.2 - the tradeoff was to either

[GitHub] flink issue #4783: [FLINK-7774][network] fix not clearing deserializers on c...

2017-10-06 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4783 Looks good, +1 to merge this ---

[GitHub] flink issue #4782: [FLINK-7772][blob] fix test instability in BlobCacheDelet...

2017-10-06 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4782 Thanks for fixing this, merging... ---

[jira] [Commented] (FLINK-7772) Test instability in BlobCacheDeleteTest

2017-10-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194904#comment-16194904 ] ASF GitHub Bot commented on FLINK-7772: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-7774) Deserializers are not cleaned up when closing input streams

2017-10-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194902#comment-16194902 ] ASF GitHub Bot commented on FLINK-7774: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-7761) Twitter example is not self-contained

2017-10-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194898#comment-16194898 ] ASF GitHub Bot commented on FLINK-7761: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-6495) Migrate Akka configuration options

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

[GitHub] flink issue #4773: [FLINK-7761] [examples] Include shaded guava dependency i...

2017-10-06 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4773 Looks good to me! ---

[GitHub] flink pull request #4774: [FLINK-6495] Fix Akka's default value for heartbea...

2017-10-06 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4774#discussion_r143248194 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/FixedDelayRestartStrategy.java --- @@ -82,7 +82,7 @@ public

[jira] [Commented] (FLINK-6495) Migrate Akka configuration options

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

[GitHub] flink pull request #4774: [FLINK-6495] Fix Akka's default value for heartbea...

2017-10-06 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4774#discussion_r143246933 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/IllegalConfigurationException.java --- @@ -42,6 +42,17 @@ public

[jira] [Closed] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

2017-10-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4660. --- Resolution: Fixed Release Note: Closing the reopened issue to update versions in which this is

[jira] [Updated] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

2017-10-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4660: Fix Version/s: 1.3.2 1.4.0 > HadoopFileSystem (with S3A) may leak connections,

[jira] [Reopened] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

2017-10-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reopened FLINK-4660: - Reopening to assign proper fix version > HadoopFileSystem (with S3A) may leak connections, which

[jira] [Commented] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

2017-10-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194857#comment-16194857 ] Stephan Ewen commented on FLINK-4660: - This was part of the 1.3.2 release and will be part of the

[jira] [Closed] (FLINK-7767) Avoid loading Hadoop conf dynamically at runtime

2017-10-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-7767. --- > Avoid loading Hadoop conf dynamically at runtime > > >

[jira] [Resolved] (FLINK-7767) Avoid loading Hadoop conf dynamically at runtime

2017-10-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-7767. - Resolution: Fixed Release Note: Fixed via bad3df54d20677157f48c3ee1f3251d2c4bce8ba > Avoid

[jira] [Resolved] (FLINK-7766) Remove obsolete reflection for hflush on HDFS

2017-10-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-7766. - Resolution: Fixed Release Note: Fixed via 7843c2ffb44f99967dc71746ac1c79b04a74fe80 > Remove

[jira] [Closed] (FLINK-7766) Remove obsolete reflection for hflush on HDFS

2017-10-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-7766. --- > Remove obsolete reflection for hflush on HDFS > - > >

[jira] [Commented] (FLINK-7766) Remove obsolete reflection for hflush on HDFS

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

[GitHub] flink pull request #4780: [FLINK-7766] [FLINK-7767] [file system sink] Clean...

2017-10-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4780 ---

[jira] [Commented] (FLINK-2973) Add flink-benchmark with compliant licenses again

2017-10-06 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194801#comment-16194801 ] Fabian Hueske commented on FLINK-2973: -- Not sure. [This

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

2017-10-06 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r143231150 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/JoinITCase.scala --- @@ -102,5 +117,154 @@ class JoinITCase

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

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

[jira] [Assigned] (FLINK-7548) Support watermark generation for TableSource

2017-10-06 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7548: Assignee: Fabian Hueske > Support watermark generation for TableSource >

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

2017-10-06 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r143222605 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala --- @@ -184,4 +229,50 @@ class

[jira] [Closed] (FLINK-4034) Dependency convergence on com.101tec:zkclient and com.esotericsoftware.kryo:kryo

2017-10-06 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-4034. - Resolution: Duplicate It seems like this work was abandoned. Closing as it is a subset of

[jira] [Commented] (FLINK-7774) Deserializers are not cleaned up when closing input streams

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

[GitHub] flink pull request #4783: [FLINK-7774][network] fix not clearing deserialize...

2017-10-06 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4783 [FLINK-7774][network] fix not clearing deserializers on closing an input ## What is the purpose of the change On cleanup of the `AbstractRecordReader`, `StreamInputProcessor`, and

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

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

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

2017-10-06 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r143211000 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,410 @@ +/* +

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

2017-10-06 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4625#discussion_r143208392 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala --- @@ -0,0 +1,410 @@ +/* +

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

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

[jira] [Commented] (FLINK-7072) Create RESTful cluster endpoint

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

[GitHub] flink issue #4742: [FLINK-7072] [REST] Add Flip-6 client for submit/job/canc...

2017-10-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4742 @tillrohrmann We got some test-failures for the CLIFrontend caused by us now using the ClusterClient for stop/cancel. This is purely a test construction issue, and I'm currently fixing them. ---

[jira] [Commented] (FLINK-7410) Use toString method to display operator names for UserDefinedFunction

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

[GitHub] flink issue #4624: [FLINK-7410] [table] Use toString method to display opera...

2017-10-06 Thread hequn8128
Github user hequn8128 commented on the issue: https://github.com/apache/flink/pull/4624 Hi @fhueske , Thanks for your review, I have addressed all your comments and rebased the code to the master :) ---

[jira] [Commented] (FLINK-7770) Hide Queryable State behind a proxy.

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

[jira] [Commented] (FLINK-7770) Hide Queryable State behind a proxy.

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

[jira] [Commented] (FLINK-7770) Hide Queryable State behind a proxy.

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

[GitHub] flink pull request #4778: [FLINK-7770][FLINK-7769][Queryable State] Refactor...

2017-10-06 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4778#discussion_r143194039 --- Diff: flink-queryable-state/flink-queryable-state-java/src/test/java/itcases/HAQueryableStateITCaseFsBackend.java --- @@ -16,7 +16,7 @@ *

[GitHub] flink pull request #4778: [FLINK-7770][FLINK-7769][Queryable State] Refactor...

2017-10-06 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4778#discussion_r143193371 --- Diff: flink-queryable-state/flink-queryable-state-java/pom.xml --- @@ -0,0 +1,149 @@ + + +http://maven.apache.org/POM/4.0.0; +

[GitHub] flink pull request #4778: [FLINK-7770][FLINK-7769][Queryable State] Refactor...

2017-10-06 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4778#discussion_r143193896 --- Diff: flink-queryable-state/flink-queryable-state-java/src/test/java/itcases/AbstractQueryableStateITCase.java --- @@ -16,7 +16,7 @@ *

[jira] [Commented] (FLINK-7698) Join with null literals leads to NPE

2017-10-06 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194585#comment-16194585 ] Xingcan Cui commented on FLINK-7698: Hi [~twalthr], this problem has be addressed in

[jira] [Created] (FLINK-7774) Deserializers are not cleaned up when closing input streams

2017-10-06 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7774: -- Summary: Deserializers are not cleaned up when closing input streams Key: FLINK-7774 URL: https://issues.apache.org/jira/browse/FLINK-7774 Project: Flink Issue

[jira] [Updated] (FLINK-7773) Test instability in UtilsTest#testYarnFlinkResourceManagerJobManagerLostLeadership

2017-10-06 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7773: --- Labels: test-stability (was: ) > Test instability in >

[jira] [Created] (FLINK-7773) Test instability in UtilsTest#testYarnFlinkResourceManagerJobManagerLostLeadership

2017-10-06 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7773: -- Summary: Test instability in UtilsTest#testYarnFlinkResourceManagerJobManagerLostLeadership Key: FLINK-7773 URL: https://issues.apache.org/jira/browse/FLINK-7773

[jira] [Commented] (FLINK-7768) Load File Systems via Java Service abstraction

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

[GitHub] flink issue #4781: [FLINK-7768] [core] Load File Systems via Java Service ab...

2017-10-06 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4781 The changes look good! 👍 I had some comments about POMs, optional and shading but those got resolved "offline". I had one comment about a test name but feel free to merge. ---

[jira] [Updated] (FLINK-7772) Test instability in BlobCacheDeleteTest

2017-10-06 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7772: --- Priority: Critical (was: Major) > Test instability in BlobCacheDeleteTest >

[jira] [Updated] (FLINK-7772) Test instability in BlobCacheDeleteTest

2017-10-06 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7772: --- Labels: test-stability (was: ) > Test instability in BlobCacheDeleteTest >

[jira] [Commented] (FLINK-7768) Load File Systems via Java Service abstraction

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

[GitHub] flink pull request #4781: [FLINK-7768] [core] Load File Systems via Java Ser...

2017-10-06 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4781#discussion_r143174730 --- Diff: flink-dist/pom.xml --- @@ -205,6 +205,32 @@ under the License. + + +

[jira] [Commented] (FLINK-7768) Load File Systems via Java Service abstraction

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

  1   2   >