[jira] [Commented] (FLINK-11835) ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLeaderChange failed

[ https://issues.apache.org/jira/browse/FLINK-11835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16839359#comment-16839359 ] Florian Schmidt commented on FLINK-11835: - After running it ~800 times I was abl

[jira] [Updated] (FLINK-11835) ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLeaderChange failed

[ https://issues.apache.org/jira/browse/FLINK-11835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-11835: Attachment: scratch_22.txt > ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLe

[jira] [Updated] (FLINK-12503) Improve the exceptions [Need Proper Errors]

[ https://issues.apache.org/jira/browse/FLINK-12503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-12503: Component/s: Runtime / Web Frontend > Improve the exceptions [Need Proper Errors] > --

[jira] [Updated] (FLINK-12504) NullPoint here NullPointException there.. It's every where

[ https://issues.apache.org/jira/browse/FLINK-12504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-12504: Component/s: API / DataStream > NullPoint here NullPointException there.. It's every where

[jira] [Assigned] (FLINK-11835) ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLeaderChange failed

[ https://issues.apache.org/jira/browse/FLINK-11835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-11835: --- Assignee: Florian Schmidt > ZooKeeperLeaderElectionITCase#testJobExecutionOnCluster

[jira] [Commented] (FLINK-10519) flink-parent:1.6.1 artifact can't be found on maven central

[ https://issues.apache.org/jira/browse/FLINK-10519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16653180#comment-16653180 ] Florian Schmidt commented on FLINK-10519: - From https://issues.sonatype.org/brow

[jira] [Comment Edited] (FLINK-10519) flink-parent:1.6.1 artifact can't be found on maven central

[ https://issues.apache.org/jira/browse/FLINK-10519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651714#comment-16651714 ] Florian Schmidt edited comment on FLINK-10519 at 10/16/18 1:58 PM: ---

[jira] [Updated] (FLINK-10521) Faulty Histogram stops Prometheus metrics from being reported

[ https://issues.apache.org/jira/browse/FLINK-10521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-10521: Description: In my setup I am using the prometheus reporter and a custom implemented hist

[jira] [Commented] (FLINK-10519) flink-parent:1.6.1 artifact can't be found on maven central

[ https://issues.apache.org/jira/browse/FLINK-10519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651714#comment-16651714 ] Florian Schmidt commented on FLINK-10519: - INFRA says they are responsible for h

[jira] [Comment Edited] (FLINK-10519) flink-parent:1.6.1 artifact can't be found on maven central

[ https://issues.apache.org/jira/browse/FLINK-10519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16650170#comment-16650170 ] Florian Schmidt edited comment on FLINK-10519 at 10/15/18 1:11 PM: ---

[jira] [Comment Edited] (FLINK-10519) flink-parent:1.6.1 artifact can't be found on maven central

[ https://issues.apache.org/jira/browse/FLINK-10519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16650170#comment-16650170 ] Florian Schmidt edited comment on FLINK-10519 at 10/15/18 1:11 PM: ---

[jira] [Comment Edited] (FLINK-10519) flink-parent:1.6.1 artifact can't be found on maven central

[ https://issues.apache.org/jira/browse/FLINK-10519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16650170#comment-16650170 ] Florian Schmidt edited comment on FLINK-10519 at 10/15/18 1:06 PM: ---

[jira] [Assigned] (FLINK-10519) flink-parent:1.6.1 artifact can't be found on maven central

[ https://issues.apache.org/jira/browse/FLINK-10519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-10519: --- Assignee: Florian Schmidt > flink-parent:1.6.1 artifact can't be found on maven cen

[jira] [Commented] (FLINK-10519) flink-parent:1.6.1 artifact can't be found on maven central

[ https://issues.apache.org/jira/browse/FLINK-10519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16650170#comment-16650170 ] Florian Schmidt commented on FLINK-10519: - I cross-posted this to https://issues

[jira] [Commented] (FLINK-10521) TaskManager metrics are not reported to prometheus after running a job

[ https://issues.apache.org/jira/browse/FLINK-10521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16646157#comment-16646157 ] Florian Schmidt commented on FLINK-10521: - [~till.rohrmann] I attached the debug

[jira] [Updated] (FLINK-10521) TaskManager metrics are not reported to prometheus after running a job

[ https://issues.apache.org/jira/browse/FLINK-10521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-10521: Attachment: taskmanager.log prometheus.log > TaskManager metrics are not r

[jira] [Updated] (FLINK-10521) TaskManager metrics are not reported to prometheus after running a job

[ https://issues.apache.org/jira/browse/FLINK-10521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-10521: Priority: Minor (was: Major) > TaskManager metrics are not reported to prometheus after r

[jira] [Updated] (FLINK-10521) TaskManager metrics are not reported to prometheus after running a job

[ https://issues.apache.org/jira/browse/FLINK-10521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-10521: Description: Update: This only seems to happen when my custom (admittedly poorly implemen

[jira] [Updated] (FLINK-10521) TaskManager metrics are not reported to prometheus after running a job

[ https://issues.apache.org/jira/browse/FLINK-10521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-10521: Attachment: (was: Screenshot 2018-10-10 at 11.16.22.png) > TaskManager metrics are not

[jira] [Updated] (FLINK-10521) TaskManager metrics are not reported to prometheus after running a job

[ https://issues.apache.org/jira/browse/FLINK-10521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-10521: Description:   I'm using prometheus to collect the metrics from Flink, and I noticed that

[jira] [Updated] (FLINK-10521) TaskManager metrics are not reported to prometheus after running a job

[ https://issues.apache.org/jira/browse/FLINK-10521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-10521: Attachment: Screenshot 2018-10-10 at 11.32.59.png > TaskManager metrics are not reported t

[jira] [Created] (FLINK-10521) TaskManager metrics are not reported to prometheus after running a job

Florian Schmidt created FLINK-10521: --- Summary: TaskManager metrics are not reported to prometheus after running a job Key: FLINK-10521 URL: https://issues.apache.org/jira/browse/FLINK-10521 Project:

[jira] [Updated] (FLINK-10521) TaskManager metrics are not reported to prometheus after running a job

[ https://issues.apache.org/jira/browse/FLINK-10521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-10521: Description:   I'm using prometheus to collect the metrics from Flink, and I noticed that

[jira] [Updated] (FLINK-10519) flink-parent:1.6.1 artifact can't be found on maven central

[ https://issues.apache.org/jira/browse/FLINK-10519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-10519: Description: The flink-parent:1.6.1 artifact can't be found on maven central: *Stacktrace

[jira] [Created] (FLINK-10519) flink-parent:1.6.1 artifact can't be found on maven central

Florian Schmidt created FLINK-10519: --- Summary: flink-parent:1.6.1 artifact can't be found on maven central Key: FLINK-10519 URL: https://issues.apache.org/jira/browse/FLINK-10519 Project: Flink

[jira] [Updated] (FLINK-8482) Implement and expose option to use min / max / left / right timestamp for joined streamrecords

[ https://issues.apache.org/jira/browse/FLINK-8482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-8482: --- Fix Version/s: 1.7.0 > Implement and expose option to use min / max / left / right timestamp

[jira] [Updated] (FLINK-8483) Implement and expose outer joins

[ https://issues.apache.org/jira/browse/FLINK-8483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-8483: --- Fix Version/s: 1.7.0 > Implement and expose outer joins > >

[jira] [Assigned] (FLINK-8483) Implement and expose outer joins

[ https://issues.apache.org/jira/browse/FLINK-8483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-8483: -- Assignee: Florian Schmidt > Implement and expose outer joins > ---

[jira] [Updated] (FLINK-8482) Implement and expose option to use min / max / left / right timestamp for joined streamrecords

[ https://issues.apache.org/jira/browse/FLINK-8482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-8482: --- Description: The idea: Expose the option of which timestamp to use for the result of a join.

[jira] [Updated] (FLINK-8482) Implement and expose option to use min / max / left / right timestamp for joined streamrecords

[ https://issues.apache.org/jira/browse/FLINK-8482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-8482: --- Description: The idea: Expose the option of which timestamp to use for the result of a join.

[jira] [Assigned] (FLINK-8482) Implement and expose option to use min / max / left / right timestamp for joined streamrecords

[ https://issues.apache.org/jira/browse/FLINK-8482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-8482: -- Assignee: Florian Schmidt > Implement and expose option to use min / max / left / righ

[jira] [Created] (FLINK-10080) Add support for processing time to interval join

Florian Schmidt created FLINK-10080: --- Summary: Add support for processing time to interval join Key: FLINK-10080 URL: https://issues.apache.org/jira/browse/FLINK-10080 Project: Flink Issue

[jira] [Updated] (FLINK-8478) Add support for time-bounded joins in DataStream API

[ https://issues.apache.org/jira/browse/FLINK-8478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-8478: --- Labels: (was: pull-request-available) > Add support for time-bounded joins in DataStream AP

[jira] [Assigned] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-9874: -- Assignee: Florian Schmidt > set_conf_ssl in E2E tests fails on macOS > ---

[jira] [Created] (FLINK-9971) Add more extensive documentation for operations that combine datastreams

Florian Schmidt created FLINK-9971: -- Summary: Add more extensive documentation for operations that combine datastreams Key: FLINK-9971 URL: https://issues.apache.org/jira/browse/FLINK-9971 Project: F

[jira] [Updated] (FLINK-9877) Add separate docs page for different join types in DataStream API

[ https://issues.apache.org/jira/browse/FLINK-9877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-9877: --- Description: https://github.com/apache/flink/pull/6407 > Add separate docs page for different

[jira] [Created] (FLINK-9877) Add separate docs page for different join types in DataStream API

Florian Schmidt created FLINK-9877: -- Summary: Add separate docs page for different join types in DataStream API Key: FLINK-9877 URL: https://issues.apache.org/jira/browse/FLINK-9877 Project: Flink

[jira] [Assigned] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-9874: -- Assignee: (was: Florian Schmidt) > set_conf_ssl in E2E tests fails on macOS >

[jira] [Updated] (FLINK-9876) ExecutionGraphCoLocationRestartTest testConstraintsAfterRestart sometimes fails with timeout

[ https://issues.apache.org/jira/browse/FLINK-9876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-9876: --- Description:  See [https://travis-ci.org/florianschmidt1994/flink/jobs/404871788] {code:java}

[jira] [Created] (FLINK-9876) ExecutionGraphCoLocationRestartTest testConstraintsAfterRestart sometimes fails with timeout

Florian Schmidt created FLINK-9876: -- Summary: ExecutionGraphCoLocationRestartTest testConstraintsAfterRestart sometimes fails with timeout Key: FLINK-9876 URL: https://issues.apache.org/jira/browse/FLINK-9876

[jira] [Commented] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546587#comment-16546587 ] Florian Schmidt commented on FLINK-9874: I think we should be able to work around

[jira] [Assigned] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-9874: -- Assignee: Florian Schmidt > set_conf_ssl in E2E tests fails on macOS > ---

[jira] [Created] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

Florian Schmidt created FLINK-9874: -- Summary: set_conf_ssl in E2E tests fails on macOS Key: FLINK-9874 URL: https://issues.apache.org/jira/browse/FLINK-9874 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-8481) Implement Scala API to expose join functionality of TimeBoundedStreamJoinOperator

[ https://issues.apache.org/jira/browse/FLINK-8481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt closed FLINK-8481. -- > Implement Scala API to expose join functionality of > TimeBoundedStreamJoinOperator > --

[jira] [Resolved] (FLINK-8481) Implement Scala API to expose join functionality of TimeBoundedStreamJoinOperator

[ https://issues.apache.org/jira/browse/FLINK-8481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt resolved FLINK-8481. Resolution: Implemented Assignee: Florian Schmidt Fix Version/s: 1.6.0 This

[jira] [Assigned] (FLINK-9855) KeyedStream.IntervalJoined#process does not work for lambdas

[ https://issues.apache.org/jira/browse/FLINK-9855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-9855: -- Assignee: Florian Schmidt > KeyedStream.IntervalJoined#process does not work for lambd

[jira] [Commented] (FLINK-8985) End-to-end test: CLI

[ https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16538863#comment-16538863 ] Florian Schmidt commented on FLINK-8985: Hey, I was playing around with the CLI

[jira] [Assigned] (FLINK-9787) Change ExecutionConfig#getGlobalJobParameters to return an instance of GlobalJobParameters instead of null if no custom globalJobParameters are set yet

[ https://issues.apache.org/jira/browse/FLINK-9787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-9787: -- Assignee: (was: Florian Schmidt) > Change ExecutionConfig#getGlobalJobParameters t

[jira] [Updated] (FLINK-9787) Change ExecutionConfig#getGlobalJobParameters to return an instance of GlobalJobParameters instead of null if no custom globalJobParameters are set yet

[ https://issues.apache.org/jira/browse/FLINK-9787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-9787: --- Fix Version/s: 2.0.0 Description: Currently when accessing ExecutionConfig#getGlobalJob

[jira] [Created] (FLINK-9787) Change ExecutionConfig#getGlobalJobParameters to return an instance of GlobalJobParameters instead of null if no custom globalJobParameters are set yet

Florian Schmidt created FLINK-9787: -- Summary: Change ExecutionConfig#getGlobalJobParameters to return an instance of GlobalJobParameters instead of null if no custom globalJobParameters are set yet Key: FLINK-9787

[jira] [Assigned] (FLINK-9787) Change ExecutionConfig#getGlobalJobParameters to return an instance of GlobalJobParameters instead of null if no custom globalJobParameters are set yet

[ https://issues.apache.org/jira/browse/FLINK-9787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-9787: -- Assignee: Florian Schmidt > Change ExecutionConfig#getGlobalJobParameters to return an

[jira] [Commented] (FLINK-9380) Failing end-to-end tests should not clean up logs

[ https://issues.apache.org/jira/browse/FLINK-9380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536801#comment-16536801 ] Florian Schmidt commented on FLINK-9380: Hi [~deepaks4077], have you had the chan

[jira] [Closed] (FLINK-8937) Refactor flink end-to-end test skeleton

[ https://issues.apache.org/jira/browse/FLINK-8937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt closed FLINK-8937. -- > Refactor flink end-to-end test skeleton > --- > >

[jira] [Resolved] (FLINK-8937) Refactor flink end-to-end test skeleton

[ https://issues.apache.org/jira/browse/FLINK-8937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt resolved FLINK-8937. Resolution: Implemented Implemented with FLINK-9257 > Refactor flink end-to-end test skele

[jira] [Created] (FLINK-9728) Wrong ruby version for building flink docs in docker container

Florian Schmidt created FLINK-9728: -- Summary: Wrong ruby version for building flink docs in docker container Key: FLINK-9728 URL: https://issues.apache.org/jira/browse/FLINK-9728 Project: Flink

[jira] [Updated] (FLINK-9709) Docs: Unnecessary transition in flink job state visualization

[ https://issues.apache.org/jira/browse/FLINK-9709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-9709: --- Summary: Docs: Unnecessary transition in flink job state visualization (was: Docs: Unnecessa

[jira] [Updated] (FLINK-9709) Docs: Unnecessary transition in flink job lifecycle visualization

[ https://issues.apache.org/jira/browse/FLINK-9709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-9709: --- Description: The docs at [https://ci.apache.org/projects/flink/flink-docs-release-1.5/interna

[jira] [Created] (FLINK-9709) Docs: Unnecessary transition in flink job lifecycle visualization

Florian Schmidt created FLINK-9709: -- Summary: Docs: Unnecessary transition in flink job lifecycle visualization Key: FLINK-9709 URL: https://issues.apache.org/jira/browse/FLINK-9709 Project: Flink

[jira] [Created] (FLINK-9638) Add helper script to run single e2e test

Florian Schmidt created FLINK-9638: -- Summary: Add helper script to run single e2e test Key: FLINK-9638 URL: https://issues.apache.org/jira/browse/FLINK-9638 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-9594) Add documentation for e2e test changes introduced with FLINK-9257

Florian Schmidt created FLINK-9594: -- Summary: Add documentation for e2e test changes introduced with FLINK-9257 Key: FLINK-9594 URL: https://issues.apache.org/jira/browse/FLINK-9594 Project: Flink

[jira] [Assigned] (FLINK-9594) Add documentation for e2e test changes introduced with FLINK-9257

[ https://issues.apache.org/jira/browse/FLINK-9594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-9594: -- Assignee: Florian Schmidt > Add documentation for e2e test changes introduced with FLI

[jira] [Created] (FLINK-9356) Improve error message for when queryable state not ready / reachable

Florian Schmidt created FLINK-9356: -- Summary: Improve error message for when queryable state not ready / reachable Key: FLINK-9356 URL: https://issues.apache.org/jira/browse/FLINK-9356 Project: Flink

[jira] [Updated] (FLINK-9336) Queryable state fails with Exception after task manager restore

[ https://issues.apache.org/jira/browse/FLINK-9336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-9336: --- Description:   The following steps can be used to reproduce the Exception: # Run an app with

[jira] [Updated] (FLINK-9336) Queryable state fails with Exception after task manager restore

[ https://issues.apache.org/jira/browse/FLINK-9336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-9336: --- Description:   The following steps can be used to reproduce the Exception: # Run an app with

[jira] [Created] (FLINK-9336) Queryable state fails with Exception after task manager restore

Florian Schmidt created FLINK-9336: -- Summary: Queryable state fails with Exception after task manager restore Key: FLINK-9336 URL: https://issues.apache.org/jira/browse/FLINK-9336 Project: Flink

[jira] [Assigned] (FLINK-9257) End-to-end tests prints "All tests PASS" even if individual test-script returns non-zero exit code

[ https://issues.apache.org/jira/browse/FLINK-9257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-9257: -- Assignee: Florian Schmidt > End-to-end tests prints "All tests PASS" even if individual

[jira] [Assigned] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator

[ https://issues.apache.org/jira/browse/FLINK-8480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-8480: -- Assignee: Florian Schmidt > Implement Java API to expose join functionality of > TimeB

[jira] [Created] (FLINK-9257) End-to-end tests prints "All tests PASS" even if individual test-script returns non-zero exit code

Florian Schmidt created FLINK-9257: -- Summary: End-to-end tests prints "All tests PASS" even if individual test-script returns non-zero exit code Key: FLINK-9257 URL: https://issues.apache.org/jira/browse/FLINK-92

[jira] [Created] (FLINK-9078) End-to-end test: Add test that verifies that a specific classloading issue with avro is fixed

Florian Schmidt created FLINK-9078: -- Summary: End-to-end test: Add test that verifies that a specific classloading issue with avro is fixed Key: FLINK-9078 URL: https://issues.apache.org/jira/browse/FLINK-9078

[jira] [Updated] (FLINK-9078) End-to-end test: Add test that verifies that a specific classloading issue with avro is fixed

[ https://issues.apache.org/jira/browse/FLINK-9078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-9078: --- Affects Version/s: 1.5.0 Component/s: Tests > End-to-end test: Add test that verifie

[jira] [Assigned] (FLINK-8980) End-to-end test: BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-8980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-8980: -- Assignee: Florian Schmidt > End-to-end test: BucketingSink > --

[jira] [Created] (FLINK-9039) Broken link to Hadoop Setup Guide in docs

Florian Schmidt created FLINK-9039: -- Summary: Broken link to Hadoop Setup Guide in docs Key: FLINK-9039 URL: https://issues.apache.org/jira/browse/FLINK-9039 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-9020) Move test projects of end-to-end tests in separate modules

[ https://issues.apache.org/jira/browse/FLINK-9020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16404638#comment-16404638 ] Florian Schmidt commented on FLINK-9020: Sure [~kkl0u] The new structure will look

[jira] [Assigned] (FLINK-9020) Move test projects of end-to-end tests in separate modules

[ https://issues.apache.org/jira/browse/FLINK-9020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-9020: -- Assignee: Florian Schmidt > Move test projects of end-to-end tests in separate modules

[jira] [Updated] (FLINK-9020) Move test projects of end-to-end tests in separate modules

[ https://issues.apache.org/jira/browse/FLINK-9020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-9020: --- Affects Version/s: 1.5.0 > Move test projects of end-to-end tests in separate modules > --

[jira] [Created] (FLINK-9020) Move test projects of end-to-end tests in separate modules

Florian Schmidt created FLINK-9020: -- Summary: Move test projects of end-to-end tests in separate modules Key: FLINK-9020 URL: https://issues.apache.org/jira/browse/FLINK-9020 Project: Flink

[jira] [Commented] (FLINK-8937) Refactor flink end-to-end test skeleton

[ https://issues.apache.org/jira/browse/FLINK-8937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16397089#comment-16397089 ] Florian Schmidt commented on FLINK-8937: [~aljoscha] any opinions on this? > Refa

[jira] [Created] (FLINK-8937) Refactor flink end-to-end test skeleton

Florian Schmidt created FLINK-8937: -- Summary: Refactor flink end-to-end test skeleton Key: FLINK-8937 URL: https://issues.apache.org/jira/browse/FLINK-8937 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-8929) "UnknownTaskExecutorException: No TaskExecutor registered" when having tab open for taskmanager that does not exist (anymore)

Florian Schmidt created FLINK-8929: -- Summary: "UnknownTaskExecutorException: No TaskExecutor registered" when having tab open for taskmanager that does not exist (anymore) Key: FLINK-8929 URL: https://issues.apac

[jira] [Closed] (FLINK-8870) End-to-end tests wrongly pass if md5sum is not installed

[ https://issues.apache.org/jira/browse/FLINK-8870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt closed FLINK-8870. -- Resolution: Invalid Behaves as expected, I just misinterpreted the output > End-to-end tests wr

[jira] [Created] (FLINK-8870) End-to-end tests wrongly pass if md5sum is not installed

Florian Schmidt created FLINK-8870: -- Summary: End-to-end tests wrongly pass if md5sum is not installed Key: FLINK-8870 URL: https://issues.apache.org/jira/browse/FLINK-8870 Project: Flink Is

[jira] [Created] (FLINK-8528) Bucket MapState of TimeBoundedStreamJoinOperator for improved performance

Florian Schmidt created FLINK-8528: -- Summary: Bucket MapState of TimeBoundedStreamJoinOperator for improved performance Key: FLINK-8528 URL: https://issues.apache.org/jira/browse/FLINK-8528 Project:

[jira] [Created] (FLINK-8524) Incorrect JavaDoc in TypeExtractor.getBinaryOperatorReturnType

Florian Schmidt created FLINK-8524: -- Summary: Incorrect JavaDoc in TypeExtractor.getBinaryOperatorReturnType Key: FLINK-8524 URL: https://issues.apache.org/jira/browse/FLINK-8524 Project: Flink

[jira] [Assigned] (FLINK-8478) Add support for time-bounded joins in DataStream API

[ https://issues.apache.org/jira/browse/FLINK-8478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-8478: -- Assignee: Florian Schmidt > Add support for time-bounded joins in DataStream API >

[jira] [Created] (FLINK-8483) Implement and expose outer joins

Florian Schmidt created FLINK-8483: -- Summary: Implement and expose outer joins Key: FLINK-8483 URL: https://issues.apache.org/jira/browse/FLINK-8483 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-8482) Implement and expose option to use min / max / left / right timestamp for joined streamrecords

[ https://issues.apache.org/jira/browse/FLINK-8482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-8482: --- Summary: Implement and expose option to use min / max / left / right timestamp for joined stre

[jira] [Created] (FLINK-8482) Expose option to use min / max / left / right timestamp for joined streamrecords

Florian Schmidt created FLINK-8482: -- Summary: Expose option to use min / max / left / right timestamp for joined streamrecords Key: FLINK-8482 URL: https://issues.apache.org/jira/browse/FLINK-8482 Pr

[jira] [Updated] (FLINK-8479) Implement time-bounded inner join of streams as a TwoInputStreamOperator

[ https://issues.apache.org/jira/browse/FLINK-8479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-8479: --- Summary: Implement time-bounded inner join of streams as a TwoInputStreamOperator (was: Imple

[jira] [Created] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator

Florian Schmidt created FLINK-8480: -- Summary: Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator Key: FLINK-8480 URL: https://issues.apache.org/jira/browse/FLINK-8480 Pr

[jira] [Created] (FLINK-8481) Implement Scala API to expose join functionality of TimeBoundedStreamJoinOperator

Florian Schmidt created FLINK-8481: -- Summary: Implement Scala API to expose join functionality of TimeBoundedStreamJoinOperator Key: FLINK-8481 URL: https://issues.apache.org/jira/browse/FLINK-8481 P

[jira] [Created] (FLINK-8479) Implement TwoInputStreamOperator to join two streams

Florian Schmidt created FLINK-8479: -- Summary: Implement TwoInputStreamOperator to join two streams Key: FLINK-8479 URL: https://issues.apache.org/jira/browse/FLINK-8479 Project: Flink Issue

[jira] [Created] (FLINK-8478) Add support for time-bounded joins in DataStream API

Florian Schmidt created FLINK-8478: -- Summary: Add support for time-bounded joins in DataStream API Key: FLINK-8478 URL: https://issues.apache.org/jira/browse/FLINK-8478 Project: Flink Issue