execution.job-listeners 只可以设置 JobListener 的实现。
需求场景应该使用 JobStatusListener
Best,
TonyChen
> 2022年11月24日 11:55，casel.chen 写道：
>
> 可以使用 execution.job-listeners 参数吗？这个参数的用法是怎样的？
>
>
>
>
>
>
>
>
>
>
>
> 在 2022-11-24 10:41:35，"Yang Wang&q
关注这个话题，感谢您的分享。
看了一下文档，貌似只有1.15及以上版本有这个metric，对于1.14及以下版本有什么好的思路吗？谢谢
Best,
TonyChen
> 2022年11月23日 09:28，RS 写道：
>
> Hi，
>
>
> Flink的Metric了解下，里面应该有作业的状态
> https://nightlies.apache.org/flink/flink-docs-master/docs/ops/metrics/#reporter
>
>
> 配置不同的Me
升个小版本，1.14.3就有AUTOMATIC
Best,
TonyChen
> 2022年10月28日 17:09，junjie.m...@goupwith.com 写道：
>
> hi,weijie:
> 我使用的是flink1.14里是不支持设置execution.runtime-mode=AUTOMATIC的，会报如下错误：
> org.apache.flink.table.api.TableException: Unsupported mode 'AUTOMATIC' for
> 'execution.runtime-mode'
是不是可以看下这个
https://github.com/apache/flink/blob/master/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/ScanTableSource.java#L94
Best,
TonyChen
> 2022年10月28日 15:12，junjie.m...@goupwith.com 写道：
>
> 大家好：
>有个问题判断Table是有界还是无界，或者通过TableEnv如何能得到sou
imeout interval for closing the session when the
session hasn't been accessed during the interval. "
+ "If setting to zero or negative value, the
session will not be closed.");
Best,
TonyChen
> 2022年10月20日 09:28，TonyChen 写道：
>
> Hi all
>
,
TonyChen
Best,
TonyChen
在FLINK-SQL下用eventtime和proctime都可以进行CEP计算
--
Sent from: http://apache-flink.147419.n8.nabble.com/
.flush(JdbcBatchingOutputFormat.java:173)
at
org.apache.flink.connector.jdbc.internal.JdbcBatchingOutputFormat.writeRecord(JdbcBatchingOutputFormat.java:156)
... 27 more
Best,
TonyChen
这个问题解决了吗？现在1.11.2仍然有这个问题，或者有什么临时解决方案，
registerFunction已经不好使了，createTemporarySystemFunction 报错 No match found for
function signature
--
Sent from: http://apache-flink.147419.n8.nabble.com/
10 17:37:01,962 INFO com.boteratech.kunpeng.dlink.misc.HBaseTest -
2900 time_characteristicscreate_time
ux�e
Best,
TonyChen
> 2020年10月10日 下午5:12，Dream-底限 写道：
>
> hi、phoenix文档中数据类型部分有描述兼容现有hbase类型的类型，你可以看一下，就是名字有些区别
>
> TonyChen 于20
BIGINT,
"time_characteristics"."create_time" varchar
);
在这样操作之后，phoenix获取数据仍是之前的现象。我已经用了最基本的数据类型。怎么判定哪些数据类型phoenix类型和hbase类型是兼容的？
谢谢
Best,
TonyChen
> 2020年10月10日 下午4:31，Dream-底限 写道：
>
> hi、phoenix类型和hbase类型有一部分不兼容：1、使用phoenix建表并通过phoenix jdbc插入数据；2、使用hbase
>
我这个表就是用 phoenix 创建的。。
Best,
TonyChen
> 2020年10月10日 下午4:11，Dream-底限 写道：
>
> hi、phoenix要映射现有hbase表，改一下phoenix建标语句应该可以解决
>
> TonyChen 于2020年10月10日周六 下午4:03写道：
>
>> 查了下
>>
>> hbase(main):011:0> get 'ods_iot_gasdevice', '2900'
>> COLUMN
wer timestamp=1602314819543, value=\x00\x00\x00T
status_info:device_status timestamp=1602314819543,
value=\x00\x00\x00\x02
time_characteristics:create_time timestamp=1602314819543,
value=\x00\x00\x01u\x13\x1F\x1Fv
1 row(s) in 0.1950 seconds
Best,
TonyChen
> 2020年10月10日 下午3:51，J
0T15:26:51.173)
3> +I(2938,2938,10e55f27f137a7f,22,4,2020-10-10T15:26:51.173)
7> +I(2942,2942,52ae903a2633739,91,1,2020-10-10T15:26:51.176)
3> +I(2950,2950,e3e60cd0630aa66,88,4,2020-10-10T15:26:52.174)
1> +I(2948,2948,2cca133cca14cbf,44,1,2020-10-10T15:26:52.174)
2> +I(2949,2949,7cc761cdb8bb924,77,4,2020-10-10T15:26:52.174)
Best,
TonyChen
| null | null | null
|
| 2950| null | | null | null | null
|
+-----++--+++--+
51 rows selected (0.034 seconds)
Best,
TonyChen
收到，谢谢。
Best,
TonyChen
> 2020年9月16日 下午12:12，Jark Wu 写道：
>
> 新版 jdbc connector 的这个功能目前已经有个 PR [1] 在支持中了，预计在1.12 中会支持。
>
> Best,
> Jark
>
> [1]: https://github.com/apache/flink/pull/13245
>
> On Wed, 16 Sep 2020 at 11:25, 陈韬 wrote:
>
>> JDBC Source中
17 matches
Mail list logo
