[
https://issues.apache.org/jira/browse/FLINK-11789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782314#comment-16782314
]
Yun Tang commented on FLINK-11789:
--
[~shengjk1] When job fails, we should also consider
Elias Levy created FLINK-11794:
--
Summary: Allow compression of row format files created by
StreamingFileSink
Key: FLINK-11794
URL: https://issues.apache.org/jira/browse/FLINK-11794
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782311#comment-16782311
]
Julien Nioche commented on FLINK-11783:
---
Same issue with a different job on the sa
[
https://issues.apache.org/jira/browse/FLINK-11717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11717:
---
Labels: pull-request-available (was: )
> Translate the "Material" page into Chinese
> -
TisonKun commented on a change in pull request #7679: [FLINK-11501][Kafka
Connector] Add ratelimiting to Kafka consumer
URL: https://github.com/apache/flink/pull/7679#discussion_r261814632
##
File path:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/strea
[
https://issues.apache.org/jira/browse/FLINK-11790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-11790.
--
Resolution: Implemented
Fix Version/s: 1.9.0
> Introduce basic Flink RelNode interface
> --
[
https://issues.apache.org/jira/browse/FLINK-11790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-11790:
---
Component/s: (was: API / Table SQL)
SQL / Planner
> Introduce basic Flink RelNo
KurtYoung closed pull request #7878: [FLINK-11790][table-planner-blink]
Introduce FlinkRelNode interface and FlinkConventions
URL: https://github.com/apache/flink/pull/7878
This is an automated message from the Apache Git Se
[
https://issues.apache.org/jira/browse/FLINK-11790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782291#comment-16782291
]
Kurt Young commented on FLINK-11790:
fixed in e3248d844c728c714857c5d69520f08ddf4e4c
KurtYoung commented on issue #7878: [FLINK-11790][table-planner-blink]
Introduce FlinkRelNode interface and FlinkConventions
URL: https://github.com/apache/flink/pull/7878#issuecomment-46197
Looks like the commit message have not changed. I will change it while
merging...
godfreyhe commented on issue #7878: [FLINK-11790][table-runtime-blink]
Introduce FlinkRelNode interface and FlinkConventions
URL: https://github.com/apache/flink/pull/7878#issuecomment-46066
Thanks a lot for the review @KurtYoung . Those class is only belong to
`table-planner-blink` no
godfreyhe commented on a change in pull request #7878:
[FLINK-11790][table-runtime-blink] Introduce FlinkRelNode interface and
FlinkConventions
URL: https://github.com/apache/flink/pull/7878#discussion_r261813909
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/o
[
https://issues.apache.org/jira/browse/FLINK-11501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved FLINK-11501.
--
Resolution: Implemented
Fix Version/s: 1.9.0
> Add a ratelimiting feature to the FlinkK
tweise commented on issue #7679: [FLINK-11501][Kafka Connector] Add
ratelimiting to Kafka consumer
URL: https://github.com/apache/flink/pull/7679#issuecomment-468879741
@glaksh100 thanks for the contribution!
This is an autom
[
https://issues.apache.org/jira/browse/FLINK-7344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782248#comment-16782248
]
vinoyang commented on FLINK-7344:
-
Hi all, if no one is working on this, I will try to ta
[
https://issues.apache.org/jira/browse/FLINK-11617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782230#comment-16782230
]
Thomas Weise commented on FLINK-11617:
--
1.8: 704bc60bdb02681170a74ffcac72bfdab6658
[
https://issues.apache.org/jira/browse/FLINK-11617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved FLINK-11617.
--
Resolution: Fixed
Fix Version/s: 1.8.0
> Kinesis Connector getRecords() failure logging
glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka
Connector] Add ratelimiting to Kafka consumer
URL: https://github.com/apache/flink/pull/7679#discussion_r261769488
##
File path:
flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/stre
glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka
Connector] Add ratelimiting to Kafka consumer
URL: https://github.com/apache/flink/pull/7679#discussion_r261769464
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/io/ratelimiting/FlinkConn
glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka
Connector] Add ratelimiting to Kafka consumer
URL: https://github.com/apache/flink/pull/7679#discussion_r261769531
##
File path:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/stre
Xeli edited a comment on issue #6594: [FLINK-9311] [pubsub] Added PubSub source
connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#issuecomment-468731002
Hello @rmetzger
Let me address them point by point:
1.
I really lik
flinkbot edited a comment on issue #7706: [FLINK-11617] [kinesis connector]
Kinesis Connector getRecords() failure logging is misleading
URL: https://github.com/apache/flink/pull/7706#issuecomment-463632400
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot.
glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka
Connector] Add ratelimiting to Kafka consumer
URL: https://github.com/apache/flink/pull/7679#discussion_r261723001
##
File path:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/stre
glaksh100 edited a comment on issue #7679: [FLINK-11501][Kafka Connector] Add
ratelimiting to Kafka consumer
URL: https://github.com/apache/flink/pull/7679#issuecomment-468772934
As per discussion on the [mailing
list](https://lists.apache.org/thread.html/3de9d2353cf22aea0448fb744314103b5f
glaksh100 commented on issue #7679: [FLINK-11501][Kafka Connector] Add
ratelimiting to Kafka consumer
URL: https://github.com/apache/flink/pull/7679#issuecomment-468772934
As per discussion on the [mailing
list](https://lists.apache.org/thread.html/3de9d2353cf22aea0448fb744314103b5f8819521
flinkbot edited a comment on issue #7679: [FLINK-11501][Kafka Connector] Add
ratelimiting to Kafka consumer
URL: https://github.com/apache/flink/pull/7679#issuecomment-462574731
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to re
flinkbot edited a comment on issue #7872: [FLINK-11420][core] Fixed duplicate
method of TraversableSerializer
URL: https://github.com/apache/flink/pull/7872#issuecomment-468577664
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
igalshilman commented on a change in pull request #7872: [FLINK-11420][core]
Fixed duplicate method of TraversableSerializer
URL: https://github.com/apache/flink/pull/7872#discussion_r261709583
##
File path:
flink-core/src/test/java/org/apache/flink/api/common/typeutils/SerializerT
igalshilman commented on a change in pull request #7872: [FLINK-11420][core]
Fixed duplicate method of TraversableSerializer
URL: https://github.com/apache/flink/pull/7872#discussion_r261715744
##
File path:
flink-core/src/test/java/org/apache/flink/testutils/TupleEqualityMatcher.j
igalshilman commented on a change in pull request #7872: [FLINK-11420][core]
Fixed duplicate method of TraversableSerializer
URL: https://github.com/apache/flink/pull/7872#discussion_r261708410
##
File path:
flink-core/src/test/java/org/apache/flink/api/common/typeutils/SerializerT
igalshilman commented on a change in pull request #7872: [FLINK-11420][core]
Fixed duplicate method of TraversableSerializer
URL: https://github.com/apache/flink/pull/7872#discussion_r261715920
##
File path:
flink-core/src/test/java/org/apache/flink/testutils/TupleEqualityMatcher.j
igalshilman commented on a change in pull request #7872: [FLINK-11420][core]
Fixed duplicate method of TraversableSerializer
URL: https://github.com/apache/flink/pull/7872#discussion_r261712788
##
File path:
flink-core/src/test/java/org/apache/flink/testutils/TupleEqualityMatcher.j
Xeli edited a comment on issue #6594: [FLINK-9311] [pubsub] Added PubSub source
connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#issuecomment-468731002
Hello @rmetzger
Let me address them point by point:
1.
I really lik
Xeli edited a comment on issue #6594: [FLINK-9311] [pubsub] Added PubSub source
connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#issuecomment-468731002
Hello @rmetzger
Let me address them point by point:
1.
I really lik
[
https://issues.apache.org/jira/browse/FLINK-11320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16781893#comment-16781893
]
Allen Wang commented on FLINK-11320:
[~Salatich] We already have an implementation a
Konstantin Knauf created FLINK-11793:
Summary: Make KafkaProducer more resilient to Kafka Broker Failures
Key: FLINK-11793
URL: https://issues.apache.org/jira/browse/FLINK-11793
Project: Flink
Konstantin Knauf created FLINK-11792:
Summary: Make KafkaConsumer more resilient to Kafka Broker
Failures
Key: FLINK-11792
URL: https://issues.apache.org/jira/browse/FLINK-11792
Project: Flink
flinkbot edited a comment on issue #7801: [FLINK-11722][javadocs] Fix the
outdated java doc in AkkaRpcServiceUtils
URL: https://github.com/apache/flink/pull/7801#issuecomment-466295037
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
rmetzger commented on issue #7801: [FLINK-11722][javadocs] Fix the outdated
java doc in AkkaRpcServiceUtils
URL: https://github.com/apache/flink/pull/7801#issuecomment-468734372
@flinkbot please re-evaluate the labels for this pull request
--
flinkbot edited a comment on issue #7850: [FLINK-11183][metrics] Properly
measure current memory usage
URL: https://github.com/apache/flink/pull/7850#issuecomment-467904893
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
flinkbot edited a comment on issue #7843: [FLINK-11752] [dist] Move
flink-python to opt
URL: https://github.com/apache/flink/pull/7843#issuecomment-467624899
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull reque
flinkbot edited a comment on issue #7874: [FLINK-11752] [dist] Move
flink-python to opt (backport)
URL: https://github.com/apache/flink/pull/7874#issuecomment-468607399
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your
flinkbot edited a comment on issue #7862: [FLINK-11779] CLI ignores -m
parameter if high-availability is ZOOKEEPER
URL: https://github.com/apache/flink/pull/7862#issuecomment-468252495
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
flinkbot edited a comment on issue #7826: [hotfix] fix typos in description
URL: https://github.com/apache/flink/pull/7826#issuecomment-467018196
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will u
flinkbot edited a comment on issue #7822: [FLINK-11726][network] Refactor the
creation of ResultPartition and InputGate into NetworkEnvironment
URL: https://github.com/apache/flink/pull/7822#issuecomment-466952983
Thanks a lot for your contribution to the Apache Flink project. I'm the
@fli
Xeli commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source
connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#issuecomment-468731002
Hello @rmetzger
Let me address them point by point:
1.
I really like the i
flinkbot edited a comment on issue #7879: [FLINK-11791] Describe how to build
Flink with Hadoop in build guide
URL: https://github.com/apache/flink/pull/7879#issuecomment-468697094
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
TisonKun commented on a change in pull request #7880: [FLINK-11336][zk] Delete
ZNodes when ZooKeeperHaServices#closeAndCleanupAllData
URL: https://github.com/apache/flink/pull/7880#discussion_r261670182
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/highavailabi
[
https://issues.apache.org/jira/browse/FLINK-7175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-7175.
-
Resolution: Fixed
This was done by combination of external benchmark repository:
https://github.c
[
https://issues.apache.org/jira/browse/FLINK-11336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11336:
---
Labels: pull-request-available (was: )
> Flink HA didn't remove ZK metadata
> -
dawidwys commented on issue #7872: [FLINK-11420][core] Fixed duplicate method
of TraversableSerializer
URL: https://github.com/apache/flink/pull/7872#issuecomment-468717140
Could you have a look at this PR @igalshilman @aljoscha
flinkbot commented on issue #7880: [FLINK-11336][zk] Delete ZNodes when
ZooKeeperHaServices#closeAndCleanupAllData
URL: https://github.com/apache/flink/pull/7880#issuecomment-468714635
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
tillrohrmann opened a new pull request #7880: [FLINK-11336][zk] Delete ZNodes
when ZooKeeperHaServices#closeAndCleanupAllData
URL: https://github.com/apache/flink/pull/7880
## What is the purpose of the change
When calling ZooKeeperHaServices#closeAndCleanupAllData we should delete t
godfreyhe commented on issue #7642: [FLINK-11516][table] Port and move some
Descriptor classes to flink-table-common
URL: https://github.com/apache/flink/pull/7642#issuecomment-468713995
Looks good to me.
I want to extend `max` and `min` to `Comparable` type (e.g. `Date`, `Time`, `
B
[
https://issues.apache.org/jira/browse/FLINK-11397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-11397.
--
Resolution: Cannot Reproduce
I'm closing this issue, since there is no known performance issue
pnowojski edited a comment on issue #7713: [FLINK-10995][network] Copy
intermediate serialization results only once for broadcast mode
URL: https://github.com/apache/flink/pull/7713#issuecomment-468709668
@zhijiangW in what scenarios is the `RecordWriter` being used for
broadcasting messag
pnowojski edited a comment on issue #7713: [FLINK-10995][network] Copy
intermediate serialization results only once for broadcast mode
URL: https://github.com/apache/flink/pull/7713#issuecomment-468709668
@zhijiangW in what scenarios is the `RecordWriter` being used for
broadcasting messag
flinkbot edited a comment on issue #7713: [FLINK-10995][network] Copy
intermediate serialization results only once for broadcast mode
URL: https://github.com/apache/flink/pull/7713#issuecomment-463979858
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I h
pnowojski commented on issue #7713: [FLINK-10995][network] Copy intermediate
serialization results only once for broadcast mode
URL: https://github.com/apache/flink/pull/7713#issuecomment-468709668
@zhijiangW in what scenarios is the `RecordWriter` being used for
broadcasting messages? I'm
kl0u commented on a change in pull request #7876: [FLINK-11751] Extend release
notes for Flink 1.8
URL: https://github.com/apache/flink/pull/7876#discussion_r261649337
##
File path: docs/release-notes/#flink-1.8.md#
##
@@ -0,0 +1,174 @@
+ Notes - Flink 1.8"
+---
+
+
+
+The
kl0u commented on a change in pull request #7876: [FLINK-11751] Extend release
notes for Flink 1.8
URL: https://github.com/apache/flink/pull/7876#discussion_r261650097
##
File path: docs/release-notes/#flink-1.8.md#
##
@@ -0,0 +1,174 @@
+ Notes - Flink 1.8"
+---
+
+
+
+The
kl0u commented on a change in pull request #7876: [FLINK-11751] Extend release
notes for Flink 1.8
URL: https://github.com/apache/flink/pull/7876#discussion_r261647841
##
File path: docs/release-notes/#flink-1.8.md#
##
@@ -0,0 +1,174 @@
+ Notes - Flink 1.8"
+---
+
+
+
+The
kl0u commented on a change in pull request #7876: [FLINK-11751] Extend release
notes for Flink 1.8
URL: https://github.com/apache/flink/pull/7876#discussion_r261648174
##
File path: docs/release-notes/#flink-1.8.md#
##
@@ -0,0 +1,174 @@
+ Notes - Flink 1.8"
+---
+
+
+
+The
kl0u commented on a change in pull request #7876: [FLINK-11751] Extend release
notes for Flink 1.8
URL: https://github.com/apache/flink/pull/7876#discussion_r261649620
##
File path: docs/release-notes/#flink-1.8.md#
##
@@ -0,0 +1,174 @@
+ Notes - Flink 1.8"
+---
+
+
+
+The
kl0u commented on a change in pull request #7876: [FLINK-11751] Extend release
notes for Flink 1.8
URL: https://github.com/apache/flink/pull/7876#discussion_r261650358
##
File path: docs/release-notes/#flink-1.8.md#
##
@@ -0,0 +1,174 @@
+ Notes - Flink 1.8"
+---
+
+
+
+The
kl0u commented on a change in pull request #7876: [FLINK-11751] Extend release
notes for Flink 1.8
URL: https://github.com/apache/flink/pull/7876#discussion_r261647966
##
File path: docs/release-notes/#flink-1.8.md#
##
@@ -0,0 +1,174 @@
+ Notes - Flink 1.8"
+---
+
+
+
+The
kl0u commented on a change in pull request #7876: [FLINK-11751] Extend release
notes for Flink 1.8
URL: https://github.com/apache/flink/pull/7876#discussion_r261648896
##
File path: docs/release-notes/#flink-1.8.md#
##
@@ -0,0 +1,174 @@
+ Notes - Flink 1.8"
+---
+
+
+
+The
[
https://issues.apache.org/jira/browse/FLINK-11249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-11249:
-
Fix Version/s: (was: 1.8.0)
> FlinkKafkaProducer011 can not be migrated to FlinkKafk
[
https://issues.apache.org/jira/browse/FLINK-11420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-11420:
Assignee: Dawid Wysakowicz
> Serialization of case classes containing a Map[Strin
[
https://issues.apache.org/jira/browse/FLINK-11249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-11249:
-
Priority: Major (was: Blocker)
> FlinkKafkaProducer011 can not be migrated to FlinkKafk
[
https://issues.apache.org/jira/browse/FLINK-11249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-11249:
-
Fix Version/s: (was: 1.7.3)
> FlinkKafkaProducer011 can not be migrated to FlinkKafk
rmetzger commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source
connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#issuecomment-468698788
I've tested the PR a bit again, and I talked with @StephanEwen about the
`MultipleIdsMe
fpompermaier 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_r261639256
##
File path:
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/Parquet
flinkbot commented on issue #7879: [FLINK-11791] Describe how to build Flink
with Hadoop in build guide
URL: https://github.com/apache/flink/pull/7879#issuecomment-468697094
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
[
https://issues.apache.org/jira/browse/FLINK-11791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11791:
---
Labels: pull-request-available (was: )
> Describe how to build Flink with Hadoop in build g
aljoscha opened a new pull request #7879: [FLINK-11791] Describe how to build
Flink with Hadoop in build guide
URL: https://github.com/apache/flink/pull/7879
I think this might have to go away in the future but for now we still allow
people to do this. Plus I want to link to this from the
Fokko commented on issue #7519: FLINK-11378 - Allow writing to Hadoop
compatible Filesystems via Hado…
URL: https://github.com/apache/flink/pull/7519#issuecomment-468696725
We're running the GCS connector using the HDFS interface. We're having some
issues with performance, after firing up
Aljoscha Krettek created FLINK-11791:
Summary: Describe how to build Flink with Hadoop in build guide
Key: FLINK-11791
URL: https://issues.apache.org/jira/browse/FLINK-11791
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16781753#comment-16781753
]
Kurt Young commented on FLINK-11701:
fixed in 76f979b7d35125b161e5cd71a948b969aa712e
[
https://issues.apache.org/jira/browse/FLINK-11701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-11701.
--
Resolution: Fixed
Fix Version/s: 1.9.0
> Introduce an abstract set of data formats
> --
KurtYoung closed pull request #7816: [FLINK-11701][table-runtime-blink]
Introduce an abstract set of data formats
URL: https://github.com/apache/flink/pull/7816
This is an automated message from the Apache Git Service.
To re
[
https://issues.apache.org/jira/browse/FLINK-11724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-11724.
--
> Add copyToUnsafe, copyFromUnsafe and equalTo to MemorySegment
>
[
https://issues.apache.org/jira/browse/FLINK-11702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-11702.
--
> Introduce a new table type system: InternalType
> ---
>
>
Salatich opened a new pull request #7877: [FLINK-11320][Connectors / Kafka]
Support user callback in Kafka sink
URL: https://github.com/apache/flink/pull/7877
## What is the purpose of the change
Get user a possibility to provide a custom callback which should be created
based o
Salatich closed pull request #7877: [FLINK-11320][Connectors / Kafka] Support
user callback in Kafka sink
URL: https://github.com/apache/flink/pull/7877
This is an automated message from the Apache Git Service.
To respond to
KurtYoung commented on issue #7816: [FLINK-11701][table-runtime-blink]
Introduce an abstract set of data formats
URL: https://github.com/apache/flink/pull/7816#issuecomment-468692154
merging...
This is an automated message fr
rmetzger commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source
connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#issuecomment-468689632
> I currently see one exception quite often: `DEADLINE_EXCEEDED` which is
basically a t
twalthr commented on issue #7664: [FLINK-11449][table] Uncouple the Expression
class from RexNodes.
URL: https://github.com/apache/flink/pull/7664#issuecomment-468688050
FYI: I merged the third commit in a7aa58b62ccbb6e02f22ae1282e8fbc246641022.
[
https://issues.apache.org/jira/browse/FLINK-11789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16781722#comment-16781722
]
shengjk1 commented on FLINK-11789:
--
i think delete checkpoints/JOB_ID}} should con
[
https://issues.apache.org/jira/browse/FLINK-9003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-9003.
-
Resolution: Fixed
Merged on master with bbbd35c904e9e02d40fdac0ffe6f8d0b6cfaac85
and on release-
pnowojski edited a comment on issue #7604: [FLINK-11249] FlinkKafkaProducer011
can not be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7604#issuecomment-468682545
There were couple of issues with the tests that you proposed @tvielgouarin.
One of them was that yo
pnowojski edited a comment on issue #7604: [FLINK-11249] FlinkKafkaProducer011
can not be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7604#issuecomment-468682545
There were couple of issues with the tests that you proposed @tvielgouarin.
One of them was that yo
pnowojski edited a comment on issue #7604: [FLINK-11249] FlinkKafkaProducer011
can not be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7604#issuecomment-468682545
There were couple of issues with the tests that you proposed @tvielgouarin.
One of them was that yo
pnowojski commented on issue #7604: [FLINK-11249] FlinkKafkaProducer011 can not
be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7604#issuecomment-468682545
There were couple of issues with the tests that you proposed @tvielgouarin.
One of them was that you were
asfgit closed pull request #7846: [FLINK-9003][E2E] Add operators with input
type that goes through custom, stateful serialization
URL: https://github.com/apache/flink/pull/7846
This is an automated message from the Apache G
pnowojski commented on a change in pull request #6705: [FLINK-10356][network]
add sanity checks to SpillingAdaptiveSpanningRecordDeserializer
URL: https://github.com/apache/flink/pull/6705#discussion_r261607555
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/n
pnowojski commented on a change in pull request #6705: [FLINK-10356][network]
add sanity checks to SpillingAdaptiveSpanningRecordDeserializer
URL: https://github.com/apache/flink/pull/6705#discussion_r261617990
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/n
pnowojski commented on a change in pull request #6705: [FLINK-10356][network]
add sanity checks to SpillingAdaptiveSpanningRecordDeserializer
URL: https://github.com/apache/flink/pull/6705#discussion_r261610364
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/n
pnowojski commented on a change in pull request #6705: [FLINK-10356][network]
add sanity checks to SpillingAdaptiveSpanningRecordDeserializer
URL: https://github.com/apache/flink/pull/6705#discussion_r261612661
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/n
pnowojski commented on a change in pull request #6705: [FLINK-10356][network]
add sanity checks to SpillingAdaptiveSpanningRecordDeserializer
URL: https://github.com/apache/flink/pull/6705#discussion_r261614343
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/n
1 - 100 of 274 matches
Mail list logo
