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:
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
[
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
[
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
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
[
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
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
[
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://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:
[
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
>
[
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
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
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:
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
[
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
>
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:
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:
[
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
>
[
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
>
[
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
[
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
>
>
[
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 /
[
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
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
[
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.
[
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.
Florian Schmidt created FLINK-9876:
--
Summary: ExecutionGraphCoLocationRestartTest
testConstraintsAfterRestart sometimes fails with timeout
Key: FLINK-9876
URL: https://issues.apache.org/jira/browse/FLINK-9876
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
[
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
>
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
[
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]
[
https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546587#comment-16546587
]
Florian Schmidt commented on FLINK-9874:
I think we should be able to work around this issue by
[
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
>
[
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
[
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
[
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
>
[
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
[
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
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
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538863#comment-16538863
]
Florian Schmidt commented on FLINK-8985:
Hey,
I was playing around with the CLI a little bit as
[
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
> ---
>
>
[
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
[
https://issues.apache.org/jira/browse/FLINK-9380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16536801#comment-16536801
]
Florian Schmidt commented on FLINK-9380:
Hi [~deepaks4077], have you had the chance to make
[
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:
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
[
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
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
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
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
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
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
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.apache.org/jira/browse/FLINK-8937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397089#comment-16397089
]
Florian Schmidt commented on FLINK-8937:
[~aljoscha] any opinions on this?
> Refactor flink
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:
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-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
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
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
[
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
>
[
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
[
https://issues.apache.org/jira/browse/FLINK-9020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404638#comment-16404638
]
Florian Schmidt commented on FLINK-9020:
Sure [~kkl0u]
The new structure will look like the
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
[
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
>
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-10519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650170#comment-16650170
]
Florian Schmidt edited comment on FLINK-10519 at 10/15/18 1:06 PM:
---
I
[
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
[
https://issues.apache.org/jira/browse/FLINK-10519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650170#comment-16650170
]
Florian Schmidt commented on FLINK-10519:
-
I cross-posted this to
[
https://issues.apache.org/jira/browse/FLINK-10519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650170#comment-16650170
]
Florian Schmidt edited comment on FLINK-10519 at 10/15/18 1:11 PM:
---
-I
[
https://issues.apache.org/jira/browse/FLINK-10519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16650170#comment-16650170
]
Florian Schmidt edited comment on FLINK-10519 at 10/15/18 1:11 PM:
---
I
[
https://issues.apache.org/jira/browse/FLINK-10519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16653180#comment-16653180
]
Florian Schmidt commented on FLINK-10519:
-
From
[
https://issues.apache.org/jira/browse/FLINK-10519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651714#comment-16651714
]
Florian Schmidt commented on FLINK-10519:
-
INFRA says they are responsible for hosting in this
[
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
[
https://issues.apache.org/jira/browse/FLINK-10519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16651714#comment-16651714
]
Florian Schmidt edited comment on FLINK-10519 at 10/16/18 1:58 PM:
---
[
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
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
[
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
[
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
[
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
[
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
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-10521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646157#comment-16646157
]
Florian Schmidt commented on FLINK-10521:
-
[~till.rohrmann] I attached the debug logs. Turning
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
[
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:
[
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
>
[
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
[
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]
>
[
https://issues.apache.org/jira/browse/FLINK-11835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16839359#comment-16839359
]
Florian Schmidt commented on FLINK-11835:
-
After running it ~800 times I was able to reproduce
[
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
>
92 matches
Mail list logo
