[
https://issues.apache.org/jira/browse/FLINK-10701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10701:
---
Labels: pull-request-available (was: )
> Move modern kafka connector module into connector
[
https://issues.apache.org/jira/browse/FLINK-10701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1272#comment-1272
]
ASF GitHub Bot commented on FLINK-10701:
yanghua opened a new pull request #6954
yanghua opened a new pull request #6954: [FLINK-10701] Move modern kafka
connector module into connector profile
URL: https://github.com/apache/flink/pull/6954
## What is the purpose of the change
*This pull request moves modern kafka connector module into connector
profile*
[
https://issues.apache.org/jira/browse/FLINK-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1203#comment-1203
]
ASF GitHub Bot commented on FLINK-10558:
TisonKun edited a comment on issue #695
[
https://issues.apache.org/jira/browse/FLINK-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1202#comment-1202
]
ASF GitHub Bot commented on FLINK-10558:
TisonKun commented on issue #6953: [FLI
TisonKun edited a comment on issue #6953: [FLINK-10558] [yarn-test] Port
YARNHighAvailabilityITCase to new code…
URL: https://github.com/apache/flink/pull/6953#issuecomment-433648252
The main process I think this test should have is,
1. start the session
2. submit a somehow blockin
TisonKun commented on issue #6953: [FLINK-10558] [yarn-test] Port
YARNHighAvailabilityITCase to new code…
URL: https://github.com/apache/flink/pull/6953#issuecomment-433648252
The main process I think this test should have is, 1. start the session 2.
submit a somehow blocking job 3. verify
[
https://issues.apache.org/jira/browse/FLINK-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10558:
---
Labels: pull-request-available (was: )
> Port YARNHighAvailabilityITCase and YARNSessionCap
[
https://issues.apache.org/jira/browse/FLINK-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1198#comment-1198
]
ASF GitHub Bot commented on FLINK-10558:
TisonKun opened a new pull request #695
TisonKun opened a new pull request #6953: [FLINK-10558] [yarn-test] Port
YARNHighAvailabilityITCase to new code…
URL: https://github.com/apache/flink/pull/6953
… base
## What is the purpose of the change
## Brief change log
## Verifying this change
*(Please p
xueyumusic opened a new pull request #6952: [hotfix][cep] fix typos in cep
quantifier
URL: https://github.com/apache/flink/pull/6952
This PR is a hotfix for typos in cep quantifier's combinations and
consecutive's exception msg.
---
[
https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10114:
Assignee: vinoyang (was: lihongli)
> Support Orc for StreamingFileSink
> ---
[
https://issues.apache.org/jira/browse/FLINK-10693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10693:
---
Labels: pull-request-available (was: )
> Fix Scala EitherSerializer duplication
> -
[
https://issues.apache.org/jira/browse/FLINK-10693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1114#comment-1114
]
ASF GitHub Bot commented on FLINK-10693:
StephanEwen opened a new pull request #
StephanEwen opened a new pull request #6951: [FLINK-10693] [Scala API] Fix
incorrect duplication in EitherSerializer
URL: https://github.com/apache/flink/pull/6951
## What is the purpose of the change / Brief change log
Fixes the duplication of the Scala `EitherSerialzer` that never
[
https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-10114:
Assignee: lihongli (was: vinoyang)
> Support Orc for StreamingFileSink
> ---
[
https://issues.apache.org/jira/browse/FLINK-10692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1042#comment-1042
]
ASF GitHub Bot commented on FLINK-10692:
tillrohrmann closed pull request #6940:
[
https://issues.apache.org/jira/browse/FLINK-10692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-10692.
-
Resolution: Fixed
Fixed via
1.7.0:
https://github.com/apache/flink/commit/48341217d507066a11bd4
tillrohrmann commented on issue #6941: [BP-1.6][FLINK-10692] Harden Confluent
schema registry E2E test
URL: https://github.com/apache/flink/pull/6941#issuecomment-433612794
Thanks for the review @zentol. Failing test case is unrelated.
--
tillrohrmann closed pull request #6941: [BP-1.6][FLINK-10692] Harden Confluent
schema registry E2E test
URL: https://github.com/apache/flink/pull/6941
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance
tillrohrmann commented on issue #6940: [FLINK-10692] Harden Confluent schema
registry E2E test
URL: https://github.com/apache/flink/pull/6940#issuecomment-433612753
Thanks for the review @zentol
This is an automated message
tillrohrmann closed pull request #6940: [FLINK-10692] Harden Confluent schema
registry E2E test
URL: https://github.com/apache/flink/pull/6940
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As th
[
https://issues.apache.org/jira/browse/FLINK-10692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1041#comment-1041
]
ASF GitHub Bot commented on FLINK-10692:
tillrohrmann commented on issue #6940:
[
https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665997#comment-16665997
]
ASF GitHub Bot commented on FLINK-10600:
yanghua commented on issue #6924: [FLIN
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-433603466
@pnowojski I solved the test problem and it is now ready to be reviewed
again.
--
[
https://issues.apache.org/jira/browse/FLINK-10668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665976#comment-16665976
]
ASF GitHub Bot commented on FLINK-10668:
hequn8128 opened a new pull request #69
[
https://issues.apache.org/jira/browse/FLINK-10668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10668:
---
Labels: pull-request-available (was: )
> Streaming File Sink E2E test fails because not all
hequn8128 opened a new pull request #6950: [FLINK-10668][e2e] Streaming File
Sink E2E test fails because not all legitimate exceptions are excluded
URL: https://github.com/apache/flink/pull/6950
## What is the purpose of the change
Streaming File Sink E2E test fails because not a
[
https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665975#comment-16665975
]
Jiayi Liao edited comment on FLINK-5601 at 10/27/18 7:46 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665975#comment-16665975
]
Jiayi Liao commented on FLINK-5601:
---
[~aljoscha][~kkl0u]
Here is my idea:
In Timestam
[
https://issues.apache.org/jira/browse/FLINK-10676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16665968#comment-16665968
]
ASF GitHub Bot commented on FLINK-10676:
hequn8128 opened a new pull request #69
[
https://issues.apache.org/jira/browse/FLINK-10676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10676:
---
Labels: pull-request-available (was: )
> Add 'as' method for OverWindowWithOrderBy in Java
hequn8128 opened a new pull request #6949: [FLINK-10676][table] Add 'as' method
for OverWindowWithOrderBy
URL: https://github.com/apache/flink/pull/6949
## What is the purpose of the change
The preceding clause of OVER Window in the traditional database is optional.
The default
33 matches
Mail list logo
