[
https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-6918:
-
Labels: test-stability (was: )
> Failing tests: ChainLengthDecreaseTest and
[
https://issues.apache.org/jira/browse/FLINK-6893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050058#comment-16050058
]
ASF GitHub Bot commented on FLINK-6893:
---
GitHub user sunjincheng121 opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050056#comment-16050056
]
mingleizhang commented on FLINK-4602:
-
[~Zentol] Oh. Thanks, I see. I will not do it until 2.0 should
[
https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050057#comment-16050057
]
Till Rohrmann commented on FLINK-6918:
--
Another instance: This time for the
[
https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-6918:
-
Priority: Critical (was: Major)
> Failing tests: ChainLengthDecreaseTest and
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/4128
[FLINK-6893][table]Add BIN supported in SQL
In this PR. have Add BIN supported in SQL,e.g.:
```
BIN(12) -> "1100"
BIN(10)-> "1010"
```
- [x] General
- The pull
[
https://issues.apache.org/jira/browse/FLINK-3387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050068#comment-16050068
]
mingleizhang commented on FLINK-3387:
-
Hey, [~sbcd90] Are you still working on this yet ?
> Replace
sunjincheng created FLINK-6924:
--
Summary: ADD LOG/LPAD/RPAD/BIN supported in TableAPI
Key: FLINK-6924
URL: https://issues.apache.org/jira/browse/FLINK-6924
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050045#comment-16050045
]
Chesnay Schepler commented on FLINK-4602:
-
[~mingleizhang] This issue is marked for 2.0 since it
[
https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050066#comment-16050066
]
sunjincheng commented on FLINK-6895:
Hi, [~wheat9] I noticed that you had opened a nice PR(4078).
[
https://issues.apache.org/jira/browse/FLINK-6893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-6893:
--
Assignee: sunjincheng
> Add BIN supported in SQL
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050072#comment-16050072
]
Till Rohrmann commented on FLINK-6918:
--
Once FLINK-4714 has been fixed, this issue should resolve as
[
https://issues.apache.org/jira/browse/FLINK-6602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050224#comment-16050224
]
Fabian Hueske commented on FLINK-6602:
--
The fix looks good! Please open a pull request with that :-)
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4093
---
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
[
https://issues.apache.org/jira/browse/FLINK-6263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050148#comment-16050148
]
Konstantin Lalafaryan commented on FLINK-6263:
--
What is the status of this bug ? We have the
[
https://issues.apache.org/jira/browse/FLINK-6263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050152#comment-16050152
]
Tzu-Li (Gordon) Tai commented on FLINK-6263:
Could you briefly describe how / when this error
Github user StefanRRichter commented on the pull request:
https://github.com/apache/flink/commit/9141379f6d2654886d48154b453170cc23b89a87#commitcomment-22558757
In
flink-runtime/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopDataInputStream.java:
In
[
https://issues.apache.org/jira/browse/FLINK-6776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050180#comment-16050180
]
ASF GitHub Bot commented on FLINK-6776:
---
Github user StefanRRichter closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-6776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050179#comment-16050179
]
ASF GitHub Bot commented on FLINK-6776:
---
Github user StefanRRichter commented on the issue:
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4111#discussion_r122152659
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -871,12 +871,24 @@ class CodeGenerator(
[
https://issues.apache.org/jira/browse/FLINK-6602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-6602:
Assignee: Zhe Li
> Table source with defined time attributes allows empty string
>
[
https://issues.apache.org/jira/browse/FLINK-6748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050243#comment-16050243
]
ASF GitHub Bot commented on FLINK-6748:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4094
---
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
[
https://issues.apache.org/jira/browse/FLINK-6750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050244#comment-16050244
]
ASF GitHub Bot commented on FLINK-6750:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-6918:
Assignee: Till Rohrmann
> Failing tests: ChainLengthDecreaseTest and
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4129
[FLINK-6918] [tests] Harden AbstractOperatorRestoreTestBase by retrying
CancelWithSavepoint messages
The problem is that a StreamTask can be in state RUNNING without internally
being running.
[
https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050077#comment-16050077
]
ASF GitHub Bot commented on FLINK-6918:
---
GitHub user tillrohrmann opened a pull request:
sunjincheng created FLINK-6926:
--
Summary: Add MD5/SHA1/SHA2 supported in SQL
Key: FLINK-6926
URL: https://issues.apache.org/jira/browse/FLINK-6926
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-6927:
--
Summary: Support pattern group in CEP
Key: FLINK-6927
URL: https://issues.apache.org/jira/browse/FLINK-6927
Project: Flink
Issue Type: Bug
Components: CEP
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4120
The PR descriptions says that you're downgrading the dependency versions,
but with the second commit your actually upgrading them.
Also, couldn't we move the dependency management into
[
https://issues.apache.org/jira/browse/FLINK-5659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050158#comment-16050158
]
ASF GitHub Bot commented on FLINK-5659:
---
Github user zentol closed the pull request at:
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/3219
---
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
[
https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050157#comment-16050157
]
Tzu-Li (Gordon) Tai commented on FLINK-6928:
I agree that the {{defaultTopic}} configuration
[
https://issues.apache.org/jira/browse/FLINK-6836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050238#comment-16050238
]
ASF GitHub Bot commented on FLINK-6836:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4120
I first thought I had to downgrade, because of the aforementioned problem.
However, Hadoop 2.8.0 needs at least httpclient `4.5.2`. Luckily, they fixed
the problem with the
[
https://issues.apache.org/jira/browse/FLINK-6602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050038#comment-16050038
]
Zhe Li commented on FLINK-6602:
---
Fabian，
I understand what you mean.
So I modified the codes in
[
https://issues.apache.org/jira/browse/FLINK-6836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050134#comment-16050134
]
ASF GitHub Bot commented on FLINK-6836:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Erik van Oosten updated FLINK-6928:
---
Description:
When using a Kafka sink, the defaultTopic needs to exist even when it is never
[
https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Erik van Oosten updated FLINK-6928:
---
Description:
When using a Kafka sink, the defaultTopic needs to exist even when it is never
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/4019
Merged in 9141379f6d.
---
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
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/commit/9141379f6d2654886d48154b453170cc23b89a87#commitcomment-22558746
Good change, but I think this could use a guarding unit test.
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-6776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-6776.
-
Resolution: Implemented
Fix Version/s: 1.4.0
Implemented in 9141379f6d
> Use skip instead
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/commit/9141379f6d2654886d48154b453170cc23b89a87#commitcomment-22558742
In
flink-runtime/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopDataInputStream.java:
In
Github user StefanRRichter closed the pull request at:
https://github.com/apache/flink/pull/4019
---
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
Erik van Oosten created FLINK-6928:
--
Summary: Kafka source: default topic needs to exist
Key: FLINK-6928
URL: https://issues.apache.org/jira/browse/FLINK-6928
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-6891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6891:
---
Description:
LOG(X), LOG(B,X)
If called with one parameter, this function returns the natural
[
https://issues.apache.org/jira/browse/FLINK-6046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050450#comment-16050450
]
Nico Kruber commented on FLINK-6046:
since the broken cleanup for the current blob store is a deal
[
https://issues.apache.org/jira/browse/FLINK-6682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050370#comment-16050370
]
ASF GitHub Bot commented on FLINK-6682:
---
Github user zhangminglei commented on the issue:
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/4125
Hi @zentol . Please helps review if you are free, should I add some extra
information ? Thanks.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-5908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-5908:
---
Fix Version/s: (was: 1.4.0)
(was: 1.2.2)
> Blob Cache can (rarely) get
[
https://issues.apache.org/jira/browse/FLINK-5908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050456#comment-16050456
]
Nico Kruber commented on FLINK-5908:
let's solve this during the re-write of the BLOB store with
Fabian Hueske created FLINK-6930:
Summary: Selecting window start / end on row-based Tumble/Slide
window causes NPE
Key: FLINK-6930
URL: https://issues.apache.org/jira/browse/FLINK-6930
Project:
[
https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5991:
---
Labels: (was: api-breaking api-deprecation)
> Expose Broadcast Operator State
[
https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5991:
---
Labels: api-breaking api-deprecation (was: )
> Expose Broadcast Operator State
[
https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050423#comment-16050423
]
ASF GitHub Bot commented on FLINK-6896:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4111#discussion_r122194058
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -871,12 +871,24 @@ class CodeGenerator(
[
https://issues.apache.org/jira/browse/FLINK-6046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-6046:
---
Component/s: Network
> Add support for oversized messages during deployment
>
[
https://issues.apache.org/jira/browse/FLINK-5908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-5908:
---
Component/s: Network
> Blob Cache can (rarely) get corrupted on failed blob downloads
>
[
https://issues.apache.org/jira/browse/FLINK-5908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-5908:
---
Affects Version/s: 1.4.0
1.3.0
> Blob Cache can (rarely) get corrupted on
[
https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050474#comment-16050474
]
ASF GitHub Bot commented on FLINK-6896:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4111#discussion_r122201344
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -871,12 +871,24 @@ class CodeGenerator(
[
https://issues.apache.org/jira/browse/FLINK-6751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6751:
-
Issue Type: Task (was: Sub-task)
Parent: (was: FLINK-5354)
> Table API / SQL Docs:
[
https://issues.apache.org/jira/browse/FLINK-6917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6917:
---
Labels: (was: ta)
> Introduce test base for end-to-end testing serializer config
[
https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050271#comment-16050271
]
ASF GitHub Bot commented on FLINK-6896:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4111#discussion_r122168412
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -871,12 +871,24 @@ class CodeGenerator(
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4111#discussion_r122176275
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -871,12 +871,24 @@ class
[
https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050358#comment-16050358
]
ASF GitHub Bot commented on FLINK-6896:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6747:
-
Issue Type: Task (was: Sub-task)
Parent: (was: FLINK-5354)
> Table API / SQL Docs:
[
https://issues.apache.org/jira/browse/FLINK-6747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-6747:
Assignee: Fabian Hueske
> Table API / SQL Docs: Streaming Page
>
[
https://issues.apache.org/jira/browse/FLINK-6750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6750:
-
Comment: was deleted
(was: Done for 1.3.1 with 89850f21dc596b2b845ce98433263496e512ef54
Done for
[
https://issues.apache.org/jira/browse/FLINK-6748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-6748.
Resolution: Done
Fix Version/s: 1.4.0
1.3.1
Done for 1.3.1 with
[
https://issues.apache.org/jira/browse/FLINK-6751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6751:
-
Description:
Update and extend the documentation of UDFs in the Table API / SQL:
[
https://issues.apache.org/jira/browse/FLINK-6750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6750:
-
Description:
Update and refine the documentation about TableSources and TableSinks.
There are a
Fabian Hueske created FLINK-6929:
Summary: Add documentation for Table API OVER windows
Key: FLINK-6929
URL: https://issues.apache.org/jira/browse/FLINK-6929
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050332#comment-16050332
]
ASF GitHub Bot commented on FLINK-6896:
---
Github user sunjincheng121 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050341#comment-16050341
]
ASF GitHub Bot commented on FLINK-6896:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4111#discussion_r122178152
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -871,12 +871,24 @@ class CodeGenerator(
[
https://issues.apache.org/jira/browse/FLINK-6750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6750:
-
Issue Type: Task (was: Sub-task)
Parent: (was: FLINK-5354)
> Table API / SQL Docs:
[
https://issues.apache.org/jira/browse/FLINK-6747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6747:
-
Description:
Extend {{./docs/dev/table/streaming.md}} page.
Missing are sections about
- Dynamic
[
https://issues.apache.org/jira/browse/FLINK-5354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5354.
Resolution: Done
Fix Version/s: 1.4.0
1.3.1
Done for 1.3.1 with
[
https://issues.apache.org/jira/browse/FLINK-6917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6917:
---
Labels: ta (was: )
> Introduce test base for end-to-end testing serializer config
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4111#discussion_r122168658
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -871,12 +871,24 @@ class CodeGenerator(
[
https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050272#comment-16050272
]
ASF GitHub Bot commented on FLINK-6896:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-6750.
--
Resolution: Fixed
Fix Version/s: 1.4.0
1.3.1
Done for 1.3.1 with
[
https://issues.apache.org/jira/browse/FLINK-6750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reopened FLINK-6750:
--
> Table API / SQL Docs: Table Sources & Sinks Page
>
[
https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050326#comment-16050326
]
ASF GitHub Bot commented on FLINK-6896:
---
Github user sunjincheng121 commented on a diff in the pull
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4111#discussion_r122176847
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -871,12 +871,24 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4111#discussion_r122180812
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -871,12 +871,24 @@ class CodeGenerator(
Stefan Richter created FLINK-6931:
-
Summary: Support custom compression formats for checkpoints
(+Upgrade/Compatibility)
Key: FLINK-6931
URL: https://issues.apache.org/jira/browse/FLINK-6931
Project:
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/4130
[FLINK-6773] [checkpoint] Introduce compression (snappy) for keyed stâ¦
This PR introduce optional snappy compression for the keyed state in full
checkpoints and savepoints. This feature
[
https://issues.apache.org/jira/browse/FLINK-6836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050495#comment-16050495
]
ASF GitHub Bot commented on FLINK-6836:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4120
+1 to merge.
---
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
[
https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050502#comment-16050502
]
ASF GitHub Bot commented on FLINK-6896:
---
Github user sunjincheng121 commented on a diff in the pull
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4111#discussion_r122205799
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -871,12 +871,24 @@ class
[
https://issues.apache.org/jira/browse/FLINK-6773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050508#comment-16050508
]
ASF GitHub Bot commented on FLINK-6773:
---
GitHub user StefanRRichter opened a pull request:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/4130
CC @tillrohrmann
---
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
[
https://issues.apache.org/jira/browse/FLINK-6773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050513#comment-16050513
]
ASF GitHub Bot commented on FLINK-6773:
---
Github user StefanRRichter commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050535#comment-16050535
]
Fabian Hueske commented on FLINK-6886:
--
Maybe there's another way to fix this problem. I played a bit
[
https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050537#comment-16050537
]
ASF GitHub Bot commented on FLINK-6896:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050551#comment-16050551
]
Alexander Chermenin commented on FLINK-4641:
Hi [~dian.fu]! Yes of course, you're welcome!
1 - 100 of 148 matches
Mail list logo
