[
https://issues.apache.org/jira/browse/FLINK-7024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178065#comment-16178065
]
ASF GitHub Bot commented on FLINK-7024:
---
Github user sunjincheng121 commented on the issue:
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/4210
Hi @wuchong I had rebase the PR. Please look at the PR. :-)
Thanks, jincheng
---
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178062#comment-16178062
]
ASF GitHub Bot commented on FLINK-7465:
---
Github user sunjincheng121 commented on the issue:
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/4652
@fhueske @Jacob Park I am appreciated if you can review the PR.
Thanks, jincheng
---
[
https://issues.apache.org/jira/browse/FLINK-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178061#comment-16178061
]
ASF GitHub Bot commented on FLINK-6465:
---
Github user sunjincheng121 commented on the issue:
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/4556
I have update the PP. Please look at the PR. :) @fhueske @twalthr @wuchong
@shaoxuan-wang
---
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4665#discussion_r140645413
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/EvictingWindowOperator.java
---
@@ -231,6 +231,8 @@
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178044#comment-16178044
]
ASF GitHub Bot commented on FLINK-6233:
---
Github user xccui commented on a diff in the pull request:
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4625#discussion_r140645274
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala
---
@@ -131,340 +116,308 @@ class
[
https://issues.apache.org/jira/browse/FLINK-7674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178036#comment-16178036
]
ASF GitHub Bot commented on FLINK-7674:
---
GitHub user bowenli86 opened a pull request:
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/4711
[FLINK-7674][Streaming Connectors] NullPointerException in
ContinuousFileMonitoringFunction close
## What is the purpose of the change
If the ContinuousFileMonitoringFunction is closed
[
https://issues.apache.org/jira/browse/FLINK-7674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-7674:
---
Assignee: Bowen Li
> NullPointerException in ContinuousFileMonitoringFunction close
>
[
https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7635:
Priority: Major (was: Minor)
> Support sideOutput in ProcessWindowFunciton
>
[
https://issues.apache.org/jira/browse/FLINK-7677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li resolved FLINK-7677.
-
Resolution: Duplicate
> Add side outputs to ProcessWindowFunction
>
[
https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7635:
Fix Version/s: (was: 1.3.3)
> Support sideOutput in ProcessWindowFunciton
>
[
https://issues.apache.org/jira/browse/FLINK-6893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178014#comment-16178014
]
ASF GitHub Bot commented on FLINK-6893:
---
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/4128#discussion_r140644236
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/sql/ScalarSqlFunctions.scala
---
@@ -33,6 +33,14 @@ object
[
https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16178004#comment-16178004
]
ASF GitHub Bot commented on FLINK-7446:
---
GitHub user fhueske opened a pull request:
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/4710
[FLINK-7446] [table] Change DefinedRowtimeAttribute to work on existing
field.
## What is the purpose of the change
Changes the contract of the `DefinedRowtimeAttribute` interface. The
Ted Yu created FLINK-7679:
-
Summary: Upgrade maven enforcer plugin to 3.0.0-M1
Key: FLINK-7679
URL: https://issues.apache.org/jira/browse/FLINK-7679
Project: Flink
Issue Type: Bug
Rong Rong created FLINK-7678:
Summary: SQL UserDefineTableFunction does not take CompositeType
input correctly
Key: FLINK-7678
URL: https://issues.apache.org/jira/browse/FLINK-7678
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16177962#comment-16177962
]
Tzu-Li (Gordon) Tai edited comment on FLINK-7673 at 9/23/17 8:23 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-7673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16177962#comment-16177962
]
Tzu-Li (Gordon) Tai edited comment on FLINK-7673 at 9/23/17 8:21 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-7673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16177962#comment-16177962
]
Tzu-Li (Gordon) Tai commented on FLINK-7673:
Yes, it would definitely be nice to eventually
Ufuk Celebi created FLINK-7677:
--
Summary: Add side outputs to ProcessWindowFunction
Key: FLINK-7677
URL: https://issues.apache.org/jira/browse/FLINK-7677
Project: Flink
Issue Type: Improvement
Github user Aitozi commented on a diff in the pull request:
https://github.com/apache/flink/pull/4665#discussion_r140635202
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/EvictingWindowOperator.java
---
@@ -231,6 +231,8 @@
Github user Aitozi commented on a diff in the pull request:
https://github.com/apache/flink/pull/4665#discussion_r140634868
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java
---
@@ -405,6 +411,8 @@ public void
Ufuk Celebi created FLINK-7676:
--
Summary: ContinuousFileMonitoringFunction fails with
GoogleHadoopFileSystem
Key: FLINK-7676
URL: https://issues.apache.org/jira/browse/FLINK-7676
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16177734#comment-16177734
]
ASF GitHub Bot commented on FLINK-7675:
---
GitHub user tony810430 opened a pull request:
GitHub user tony810430 opened a pull request:
https://github.com/apache/flink/pull/4709
[FLINK-7675] [metrics] LatestCompletedCheckpointExternalPathGauge should
check if external path is exist
- check if external path is null
- update test to test the corresponding behavior
[
https://issues.apache.org/jira/browse/FLINK-7675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei updated FLINK-7675:
---
Description:
For internal checkpoint, {{CompletedCheckpointStats.getExternalPath()}} could
be
[
https://issues.apache.org/jira/browse/FLINK-7675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei updated FLINK-7675:
---
Description:
For internal checkpoint, {{CompletedCheckpointStats.getExternalPath()}} could
be
[
https://issues.apache.org/jira/browse/FLINK-7675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-7675:
--
Assignee: Wei-Che Wei
> LatestCompletedCheckpointExternalPathGauge should check if external
Wei-Che Wei created FLINK-7675:
--
Summary: LatestCompletedCheckpointExternalPathGauge should check
if external path is exist
Key: FLINK-7675
URL: https://issues.apache.org/jira/browse/FLINK-7675
Project:
Ufuk Celebi created FLINK-7674:
--
Summary: NullPointerException in ContinuousFileMonitoringFunction
close
Key: FLINK-7674
URL: https://issues.apache.org/jira/browse/FLINK-7674
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16177629#comment-16177629
]
Robert Metzger commented on FLINK-7673:
---
Thank you for looking into this! It is indeed annoying that
[
https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16177627#comment-16177627
]
Bin Wang commented on FLINK-6115:
-
I am a new user of Flink, I would like to recommend to support null
[
https://issues.apache.org/jira/browse/FLINK-7673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-7673:
--
Component/s: Kinesis Connector
> Flink Kinesis connector - remove dependency on the ASL code
>
[
https://issues.apache.org/jira/browse/FLINK-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16177622#comment-16177622
]
Robert Metzger commented on FLINK-7672:
---
The last time I worked with the flink kinesis connector, it
39 matches
Mail list logo
