[
https://issues.apache.org/jira/browse/FLINK-7537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou updated FLINK-7537:
Description:
InfluxDBSink via implementation RichSinkFunction.
[BAHIR-134|https://issues.apache.org/jira/br
[
https://issues.apache.org/jira/browse/FLINK-7538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou closed FLINK-7538.
---
Resolution: Invalid
> Add InfluxDB Sink for Flink Streaming
> -
>
>
Hai Zhou created FLINK-7538:
---
Summary: Add InfluxDB Sink for Flink Streaming
Key: FLINK-7538
URL: https://issues.apache.org/jira/browse/FLINK-7538
Project: Flink
Issue Type: Wish
Report
Hai Zhou created FLINK-7537:
---
Summary: Add InfluxDB Sink for Flink Streaming
Key: FLINK-7537
URL: https://issues.apache.org/jira/browse/FLINK-7537
Project: Flink
Issue Type: Wish
Componen
Hai Zhou created FLINK-7536:
---
Summary: Add MongoDB Source/Sink for Flink Streaming
Key: FLINK-7536
URL: https://issues.apache.org/jira/browse/FLINK-7536
Project: Flink
Issue Type: Wish
Co
GitHub user mcfongtw opened a pull request:
https://github.com/apache/flink/pull/4605
[FLINK-4500] [C* Connector] CassandraSinkBase implements
CheckpointedFunction
## What is the purpose of the change
Have CassandraSinkBase to implement CheckpointedFunction so that all
in-fligh
[
https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142979#comment-16142979
]
ASF GitHub Bot commented on FLINK-4500:
---
GitHub user mcfongtw opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142972#comment-16142972
]
ASF GitHub Bot commented on FLINK-5734:
---
Github user heytitle commented on the issue
Github user heytitle commented on the issue:
https://github.com/apache/flink/pull/3511
Hi @ggevay,
I have rebased master and resolved all coding style related issues and
pushed the code to
https://github.com/heytitle/flink/tree/FLINK-5734-rebase-master-temp
For the n
[
https://issues.apache.org/jira/browse/FLINK-7535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142926#comment-16142926
]
ASF GitHub Bot commented on FLINK-7535:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4604
[FLINK-7535] Port DashboardConfigHandler to new REST endpoint
## What is the purpose of the change
Lets DashboardConfigHandler implement the LegacyRestHandler. Moreover, this
commit
Till Rohrmann created FLINK-7535:
Summary: Port DashboardConfigHandler to new REST endpoint
Key: FLINK-7535
URL: https://issues.apache.org/jira/browse/FLINK-7535
Project: Flink
Issue Type: Su
[
https://issues.apache.org/jira/browse/FLINK-7534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142918#comment-16142918
]
ASF GitHub Bot commented on FLINK-7534:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4603
[FLINK-7534] Create LegacyRestHandlerAdapter for old REST handlers
## What is the purpose of the change
Introduce LegacyRestHandler interface which the old REST handler have to
impleme
Till Rohrmann created FLINK-7534:
Summary: Create LegacyRestHandlerAdapter for the old REST handlers
Key: FLINK-7534
URL: https://issues.apache.org/jira/browse/FLINK-7534
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-7533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142876#comment-16142876
]
ASF GitHub Bot commented on FLINK-7533:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4602
[FLINK-7533] Let LeaderGatewayRetriever retry failed gateway retrievals
## What is the purpose of the change
In case that the `LeaderGatewayRetriever` fails to retrieve the leader
gate
Till Rohrmann created FLINK-7533:
Summary: Retry failed gateway retrievals in the
LeaderGatewayRetriever
Key: FLINK-7533
URL: https://issues.apache.org/jira/browse/FLINK-7533
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142874#comment-16142874
]
ASF GitHub Bot commented on FLINK-7532:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4601
[FLINK-7532] Add web content handler to DispatcherRestEndpoint
## What is the purpose of the change
Adds the StaticFileContentHandler to the DispatcherRestEndpoint if the
flink-runt
Till Rohrmann created FLINK-7532:
Summary: Add StaticFileServerHandler to DispatcherRestEndpoint
Key: FLINK-7532
URL: https://issues.apache.org/jira/browse/FLINK-7532
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142863#comment-16142863
]
ASF GitHub Bot commented on FLINK-7531:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4600
[FLINK-7531] Move Flink legacy rest handler to flink-runtime
## What is the purpose of the change
Moves the existing REST handler from `flink-runtime-web` to `flink-runtime`.
#
Till Rohrmann created FLINK-7531:
Summary: Move existing REST handler to flink-runtime
Key: FLINK-7531
URL: https://issues.apache.org/jira/browse/FLINK-7531
Project: Flink
Issue Type: Sub-tas
Till Rohrmann created FLINK-7530:
Summary: Port existing REST handlers to support Flip-6 components
Key: FLINK-7530
URL: https://issues.apache.org/jira/browse/FLINK-7530
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-7529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142859#comment-16142859
]
ASF GitHub Bot commented on FLINK-7529:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4599
[FLINK-7529] Retrieve complete REST address from gateway
## What is the purpose of the change
With this change, the complete REST address (protocol://hostname:port) is
retrieved
fr
Till Rohrmann created FLINK-7529:
Summary: Retrieve complete REST address from RestfulGateway
Key: FLINK-7529
URL: https://issues.apache.org/jira/browse/FLINK-7529
Project: Flink
Issue Type:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4598
[FLINK-7528] Create DispatcherRestEndpoint and integrate with Dispatcher
## What is the purpose of the change
This commit creates the DispatcherRestEndpoint and integrates it with the
[
https://issues.apache.org/jira/browse/FLINK-7528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142852#comment-16142852
]
ASF GitHub Bot commented on FLINK-7528:
---
GitHub user tillrohrmann opened a pull requ
Till Rohrmann created FLINK-7528:
Summary: Create Dispatcher REST endpoint
Key: FLINK-7528
URL: https://issues.apache.org/jira/browse/FLINK-7528
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-7442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142845#comment-16142845
]
ASF GitHub Bot commented on FLINK-7442:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4564
@StephanEwen I finally ironed out the last kinks. I think this is now ready
for a final review.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHu
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4597
[FLINK-7527] [rest] Let AbstractRestHandler extend RedirectHandler
## What is the purpose of the change
By letting the `AbstractRestHandler` extend the` RedirectHandler`, we add
redire
[
https://issues.apache.org/jira/browse/FLINK-7527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142830#comment-16142830
]
ASF GitHub Bot commented on FLINK-7527:
---
GitHub user tillrohrmann opened a pull requ
Till Rohrmann created FLINK-7527:
Summary: Add redirection logic to AbstractRestHandler
Key: FLINK-7527
URL: https://issues.apache.org/jira/browse/FLINK-7527
Project: Flink
Issue Type: Improv
Github user heytitle commented on the issue:
https://github.com/apache/flink/pull/3511
Hi @ggevay,
I'm currently fixing coding style. Maybe you can help me take a look at
what Greg suggested related `FixedLengthRecordSorter`
---
If your project is set up for it, you can rep
[
https://issues.apache.org/jira/browse/FLINK-7523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142762#comment-16142762
]
ASF GitHub Bot commented on FLINK-7523:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4596
[FLINK-7523] Add proper resource shutdown to
ResourceManager/JobManagerRunner
## What is the purpose of the change
This commit waits for the completion of the shutdown of the ResourceM
[
https://issues.apache.org/jira/browse/FLINK-7526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142750#comment-16142750
]
ASF GitHub Bot commented on FLINK-7526:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4595
[FLINK-7526] [TaskExecutor] Filter out duplicate JobManager gained
leadership messages
## What is the purpose of the change
This commit filters out duplicate JobManager gained leadersh
Till Rohrmann created FLINK-7526:
Summary: TaskExecutor should filter out duplicate JobManager
gained leadership messages
Key: FLINK-7526
URL: https://issues.apache.org/jira/browse/FLINK-7526
Project:
[
https://issues.apache.org/jira/browse/FLINK-7071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7071.
Resolution: Done
Fix Version/s: 1.4.0
Added via c019787e5f6873b44607f55ba7a5bd876cb41421
> C
[
https://issues.apache.org/jira/browse/FLINK-7072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7072.
Resolution: Done
Fix Version/s: 1.4.0
Added via c019787e5f6873b44607f55ba7a5bd876cb41421
> C
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4569
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142712#comment-16142712
]
ASF GitHub Bot commented on FLINK-7040:
---
Github user asfgit closed the pull request
46 matches
Mail list logo
