[
https://issues.apache.org/jira/browse/FLINK-11223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-11223:
Assignee: TANG Wen-hui
> Time zone problem for time processing function
>
shuiqiangchen opened a new pull request #7370: [FLINK-11161]Unable to import
java packages in scala-shell
URL: https://github.com/apache/flink/pull/7370
## What is the purpose of the change
Solved the problem of Unable to import java packages in scala-shell while
enabling
[
https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729371#comment-16729371
]
Jeff Zhang commented on FLINK-11222:
I see, thanks [~dian.fu] then I think it makes sense to do this
[
https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729359#comment-16729359
]
Dian Fu commented on FLINK-11222:
-
The package name will not be changed. Just need to update the
[
https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729358#comment-16729358
]
Jeff Zhang commented on FLINK-11222:
[~dian.fu] Oh, maybe my misunderstanding, I thought it was
[
https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729345#comment-16729345
]
Dian Fu commented on FLINK-11222:
-
This is just a modification of the method signature of a test method
[
https://issues.apache.org/jira/browse/FLINK-11219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729344#comment-16729344
]
xuqianjin commented on FLINK-11219:
---
hi [~Zentol] I tried removing the exclusions and relocating
[
https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729342#comment-16729342
]
Jeff Zhang commented on FLINK-11222:
I think we need to reach consensus in community first, I will
[
https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ryantaocer reassigned FLINK-10644:
--
Assignee: ryantaocer (was: JIN SUN)
> Batch Job: Speculative execution
>
[
https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729310#comment-16729310
]
Hequn Cheng commented on FLINK-11222:
-
[~zjffdu] good point. I agree with you that we should be
[
https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-11222:
Summary: Change api.scala.DataStream to api.datastream.DataStream for
createHarnessTester in
Hequn Cheng created FLINK-11222:
---
Summary: Change api.scala.DataStream to api.datastream.DataStream
in HarnessTestBase
Key: FLINK-11222
URL: https://issues.apache.org/jira/browse/FLINK-11222
Project:
[
https://issues.apache.org/jira/browse/FLINK-11223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11223:
Summary: Time zone problem for time processing function (was: Time zone
problem in flink)
>
[
https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729307#comment-16729307
]
Jeff Zhang commented on FLINK-11222:
[~hequn8128] This would introduce incompatibility, we should be
[
https://issues.apache.org/jira/browse/FLINK-11223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11223:
Summary: Time zone problem in flink (was: Time zone problem of row time
field )
> Time zone
sunjincheng created FLINK-11223:
---
Summary: Time zone problem of row time field
Key: FLINK-11223
URL: https://issues.apache.org/jira/browse/FLINK-11223
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-11222:
---
Assignee: Dian Fu
> Change api.scala.DataStream to api.datastream.DataStream in HarnessTestBase
>
[
https://issues.apache.org/jira/browse/FLINK-11220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729279#comment-16729279
]
Jark Wu commented on FLINK-11220:
-
I agree with [~sunjincheng121]'s point. CAST one of the rowtime
[
https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-7208.
--
Resolution: Fixed
Fix Version/s: 1.8.0
Fixed in master:
[
https://issues.apache.org/jira/browse/FLINK-11142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-11142.
---
Resolution: Fixed
Fix Version/s: 1.8.0
Fixed in master:
[
https://issues.apache.org/jira/browse/FLINK-11142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11142:
Comment: was deleted
(was: Set Fix Versions)
> Undefined behavior in the conversion from
[
https://issues.apache.org/jira/browse/FLINK-11142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reopened FLINK-11142:
-
Set Fix Versions
> Undefined behavior in the conversion from DataStream/DataSet to Table
>
[
https://issues.apache.org/jira/browse/FLINK-11142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-11142.
---
Resolution: Fixed
> Undefined behavior in the conversion from DataStream/DataSet to Table
>
asfgit closed pull request #7201: [FLINK-7208] [table] Optimize
Min/MaxWithRetractAggFunction with DataView
URL: https://github.com/apache/flink/pull/7201
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of
[
https://issues.apache.org/jira/browse/FLINK-11220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729271#comment-16729271
]
Xingcan Cui commented on FLINK-11220:
-
Hi [~sunjincheng121], if users want to preserve a rowtime
[
https://issues.apache.org/jira/browse/FLINK-9457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
boshu Zheng reassigned FLINK-9457:
--
Assignee: boshu Zheng (was: vinoyang)
> Cancel container requests when cancelling pending
[
https://issues.apache.org/jira/browse/FLINK-11220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729262#comment-16729262
]
sunjincheng commented on FLINK-11220:
-
Hi [~xccui] ,
Thanks for your explanations. Solving this
[
https://issues.apache.org/jira/browse/FLINK-11212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729260#comment-16729260
]
lining commented on FLINK-11212:
[~Zentol], thanks for your reply. My question is if one vertex which
shuiqiangchen commented on issue #7305: [FLINK-11161]Unable to import java
packages in scala-shell
URL: https://github.com/apache/flink/pull/7305#issuecomment-450054075
> ping @shuiqiangchen
Sorry for the late reply! I'm thinking about the coverage of unit tests and
will finish it
zjffdu commented on issue #7305: [FLINK-11161]Unable to import java packages in
scala-shell
URL: https://github.com/apache/flink/pull/7305#issuecomment-450053169
ping @shuiqiangchen
This is an automated message from the
hequn8128 commented on issue #7352: [FLINK-11142][docs] Point out fields can be
projected out for Position-based Mapping
URL: https://github.com/apache/flink/pull/7352#issuecomment-450052290
Thank you all for the review. @sunjincheng121 @KarmaGYZ
[
https://issues.apache.org/jira/browse/FLINK-10961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10961:
Assignee: vinoyang
> RuntimeException: Could not extract key when using closure
>
dianfu commented on issue #7235: [FLINK-10976] [table] Add support for
aggregate to table API
URL: https://github.com/apache/flink/pull/7235#issuecomment-450051134
@hequn8128 Thanks a lot for the review. Updated accordingly.
[
https://issues.apache.org/jira/browse/FLINK-10978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729248#comment-16729248
]
sunjincheng commented on FLINK-10978:
-
Sounds good [~hequn8128] ！ I think open the PR. after
KarmaGYZ opened a new pull request #7369: [hotfix][docs] Fix typo in whole
project
URL: https://github.com/apache/flink/pull/7369
## What is the purpose of the change
When I read the source code of ExecutionConfig, I find a typo `teh`. This PR
fix all `teh` typo in flink project.
yanghua commented on a change in pull request #7365: [hotfix][docs] Fix typo
and make improvement in User-defined Sources …
URL: https://github.com/apache/flink/pull/7365#discussion_r244067194
##
File path: docs/dev/table/sourceSinks.md
##
@@ -285,7 +285,7 @@
KarmaGYZ commented on a change in pull request #7365: [hotfix][docs] Fix typo
and make improvement in User-defined Sources …
URL: https://github.com/apache/flink/pull/7365#discussion_r244066191
##
File path: docs/dev/table/sourceSinks.md
##
@@ -285,7 +285,7 @@
asfgit closed pull request #7352: [FLINK-11142][docs] Point out fields can be
projected out for Position-based Mapping
URL: https://github.com/apache/flink/pull/7352
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the
sunjincheng121 commented on issue #7201: [FLINK-7208] [table] Optimize
Min/MaxWithRetractAggFunction with DataView
URL: https://github.com/apache/flink/pull/7201#issuecomment-450044090
Merging..
This is an automated message
sunjincheng121 commented on issue #7352: [FLINK-11142][docs] Point out fields
can be projected out for Position-based Mapping
URL: https://github.com/apache/flink/pull/7352#issuecomment-450043822
merging...
This is an
[
https://issues.apache.org/jira/browse/FLINK-11219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729198#comment-16729198
]
Chesnay Schepler commented on FLINK-11219:
--
Have you tried removing the exclusions and
[
https://issues.apache.org/jira/browse/FLINK-10961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Avi Levi updated FLINK-10961:
-
Component/s: State Backends, Checkpointing
> RuntimeException: Could not extract key when using closure
[
https://issues.apache.org/jira/browse/FLINK-10961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Avi Levi updated FLINK-10961:
-
Affects Version/s: (was: 1.6.2)
1.7.0
> RuntimeException: Could not extract
[
https://issues.apache.org/jira/browse/FLINK-10953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Avi Levi closed FLINK-10953.
Resolution: Cannot Reproduce
> InterruptedException on KafkaProducer
>
[
https://issues.apache.org/jira/browse/FLINK-11053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729091#comment-16729091
]
Avi Levi commented on FLINK-11053:
--
Thanks Igal - I will
> Examples in documentation not compiling
>
azagrebin commented on a change in pull request #7351: [FLINK-11008][State
Backends, Checkpointing]SpeedUp upload state files using multithread
URL: https://github.com/apache/flink/pull/7351#discussion_r244004203
##
File path:
azagrebin commented on a change in pull request #7351: [FLINK-11008][State
Backends, Checkpointing]SpeedUp upload state files using multithread
URL: https://github.com/apache/flink/pull/7351#discussion_r244010700
##
File path:
azagrebin commented on a change in pull request #7351: [FLINK-11008][State
Backends, Checkpointing]SpeedUp upload state files using multithread
URL: https://github.com/apache/flink/pull/7351#discussion_r244004144
##
File path:
azagrebin commented on a change in pull request #7351: [FLINK-11008][State
Backends, Checkpointing]SpeedUp upload state files using multithread
URL: https://github.com/apache/flink/pull/7351#discussion_r244002977
##
File path:
azagrebin commented on a change in pull request #7351: [FLINK-11008][State
Backends, Checkpointing]SpeedUp upload state files using multithread
URL: https://github.com/apache/flink/pull/7351#discussion_r244009608
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10742:
---
Labels: pull-request-available (was: )
> Let Netty use Flink's buffers directly in
gaoyunhaii opened a new pull request #7368: [FLINK-10742][network] Let Netty
use Flink's buffers directly in credit-based mode
URL: https://github.com/apache/flink/pull/7368
## What is the purpose of the change
*This PR aims to add the zero-copy decoder for the receiver
gaoyunhaii closed pull request #7367: [Flink-10742][network] Let Netty use
Flink's buffers directly in credit-based mode
URL: https://github.com/apache/flink/pull/7367
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the
gaoyunhaii opened a new pull request #7367: [Flink-10742][network] Let Netty
use Flink's buffers directly in credit-based mode
URL: https://github.com/apache/flink/pull/7367
## What is the purpose of the change
*This PR aims to add the zero-copy decoder for the receiver
xccui closed pull request #7357: [hotfix] [table] Fix a bound problem for array
validation
URL: https://github.com/apache/flink/pull/7357
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this
xccui commented on a change in pull request #7357: [hotfix] [table] Fix a bound
problem for array validation
URL: https://github.com/apache/flink/pull/7357#discussion_r244004641
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729053#comment-16729053
]
xuqianjin edited comment on FLINK-11219 at 12/26/18 2:36 PM:
-
hi [~Zentol]
hequn8128 commented on a change in pull request #7357: [hotfix] [table] Fix a
bound problem for array validation
URL: https://github.com/apache/flink/pull/7357#discussion_r244003657
##
File path:
hequn8128 removed a comment on issue #7357: [hotfix] [table] Fix a bound
problem for array validation
URL: https://github.com/apache/flink/pull/7357#issuecomment-449974600
@xccui Thanks for fixing the bug. I found another bound problem in
[
https://issues.apache.org/jira/browse/FLINK-11219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729053#comment-16729053
]
xuqianjin commented on FLINK-11219:
---
[~Zentol] However, the Jackson version required by calcite1.18.0
hequn8128 commented on issue #7357: [hotfix] [table] Fix a bound problem for
array validation
URL: https://github.com/apache/flink/pull/7357#issuecomment-449974600
@xccui Thanks for fixing the bug. I found another bound problem in
`DescriptorProperties.validateFixedIndexedProperties()`.
[
https://issues.apache.org/jira/browse/FLINK-11219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xuqianjin reassigned FLINK-11219:
-
Assignee: xuqianjin
> Upgrade Jackson dependency to 2.9.6
>
Hequn Cheng created FLINK-11221:
---
Summary: Support delimited identifiers in TableAPI
Key: FLINK-11221
URL: https://issues.apache.org/jira/browse/FLINK-11221
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729040#comment-16729040
]
Shiyu Chai commented on FLINK-11143:
You could try to upgrade your jdk version. I met this issue
TisonKun commented on issue #7340: [FLINK-11174] [prometheus] Flink Metrics
Prometheus label values supp…
URL: https://github.com/apache/flink/pull/7340#issuecomment-449960866
@zentol is the source I link to above an authoritative to you?
[
https://issues.apache.org/jira/browse/FLINK-11220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729019#comment-16729019
]
Xingcan Cui commented on FLINK-11220:
-
Hi [~sunjincheng121], I'd like to give some explanations
lamber-ken edited a comment on issue #7361: [hotfix][doc] fix error http port
in elasticsearch scala doc
URL: https://github.com/apache/flink/pull/7361#issuecomment-449959252
> Please provide a source for 9200 being the correct port.
hi, @zentol, here is [official elasticsearch
lamber-ken commented on issue #7361: [hotfix][doc] fix error http port in
elasticsearch scala doc
URL: https://github.com/apache/flink/pull/7361#issuecomment-449959252
> Please provide a source for 9200 being the correct port.
hi, @zentol, here is [official elasticsearch source
[
https://issues.apache.org/jira/browse/FLINK-10499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10499:
Assignee: vinoyang
> Introduce declarative resource management switch for
>
yanghua commented on issue #7361: [hotfix][doc] fix error http port in
elasticsearch scala doc
URL: https://github.com/apache/flink/pull/7361#issuecomment-449956220
@zentol Sorry, I thought that if Travis turns green, it will make it easier
for committer to merge PR, otherwise, they will
[
https://issues.apache.org/jira/browse/FLINK-10502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
boshu Zheng reassigned FLINK-10502:
---
Assignee: boshu Zheng
> Wait for resource stabilization
> ---
lamber-ken commented on issue #7361: [hotfix][doc] fix error http port in
elasticsearch scala doc
URL: https://github.com/apache/flink/pull/7361#issuecomment-449953196
> @yanghua I've told you this before, don't rerun Travis for documentation
changes. This is a completely unnecessary
zentol commented on issue #7361: [hotfix][doc] fix error http port in
elasticsearch scala doc
URL: https://github.com/apache/flink/pull/7361#issuecomment-449952567
Please provide a source for 9200 being the correct port.
zentol commented on issue #7361: [hotfix][doc] fix error http port in
elasticsearch scala doc
URL: https://github.com/apache/flink/pull/7361#issuecomment-449952408
@yanghua I've told you this before, don't rerun Travis for documentation
changes. This is a completely unnecessary waste of
zentol closed pull request #7363: [hotfix][docs] fix typo in udf and exec_conf
doc
URL: https://github.com/apache/flink/pull/7363
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a
[
https://issues.apache.org/jira/browse/FLINK-11219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16728996#comment-16728996
]
Chesnay Schepler commented on FLINK-11219:
--
We are excluding jackson from our calcite
zentol closed pull request #7364: [hotfix][doc] Replace currentLowWatermark
with currentInputWatermark
URL: https://github.com/apache/flink/pull/7364
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of
yanghua commented on a change in pull request #7365: [hotfix][docs] Fix typo
and make improvement in User-defined Sources …
URL: https://github.com/apache/flink/pull/7365#discussion_r243982805
##
File path: docs/dev/table/sourceSinks.md
##
@@ -285,7 +285,7 @@
KarmaGYZ opened a new pull request #7366: [hotfix][docs] Fix typo in
User-defined Functions
URL: https://github.com/apache/flink/pull/7366
## What is the purpose of the change
This PR Fix typo in User-defined Functions
## Brief change log
- Revert all Types.TIMESTAMP
sunjincheng created FLINK-11220:
---
Summary: Can not Select row time field in JOIN query
Key: FLINK-11220
URL: https://issues.apache.org/jira/browse/FLINK-11220
Project: Flink
Issue Type: Bug
KarmaGYZ opened a new pull request #7365: [hotfix][docs] Fix typo and make
improvement in User-defined Sources …
URL: https://github.com/apache/flink/pull/7365
…& Sinks
## What is the purpose of the change
This PR Fix typo and make improvement in User-defined Sources & Sinks
81 matches
Mail list logo
