[jira] [Commented] (FLINK-3332) Provide an exactly-once Cassandra connector

[ https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150083#comment-15150083 ] ASF GitHub Bot commented on FLINK-3332: --- Github user zentol commented on the pull re

[jira] [Closed] (FLINK-3308) [py] Remove debug mode

[ https://issues.apache.org/jira/browse/FLINK-3308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-3308. --- Resolution: Fixed Resolved in 401837bdfce40b2401aaf19586a8ae3612c08d8b > [py] Remove debug mo

[jira] [Commented] (FLINK-3309) [py] Resolve maven warnings

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

[jira] [Created] (FLINK-3423) ExternalProcessRunnerTest fails on Windows

Chesnay Schepler created FLINK-3423: --- Summary: ExternalProcessRunnerTest fails on Windows Key: FLINK-3423 URL: https://issues.apache.org/jira/browse/FLINK-3423 Project: Flink Issue Type: Bu

[jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150166#comment-15150166 ] Maximilian Michels commented on FLINK-1502: --- Hi [~eastcirclek]! In addition to w

[jira] [Commented] (FLINK-1159) Case style anonymous functions not supported by Scala API

[ https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150174#comment-15150174 ] Stefano Baghino commented on FLINK-1159: If that's ok with [~aljoscha] I would ass

[jira] [Commented] (FLINK-3420) Remove "ReadTextFileWithValue" from StreamExecutionEnvironment

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

[jira] [Commented] (FLINK-3420) Remove "ReadTextFileWithValue" from StreamExecutionEnvironment

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

[jira] [Commented] (FLINK-3379) Refactor TimestampExtractor

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

[jira] [Resolved] (FLINK-3420) Remove "ReadTextFileWithValue" from StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-3420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3420. - Resolution: Fixed Fixed via ebab47077f9a5a545a5e897f76936d715b0f0ce9 > Remove "ReadTextFileWithVa

[jira] [Assigned] (FLINK-3420) Remove "ReadTextFileWithValue" from StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-3420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-3420: --- Assignee: Stephan Ewen > Remove "ReadTextFileWithValue" from StreamExecutionEnvironment > ---

[jira] [Closed] (FLINK-3420) Remove "ReadTextFileWithValue" from StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-3420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3420. --- > Remove "ReadTextFileWithValue" from StreamExecutionEnvironment > ---

[jira] [Created] (FLINK-3424) FileStateBackendtest.testStateOutputStream fails on windows

Chesnay Schepler created FLINK-3424: --- Summary: FileStateBackendtest.testStateOutputStream fails on windows Key: FLINK-3424 URL: https://issues.apache.org/jira/browse/FLINK-3424 Project: Flink

[jira] [Created] (FLINK-3425) DataSinkTaskTest.Failing[Sorting]DataSinkTask fails on Windows

Chesnay Schepler created FLINK-3425: --- Summary: DataSinkTaskTest.Failing[Sorting]DataSinkTask fails on Windows Key: FLINK-3425 URL: https://issues.apache.org/jira/browse/FLINK-3425 Project: Flink

[jira] [Created] (FLINK-3426) JobManagerLeader[Re]ElectionTest.testleaderElection fails on Windows

Chesnay Schepler created FLINK-3426: --- Summary: JobManagerLeader[Re]ElectionTest.testleaderElection fails on Windows Key: FLINK-3426 URL: https://issues.apache.org/jira/browse/FLINK-3426 Project: Fli

[jira] [Commented] (FLINK-1159) Case style anonymous functions not supported by Scala API

[ https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150198#comment-15150198 ] Stephan Ewen commented on FLINK-1159: - Sure, I'll assign the issue you. As far as I kn

[jira] [Assigned] (FLINK-3424) FileStateBackendtest.testStateOutputStream fails on windows

[ https://issues.apache.org/jira/browse/FLINK-3424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-3424: --- Assignee: Chesnay Schepler > FileStateBackendtest.testStateOutputStream fails on wind

[jira] [Assigned] (FLINK-3425) DataSinkTaskTest.Failing[Sorting]DataSinkTask fails on Windows

[ https://issues.apache.org/jira/browse/FLINK-3425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-3425: --- Assignee: Chesnay Schepler > DataSinkTaskTest.Failing[Sorting]DataSinkTask fails on W

[jira] [Updated] (FLINK-1159) Case style anonymous functions not supported by Scala API

[ https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-1159: Assignee: Stefano Baghino (was: Aljoscha Krettek) > Case style anonymous functions not supported by

[jira] [Assigned] (FLINK-3426) JobManagerLeader[Re]ElectionTest.testleaderElection fails on Windows

[ https://issues.apache.org/jira/browse/FLINK-3426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-3426: --- Assignee: Chesnay Schepler > JobManagerLeader[Re]ElectionTest.testleaderElection fail

[jira] [Commented] (FLINK-3426) JobManagerLeader[Re]ElectionTest.testleaderElection fails on Windows

[ https://issues.apache.org/jira/browse/FLINK-3426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150201#comment-15150201 ] Stephan Ewen commented on FLINK-3426: - I general, it is always good to create file URI

[jira] [Updated] (FLINK-3423) ExternalProcessRunnerTest fails on Windows

[ https://issues.apache.org/jira/browse/FLINK-3423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-3423: Description: Tests run: 4, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 5.853 sec <<<

[jira] [Commented] (FLINK-3423) ExternalProcessRunnerTest fails on Windows

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

[jira] [Commented] (FLINK-1159) Case style anonymous functions not supported by Scala API

[ https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150214#comment-15150214 ] Aljoscha Krettek commented on FLINK-1159: - Assigned it to you. > Case style anony

[jira] [Commented] (FLINK-3426) JobManagerLeader[Re]ElectionTest.testleaderElection fails on Windows

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

[jira] [Commented] (FLINK-3419) Drop partitionByHash from DataStream

[ https://issues.apache.org/jira/browse/FLINK-3419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150217#comment-15150217 ] Stephan Ewen commented on FLINK-3419: - You can simply swap the {{partitionByHash}} cal

[jira] [Resolved] (FLINK-3243) Fix Interplay of TimeCharacteristic and Time Windows

[ https://issues.apache.org/jira/browse/FLINK-3243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3243. - Resolution: Fixed Fix Version/s: 1.0.0 Fixed in https://github.com/apache/flink/co

[jira] [Commented] (FLINK-3422) Scramble HashPartitioner hashes

[ https://issues.apache.org/jira/browse/FLINK-3422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150221#comment-15150221 ] Stephan Ewen commented on FLINK-3422: - True enough, but all the more reason to fix tha

[jira] [Commented] (FLINK-2922) Add Queryable Window Operator

[ https://issues.apache.org/jira/browse/FLINK-2922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150222#comment-15150222 ] Aljoscha Krettek commented on FLINK-2922: - [~uce] this can be closed because you w

[jira] [Resolved] (FLINK-3200) Use Partitioned State Abstraction in WindowOperator

[ https://issues.apache.org/jira/browse/FLINK-3200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3200. - Resolution: Fixed Fix Version/s: 1.0.0 > Use Partitioned State Abstraction in Windo

[jira] [Resolved] (FLINK-3402) Refactor Common Parts of Stream/Batch Documentation

[ https://issues.apache.org/jira/browse/FLINK-3402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3402. - Resolution: Fixed Fix Version/s: 1.0.0 Done in https://github.com/apache/flink/com

[jira] [Commented] (FLINK-3243) Fix Interplay of TimeCharacteristic and Time Windows

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

[jira] [Commented] (FLINK-3243) Fix Interplay of TimeCharacteristic and Time Windows

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

[jira] [Assigned] (FLINK-3418) RocksDB HDFSCopyFromLocal util doesn't respect our Hadoop security configuration

[ https://issues.apache.org/jira/browse/FLINK-3418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-3418: --- Assignee: Aljoscha Krettek > RocksDB HDFSCopyFromLocal util doesn't respect our Hadoo

[jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150239#comment-15150239 ] Stephan Ewen commented on FLINK-1502: - I agree with [~mxm], not all metrics should go

[jira] [Commented] (FLINK-3425) DataSinkTaskTest.Failing[Sorting]DataSinkTask fails on Windows

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

[jira] [Reopened] (FLINK-3386) Kafka consumers should not necessarily fail on expiring data

[ https://issues.apache.org/jira/browse/FLINK-3386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-3386: --- Assignee: Robert Metzger I agree with Stephan. Its not really a duplicate. I'm reopening the

[jira] [Commented] (FLINK-3412) Remove implicit conversions JavaStream / ScalaStream

[ https://issues.apache.org/jira/browse/FLINK-3412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150270#comment-15150270 ] Stephan Ewen commented on FLINK-3412: - I actually already did this as part of some cod

[jira] [Updated] (FLINK-3386) Kafka consumers are not properly respecting the "auto.offset.reset" behavior

[ https://issues.apache.org/jira/browse/FLINK-3386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3386: -- Summary: Kafka consumers are not properly respecting the "auto.offset.reset" behavior (was: Kaf

[jira] [Commented] (FLINK-3424) FileStateBackendtest.testStateOutputStream fails on windows

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

[jira] [Commented] (FLINK-3424) FileStateBackendtest.testStateOutputStream fails on windows

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

[jira] [Commented] (FLINK-3425) DataSinkTaskTest.Failing[Sorting]DataSinkTask fails on Windows

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

[jira] [Commented] (FLINK-3423) ExternalProcessRunnerTest fails on Windows

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

[jira] [Commented] (FLINK-3309) [py] Resolve maven warnings

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

[jira] [Commented] (FLINK-3426) JobManagerLeader[Re]ElectionTest.testleaderElection fails on Windows

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

[jira] [Commented] (FLINK-3332) Provide an exactly-once Cassandra connector

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

[jira] [Created] (FLINK-3427) Add watermark monitoring to JobManager web frontend

Robert Metzger created FLINK-3427: - Summary: Add watermark monitoring to JobManager web frontend Key: FLINK-3427 URL: https://issues.apache.org/jira/browse/FLINK-3427 Project: Flink Issue Typ

[jira] [Commented] (FLINK-3426) JobManagerLeader[Re]ElectionTest.testleaderElection fails on Windows

[ https://issues.apache.org/jira/browse/FLINK-3426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150301#comment-15150301 ] ASF GitHub Bot commented on FLINK-3426: --- Github user zentol commented on the pull re

[jira] [Created] (FLINK-3428) Add fixed time trailing timestamp/watermark extractor

Robert Metzger created FLINK-3428: - Summary: Add fixed time trailing timestamp/watermark extractor Key: FLINK-3428 URL: https://issues.apache.org/jira/browse/FLINK-3428 Project: Flink Issue T

[jira] [Created] (FLINK-3429) Add histogram-based timestamp/watermark extractor

Robert Metzger created FLINK-3429: - Summary: Add histogram-based timestamp/watermark extractor Key: FLINK-3429 URL: https://issues.apache.org/jira/browse/FLINK-3429 Project: Flink Issue Type:

[jira] [Created] (FLINK-3430) Remove "no POJO" warning in TypeAnalyzer

Aljoscha Krettek created FLINK-3430: --- Summary: Remove "no POJO" warning in TypeAnalyzer Key: FLINK-3430 URL: https://issues.apache.org/jira/browse/FLINK-3430 Project: Flink Issue Type: Impr

[jira] [Commented] (FLINK-3430) Remove "no POJO" warning in TypeAnalyzer

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

[jira] [Updated] (FLINK-3418) RocksDB HDFSCopyFromLocal util doesn't respect our Hadoop security configuration

[ https://issues.apache.org/jira/browse/FLINK-3418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3418: Priority: Blocker (was: Critical) > RocksDB HDFSCopyFromLocal util doesn't respect our Hado

[jira] [Commented] (FLINK-3425) DataSinkTaskTest.Failing[Sorting]DataSinkTask fails on Windows

[ https://issues.apache.org/jira/browse/FLINK-3425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150320#comment-15150320 ] ASF GitHub Bot commented on FLINK-3425: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-3425) DataSinkTaskTest.Failing[Sorting]DataSinkTask fails on Windows

[ https://issues.apache.org/jira/browse/FLINK-3425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150323#comment-15150323 ] ASF GitHub Bot commented on FLINK-3425: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-3379) Refactor TimestampExtractor

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

[jira] [Commented] (FLINK-3309) [py] Resolve maven warnings

[ https://issues.apache.org/jira/browse/FLINK-3309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150330#comment-15150330 ] ASF GitHub Bot commented on FLINK-3309: --- Github user chiwanpark commented on a diff

[jira] [Closed] (FLINK-3415) TimestampExctractor accepts negative watermarks

[ https://issues.apache.org/jira/browse/FLINK-3415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3415. --- > TimestampExctractor accepts negative watermarks > > >

[jira] [Resolved] (FLINK-3401) AscendingTimestampExtractor should not fail on order violation

[ https://issues.apache.org/jira/browse/FLINK-3401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3401. - Resolution: Fixed Fixed via e08d7a6f30f8e3b845ff33d4266fbd4fad4bec63 > AscendingTimestampExtracto

[jira] [Resolved] (FLINK-3415) TimestampExctractor accepts negative watermarks

[ https://issues.apache.org/jira/browse/FLINK-3415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3415. - Resolution: Fixed Fixed via 74c2b80bc29bb0e2c0c2508da4b3f0bb58e2bd38 > TimestampExctractor accept

[jira] [Closed] (FLINK-3401) AscendingTimestampExtractor should not fail on order violation

[ https://issues.apache.org/jira/browse/FLINK-3401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3401. --- > AscendingTimestampExtractor should not fail on order violation > ---

[jira] [Closed] (FLINK-3379) Refactor TimestampExtractor

[ https://issues.apache.org/jira/browse/FLINK-3379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3379. --- > Refactor TimestampExtractor > --- > > Key: FLINK-3379 >

[jira] [Resolved] (FLINK-3379) Refactor TimestampExtractor

[ https://issues.apache.org/jira/browse/FLINK-3379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3379. - Resolution: Fixed Fixed via 74c2b80bc29bb0e2c0c2508da4b3f0bb58e2bd38 > Refactor TimestampExtracto

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

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

[jira] [Commented] (FLINK-3309) [py] Resolve maven warnings

[ https://issues.apache.org/jira/browse/FLINK-3309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150341#comment-15150341 ] ASF GitHub Bot commented on FLINK-3309: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

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

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

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

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

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

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

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

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

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

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

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

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

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

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

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

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

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

[jira] [Commented] (FLINK-3396) Job submission Savepoint restore logic flawed

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

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

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

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

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

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

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

[jira] [Commented] (FLINK-3396) Job submission Savepoint restore logic flawed

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

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

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

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

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

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

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

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

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

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

[ https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150391#comment-15150391 ] ASF GitHub Bot commented on FLINK-3179: --- Github user fhueske commented on the pull r

[jira] [Commented] (FLINK-1989) Sorting of POJO data set from TableEnv yields NotSerializableException

[ https://issues.apache.org/jira/browse/FLINK-1989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150408#comment-15150408 ] Aljoscha Krettek commented on FLINK-1989: - [~fhueske] what's the state of this wit

[jira] [Commented] (FLINK-2737) KeyedDataStream should not be a subclass of DataStream

[ https://issues.apache.org/jira/browse/FLINK-2737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150409#comment-15150409 ] Aljoscha Krettek commented on FLINK-2737: - [~StephanEwen] Do we wan't to fix this

[jira] [Created] (FLINK-3431) Add retrying logic for RocksDB snapshots

Gyula Fora created FLINK-3431: - Summary: Add retrying logic for RocksDB snapshots Key: FLINK-3431 URL: https://issues.apache.org/jira/browse/FLINK-3431 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-3431) Add retrying logic for RocksDB snapshots

[ https://issues.apache.org/jira/browse/FLINK-3431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150419#comment-15150419 ] Aljoscha Krettek commented on FLINK-3431: - We could also not fail on checkpoint re

[jira] [Commented] (FLINK-3431) Add retrying logic for RocksDB snapshots

[ https://issues.apache.org/jira/browse/FLINK-3431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150442#comment-15150442 ] Gyula Fora commented on FLINK-3431: --- I think we should do that too, but we should still

[jira] [Created] (FLINK-3432) ZookeeperOffsetHandlerTest fails on windows

Chesnay Schepler created FLINK-3432: --- Summary: ZookeeperOffsetHandlerTest fails on windows Key: FLINK-3432 URL: https://issues.apache.org/jira/browse/FLINK-3432 Project: Flink Issue Type: B

[jira] [Commented] (FLINK-1989) Sorting of POJO data set from TableEnv yields NotSerializableException

[ https://issues.apache.org/jira/browse/FLINK-1989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150463#comment-15150463 ] Fabian Hueske commented on FLINK-1989: -- This will work, in fact it is already working

[jira] [Commented] (FLINK-3315) Fix Slot Sharing in Streaming API

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

[jira] [Commented] (FLINK-3430) Remove "no POJO" warning in TypeAnalyzer

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

[jira] [Commented] (FLINK-3332) Provide an exactly-once Cassandra connector

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

[jira] [Commented] (FLINK-3401) AscendingTimestampExtractor should not fail on order violation

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

[jira] [Commented] (FLINK-3332) Provide an exactly-once Cassandra connector

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

[jira] [Commented] (FLINK-3401) AscendingTimestampExtractor should not fail on order violation

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

[jira] [Commented] (FLINK-3299) Remove ApplicationID from Environment

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

[jira] [Commented] (FLINK-2021) Rework examples to use ParameterTool

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

[jira] [Commented] (FLINK-3375) Allow Watermark Generation in the Kafka Source

[ https://issues.apache.org/jira/browse/FLINK-3375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15150487#comment-15150487 ] Stephan Ewen commented on FLINK-3375: - Sounds good all in all. I would like to target

  1   2   3   >