[
https://issues.apache.org/jira/browse/FLINK-8327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raymond Tay updated FLINK-8327:
---
Environment:
h3. Environment
* Local flink cluster version 1.4.0
* {{classloader.resolve-order: child-
[
https://issues.apache.org/jira/browse/FLINK-8327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raymond Tay updated FLINK-8327:
---
Description:
h2. Description
Was trying out the {{Queryable State}} and ran into a problem where the
[
https://issues.apache.org/jira/browse/FLINK-8327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raymond Tay updated FLINK-8327:
---
Environment:
h3. Environment
* Local flink cluster version 1.4.0
* {{classloader.resolve-order: child-
[
https://issues.apache.org/jira/browse/FLINK-8327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raymond Tay updated FLINK-8327:
---
Description:
h2. Description
Was trying out the {{Queryable State}} and ran into a problem where the
[
https://issues.apache.org/jira/browse/FLINK-8327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raymond Tay updated FLINK-8327:
---
Environment:
h3. Environment
* Local flink cluster version 1.4.0
* {{classloader.resolve-order: chil
Raymond Tay created FLINK-8327:
--
Summary: ClassLoader resolution of child-first does not appear to
work
Key: FLINK-8327
URL: https://issues.apache.org/jira/browse/FLINK-8327
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-4817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-4817:
--
Assignee: Wei-Che Wei
> Checkpoint Coordinator should be called to restore state with a specifi
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305966#comment-16305966
]
ASF GitHub Bot commented on FLINK-7797:
---
Github user xccui commented on a diff in th
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/5140#discussion_r159023858
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala
---
@@ -142,50 +143,47 @@ class D
[
https://issues.apache.org/jira/browse/FLINK-8324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305890#comment-16305890
]
ASF GitHub Bot commented on FLINK-8324:
---
GitHub user tony810430 opened a pull reques
GitHub user tony810430 opened a pull request:
https://github.com/apache/flink/pull/5214
[FLINK-8324] [kafka] Expose another offsets metrics by using new metric API
to specify user defined variables
## What is the purpose of the change
Add two metrics for current offsets and
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305847#comment-16305847
]
ASF GitHub Bot commented on FLINK-7797:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305855#comment-16305855
]
ASF GitHub Bot commented on FLINK-7797:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305851#comment-16305851
]
ASF GitHub Bot commented on FLINK-7797:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305850#comment-16305850
]
ASF GitHub Bot commented on FLINK-7797:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305856#comment-16305856
]
ASF GitHub Bot commented on FLINK-7797:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305854#comment-16305854
]
ASF GitHub Bot commented on FLINK-7797:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305859#comment-16305859
]
ASF GitHub Bot commented on FLINK-7797:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305857#comment-16305857
]
ASF GitHub Bot commented on FLINK-7797:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305852#comment-16305852
]
ASF GitHub Bot commented on FLINK-7797:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305858#comment-16305858
]
ASF GitHub Bot commented on FLINK-7797:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305853#comment-16305853
]
ASF GitHub Bot commented on FLINK-7797:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305849#comment-16305849
]
ASF GitHub Bot commented on FLINK-7797:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305860#comment-16305860
]
ASF GitHub Bot commented on FLINK-7797:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5140#discussion_r159012674
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamJoin.scala
---
@@ -268,13 +364,16 @@ abstract clas
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5140#discussion_r158738627
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinAwareCollector.scala
---
@@ -0,0 +1,68 @@
+/*
+ * Licen
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5140#discussion_r159012976
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamJoin.scala
---
@@ -382,6 +498,29 @@ abstract class
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305848#comment-16305848
]
ASF GitHub Bot commented on FLINK-7797:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5140#discussion_r159014190
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamJoin.scala
---
@@ -133,6 +149,19 @@ abstract class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5140#discussion_r159011164
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamJoin.scala
---
@@ -182,16 +196,64 @@ abstract clas
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5140#discussion_r159012517
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamJoin.scala
---
@@ -241,17 +288,66 @@ abstract clas
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5140#discussion_r159013964
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/JoinITCase.scala
---
@@ -461,6 +462,302 @@ class JoinITCase e
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5140#discussion_r159013510
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/StreamWindowJoinHarnessTest.scala
---
@@ -20,20 +20,25 @@ packag
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5140#discussion_r159009795
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamJoin.scala
---
@@ -62,15 +65,23 @@ abstract class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5140#discussion_r159010693
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamJoin.scala
---
@@ -182,16 +196,64 @@ abstract clas
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5140#discussion_r159011797
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinAwareCollector.scala
---
@@ -0,0 +1,68 @@
+/*
+ * Licen
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5140#discussion_r159014072
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/JoinITCase.scala
---
@@ -461,6 +462,302 @@ class JoinITCase e
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5140#discussion_r159010195
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamJoin.scala
---
@@ -143,29 +172,14 @@ abstract clas
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5140#discussion_r158737260
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala
---
@@ -142,50 +143,47 @@ class
[
https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305745#comment-16305745
]
Seth Wiesman commented on FLINK-3655:
-
[~fhueske] I have been looking for this feature
GitHub user yew1eb opened a pull request:
https://github.com/apache/flink/pull/5213
[docs][metrics] Fix typo of metrics docs
## What is the purpose of the change
1. Fix typo of Threads.Count metric in docs.
2. Fix `Liquid Exception: highlight tag was never closed in
monitor
[
https://issues.apache.org/jira/browse/FLINK-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305614#comment-16305614
]
Shashank Agarwal commented on FLINK-7760:
-
No I have’t changed the version or code
[
https://issues.apache.org/jira/browse/FLINK-7949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305562#comment-16305562
]
ASF GitHub Bot commented on FLINK-7949:
---
Github user bartektartanus commented on the
Github user bartektartanus commented on the issue:
https://github.com/apache/flink/pull/4924
Hi @tillrohrmann
I've finally managed to write a simple test that fails without my change in
AsyncWaitOperator class. Test steps:
1. add enough records to fill up the AsyncWaitOperator
[
https://issues.apache.org/jira/browse/FLINK-8323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305552#comment-16305552
]
ASF GitHub Bot commented on FLINK-8323:
---
GitHub user sunjincheng121 opened a pull re
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/5212
[FLINK-8323][table] fix MOD scalar function bug.
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the community review your
[
https://issues.apache.org/jira/browse/FLINK-8169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305527#comment-16305527
]
sunjincheng commented on FLINK-8169:
Hi [~twalthr] +1 to clear the processing of time
[
https://issues.apache.org/jira/browse/FLINK-8319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-8319.
-
Resolution: Duplicate
Seems similar to https://issues.apache.org/jira/browse/FLINK-7756
> Savepoi
[
https://issues.apache.org/jira/browse/FLINK-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305505#comment-16305505
]
Kostas Kloudas commented on FLINK-7760:
---
This looks like either a backwards compatib
[
https://issues.apache.org/jira/browse/FLINK-8312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305504#comment-16305504
]
ASF GitHub Bot commented on FLINK-8312:
---
Github user sunjincheng121 commented on the
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/5206
@Xpray Thanks for the update.
+1 to merged.
Best, Jincheng
---
[
https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305502#comment-16305502
]
Kostas Kloudas commented on FLINK-7756:
---
Hi [~shashank734]. Could you try to see if
[
https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-5506.
-
Resolution: Fixed
master: a355df6e33f402beac01c2908cb0c64cfeccadb2
release-1.4: 96051e516bdc114b04c5a3cbb7
[
https://issues.apache.org/jira/browse/FLINK-8326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305313#comment-16305313
]
ASF GitHub Bot commented on FLINK-8326:
---
GitHub user tony810430 opened a pull reques
GitHub user tony810430 opened a pull request:
https://github.com/apache/flink/pull/5211
[FLINK-8326] [chks]
CheckpointCoordinatorTest#testRestoreLatestCheckpointedStateScaleOut() didn't
use the correct parameter to trigger test function
## What is the purpose of the change
Wei-Che Wei created FLINK-8326:
--
Summary:
CheckpointCoordinatorTest#testRestoreLatestCheckpointedStateScaleOut() didn't
use the correct parameter to trigger test function
Key: FLINK-8326
URL: https://issues.apache.o
[
https://issues.apache.org/jira/browse/FLINK-8316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16305173#comment-16305173
]
ASF GitHub Bot commented on FLINK-8316:
---
GitHub user xccui opened a pull request:
GitHub user xccui opened a pull request:
https://github.com/apache/flink/pull/5210
[FLINK-8316][table]The CsvTableSink and the CsvInputFormat are not in sync
## What is the purpose of the change
This PR adds an extra parameter (`trailingDelim`) to `CsvTableSink` to
enable a
sunjincheng created FLINK-8325:
--
Summary: Add support for constant parameters in GROUP WINDOW
aggregate
Key: FLINK-8325
URL: https://issues.apache.org/jira/browse/FLINK-8325
Project: Flink
Issu
59 matches
Mail list logo
