[
https://issues.apache.org/jira/browse/FLINK-7495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309599#comment-16309599
]
ASF GitHub Bot commented on FLINK-7495:
---
Github user aljoscha commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened FLINK-7495:
-
Reopen to change fix versions
> AbstractUdfStreamOperator#initializeState() should be called
[
https://issues.apache.org/jira/browse/FLINK-7495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-7495.
---
Resolution: Fixed
Fix Version/s: 1.3.3
Fixed on release-1.3 in
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4621
@PedroMrChaves Thanks, I also merged on the `release-1.3` branch so it will
be released if/when a Flink 1.3.3 gets released.
---
[
https://issues.apache.org/jira/browse/FLINK-5880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309592#comment-16309592
]
Aljoscha Krettek commented on FLINK-5880:
-
Sure, but the main point of that blog-post is the use
[
https://issues.apache.org/jira/browse/FLINK-8334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-8334.
---
Resolution: Not A Problem
> Elasticsearch Connector throwing
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5208
With this change we will have Jackson shaded/relocated twice in
`flink-dist`: once under `org.apacha.flink.shaded.jackson2` and once under
`org.apache.flink.mesos.shaded`.
@zentol Wouldn't
[
https://issues.apache.org/jira/browse/FLINK-8265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309587#comment-16309587
]
ASF GitHub Bot commented on FLINK-8265:
---
Github user aljoscha commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309574#comment-16309574
]
ASF GitHub Bot commented on FLINK-8323:
---
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/5212#discussion_r159413615
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/ScalarOperators.scala
---
@@ -47,9 +47,22 @@ object
[
https://issues.apache.org/jira/browse/FLINK-8323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309557#comment-16309557
]
ASF GitHub Bot commented on FLINK-8323:
---
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/5212#discussion_r159411155
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarFunctionsTest.scala
---
@@ -356,8 +356,117 @@ class
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5219#discussion_r159401004
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -659,128 +655,107 @@ protected int savepoint(String[] args) {
[
https://issues.apache.org/jira/browse/FLINK-8332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309499#comment-16309499
]
ASF GitHub Bot commented on FLINK-8332:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309500#comment-16309500
]
ASF GitHub Bot commented on FLINK-8332:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309496#comment-16309496
]
ASF GitHub Bot commented on FLINK-8332:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309497#comment-16309497
]
ASF GitHub Bot commented on FLINK-8332:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5219#discussion_r159252679
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/CliFrontendSavepointTest.java
---
@@ -77,23 +74,25 @@
public void
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5219#discussion_r159402067
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/CliFrontendSavepointTest.java
---
@@ -178,65 +185,30 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-8332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309495#comment-16309495
]
ASF GitHub Bot commented on FLINK-8332:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309498#comment-16309498
]
ASF GitHub Bot commented on FLINK-8332:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5219#discussion_r159403066
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/CliFrontendSavepointTest.java
---
@@ -178,65 +185,30 @@ public void
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5219#discussion_r159400326
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/CliFrontendSavepointTest.java
---
@@ -149,23 +153,26 @@ public void
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5219#discussion_r159255690
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/CliFrontendSavepointTest.java
---
@@ -128,13 +131,14 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-8169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309486#comment-16309486
]
Timo Walther commented on FLINK-8169:
-
I added FLINK-8353 where we can continue the discussion.
>
Timo Walther created FLINK-8353:
---
Summary: Add support for timezones
Key: FLINK-8353
URL: https://issues.apache.org/jira/browse/FLINK-8353
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-8169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309481#comment-16309481
]
Timo Walther commented on FLINK-8169:
-
Hi [~sunjincheng121], this issue should actually only improve
Github user xccui commented on the issue:
https://github.com/apache/flink/pull/5169
Thanks for the review @twalthr ð
---
[
https://issues.apache.org/jira/browse/FLINK-8258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309471#comment-16309471
]
ASF GitHub Bot commented on FLINK-8258:
---
Github user xccui commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309469#comment-16309469
]
ASF GitHub Bot commented on FLINK-8258:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5169
---
[
https://issues.apache.org/jira/browse/FLINK-8258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-8258.
-
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed in 1.5:
[
https://issues.apache.org/jira/browse/FLINK-8258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309454#comment-16309454
]
ASF GitHub Bot commented on FLINK-8258:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/5169
Thank you @xccui. Looks good to me. I will merge this...
---
[
https://issues.apache.org/jira/browse/FLINK-8323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309428#comment-16309428
]
ASF GitHub Bot commented on FLINK-8323:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309427#comment-16309427
]
ASF GitHub Bot commented on FLINK-8323:
---
Github user twalthr commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5212#discussion_r159392048
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarFunctionsTest.scala
---
@@ -356,8 +356,117 @@ class
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5212#discussion_r159393961
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/ScalarOperators.scala
---
@@ -47,9 +47,22 @@ object
[
https://issues.apache.org/jira/browse/FLINK-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309388#comment-16309388
]
ASF GitHub Bot commented on FLINK-7475:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4963#discussion_r159388932
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBListState.java
---
@@ -158,4
[
https://issues.apache.org/jira/browse/FLINK-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309387#comment-16309387
]
ASF GitHub Bot commented on FLINK-7475:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4963#discussion_r159388540
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBListState.java
---
@@ -158,4
[
https://issues.apache.org/jira/browse/FLINK-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309381#comment-16309381
]
ASF GitHub Bot commented on FLINK-7475:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4963#discussion_r159388106
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/util/MergeUtils.java
---
@@ -0,0 +1,63 @@
[
https://issues.apache.org/jira/browse/FLINK-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309378#comment-16309378
]
ASF GitHub Bot commented on FLINK-7475:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4963#discussion_r159387906
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/util/MergeUtilsTest.java
---
@@ -0,0 +1,46
[
https://issues.apache.org/jira/browse/FLINK-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309380#comment-16309380
]
ASF GitHub Bot commented on FLINK-7475:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4963#discussion_r159387760
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapListState.java
---
@@ -120,4 +121,16 @@ public void add(V value) {
[
https://issues.apache.org/jira/browse/FLINK-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309377#comment-16309377
]
ASF GitHub Bot commented on FLINK-7475:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4963#discussion_r159387626
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackend.java
---
@@ -497,6 +497,15 @@ public String
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4963#discussion_r159386696
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/util/MergeUtils.java
---
@@ -0,0 +1,63 @@
[
https://issues.apache.org/jira/browse/FLINK-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309369#comment-16309369
]
ASF GitHub Bot commented on FLINK-7475:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4963#discussion_r159386188
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/util/MergeUtils.java
---
@@ -0,0 +1,63 @@
[
https://issues.apache.org/jira/browse/FLINK-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309365#comment-16309365
]
ASF GitHub Bot commented on FLINK-7475:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309357#comment-16309357
]
ASF GitHub Bot commented on FLINK-8175:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309358#comment-16309358
]
ASF GitHub Bot commented on FLINK-8175:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5112#discussion_r159384609
--- Diff:
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/experimental/package.scala
---
@@ -16,23 +16,25 @@
* limitations under
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5112#discussion_r159384731
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/streaming/experimental/CollectITCase.java
---
@@ -7,7 +7,7 @@
* "License"); you may not
[
https://issues.apache.org/jira/browse/FLINK-8322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309341#comment-16309341
]
ASF GitHub Bot commented on FLINK-8322:
---
GitHub user bowenli86 opened a pull request:
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/5236
[FLINK-8322] support getting number of existing timers in TimerService
## What is the purpose of the change
There are pretty common use cases where users want to use timers as
[
https://issues.apache.org/jira/browse/FLINK-6206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309273#comment-16309273
]
ASF GitHub Bot commented on FLINK-6206:
---
GitHub user tygrash opened a pull request:
GitHub user tygrash opened a pull request:
https://github.com/apache/flink/pull/5235
[FLINK-6206] [runtime] Changed log level to for task state transition log
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the
[
https://issues.apache.org/jira/browse/FLINK-8322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-8322:
Description: There are pretty common use cases where users want to use
timers as scheduled threads - e.g.
101 - 163 of 163 matches
Mail list logo
