[jira] [Updated] (FLINK-3986) Rename readFileStream from the StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-3986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3986: Summary: Rename readFileStream from the StreamExecutionEnvironment (was: Rename the readFil

[GitHub] flink issue #1973: [FLINK-3869] Relax window fold generic parameters

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/1973 So we shouldn't fix and but keep track of it for Flink 2.0? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not h

[jira] [Commented] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive

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

[jira] [Commented] (FLINK-4016) FoldApplyWindowFunction is not properly initialized

[ https://issues.apache.org/jira/browse/FLINK-4016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320140#comment-15320140 ] Aljoscha Krettek commented on FLINK-4016: - [~rvdwenden] If you have a fix, please

[jira] [Commented] (FLINK-4008) Hello,I am not able to create jar of flink-streaming-connectors ...I am able to create jar of others like twitter,kafka,flume but I am not able to create jar of flink-s

[ https://issues.apache.org/jira/browse/FLINK-4008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320019#comment-15320019 ] Tzu-Li (Gordon) Tai commented on FLINK-4008: Don't build under the kinesis con

[jira] [Commented] (FLINK-4008) Hello,I am not able to create jar of flink-streaming-connectors ...I am able to create jar of others like twitter,kafka,flume but I am not able to create jar of flink-s

[ https://issues.apache.org/jira/browse/FLINK-4008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319984#comment-15319984 ] Akshay Shingote commented on FLINK-4008: How can I build the snapshot ?? Can you p

[jira] [Commented] (FLINK-4016) FoldApplyWindowFunction is not properly initialized

[ https://issues.apache.org/jira/browse/FLINK-4016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319181#comment-15319181 ] RWenden commented on FLINK-4016: I already made a commit with message

[jira] [Closed] (FLINK-4003) Use intrinsics for MathUtils logarithms

[ https://issues.apache.org/jira/browse/FLINK-4003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4003. - Resolution: Implemented Implemented in 1bbc1fb4d7b8701c38e6f6a78f3709448181d559 > Use intrinsics for Math

[jira] [Commented] (FLINK-4003) Use intrinsics for MathUtils logarithms

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

[GitHub] flink pull request #2059: [FLINK-4003] Use intrinsics for MathUtils logarith...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2059 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-2832) Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement

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

[GitHub] flink issue #2076: [FLINK-2832] [tests] Hardens RandomSamplerTest

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2076 Merging this, addressing @chiwanpark 's comments... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have t

[jira] [Commented] (FLINK-3530) Kafka09ITCase.testBigRecordJob fails on Travis

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

[GitHub] flink issue #2080: [FLINK-3530] Fix Kafka08 instability: Avoid restarts from...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2080 Do you know where the canceling looses the time? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure

[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319051#comment-15319051 ] ASF GitHub Bot commented on FLINK-4002: --- Github user omaralvarez commented on the is

[GitHub] flink issue #2063: [FLINK-4002] [py] Improve testing infraestructure

Github user omaralvarez commented on the issue: https://github.com/apache/flink/pull/2063 I think everything should be ready now. I was not able to pinpoint why HDFS worked, I assume `distributeFiles()` copied the complete directory and that is why it worked, but I'm not 100% sure.

[jira] [Closed] (FLINK-3906) Global Clustering Coefficient

[ https://issues.apache.org/jira/browse/FLINK-3906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3906. - Resolution: Implemented Implemented in 8da1a75ceb30ef1bce27a2426dab3a0f66b94b64 > Global Clustering Coeff

[GitHub] flink issue #1962: [FLINK-3857][Streaming Connectors]Add reconnect attempt t...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/1962 I took a quick look at this. I am wondering if this actually needs an extra timer service for retries. Can this be solved without a timer? The failures could be detected in the `invoke(.

[jira] [Commented] (FLINK-3857) Add reconnect attempt to Elasticsearch host

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

[jira] [Commented] (FLINK-3906) Global Clustering Coefficient

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

[GitHub] flink pull request #1997: [FLINK-3906] [gelly] Global Clustering Coefficient

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1997 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-4025) Add possiblity for the RMQ Streaming Source to customize the queue

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

[GitHub] flink issue #2073: [FLINK-4025] Add possiblity for the RMQ Streaming Source ...

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2073 The change looks good, I'll merge it. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabl

[jira] [Commented] (FLINK-4025) Add possiblity for the RMQ Streaming Source to customize the queue

[ https://issues.apache.org/jira/browse/FLINK-4025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318978#comment-15318978 ] Robert Metzger commented on FLINK-4025: --- I understand. I'll merge your change first

[jira] [Commented] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive

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

[GitHub] flink issue #1973: [FLINK-3869] Relax window fold generic parameters

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/1973 I think the API breaking changes preventer will reject this. It is all public methods, and the signature changes (implicit parameters and context bounds are parameters in the bytecode) --- I

[jira] [Commented] (FLINK-3805) BloomFilter initialized with no memory available

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

[GitHub] flink issue #1999: [FLINK-3805] BloomFilter initialized with no memory avail...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/1999 @rekhajoshm Will you be adding a test case for this pull request? If not, I think it should be closed, because we cannot merge it without a test. --- If your project is set up for it, you can re

[jira] [Commented] (FLINK-4008) Hello,I am not able to create jar of flink-streaming-connectors ...I am able to create jar of others like twitter,kafka,flume but I am not able to create jar of flink-s

[ https://issues.apache.org/jira/browse/FLINK-4008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318955#comment-15318955 ] Stephan Ewen commented on FLINK-4008: - There is no "flink-streaming-connectors" JAR fi

[jira] [Commented] (FLINK-4015) FlinkKafkaProducer08 fails when partition leader changes

[ https://issues.apache.org/jira/browse/FLINK-4015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318949#comment-15318949 ] Sebastian Klemke commented on FLINK-4015: - For our application, it should never dr

[jira] [Commented] (FLINK-3922) Infinite recursion on TypeExtractor

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

[GitHub] flink issue #2011: [FLINK-3922] [types] Infinite recursion on TypeExtractor

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2011 Will merge this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so

[jira] [Commented] (FLINK-4011) Unable to access completed job in web frontend

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

[GitHub] flink issue #2065: [FLINK-4011] Keep UserCodeClassLoader in archived Executi...

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2065 Thank you for the review. I'll merge it --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature ena

[jira] [Commented] (FLINK-4015) FlinkKafkaProducer08 fails when partition leader changes

[ https://issues.apache.org/jira/browse/FLINK-4015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318920#comment-15318920 ] Stephan Ewen commented on FLINK-4015: - What kind of behavior should the sink have? If

[jira] [Commented] (FLINK-3405) Extend NiFiSource with interface StoppableFunction

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

[GitHub] flink issue #2047: FLINK-3405: Extend NiFiSource with interface StoppableFun...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2047 All right, merging this, thanks! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[GitHub] flink issue #2058: Not able to create flink-streaming-connectors jar

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2058 Can you close the pull request and continue the discussion on JIRA? This here is not the right place for such a discussion. --- If your project is set up for it, you can reply to this email a

[jira] [Commented] (FLINK-4003) Use intrinsics for MathUtils logarithms

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

[GitHub] flink issue #2059: [FLINK-4003] Use intrinsics for MathUtils logarithms

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2059 Looks good, +1 to merge this --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and

[jira] [Commented] (FLINK-3921) StringParser not specifying encoding to use

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

[GitHub] flink issue #2060: [FLINK-3921] StringParser encoding

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2060 Let's make this configurable on `GenericCsvInputFormat`, with the default of "UTF-8" (this is what we use in other places as the default, too). The charset affects the - delimiter

[jira] [Commented] (FLINK-3967) Provide RethinkDB Sink for Flink

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

[GitHub] flink issue #2031: FLINK-3967 - Flink Sink for Rethink Db

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2031 Hi @mans2singh ! This looks like a good piece of work, and ReThinkDB is an interesting technology! An Apache-compatible licence is also good. We are facing a bit of a mainten

[GitHub] flink issue #2032: [FLINK-3965] [gelly] Delegating GraphAlgorithm

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2032 I see no problem with merging this, from a code perspective. I do not completely get all the mechanics and reasoning behind this, so would be great if @vasia could comment on this. ---

[jira] [Commented] (FLINK-3965) Delegating GraphAlgorithm

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

[jira] [Commented] (FLINK-3868) Specialized CopyableValue serializers and comparators

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

[GitHub] flink issue #1983: [FLINK-3868] [core] Specialized CopyableValue serializers...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/1983 I think the code looks good. There are no tests so far, though. I am wondering if some would help to catch copy/paste errors. It is very easy to write comparator tests simply extendin

[jira] [Commented] (FLINK-3530) Kafka09ITCase.testBigRecordJob fails on Travis

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

[GitHub] flink pull request #2080: [FLINK-3530] Fix Kafka08 instability: Avoid restar...

GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/2080 [FLINK-3530] Fix Kafka08 instability: Avoid restarts from SuccessExce… This pull request is improving the Kafka tests stability. These tests have one artificial test failure, the code sho

[jira] [Updated] (FLINK-3907) Directed Clustering Coefficient

[ https://issues.apache.org/jira/browse/FLINK-3907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3907: -- Fix Version/s: 1.1.0 > Directed Clustering Coefficient > --- > >

[jira] [Commented] (FLINK-3907) Directed Clustering Coefficient

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

[GitHub] flink pull request #2079: [FLINK-3907] [gelly] Directed Clustering Coefficie...

GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/2079 [FLINK-3907] [gelly] Directed Clustering Coefficient You can merge this pull request into a Git repository by running: $ git pull https://github.com/greghogan/flink 3907_directed_clustering

[jira] [Updated] (FLINK-4028) AbstractAlignedProcessingTimeWindowOperator creates wrong TimeWindow

[ https://issues.apache.org/jira/browse/FLINK-4028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4028: Priority: Blocker (was: Major) > AbstractAlignedProcessingTimeWindowOperator creates wrong TimeWind

[jira] [Updated] (FLINK-4028) AbstractAlignedProcessingTimeWindowOperator creates wrong TimeWindow

[ https://issues.apache.org/jira/browse/FLINK-4028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4028: Fix Version/s: 1.1.0 > AbstractAlignedProcessingTimeWindowOperator creates wrong TimeWindow > --

[jira] [Commented] (FLINK-4000) Exception: Could not restore checkpointed state to operators and functions; during Job Restart (Job restart is triggered due to one of the task manager failure)

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

[GitHub] flink issue #2062: [FLINK-4000] Fix for checkpoint state restore at MessageA...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2062 Thanks, this is a critical fix. +1 Merging this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project doe

[jira] [Commented] (FLINK-4011) Unable to access completed job in web frontend

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

[GitHub] flink issue #2065: [FLINK-4011] Keep UserCodeClassLoader in archived Executi...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2065 Given the current status, this is a good pragmatic fif. +1 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[jira] [Commented] (FLINK-4017) [py] Add Aggregation support to Python API

[ https://issues.apache.org/jira/browse/FLINK-4017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318713#comment-15318713 ] Geoffrey Mon commented on FLINK-4017: - Thanks for the advice. The issue that was hinde

[jira] [Created] (FLINK-4028) AbstractAlignedProcessingTimeWindowOperator creates wrong TimeWindow

Aljoscha Krettek created FLINK-4028: --- Summary: AbstractAlignedProcessingTimeWindowOperator creates wrong TimeWindow Key: FLINK-4028 URL: https://issues.apache.org/jira/browse/FLINK-4028 Project: Fli

[jira] [Commented] (FLINK-4017) [py] Add Aggregation support to Python API

[ https://issues.apache.org/jira/browse/FLINK-4017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318695#comment-15318695 ] Chesnay Schepler commented on FLINK-4017: - when using the python API data always e

[jira] [Commented] (FLINK-4017) [py] Add Aggregation support to Python API

[ https://issues.apache.org/jira/browse/FLINK-4017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318696#comment-15318696 ] Chesnay Schepler commented on FLINK-4017: - what other issues did you come across?

[jira] [Commented] (FLINK-4017) [py] Add Aggregation support to Python API

[ https://issues.apache.org/jira/browse/FLINK-4017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318676#comment-15318676 ] Geoffrey Mon commented on FLINK-4017: - At least one of the issues I have come across i

[jira] [Assigned] (FLINK-3530) Kafka09ITCase.testBigRecordJob fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-3530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3530: - Assignee: Robert Metzger > Kafka09ITCase.testBigRecordJob fails on Travis > -

[jira] [Commented] (FLINK-3530) Kafka09ITCase.testBigRecordJob fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-3530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318631#comment-15318631 ] Robert Metzger commented on FLINK-3530: --- I have a similar failure like this: https:

[jira] [Closed] (FLINK-4013) GraphAlgorithms to simplify directed and undirected graphs

[ https://issues.apache.org/jira/browse/FLINK-4013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4013. - Resolution: Fixed Implemented in 7160a681240deab693aa4d69c24c4a8a63bb58ba > GraphAlgorithms to simplify d

[jira] [Closed] (FLINK-3980) Remove ExecutionConfig.PARALLELISM_UNKNOWN

[ https://issues.apache.org/jira/browse/FLINK-3980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3980. - Resolution: Implemented Implemented in 21454973ed4edfb3e27bc50ed0279f5708d54fa2 > Remove ExecutionConfig.

[jira] [Closed] (FLINK-3925) GraphAlgorithm to filter by maximum degree

[ https://issues.apache.org/jira/browse/FLINK-3925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3925. - Resolution: Implemented Implemented in a611271b3ef7a084ec8e7edc4d4dc241550d7ad8 > GraphAlgorithm to filte

[jira] [Commented] (FLINK-4013) GraphAlgorithms to simplify directed and undirected graphs

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

[jira] [Commented] (FLINK-3925) GraphAlgorithm to filter by maximum degree

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

[jira] [Commented] (FLINK-3980) Remove ExecutionConfig.PARALLELISM_UNKNOWN

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

[GitHub] flink pull request #2005: [FLINK-3925] GraphAlgorithm to filter by maximum d...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2005 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[GitHub] flink pull request #2064: [FLINK-3980] [core] Remove ExecutionConfig.PARALLE...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2064 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[GitHub] flink pull request #2067: [FLINK-4013] [gelly] GraphAlgorithms to simplify d...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2067 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-3868) Specialized CopyableValue serializers and comparators

[ https://issues.apache.org/jira/browse/FLINK-3868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318592#comment-15318592 ] ASF GitHub Bot commented on FLINK-3868: --- Github user greghogan commented on the issu

[GitHub] flink issue #1983: [FLINK-3868] [core] Specialized CopyableValue serializers...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/1983 @StephanEwen updated per your suggestions. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Updated] (FLINK-1736) Add CountVectorizer to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1736: - Assignee: ROSHANI NAGMOTE (was: Alexander Alexandrov) > Add CountVectorizer to machine learning l

[jira] [Commented] (FLINK-3965) Delegating GraphAlgorithm

[ https://issues.apache.org/jira/browse/FLINK-3965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318469#comment-15318469 ] ASF GitHub Bot commented on FLINK-3965: --- Github user greghogan commented on the issu

[GitHub] flink issue #2032: [FLINK-3965] [gelly] Delegating GraphAlgorithm

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2032 @StephanEwen do you think this is a good and proper strategy? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does no

[jira] [Commented] (FLINK-3978) Add hasBroadcastVariable method to RuntimeContext

[ https://issues.apache.org/jira/browse/FLINK-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318398#comment-15318398 ] ASF GitHub Bot commented on FLINK-3978: --- Github user greghogan commented on the issu

[jira] [Commented] (FLINK-3978) Add hasBroadcastVariable method to RuntimeContext

[ https://issues.apache.org/jira/browse/FLINK-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318399#comment-15318399 ] ASF GitHub Bot commented on FLINK-3978: --- Github user greghogan closed the pull reque

[GitHub] flink issue #2039: [FLINK-3978] [core] Add hasBroadcastVariable method to Ru...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2039 This was closed in 5b0287971fa2beda360105d96e7bfbc7a110fae7 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not

[GitHub] flink pull request #2039: [FLINK-3978] [core] Add hasBroadcastVariable metho...

Github user greghogan closed the pull request at: https://github.com/apache/flink/pull/2039 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is e

[jira] [Commented] (FLINK-3980) Remove ExecutionConfig.PARALLELISM_UNKNOWN

[ https://issues.apache.org/jira/browse/FLINK-3980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318385#comment-15318385 ] ASF GitHub Bot commented on FLINK-3980: --- Github user greghogan commented on the issu

[GitHub] flink issue #2064: [FLINK-3980] [core] Remove ExecutionConfig.PARALLELISM_UN...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2064 Will rebase and merge ... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wish

[jira] [Commented] (FLINK-3777) Add open and close methods to manage IF lifecycle

[ https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318374#comment-15318374 ] Flavio Pompermaier commented on FLINK-3777: --- In our use case we have this very c

[jira] [Commented] (FLINK-4024) FileSourceFunction not adjusted to new IF lifecycle

[ https://issues.apache.org/jira/browse/FLINK-4024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318338#comment-15318338 ] Stephan Ewen commented on FLINK-4024: - Related: I commented on FLINK-3777 voicing some

[jira] [Commented] (FLINK-3777) Add open and close methods to manage IF lifecycle

[ https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318333#comment-15318333 ] Stephan Ewen commented on FLINK-3777: - I understand that these allow initialization ac

[jira] [Commented] (FLINK-4016) FoldApplyWindowFunction is not properly initialized

[ https://issues.apache.org/jira/browse/FLINK-4016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318320#comment-15318320 ] Aljoscha Krettek commented on FLINK-4016: - I don't think so, FLINK-3977 describes

[jira] [Commented] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer

[ https://issues.apache.org/jira/browse/FLINK-3923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318272#comment-15318272 ] Tzu-Li (Gordon) Tai commented on FLINK-3923: The consumer isn't using the KCL

[jira] [Commented] (FLINK-4016) FoldApplyWindowFunction is not properly initialized

[ https://issues.apache.org/jira/browse/FLINK-4016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318226#comment-15318226 ] RWenden commented on FLINK-4016: Isn't it a better idea to close Jira 3977 and re-open 401

[jira] [Commented] (FLINK-4016) FoldApplyWindowFunction is not properly initialized

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

[GitHub] flink issue #2070: [FLINK-4016] initialize FoldApplyWindowFunction properly

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2070 Hi, the clean way to go about this is to close this PR and open a new one for `FLINK-3977`. I wrote a new comment in the issue, outlining how the problem can be solved: https://issues.apache.org

[jira] [Commented] (FLINK-3977) Subclasses of InternalWindowFunction must support OutputTypeConfigurable

[ https://issues.apache.org/jira/browse/FLINK-3977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318161#comment-15318161 ] Aljoscha Krettek commented on FLINK-3977: - The way to solve this is to make subcla

[jira] [Commented] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer

[ https://issues.apache.org/jira/browse/FLINK-3923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318155#comment-15318155 ] Abdullah Ozturk commented on FLINK-3923: I think it is really good idea. Except, I

[GitHub] flink pull request #2077: [FLINK-4026] Fix code, grammar, and link issues in...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2077 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Resolved] (FLINK-4026) Fix code, grammar, and link issues in the Streaming documentation

[ https://issues.apache.org/jira/browse/FLINK-4026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-4026. - Resolution: Fixed Fix Version/s: 1.1.0 Fixed > Fix code, grammar, and link issues

[jira] [Commented] (FLINK-4026) Fix code, grammar, and link issues in the Streaming documentation

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

[jira] [Commented] (FLINK-4026) Fix code, grammar, and link issues in the Streaming documentation

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

  1   2   >