twalthr commented on a change in pull request #7587: [FLINK-11064] [table]
Setup a new flink-table module structure
URL: https://github.com/apache/flink/pull/7587#discussion_r252147236
##
File path: flink-table/flink-table-dist/pom.xml
##
@@ -0,0 +1,103 @@
+
+
+http://mave
tzulitai commented on a change in pull request #7590: [FLINK-11329][core]
Migrating CompositeSerializers
URL: https://github.com/apache/flink/pull/7590#discussion_r252145959
##
File path:
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/OptionSerializer.scala
##
tzulitai commented on a change in pull request #7590: [FLINK-11329][core]
Migrating CompositeSerializers
URL: https://github.com/apache/flink/pull/7590#discussion_r252144982
##
File path:
flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/ScalaOptionSerializerConfigSnap
[
https://issues.apache.org/jira/browse/FLINK-11447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16755785#comment-16755785
]
Dian Fu commented on FLINK-11447:
-
Thanks [~dawidwys] for the sharing your thoughts. If
wujinhu commented on issue #7599: [FLINK-11442] upgrade oss sdk version
URL: https://github.com/apache/flink/pull/7599#issuecomment-458840957
@StefanRRichter Please help to review this PR, thanks :)
This is an automated messag
tzulitai commented on a change in pull request #7590: [FLINK-11329][core]
Migrating CompositeSerializers
URL: https://github.com/apache/flink/pull/7590#discussion_r252140553
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.
Myasuka removed a comment on issue #7595: [FLINK-11363][tests] Port
TaskManagerConfigurationTest to new code base
URL: https://github.com/apache/flink/pull/7595#issuecomment-458839395
LGTM +1
This is an automated message from
igalshilman commented on a change in pull request #7590: [FLINK-11329][core]
Migrating CompositeSerializers
URL: https://github.com/apache/flink/pull/7590#discussion_r252140569
##
File path:
flink-end-to-end-tests/flink-stream-state-ttl-test/src/main/java/org/apache/flink/streaming
Myasuka commented on issue #7595: [FLINK-11363][tests] Port
TaskManagerConfigurationTest to new code base
URL: https://github.com/apache/flink/pull/7595#issuecomment-458839395
LGTM +1
This is an automated message from the Apa
igalshilman commented on a change in pull request #7590: [FLINK-11329][core]
Migrating CompositeSerializers
URL: https://github.com/apache/flink/pull/7590#discussion_r252139996
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateFactory.java
##
igalshilman commented on a change in pull request #7590: [FLINK-11329][core]
Migrating CompositeSerializers
URL: https://github.com/apache/flink/pull/7590#discussion_r252139840
##
File path:
flink-end-to-end-tests/flink-stream-state-ttl-test/src/main/java/org/apache/flink/streaming
tzulitai commented on a change in pull request #7590: [FLINK-11329][core]
Migrating CompositeSerializers
URL: https://github.com/apache/flink/pull/7590#discussion_r252139206
##
File path:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java
#
tzulitai commented on a change in pull request #7590: [FLINK-11329][core]
Migrating CompositeSerializers
URL: https://github.com/apache/flink/pull/7590#discussion_r252134315
##
File path:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/NullableSerializer.java
Myasuka commented on issue #7598: [FLINK-11333][protobuf] First-class
serializer support for Protobuf types
URL: https://github.com/apache/flink/pull/7598#issuecomment-458831260
CC @tzulitai would you please review this part of code?
---
tzulitai commented on a change in pull request #7590: [FLINK-11329][core]
Migrating CompositeSerializers
URL: https://github.com/apache/flink/pull/7590#discussion_r252132629
##
File path:
flink-end-to-end-tests/flink-stream-state-ttl-test/src/main/java/org/apache/flink/streaming/te
tzulitai commented on a change in pull request #7590: [FLINK-11329][core]
Migrating CompositeSerializers
URL: https://github.com/apache/flink/pull/7590#discussion_r252130677
##
File path:
flink-end-to-end-tests/flink-stream-state-ttl-test/src/main/java/org/apache/flink/streaming/te
tzulitai commented on a change in pull request #7590: [FLINK-11329][core]
Migrating CompositeSerializers
URL: https://github.com/apache/flink/pull/7590#discussion_r252130677
##
File path:
flink-end-to-end-tests/flink-stream-state-ttl-test/src/main/java/org/apache/flink/streaming/te
zhijiang created FLINK-11460:
Summary: Remove useless AcknowledgeStreamMockEnvironment
Key: FLINK-11460
URL: https://issues.apache.org/jira/browse/FLINK-11460
Project: Flink
Issue Type: Task
tzulitai commented on a change in pull request #7590: [FLINK-11329][core]
Migrating CompositeSerializers
URL: https://github.com/apache/flink/pull/7590#discussion_r252128586
##
File path:
flink-end-to-end-tests/flink-stream-state-ttl-test/src/main/java/org/apache/flink/streaming/te
tzulitai commented on a change in pull request #7590: [FLINK-11329][core]
Migrating CompositeSerializers
URL: https://github.com/apache/flink/pull/7590#discussion_r252128501
##
File path:
flink-end-to-end-tests/flink-stream-state-ttl-test/src/main/java/org/apache/flink/streaming/te
tzulitai commented on a change in pull request #7590: [FLINK-11329][core]
Migrating CompositeSerializers
URL: https://github.com/apache/flink/pull/7590#discussion_r252128802
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateFactory.java
#
tzulitai commented on a change in pull request #7590: [FLINK-11329][core]
Migrating CompositeSerializers
URL: https://github.com/apache/flink/pull/7590#discussion_r252127263
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeSerializer.java
#
tzulitai edited a comment on issue #7566: [FLINK-11328][core] Migrate
NFAStateSerializer to new TypeSerializer interface
URL: https://github.com/apache/flink/pull/7566#issuecomment-458822350
Thanks @dawidwys! I looked at all 3 commits; the refactoring part is also
nice to have.
The actu
tzulitai commented on issue #7566: [FLINK-11328][core] Migrate
NFAStateSerializer to new TypeSerializer interface
URL: https://github.com/apache/flink/pull/7566#issuecomment-458822350
Thanks @dawidwys! I looked at all 3 commits; the refactoring part is also
nice to have.
The actual migr
[
https://issues.apache.org/jira/browse/FLINK-11450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16755713#comment-16755713
]
Dian Fu commented on FLINK-11450:
-
[~twalthr] Sounds great. Will submit a PR ASAP.
> P
wujinhu commented on issue #7599: [FLINK-11442] upgrade oss sdk version
URL: https://github.com/apache/flink/pull/7599#issuecomment-458821842
**Testing results:**
[INFO] ---
[INFO] T E S T S
[INFO]
[
https://issues.apache.org/jira/browse/FLINK-11442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11442:
---
Labels: pull-request-available (was: )
> Upgrade OSS SDK Version
> ---
wujinhu opened a new pull request #7599: [FLINK-11442] upgrade oss sdk version
URL: https://github.com/apache/flink/pull/7599
## What is the purpose of the change
Upgrade oss sdk version to exclude org.json dependency
https://issues.apache.org/jira/browse/FLINK-11442
XuQianJin-Stars commented on issue #7450: [FLINK-11296][Table API & SQL]
Support truncate in TableAPI
URL: https://github.com/apache/flink/pull/7450#issuecomment-458809680
hi @wuchong Thank you very much. I know you are very busy.
best
qianjin
---
wuchong commented on issue #7450: [FLINK-11296][Table API & SQL] Support
truncate in TableAPI
URL: https://github.com/apache/flink/pull/7450#issuecomment-458806492
Thank @XuQianJin-Stars and sorry for the late reply. The PR looks good to
me now.
Will merge this soon.
[
https://issues.apache.org/jira/browse/FLINK-11333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11333:
---
Labels: pull-request-available (was: )
> First-class support for Protobuf types with evolva
Myasuka opened a new pull request #7598: [FLINK-11333][protobuf] First-class
serializer support for Protobuf types
URL: https://github.com/apache/flink/pull/7598
## What is the purpose of the change
Support Protobuf types directly in Flink. Unlike the built-in avro
serializer of
jinglining commented on a change in pull request #7567: [FLINK-11358][tests]
Port LeaderChangeStateCleanupTest to new code base
URL: https://github.com/apache/flink/pull/7567#discussion_r252108778
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/Lea
jinglining commented on a change in pull request #7567: [FLINK-11358][tests]
Port LeaderChangeStateCleanupTest to new code base
URL: https://github.com/apache/flink/pull/7567#discussion_r252108778
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/Lea
chensi2017 opened a new pull request #7597: fix wrong format
URL: https://github.com/apache/flink/pull/7597
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
hequn8128 commented on a change in pull request #6787: [FLINK-8577][table]
Implement proctime DataStream to Table upsert conversion
URL: https://github.com/apache/flink/pull/6787#discussion_r252105308
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/p
[
https://issues.apache.org/jira/browse/FLINK-9054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
guchunhui updated FLINK-9054:
-
Comment: was deleted
(was: Hi,I also have this problem with Flink 1.6. Do you solve this problem?)
> Il
[
https://issues.apache.org/jira/browse/FLINK-9054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16755630#comment-16755630
]
guchunhui edited comment on FLINK-9054 at 1/30/19 3:14 AM:
---
Hi,
[
https://issues.apache.org/jira/browse/FLINK-9054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16755630#comment-16755630
]
guchunhui commented on FLINK-9054:
--
Hi,I also have this problem with Flink 1.6.
> Ille
klion26 commented on issue #7596: Release 1.7 sortPartition bug
URL: https://github.com/apache/flink/pull/7596#issuecomment-458785790
@zhaijp You can report bug using
[JIRA](https://issues.apache.org/jira/projects/FLINK). Maybe you could close
this pr.
jinglining commented on issue #7582: [FLINK-11424][metrics]fix remove error
type Gauge in DatadogHttpReporter
URL: https://github.com/apache/flink/pull/7582#issuecomment-458785073
The Travis CI build failed, because of YarnFlinkResourceManagerTest which
case is always fail recently。
-
[
https://issues.apache.org/jira/browse/FLINK-10897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16747409#comment-16747409
]
boshu Zheng edited comment on FLINK-10897 at 1/30/19 2:13 AM:
[
https://issues.apache.org/jira/browse/FLINK-11380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16755576#comment-16755576
]
lining commented on FLINK-11380:
I meet this too. https://api.travis-ci.org/v3/job/48521
[
https://issues.apache.org/jira/browse/FLINK-11380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16755576#comment-16755576
]
lining edited comment on FLINK-11380 at 1/30/19 2:12 AM:
-
I met
hequn8128 commented on a change in pull request #6787: [FLINK-8577][table]
Implement proctime DataStream to Table upsert conversion
URL: https://github.com/apache/flink/pull/6787#discussion_r252089234
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/p
zhaijp opened a new pull request #7596: Release 1.7 sortPartition bug
URL: https://github.com/apache/flink/pull/7596
### I found a bug when I use sortPartition
public class WordCountExample {
public static void main(String[] args) throws Exception {
final Execution
TisonKun commented on a change in pull request #7570: [FLINK-11422] Prefer
testing class to mock StreamTask in AbstractStre…
URL: https://github.com/apache/flink/pull/7570#discussion_r252085826
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/MockStr
suez1224 commented on a change in pull request #7356: [FLINK-10868][flink-yarn]
Enforce maximum TMs failure rate in ResourceManagers
URL: https://github.com/apache/flink/pull/7356#discussion_r252039395
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanag
suez1224 commented on a change in pull request #7356: [FLINK-10868][flink-yarn]
Enforce maximum TMs failure rate in ResourceManagers
URL: https://github.com/apache/flink/pull/7356#discussion_r252038865
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanag
suez1224 commented on a change in pull request #7356: [FLINK-10868][flink-yarn]
Enforce maximum TMs failure rate in ResourceManagers
URL: https://github.com/apache/flink/pull/7356#discussion_r252025408
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnC
suez1224 commented on a change in pull request #7356: [FLINK-10868][flink-yarn]
Enforce maximum TMs failure rate in ResourceManagers
URL: https://github.com/apache/flink/pull/7356#discussion_r252025274
##
File path: docs/_includes/generated/mesos_configuration.html
##
@@ -
suez1224 commented on a change in pull request #7356: [FLINK-10868][flink-yarn]
Enforce maximum TMs failure rate in ResourceManagers
URL: https://github.com/apache/flink/pull/7356#discussion_r252024051
##
File path:
flink-mesos/src/main/java/org/apache/flink/mesos/configuration/Mes
suez1224 commented on a change in pull request #7356: [FLINK-10868][flink-yarn]
Enforce maximum TMs failure rate in ResourceManagers
URL: https://github.com/apache/flink/pull/7356#discussion_r252037753
##
File path: docs/_includes/generated/yarn_config_configuration.html
##
fhueske commented on a change in pull request #6483:
[FLINK-7243][flink-formats] Add parquet input format
URL: https://github.com/apache/flink/pull/6483#discussion_r252035267
##
File path:
flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/utils/ParquetSchem
fhueske commented on a change in pull request #6483:
[FLINK-7243][flink-formats] Add parquet input format
URL: https://github.com/apache/flink/pull/6483#discussion_r252016959
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/RowConverter
fhueske commented on a change in pull request #6483:
[FLINK-7243][flink-formats] Add parquet input format
URL: https://github.com/apache/flink/pull/6483#discussion_r251979596
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/RowConverter
fhueske commented on a change in pull request #6483:
[FLINK-7243][flink-formats] Add parquet input format
URL: https://github.com/apache/flink/pull/6483#discussion_r252025737
##
File path:
flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetMapInputFor
fhueske commented on a change in pull request #6483:
[FLINK-7243][flink-formats] Add parquet input format
URL: https://github.com/apache/flink/pull/6483#discussion_r252016613
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/RowConverter
fhueske commented on a change in pull request #6483:
[FLINK-7243][flink-formats] Add parquet input format
URL: https://github.com/apache/flink/pull/6483#discussion_r252036898
##
File path:
flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/utils/TestUtil.jav
fhueske commented on a change in pull request #6483:
[FLINK-7243][flink-formats] Add parquet input format
URL: https://github.com/apache/flink/pull/6483#discussion_r252018181
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/RowConverter
fhueske commented on a change in pull request #6483:
[FLINK-7243][flink-formats] Add parquet input format
URL: https://github.com/apache/flink/pull/6483#discussion_r252018047
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/RowConverter
fhueske commented on a change in pull request #6483:
[FLINK-7243][flink-formats] Add parquet input format
URL: https://github.com/apache/flink/pull/6483#discussion_r252033885
##
File path:
flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/utils/ParquetRecor
fhueske commented on a change in pull request #6483:
[FLINK-7243][flink-formats] Add parquet input format
URL: https://github.com/apache/flink/pull/6483#discussion_r252037449
##
File path:
flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/utils/TestUtil.jav
fhueske commented on a change in pull request #6483:
[FLINK-7243][flink-formats] Add parquet input format
URL: https://github.com/apache/flink/pull/6483#discussion_r252036720
##
File path:
flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/utils/TestUtil.jav
fhueske commented on a change in pull request #6483:
[FLINK-7243][flink-formats] Add parquet input format
URL: https://github.com/apache/flink/pull/6483#discussion_r252026077
##
File path:
flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetMapInputFor
fhueske commented on a change in pull request #6483:
[FLINK-7243][flink-formats] Add parquet input format
URL: https://github.com/apache/flink/pull/6483#discussion_r251984469
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/RowReadSuppo
fhueske commented on a change in pull request #6483:
[FLINK-7243][flink-formats] Add parquet input format
URL: https://github.com/apache/flink/pull/6483#discussion_r252013399
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/RowConverter
fhueske commented on a change in pull request #6483:
[FLINK-7243][flink-formats] Add parquet input format
URL: https://github.com/apache/flink/pull/6483#discussion_r252014383
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/RowConverter
fhueske commented on a change in pull request #6483:
[FLINK-7243][flink-formats] Add parquet input format
URL: https://github.com/apache/flink/pull/6483#discussion_r252032139
##
File path:
flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetRowInputFor
fhueske commented on a change in pull request #6483:
[FLINK-7243][flink-formats] Add parquet input format
URL: https://github.com/apache/flink/pull/6483#discussion_r252028083
##
File path:
flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetPojoInputFo
fhueske commented on a change in pull request #6483:
[FLINK-7243][flink-formats] Add parquet input format
URL: https://github.com/apache/flink/pull/6483#discussion_r252026568
##
File path:
flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetMapInputFor
fhueske commented on a change in pull request #6483:
[FLINK-7243][flink-formats] Add parquet input format
URL: https://github.com/apache/flink/pull/6483#discussion_r252027651
##
File path:
flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetPojoInputFo
[
https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16755385#comment-16755385
]
JC commented on FLINK-2491:
---
I also came across this problem trying exactly the same as [~canhu
jgrier commented on a change in pull request #7099: [FLINK-10887] [jobmaster]
Add source watermark tracking to the JobMaster
URL: https://github.com/apache/flink/pull/7099#discussion_r251966785
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.j
[
https://issues.apache.org/jira/browse/FLINK-11459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-11459:
Description:
It seems that when using minio for S3-like storage and with mis-configurations
such
jgrier commented on a change in pull request #7099: [FLINK-10887] [jobmaster]
Add source watermark tracking to the JobMaster
URL: https://github.com/apache/flink/pull/7099#discussion_r251964188
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.j
Nico Kruber created FLINK-11459:
---
Summary: Presto S3 does not show errors due to missing credentials
with minio
Key: FLINK-11459
URL: https://issues.apache.org/jira/browse/FLINK-11459
Project: Flink
stevenzwu closed pull request #7020: [FLINK-10774] [Kafka] connection leak when
partition discovery is disabled an…
URL: https://github.com/apache/flink/pull/7020
This is an automated message from the Apache Git Service.
To
stevenzwu commented on issue #7020: [FLINK-10774] [Kafka] connection leak when
partition discovery is disabled an…
URL: https://github.com/apache/flink/pull/7020#issuecomment-458650005
@tzulitai thx. let me close this PR then. @tillrohrmann can submit a diff
PR.
-
pnowojski commented on a change in pull request #6787: [FLINK-8577][table]
Implement proctime DataStream to Table upsert conversion
URL: https://github.com/apache/flink/pull/6787#discussion_r251924624
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/p
pnowojski commented on a change in pull request #6787: [FLINK-8577][table]
Implement proctime DataStream to Table upsert conversion
URL: https://github.com/apache/flink/pull/6787#discussion_r251922093
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/p
[
https://issues.apache.org/jira/browse/FLINK-11042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16755198#comment-16755198
]
Piotr Nowojski edited comment on FLINK-11042 at 1/29/19 4:48 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-11042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16755198#comment-16755198
]
Piotr Nowojski commented on FLINK-11042:
I was waiting for someone to review my
pnowojski commented on a change in pull request #7570: [FLINK-11422] Prefer
testing class to mock StreamTask in AbstractStre…
URL: https://github.com/apache/flink/pull/7570#discussion_r251916174
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/MockSt
[
https://issues.apache.org/jira/browse/FLINK-11333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16755185#comment-16755185
]
Yun Tang commented on FLINK-11333:
--
I planed to use avro-protobuf to extract Protobuf m
pnowojski edited a comment on issue #7405: [FLINK-11249] FlinkKafkaProducer011
can not be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7405#issuecomment-458609356
Sorry, I forgot to respond to that part:
> I have started to work on the last test FlinkKafkaProd
Kostas Kloudas created FLINK-11458:
--
Summary: Ensure sink commit side-effects when cancelling with
savepoint.
Key: FLINK-11458
URL: https://issues.apache.org/jira/browse/FLINK-11458
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16755180#comment-16755180
]
Edward Rojas commented on FLINK-11419:
--
[~kkl0u] I created the PR, you can review i
pnowojski commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not
be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7405#issuecomment-458609356
Sorry, I forgot to respond to that part:
> I have started to work on the last test FlinkKafkaProducer011
tvielgouarin commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can
not be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7405#issuecomment-458604699
I've manage to make the migration test from FlinkKakfaProducer011 -->
FlinkKafkaProducer work. I will m
Oscar Westra van Holthe - Kind created FLINK-11457:
--
Summary: PrometheusPushGatewayReporter either overwrites its own
metrics or creates too may labels
Key: FLINK-11457
URL: https://issues.apache.
Rong Rong created FLINK-11456:
-
Summary: Improve window operator with sliding window assigners
Key: FLINK-11456
URL: https://issues.apache.org/jira/browse/FLINK-11456
Project: Flink
Issue Type: S
Rong Rong created FLINK-11455:
-
Summary: Support evictor operations on slicing and merging
operators
Key: FLINK-11455
URL: https://issues.apache.org/jira/browse/FLINK-11455
Project: Flink
Issue
Rong Rong created FLINK-11454:
-
Summary: Support MergedStream operation
Key: FLINK-11454
URL: https://issues.apache.org/jira/browse/FLINK-11454
Project: Flink
Issue Type: Sub-task
Compo
[
https://issues.apache.org/jira/browse/FLINK-11453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-11453:
--
Summary: Support SliceStream with forwardable pane info (was: Support
SliceWindow with forwardable p
Rong Rong created FLINK-11453:
-
Summary: Support SliceWindow with forwardable pane info
Key: FLINK-11453
URL: https://issues.apache.org/jira/browse/FLINK-11453
Project: Flink
Issue Type: Sub-tas
TisonKun commented on issue #7570: [FLINK-11422] Prefer testing class to mock
StreamTask in AbstractStre…
URL: https://github.com/apache/flink/pull/7570#issuecomment-458574322
@pnowojski thanks for your advice! Address your comments. Also extract
`MockStreamStatusMaintainer` to deduplicate
[
https://issues.apache.org/jira/browse/FLINK-11266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-11266.
Resolution: Fixed
Release Note:
Convenience binaries that include hadoop are no long
GJL commented on a change in pull request #7525: [FLINK-11363][test] Check and
remove TaskManagerConfigurationTest
URL: https://github.com/apache/flink/pull/7525#discussion_r251869623
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunnerC
[
https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16710007#comment-16710007
]
Miguel E. Coimbra edited comment on FLINK-10867 at 1/29/19 2:58 PM:
--
1 - 100 of 229 matches
Mail list logo