[jira] [Commented] (FLINK-7827) creating and starting a NetCat in test cases programmatically

[ https://issues.apache.org/jira/browse/FLINK-7827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204991#comment-16204991 ] bluejoe commented on FLINK-7827: yes,right > creating and starting a NetCat in test cases

[jira] [Closed] (FLINK-5690) protobuf is not shaded properly

[ https://issues.apache.org/jira/browse/FLINK-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5690. --- > protobuf is not shaded properly > --- > > Key: FLINK-5690 >

[jira] [Resolved] (FLINK-5690) protobuf is not shaded properly

[ https://issues.apache.org/jira/browse/FLINK-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5690. - Resolution: Resolved Assignee: Aljoscha Krettek (was: Robert Metzger) Fix

[jira] [Commented] (FLINK-5690) protobuf is not shaded properly

[ https://issues.apache.org/jira/browse/FLINK-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204878#comment-16204878 ] Stephan Ewen commented on FLINK-5690: - Fixed by moving to a newer version of Akka which hides Protobuf

[jira] [Resolved] (FLINK-7809) Drop support for Scala 2.10

[ https://issues.apache.org/jira/browse/FLINK-7809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-7809. - Resolution: Done Release Note: Done in a6039cab509b619efe0739d5f7d5e6099f954cb8 > Drop

[jira] [Closed] (FLINK-7809) Drop support for Scala 2.10

[ https://issues.apache.org/jira/browse/FLINK-7809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-7809. --- > Drop support for Scala 2.10 > --- > > Key: FLINK-7809 >

[jira] [Resolved] (FLINK-7810) Switch from custom Flakka to Akka 2.4.x

[ https://issues.apache.org/jira/browse/FLINK-7810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-7810. - Resolution: Fixed Release Note: Fixed via 5a5006ceb8d19bc0f3cc490451a18b8fc21197cb

[jira] [Closed] (FLINK-7810) Switch from custom Flakka to Akka 2.4.x

[ https://issues.apache.org/jira/browse/FLINK-7810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-7810. --- > Switch from custom Flakka to Akka 2.4.x > --- > >

[jira] [Closed] (FLINK-7842) Shade jackson (org.codehouse.jackson) in flink-shaded-hadoop2

[ https://issues.apache.org/jira/browse/FLINK-7842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-7842. --- > Shade jackson (org.codehouse.jackson) in flink-shaded-hadoop2 >

[jira] [Resolved] (FLINK-7842) Shade jackson (org.codehouse.jackson) in flink-shaded-hadoop2

[ https://issues.apache.org/jira/browse/FLINK-7842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-7842. - Resolution: Fixed Release Note: Fixed via 438ee260dea61d28968dd6ea5f02142ea2f7c533 > Shade

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

[ https://issues.apache.org/jira/browse/FLINK-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-7419. - Resolution: Fixed Release Note: Fixed via dbaf262c6e2f8a5db4a40d4ecce42782dc7e2d2e > Shade

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

[ https://issues.apache.org/jira/browse/FLINK-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-7419. --- > Shade jackson dependency in flink-avro > -- > >

[jira] [Commented] (FLINK-7810) Switch from custom Flakka to Akka 2.4.x

[ https://issues.apache.org/jira/browse/FLINK-7810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204853#comment-16204853 ] ASF GitHub Bot commented on FLINK-7810: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4807: [FLINK-7810] Switch from custom Flakka to Akka 2.4...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4807 ---

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

[ https://issues.apache.org/jira/browse/FLINK-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204827#comment-16204827 ] ASF GitHub Bot commented on FLINK-7419: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #4524: [FLINK-7419] Shade jackson dependency in flink-avro

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4524 Merging this... ---

[jira] [Assigned] (FLINK-7286) Flink Dashboard fails to display bytes/records received by sources

[ https://issues.apache.org/jira/browse/FLINK-7286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 reassigned FLINK-7286: - Assignee: Hai Zhou UTC+8 > Flink Dashboard fails to display bytes/records received by

[jira] [Created] (FLINK-7842) Shade jackson (org.codehouse.jackson) in flink-shaded-hadoop2

Stephan Ewen created FLINK-7842: --- Summary: Shade jackson (org.codehouse.jackson) in flink-shaded-hadoop2 Key: FLINK-7842 URL: https://issues.apache.org/jira/browse/FLINK-7842 Project: Flink

[jira] [Commented] (FLINK-6019) Some log4j messages do not have a loglevel field set, so they can't be suppressed

[ https://issues.apache.org/jira/browse/FLINK-6019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204738#comment-16204738 ] Stephan Ewen commented on FLINK-6019: - These are meant as progress reports for the client. You should

[jira] [Closed] (FLINK-5706) Implement Flink's own S3 filesystem

[ https://issues.apache.org/jira/browse/FLINK-5706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5706. --- > Implement Flink's own S3 filesystem > --- > > Key:

[jira] [Created] (FLINK-7841) Add docs for Flink's S3 support

Stephan Ewen created FLINK-7841: --- Summary: Add docs for Flink's S3 support Key: FLINK-7841 URL: https://issues.apache.org/jira/browse/FLINK-7841 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-5706) Implement Flink's own S3 filesystem

[ https://issues.apache.org/jira/browse/FLINK-5706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5706. - Resolution: Fixed Fix Version/s: 1.4.0 Release Note: Implemented in

[jira] [Commented] (FLINK-5706) Implement Flink's own S3 filesystem

[ https://issues.apache.org/jira/browse/FLINK-5706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204737#comment-16204737 ] ASF GitHub Bot commented on FLINK-5706: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4818: [FLINK-5706] [file systems] Add S3 file systems wi...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4818 ---

[jira] [Created] (FLINK-7840) Shade Akka's Netty Dependency

Stephan Ewen created FLINK-7840: --- Summary: Shade Akka's Netty Dependency Key: FLINK-7840 URL: https://issues.apache.org/jira/browse/FLINK-7840 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-7691) Remove ClassTag in Scala DataSet API

[ https://issues.apache.org/jira/browse/FLINK-7691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-7691: Issue Type: Sub-task (was: Improvement) Parent: FLINK-3957 > Remove ClassTag in Scala

[jira] [Updated] (FLINK-7691) Remove ClassTag in Scala DataSet API

[ https://issues.apache.org/jira/browse/FLINK-7691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-7691: Fix Version/s: 2.0.0 > Remove ClassTag in Scala DataSet API >

[jira] [Commented] (FLINK-7794) Link Broken in -- https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/connectors/index.html

[ https://issues.apache.org/jira/browse/FLINK-7794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204734#comment-16204734 ] Stephan Ewen commented on FLINK-7794: - Thanks for reporting this. Do you want to open a pull request

[jira] [Commented] (FLINK-7827) creating and starting a NetCat in test cases programmatically

[ https://issues.apache.org/jira/browse/FLINK-7827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204732#comment-16204732 ] Stephan Ewen commented on FLINK-7827: - Is this intended for example programs and test? > creating and

[jira] [Commented] (FLINK-7829) Remove (or at least deprecate) DataStream.writeToFile/Csv

[ https://issues.apache.org/jira/browse/FLINK-7829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204731#comment-16204731 ] Stephan Ewen commented on FLINK-7829: - I think these methods should exist on something like a "bounded

[jira] [Commented] (FLINK-7837) AggregatingFunction does not work with immutable types

[ https://issues.apache.org/jira/browse/FLINK-7837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204730#comment-16204730 ] Stephan Ewen commented on FLINK-7837: - It should have been like that from the start, oversight on my

[jira] [Commented] (FLINK-7837) AggregatingFunction does not work with immutable types

[ https://issues.apache.org/jira/browse/FLINK-7837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204729#comment-16204729 ] Stephan Ewen commented on FLINK-7837: - +1 for this change > AggregatingFunction does not work with

[jira] [Comment Edited] (FLINK-7340) Taskmanager hung after temporary DNS outage

[ https://issues.apache.org/jira/browse/FLINK-7340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204715#comment-16204715 ] Stephan Ewen edited comment on FLINK-7340 at 10/14/17 4:27 PM: --- Thanks, that

[jira] [Commented] (FLINK-7340) Taskmanager hung after temporary DNS outage

[ https://issues.apache.org/jira/browse/FLINK-7340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204715#comment-16204715 ] Stephan Ewen commented on FLINK-7340: - Thanks, that is a good pointer! [~till.rohrmann] Can we take

[jira] [Closed] (FLINK-4377) akka.remote.OversizedPayloadException: Discarding oversized payload

[ https://issues.apache.org/jira/browse/FLINK-4377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4377. --- > akka.remote.OversizedPayloadException: Discarding oversized payload >

[jira] [Resolved] (FLINK-4377) akka.remote.OversizedPayloadException: Discarding oversized payload

[ https://issues.apache.org/jira/browse/FLINK-4377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4377. - Resolution: Duplicate Release Note: Duplicate of FLINK-4399 >

[jira] [Commented] (FLINK-6683) building with Scala 2.11 no longer uses change-scala-version.sh

[ https://issues.apache.org/jira/browse/FLINK-6683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204713#comment-16204713 ] Stephan Ewen commented on FLINK-6683: - I think this issue is not valid for 1.3 - as Greg mentioned,

[jira] [Resolved] (FLINK-6683) building with Scala 2.11 no longer uses change-scala-version.sh

[ https://issues.apache.org/jira/browse/FLINK-6683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-6683. - Resolution: Invalid > building with Scala 2.11 no longer uses change-scala-version.sh >

[jira] [Closed] (FLINK-6683) building with Scala 2.11 no longer uses change-scala-version.sh

[ https://issues.apache.org/jira/browse/FLINK-6683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-6683. --- > building with Scala 2.11 no longer uses change-scala-version.sh >

[jira] [Closed] (FLINK-2075) Shade akka and protobuf dependencies away

[ https://issues.apache.org/jira/browse/FLINK-2075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2075. --- > Shade akka and protobuf dependencies away > - > >

[jira] [Resolved] (FLINK-2075) Shade akka and protobuf dependencies away

[ https://issues.apache.org/jira/browse/FLINK-2075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2075. - Resolution: Done Fix Version/s: 1.4.0 Release Note: Solved by upgrading to a newer

[jira] [Closed] (FLINK-5989) Protobuf in akka needs to be shaded

[ https://issues.apache.org/jira/browse/FLINK-5989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5989. --- > Protobuf in akka needs to be shaded > --- > > Key:

[jira] [Resolved] (FLINK-5989) Protobuf in akka needs to be shaded

[ https://issues.apache.org/jira/browse/FLINK-5989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5989. - Resolution: Done Fix Version/s: 1.4.0 Release Note: Subsumed by issue FLINK-7810 >

[jira] [Commented] (FLINK-5989) Protobuf in akka needs to be shaded

[ https://issues.apache.org/jira/browse/FLINK-5989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204703#comment-16204703 ] Stephan Ewen commented on FLINK-5989: - This issue should be solved through the the Akka upgrade in

[jira] [Commented] (FLINK-7021) Flink Task Manager hangs on startup if one Zookeeper node is unresolvable

[ https://issues.apache.org/jira/browse/FLINK-7021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204700#comment-16204700 ] ASF GitHub Bot commented on FLINK-7021: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #4214: [FLINK-7021] Flink Task Manager hangs on startup if one Z...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4214 @skidder Do you want to follow up on this one? Otherwise, another contributor might take this over. Betting this fix into 1.4 would be great... ---

[jira] [Commented] (FLINK-5685) Connection leak in Taskmanager

[ https://issues.apache.org/jira/browse/FLINK-5685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204695#comment-16204695 ] Stephan Ewen commented on FLINK-5685: - Is there any update on this issue, or did increasing the number

[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204672#comment-16204672 ] ASF GitHub Bot commented on FLINK-7608: --- Github user yew1eb commented on the issue:

[GitHub] flink issue #4826: [FLINK-7608][metric] Refactoring latency statistics metri...

Github user yew1eb commented on the issue: https://github.com/apache/flink/pull/4826 [LatencyStatsJob.java](https://gist.github.com/yew1eb/3329239f866b691364f4d11a7f0a846a) "Source1" and "Source2" Source send a LatencyMarker per 200ms. "Map-1-A" and "Map-2-B" Map Opreater

[jira] [Commented] (FLINK-7484) CaseClassSerializer.duplicate() does not perform proper deep copy

[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204640#comment-16204640 ] ASF GitHub Bot commented on FLINK-7484: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #4822: [FLINK-7484] Perform proper deep copy in CaseClassSeriali...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4822 Seems this is merged into master, please also merge this for 1.3.x ---

[jira] [Closed] (FLINK-7510) Move some connectors to Apache Bahir

[ https://issues.apache.org/jira/browse/FLINK-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 closed FLINK-7510. - Resolution: Won't Fix > Move some connectors to Apache Bahir >

[jira] [Updated] (FLINK-7758) Fix bug Kafka09Fetcher add offset metrics

[ https://issues.apache.org/jira/browse/FLINK-7758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 updated FLINK-7758: -- Component/s: Metrics > Fix bug Kafka09Fetcher add offset metrics >

[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204575#comment-16204575 ] ASF GitHub Bot commented on FLINK-7608: --- GitHub user yew1eb opened a pull request:

[GitHub] flink pull request #4826: [FLINK-7608][metric] Refactoring latency statistic...

GitHub user yew1eb opened a pull request: https://github.com/apache/flink/pull/4826 [FLINK-7608][metric] Refactoring latency statistics metric A detailed description of this PR, see [#issue FLINK-7608: LatencyGauge change to histogram

[jira] [Commented] (FLINK-7799) Improve performance of windowed joins

[ https://issues.apache.org/jira/browse/FLINK-7799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204554#comment-16204554 ] Xingcan Cui commented on FLINK-7799: Hi [~fhueske], I've reconsidered this problem and found a

[jira] [Comment Edited] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

[ https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204394#comment-16204394 ] Michael Fong edited comment on FLINK-7839 at 10/14/17 7:56 AM: --- >From above

[jira] [Commented] (FLINK-7798) Add support for windowed joins to Table API

[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204526#comment-16204526 ] ASF GitHub Bot commented on FLINK-7798: --- Github user xccui commented on a diff in the pull request:

[GitHub] flink pull request #4825: [FLINK-7798] [table] Add support for stream window...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4825#discussion_r144688874 --- Diff: docs/dev/table/tableApi.md --- @@ -498,6 +499,23 @@ Table left = tableEnv.fromDataSet(ds1, "a, b, c"); Table right = tableEnv.fromDataSet(ds2,

[GitHub] flink pull request #4825: [FLINK-7798] [table] Add support for stream window...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4825#discussion_r144688279 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/JoinITCase.scala --- @@ -0,0 +1,114 @@ +/* + *

[jira] [Closed] (FLINK-7686) Add Flink Forward Berlin 2017 conference slides to the flink website

[ https://issues.apache.org/jira/browse/FLINK-7686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 closed FLINK-7686. - Resolution: Not A Problem > Add Flink Forward Berlin 2017 conference slides to the flink website

[jira] [Commented] (FLINK-7798) Add support for windowed joins to Table API

[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204515#comment-16204515 ] ASF GitHub Bot commented on FLINK-7798: --- Github user xccui commented on a diff in the pull request:

[jira] [Commented] (FLINK-7798) Add support for windowed joins to Table API

[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204511#comment-16204511 ] ASF GitHub Bot commented on FLINK-7798: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #4825: [FLINK-7798] [table] Add support for stream window...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4825#discussion_r144688111 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/JoinITCase.scala --- @@ -0,0 +1,114 @@ +/* + *