[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=15317860#comment-15317860 ] Tzu-Li (Gordon) Tai commented on FLINK-3923: I'm wondering whether or not it might be a better

[jira] [Commented] (FLINK-2985) Allow different field names for unionAll() in Table API

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

[GitHub] flink issue #2078: [FLINK-2985] Allow different field names for unionAll() i...

Github user gallenvara commented on the issue: https://github.com/apache/flink/pull/2078 @twalthr @fhueske can you help with reviewing this PR? 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

[jira] [Comment Edited] (FLINK-2985) Allow different field names for unionAll() in Table API

[ https://issues.apache.org/jira/browse/FLINK-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15317673#comment-15317673 ] GaoLun edited comment on FLINK-2985 at 6/7/16 2:12 AM: --- The refactoring work has

[jira] [Commented] (FLINK-2985) Allow different field names for unionAll() in Table API

[ https://issues.apache.org/jira/browse/FLINK-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15317673#comment-15317673 ] GaoLun commented on FLINK-2985: --- The refactoring work has been finished and i will go on with this issue. :)

[jira] [Commented] (FLINK-2985) Allow different field names for unionAll() in Table API

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

[GitHub] flink pull request #2078: [FLINK-2985] Allow different field names for union...

GitHub user gallenvara opened a pull request: https://github.com/apache/flink/pull/2078 [FLINK-2985] Allow different field names for unionAll() in Table API Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

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

Github user chiwanpark commented on the issue: https://github.com/apache/flink/pull/2076 Failing Travis is not related to this PR. Looks good to me! --- 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

[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=15317663#comment-15317663 ] ASF GitHub Bot commented on FLINK-2832: --- Github user chiwanpark commented on the issue:

[GitHub] flink pull request #2074: [FLINK-2985] [Table API] Allow different field nam...

Github user gallenvara closed the pull request at: https://github.com/apache/flink/pull/2074 --- 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

[jira] [Commented] (FLINK-2985) Allow different field names for unionAll() in Table API

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

[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=15317661#comment-15317661 ] ASF GitHub Bot commented on FLINK-2832: --- Github user chiwanpark commented on a diff in the pull

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

Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/2076#discussion_r6588 --- Diff: flink-java/src/test/resources/logback-test.xml --- @@ -0,0 +1,34 @@ + + + + + +%d{HH:mm:ss.SSS}

[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=15317662#comment-15317662 ] ASF GitHub Bot commented on FLINK-2832: --- Github user chiwanpark commented on a diff in the pull

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

Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/2076#discussion_r6573 --- Diff: flink-java/src/test/resources/log4j-test.properties --- @@ -0,0 +1,27 @@ +# +# Licensed to the Apache Software Foundation (ASF) under one

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

Github user mans2singh commented on the issue: https://github.com/apache/flink/pull/2031 Hey @rmetzger, @StephanEwen, Flink Folks: Just wanted to let you know that the rethinkdb java driver that I used for Flink integration is available under Apache License 2.0

[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=15317469#comment-15317469 ] ASF GitHub Bot commented on FLINK-3967: --- Github user mans2singh commented on the issue:

[jira] [Created] (FLINK-4027) FlinkKafkaProducer09 sink can lose messages

Elias Levy created FLINK-4027: - Summary: FlinkKafkaProducer09 sink can lose messages Key: FLINK-4027 URL: https://issues.apache.org/jira/browse/FLINK-4027 Project: Flink Issue Type: Bug

[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=15317087#comment-15317087 ] ASF GitHub Bot commented on FLINK-4002: --- Github user omaralvarez commented on the issue:

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

Github user omaralvarez commented on the issue: https://github.com/apache/flink/pull/2063 Yes, I had the same thought looking at the code, I could not figure out why it worked with HDFS... --- If your project is set up for it, you can reply to this email and have your reply appear

[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=15317078#comment-15317078 ] ASF GitHub Bot commented on FLINK-4002: --- Github user zentol commented on the issue:

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

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2063 looking at the code right now; i may have figured out why the files aren't copied, but i find it odd that it supposedly works with hdfs. it actually should never copy additional files if no

[jira] [Updated] (FLINK-3753) KillerWatchDog should not use kill on toKill thread

[ https://issues.apache.org/jira/browse/FLINK-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3753: -- Description: {code} // this is harsh, but this watchdog is a last resort if (toKill.isAlive()) {

[jira] [Updated] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState()

[ https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3734: -- Description: {code} DataInputView in = inputState.getState(getUserCodeClassloader()); final long

[jira] [Updated] (FLINK-3801) Upgrade Joda-Time library to 2.9.3

[ https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3801: -- Description: Currently yoda-time 2.5 is used which was very old. We should upgrade to 2.9.3 was: Currently

[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=15317071#comment-15317071 ] Chesnay Schepler commented on FLINK-4024: - it also starts the function regardless of whether

[jira] [Updated] (FLINK-3998) Access to gauges and counters in StatsDReporter#report() is not properly synchronized

[ https://issues.apache.org/jira/browse/FLINK-3998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3998: -- Description: {code} for (Map.Entry entry : gauges.entrySet()) {

[jira] [Updated] (FLINK-3958) Access to MetricRegistry doesn't have proper synchronization in some classes

[ https://issues.apache.org/jira/browse/FLINK-3958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3958: -- Description: In GraphiteReporter#getReporter(): {code} com.codahale.metrics.graphite.GraphiteReporter.Builder

[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=15317064#comment-15317064 ] Fabian Hueske commented on FLINK-4024: -- It appears that {{FileSourceFunction}} doesn't call

[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=15317053#comment-15317053 ] ASF GitHub Bot commented on FLINK-4002: --- Github user zentol commented on the issue:

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

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2063 you can add it to this PR as a separate commit. --- 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-4016) FoldApplyWindowFunction is not properly initialized

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

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

Github user rvdwenden commented on the issue: https://github.com/apache/flink/pull/2070 I checked in this change with this commit comment: [FLINK-3977] initialize FoldApplyWindowFunction properly Hopefully that’s enough, however, on Travis CI I see that on my commit,

[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 can confirm that there is a bug in `PythonPlanBinder.java`. When you pass packages to the `runPlan()` function, they are not copied to the temp directory in which `plan.py` file is generated.

[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=15317000#comment-15317000 ] ASF GitHub Bot commented on FLINK-4002: --- Github user omaralvarez commented on the issue:

[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=15316643#comment-15316643 ] ASF GitHub Bot commented on FLINK-4026: --- GitHub user dyanarose opened a pull request:

[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=15316599#comment-15316599 ] Chesnay Schepler commented on FLINK-3777: - small addition: there's some work being done regarding

[jira] [Issue Comment Deleted] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange

[ https://issues.apache.org/jira/browse/FLINK-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Subhankar Biswas updated FLINK-3769: Comment: was deleted (was: IMO user should be able to build different configuration for

[jira] [Issue Comment Deleted] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange

[ https://issues.apache.org/jira/browse/FLINK-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Subhankar Biswas updated FLINK-3769: Comment: was deleted (was: IMO user should be able to build different configuration for

[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=15316665#comment-15316665 ] Dyana Rose commented on FLINK-4026: --- oh the indignity, I fixed my own misspellings in the PR message,

[jira] [Updated] (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 ] Dyana Rose updated FLINK-4026: -- Description: The streaming API section of the documentation has issues with grammar that make it hard

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

GitHub user dyanarose opened a pull request: https://github.com/apache/flink/pull/2077 [FLINK-4026] Fix code, grammar, and link issues in the Streaming documentation * fixing grammar issues with he streaming API section of the documentation that make it hard to follow in places.

[jira] [Commented] (FLINK-2733) ZooKeeperLeaderElectionTest.testZooKeeperReelection fails

[ https://issues.apache.org/jira/browse/FLINK-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15316636#comment-15316636 ] Till Rohrmann commented on FLINK-2733: -- The problem seems to be a connection loss to the

[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=15316631#comment-15316631 ] Dyana Rose commented on FLINK-4026: --- I've a branch for this that I'll PR shortly > Fix code, grammar,

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

Dyana Rose created FLINK-4026: - Summary: Fix code, grammar, and link issues in the Streaming documentation Key: FLINK-4026 URL: https://issues.apache.org/jira/browse/FLINK-4026 Project: Flink

[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=15316571#comment-15316571 ] Dominik Bruhn commented on FLINK-4025: -- No, actually they address different problems although one

[jira] [Commented] (FLINK-2733) ZooKeeperLeaderElectionTest.testZooKeeperReelection fails

[ https://issues.apache.org/jira/browse/FLINK-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15316557#comment-15316557 ] Till Rohrmann commented on FLINK-2733: -- Another instance:

[jira] [Assigned] (FLINK-2733) ZooKeeperLeaderElectionTest.testZooKeeperReelection fails

[ https://issues.apache.org/jira/browse/FLINK-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-2733: Assignee: Till Rohrmann > ZooKeeperLeaderElectionTest.testZooKeeperReelection fails >

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

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2076 [FLINK-2832] [tests] Hardens RandomSamplerTest Increase the level of significance from p=0.01 to p=0.001 and add retry annotations to random sampler tests. This should decrease the

[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=15316541#comment-15316541 ] ASF GitHub Bot commented on FLINK-2832: --- GitHub user tillrohrmann opened a pull request:

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

[ https://issues.apache.org/jira/browse/FLINK-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-2832: Assignee: Till Rohrmann > Failing test:

[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=15316536#comment-15316536 ] Till Rohrmann commented on FLINK-2832: -- Here is another instance of the failure (this time the

[GitHub] flink pull request #2020: [FLINK-2314] Make Streaming File Sources Persisten...

GitHub user kl0u reopened a pull request: https://github.com/apache/flink/pull/2020 [FLINK-2314] Make Streaming File Sources Persistent This PR solves FLINK-2314 and combines a number of sub-tasks. In addition, it solves FLINK-3896 which was introduced as part of this task.

[jira] [Commented] (FLINK-2314) Make Streaming File Sources Persistent

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

[GitHub] flink pull request #2020: [FLINK-2314] Make Streaming File Sources Persisten...

Github user kl0u closed the pull request at: https://github.com/apache/flink/pull/2020 --- 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

[jira] [Commented] (FLINK-2314) Make Streaming File Sources Persistent

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

[jira] [Resolved] (FLINK-3960) Disable, fix and re-enable EventTimeWindowCheckpointingITCase

[ https://issues.apache.org/jira/browse/FLINK-3960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3960. - Resolution: Fixed Reverted in

[jira] [Resolved] (FLINK-3948) EventTimeWindowCheckpointingITCase Fails with Core Dump

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

[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=15316384#comment-15316384 ] Robert Metzger commented on FLINK-4025: --- I guess this issue is subsumed by / duplicated by

[jira] [Comment Edited] (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=15316384#comment-15316384 ] Robert Metzger edited comment on FLINK-4025 at 6/6/16 11:51 AM: I guess

[GitHub] flink issue #1856: FLINK-3650 Add maxBy/minBy to Scala DataSet API

Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/1856 @zentol , @tillrohrmann , @fhueske Any chance of review here. Sorry for regular reminders :) --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

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

[GitHub] flink pull request #2066: Updated ssh configuration in base Dockerfile

Github user techmaniack commented on a diff in the pull request: https://github.com/apache/flink/pull/2066#discussion_r65873361 --- Diff: flink-contrib/docker-flink/base/Dockerfile --- @@ -38,12 +38,12 @@ ENV JAVA_HOME /usr/java/default/ RUN echo 'root:secret' | chpasswd

[GitHub] flink issue #2074: [FLINK-2985] [Table API] Allow different field names for ...

Github user gallenvara commented on the issue: https://github.com/apache/flink/pull/2074 @twalthr @fhueske Can you help with review work? 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

[GitHub] flink pull request #2074: [FLINK-2985] [Table API] Allow different field nam...

GitHub user gallenvara opened a pull request: https://github.com/apache/flink/pull/2074 [FLINK-2985] [Table API] Allow different field names for unionAll() in Table API. Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check

[jira] [Issue Comment Deleted] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange

[ https://issues.apache.org/jira/browse/FLINK-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Subhankar Biswas updated FLINK-3769: Comment: was deleted (was: IMO user should be able to build different configuration for

[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=15316320#comment-15316320 ] Flavio Pompermaier commented on FLINK-3777: --- Hi Stephan, we decided to introduce the

[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=15316318#comment-15316318 ] Flavio Pompermaier commented on FLINK-3777: --- Hi Stephan, we decided to introduce the

[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=15316302#comment-15316302 ] Chesnay Schepler commented on FLINK-3777: - these methods allow sharing resources across splits.

[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=15316289#comment-15316289 ] 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, I wrote in the issue that you opened. This is a duplicate of https://issues.apache.org/jira/browse/FLINK-3977 and the way to fix it is to make `InternalWindowFunction` properly forward

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

[ https://issues.apache.org/jira/browse/FLINK-4016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-4016. --- Resolution: Duplicate This is a duplicate of FLINK-3977. > FoldApplyWindowFunction is not

[GitHub] flink pull request #2072: [FLINK-3948] Protect RocksDB cleanup by cleanup lo...

Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/2072 --- 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

[jira] [Commented] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange

[ https://issues.apache.org/jira/browse/FLINK-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15316252#comment-15316252 ] Subhankar Biswas commented on FLINK-3769: - IMO user should be able to build different

[jira] [Commented] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange

[ https://issues.apache.org/jira/browse/FLINK-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15316250#comment-15316250 ] Subhankar Biswas commented on FLINK-3769: - IMO user should be able to build different

[jira] [Commented] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange

[ https://issues.apache.org/jira/browse/FLINK-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15316242#comment-15316242 ] Subhankar Biswas commented on FLINK-3769: - IMO user should be able to build different

[jira] [Commented] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange

[ https://issues.apache.org/jira/browse/FLINK-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15316243#comment-15316243 ] Subhankar Biswas commented on FLINK-3769: - IMO user should be able to build different

[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=15316231#comment-15316231 ] ASF GitHub Bot commented on FLINK-4002: --- Github user omaralvarez commented on the issue:

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

Github user omaralvarez commented on the issue: https://github.com/apache/flink/pull/2063 Yes, I know that how python scripts are executed for the test is different. Let me elaborate: Since running the tests are quite costly in my laptop, I normally test my changes executing